test_streaming.cpp File Reference

#include "test.h"
#include <carla/ThreadGroup.h>
#include <carla/streaming/Client.h>
#include <carla/streaming/Server.h>
#include <carla/streaming/detail/Dispatcher.h>
#include <carla/streaming/detail/tcp/Client.h>
#include <carla/streaming/detail/tcp/Server.h>
#include <carla/streaming/low_level/Client.h>
#include <carla/streaming/low_level/Server.h>
#include <atomic>

Include dependency graph for test_streaming.cpp:

Go to the source code of this file.

Classes
struct	DoneGuard
class	io_context_running

Functions
	TEST (streaming, low_level_sending_strings)
	TEST (streaming, low_level_unsubscribing)
	TEST (streaming, low_level_tcp_small_message)
	TEST (streaming, stream_outlives_server)
	TEST (streaming, multi_stream)

Function Documentation

TEST() [1/5]

TEST	(	streaming	,
		low_level_sending_strings
	)

Definition at line 45 of file test_streaming.cpp.

References util::buffer::as_string(), carla::BufferView::CreateFrom(), carla::streaming::low_level::Server< T >::MakeStream(), io_context_running::service, carla::streaming::low_level::Server< T >::SetTimeout(), carla::streaming::low_level::Client< T >::Subscribe(), and TESTING_PORT.

Here is the call graph for this function:

TEST() [2/5]

TEST	(	streaming	,
		low_level_unsubscribing
	)

Definition at line 85 of file test_streaming.cpp.

References util::buffer::as_string(), carla::BufferView::CreateFrom(), carla::streaming::low_level::Server< T >::MakeStream(), io_context_running::service, carla::streaming::low_level::Server< T >::SetTimeout(), carla::streaming::low_level::Client< T >::Subscribe(), TESTING_PORT, and carla::streaming::low_level::Client< T >::UnSubscribe().

Here is the call graph for this function:

TEST() [3/5]

TEST	(	streaming	,
		low_level_tcp_small_message
	)

Definition at line 134 of file test_streaming.cpp.

References util::buffer::as_string(), carla::BufferView::CreateFrom(), carla::ThreadGroup::CreateThreads(), carla::streaming::detail::tcp::Server::GetLocalEndpoint(), carla::streaming::detail::tcp::Server::Listen(), carla::streaming::detail::Dispatcher::MakeStream(), carla::streaming::detail::tcp::Server::SetTimeout(), and TESTING_PORT.

Here is the call graph for this function:

TEST() [4/5]

TEST	(	streaming	,
		stream_outlives_server
	)

Definition at line 191 of file test_streaming.cpp.

References util::buffer::as_string(), carla::streaming::Client::AsyncRun(), carla::BufferView::CreateFrom(), carla::ThreadGroup::CreateThread(), carla::streaming::low_level::Server< T >::MakeStream(), carla::streaming::Client::Subscribe(), and TESTING_PORT.

Here is the call graph for this function:

TEST() [5/5]

TEST	(	streaming	,
		multi_stream
	)

Definition at line 239 of file test_streaming.cpp.

References util::buffer::as_string(), carla::BufferView::CreateFrom(), carla::streaming::low_level::Server< T >::MakeStream(), and TESTING_PORT.

Here is the call graph for this function: