test_multigpu_sensor_streams.cpp File Reference

#include "test.h"
#include <carla/Buffer.h>
#include <carla/BufferView.h>
#include <carla/multigpu/mirroredActors.h>
#include <carla/multigpu/sensorStreamRegistry.h>
#include <carla/streaming/Client.h>
#include <carla/streaming/Server.h>
#include <carla/streaming/detail/Token.h>
#include <boost/asio/io_context.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/write.hpp>
#include <algorithm>
#include <array>
#include <atomic>
#include <chrono>
#include <map>
#include <optional>
#include <set>
#include <string>
#include <thread>

Go to the source code of this file.

Functions
	TEST (MultiGpuMirroredActors, a_free_id_is_requested_for_a_new_actor)
	TEST (MultiGpuMirroredActors, a_local_id_equal_to_the_primary_id_of_another_mirror_is_not_reused)
	TEST (MultiGpuMirroredActors, a_map_prop_at_its_place_is_reused_whatever_its_id)
	TEST (MultiGpuMirroredActors, a_map_prop_at_the_primary_id_is_reused_and_mapped)
	TEST (MultiGpuMirroredActors, a_map_prop_mirroring_another_primary_actor_is_not_reused)
	TEST (MultiGpuMirroredActors, a_map_prop_with_another_mesh_is_not_reused)
	TEST (MultiGpuMirroredActors, a_mapped_actor_reuses_its_mirror_even_if_its_id_is_taken)
	TEST (MultiGpuMirroredActors, a_removed_actor_is_spawned_again_on_its_next_add)
	TEST (MultiGpuMirroredActors, a_stale_mirror_of_another_kind_is_not_reused)
	TEST (MultiGpuMirroredActors, an_id_held_by_a_dormant_actor_is_never_requested)
	TEST (MultiGpuMirroredActors, restarted_secondary_gives_every_primary_camera_its_own_actor)
	TEST (MultiGpuMirroredActors, the_spectator_is_reused_whatever_its_id)
	TEST (MultiGpuSensorStreams, bind_and_unbind_are_ignored_until_the_latest_load_opens)
	TEST (MultiGpuSensorStreams, bind_refuses_a_stream_already_bound_to_another_actor)
	TEST (MultiGpuSensorStreams, close_episode_stops_binding_but_keeps_reservations)
	TEST (MultiGpuSensorStreams, early_subscriber_of_a_reused_sensor_reconnects_to_its_stream)
	TEST (MultiGpuSensorStreams, episode_change_drops_aliases_and_reservations_but_not_sensor_streams)
	TEST (MultiGpuSensorStreams, episode_change_keeps_the_broadcast_alias)
	TEST (MultiGpuSensorStreams, resolve_after_the_sensor_stream_closed_reserves_a_new_one)
	TEST (MultiGpuSensorStreams, resolve_before_spawn_reserves_a_stream_the_sensor_adopts)
	TEST (MultiGpuSensorStreams, resolve_is_keyed_by_actor_not_creation_order)
	TEST (MultiGpuSensorStreams, restarted_secondary_binds_overlapping_ids_to_their_own_streams)
	TEST (MultiGpuSensorStreams, reused_sensor_keeps_its_stream_and_takes_over_the_reservation)
	TEST (MultiGpuSensorStreams, secondaries_with_colliding_local_ids_hand_out_distinct_primary_ids)
	TEST (MultiGpuSensorStreams, self_aliased_broadcast_stream_is_reachable_with_aliases_on)
	TEST (MultiGpuSensorStreams, subscription_by_an_unaliased_id_is_refused)
	TEST (MultiGpuSensorStreams, subscription_by_primary_id_reaches_the_adopted_stream_and_unsubscribes_by_it)
	TEST (MultiGpuSensorStreams, token_carries_the_primary_stream_id_and_the_secondary_port)
	TEST (MultiGpuSensorStreams, unbind_removes_the_alias_and_closes_an_unadopted_reservation)
	TEST (streaming, closing_a_session_after_its_alias_moved_leaves_the_new_stream_session_alone)
	TEST (streaming, find_token_does_not_create_a_stream_for_an_unknown_id)
	TEST (streaming, find_token_returns_the_existing_stream_token)
	TEST (streaming, stream_alias_can_be_set_replaced_and_removed)

Function Documentation

TEST() [1/33]

TEST	(	MultiGpuMirroredActors	,
		a_free_id_is_requested_for_a_new_actor
	)

Definition at line 555 of file test_multigpu_sensor_streams.cpp.

TEST() [2/33]

TEST	(	MultiGpuMirroredActors	,
		a_local_id_equal_to_the_primary_id_of_another_mirror_is_not_reused
	)

Definition at line 517 of file test_multigpu_sensor_streams.cpp.

TEST() [3/33]

TEST	(	MultiGpuMirroredActors	,
		a_map_prop_at_its_place_is_reused_whatever_its_id
	)

Definition at line 584 of file test_multigpu_sensor_streams.cpp.

TEST() [4/33]

TEST	(	MultiGpuMirroredActors	,
		a_map_prop_at_the_primary_id_is_reused_and_mapped
	)

Definition at line 574 of file test_multigpu_sensor_streams.cpp.

TEST() [5/33]

TEST	(	MultiGpuMirroredActors	,
		a_map_prop_mirroring_another_primary_actor_is_not_reused
	)

Definition at line 594 of file test_multigpu_sensor_streams.cpp.

TEST() [6/33]

TEST	(	MultiGpuMirroredActors	,
		a_map_prop_with_another_mesh_is_not_reused
	)

Definition at line 604 of file test_multigpu_sensor_streams.cpp.

TEST() [7/33]

TEST	(	MultiGpuMirroredActors	,
		a_mapped_actor_reuses_its_mirror_even_if_its_id_is_taken
	)

Definition at line 562 of file test_multigpu_sensor_streams.cpp.

TEST() [8/33]

TEST	(	MultiGpuMirroredActors	,
		a_removed_actor_is_spawned_again_on_its_next_add
	)

Definition at line 618 of file test_multigpu_sensor_streams.cpp.

References first.

TEST() [9/33]

TEST	(	MultiGpuMirroredActors	,
		a_stale_mirror_of_another_kind_is_not_reused
	)

Definition at line 631 of file test_multigpu_sensor_streams.cpp.

TEST() [10/33]

TEST	(	MultiGpuMirroredActors	,
		an_id_held_by_a_dormant_actor_is_never_requested
	)

Definition at line 544 of file test_multigpu_sensor_streams.cpp.

TEST() [11/33]

TEST	(	MultiGpuMirroredActors	,
		restarted_secondary_gives_every_primary_camera_its_own_actor
	)

Definition at line 528 of file test_multigpu_sensor_streams.cpp.

TEST() [12/33]

TEST	(	MultiGpuMirroredActors	,
		the_spectator_is_reused_whatever_its_id
	)

Definition at line 610 of file test_multigpu_sensor_streams.cpp.

TEST() [13/33]

TEST	(	MultiGpuSensorStreams	,
		bind_and_unbind_are_ignored_until_the_latest_load_opens
	)

Definition at line 220 of file test_multigpu_sensor_streams.cpp.

TEST() [14/33]

TEST	(	MultiGpuSensorStreams	,
		bind_refuses_a_stream_already_bound_to_another_actor
	)

Definition at line 373 of file test_multigpu_sensor_streams.cpp.

TEST() [15/33]

TEST	(	MultiGpuSensorStreams	,
		close_episode_stops_binding_but_keeps_reservations
	)

Definition at line 247 of file test_multigpu_sensor_streams.cpp.

TEST() [16/33]

TEST	(	MultiGpuSensorStreams	,
		early_subscriber_of_a_reused_sensor_reconnects_to_its_stream
	)

Definition at line 356 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Client::AsyncRun(), carla::streaming::Client::Subscribe(), and carla::streaming::Client::UnSubscribe().

TEST() [17/33]

TEST	(	MultiGpuSensorStreams	,
		episode_change_drops_aliases_and_reservations_but_not_sensor_streams
	)

Definition at line 203 of file test_multigpu_sensor_streams.cpp.

TEST() [18/33]

TEST	(	MultiGpuSensorStreams	,
		episode_change_keeps_the_broadcast_alias
	)

Definition at line 686 of file test_multigpu_sensor_streams.cpp.

TEST() [19/33]

TEST	(	MultiGpuSensorStreams	,
		resolve_after_the_sensor_stream_closed_reserves_a_new_one
	)

Definition at line 176 of file test_multigpu_sensor_streams.cpp.

TEST() [20/33]

TEST	(	MultiGpuSensorStreams	,
		resolve_before_spawn_reserves_a_stream_the_sensor_adopts
	)

Definition at line 155 of file test_multigpu_sensor_streams.cpp.

TEST() [21/33]

TEST	(	MultiGpuSensorStreams	,
		resolve_is_keyed_by_actor_not_creation_order
	)

Definition at line 140 of file test_multigpu_sensor_streams.cpp.

TEST() [22/33]

TEST	(	MultiGpuSensorStreams	,
		restarted_secondary_binds_overlapping_ids_to_their_own_streams
	)

Definition at line 642 of file test_multigpu_sensor_streams.cpp.

TEST() [23/33]

TEST	(	MultiGpuSensorStreams	,
		reused_sensor_keeps_its_stream_and_takes_over_the_reservation
	)

Definition at line 339 of file test_multigpu_sensor_streams.cpp.

TEST() [24/33]

TEST	(	MultiGpuSensorStreams	,
		secondaries_with_colliding_local_ids_hand_out_distinct_primary_ids
	)

Definition at line 257 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Client::AsyncRun(), and carla::streaming::Client::Subscribe().

TEST() [25/33]

TEST	(	MultiGpuSensorStreams	,
		self_aliased_broadcast_stream_is_reachable_with_aliases_on
	)

Definition at line 668 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Client::AsyncRun(), carla::streaming::Client::Subscribe(), and carla::streaming::Client::UnSubscribe().

TEST() [26/33]

TEST	(	MultiGpuSensorStreams	,
		subscription_by_an_unaliased_id_is_refused
	)

Definition at line 317 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Client::AsyncRun(), carla::streaming::Client::Subscribe(), and carla::streaming::Client::UnSubscribe().

TEST() [27/33]

TEST	(	MultiGpuSensorStreams	,
		subscription_by_primary_id_reaches_the_adopted_stream_and_unsubscribes_by_it
	)

Definition at line 284 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Client::AsyncRun(), carla::streaming::Client::Subscribe(), and carla::streaming::Client::UnSubscribe().

TEST() [28/33]

TEST	(	MultiGpuSensorStreams	,
		token_carries_the_primary_stream_id_and_the_secondary_port
	)

Definition at line 128 of file test_multigpu_sensor_streams.cpp.

TEST() [29/33]

TEST	(	MultiGpuSensorStreams	,
		unbind_removes_the_alias_and_closes_an_unadopted_reservation
	)

Definition at line 192 of file test_multigpu_sensor_streams.cpp.

TEST() [30/33]

TEST	(	streaming	,
		closing_a_session_after_its_alias_moved_leaves_the_new_stream_session_alone
	)

Definition at line 387 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Server::AsyncRun(), carla::streaming::detail::token_type::get_port(), carla::streaming::Server::MakeStream(), carla::streaming::Server::SetSessionsUseStreamAliases(), carla::streaming::Server::SetStreamAlias(), and TESTING_PORT.

TEST() [31/33]

TEST	(	streaming	,
		find_token_does_not_create_a_stream_for_an_unknown_id
	)

Definition at line 102 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Server::FindToken(), carla::streaming::Server::IsEnabledForROS(), and TESTING_PORT.

TEST() [32/33]

TEST	(	streaming	,
		find_token_returns_the_existing_stream_token
	)

Definition at line 109 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Server::FindToken(), carla::streaming::Server::MakeStream(), and TESTING_PORT.

TEST() [33/33]

TEST	(	streaming	,
		stream_alias_can_be_set_replaced_and_removed
	)

Definition at line 117 of file test_multigpu_sensor_streams.cpp.

References carla::streaming::Server::FindStreamAlias(), carla::streaming::Server::RemoveStreamAlias(), carla::streaming::Server::SetStreamAlias(), and TESTING_PORT.