Benchmark Class Reference

Public Member Functions
void	AddStream ()
void	AddStreams (size_t count)
	Benchmark (uint16_t port, size_t message_size, double success_ratio)
void	Run (size_t number_of_messages)

Private Attributes
Client	_client
boost::asio::io_context	_client_callback
const carla::SharedBufferView	_message
std::atomic_size_t	_number_of_messages_received {0u}
Server	_server
std::vector< Stream >	_streams
const double	_success_ratio
carla::ThreadGroup	_threads
boost::asio::executor_work_guard< boost::asio::io_context::executor_type >	_work_to_do

Detailed Description

Definition at line 31 of file test_benchmark_streaming.cpp.

Constructor & Destructor Documentation

Benchmark()

Benchmark::Benchmark ( uint16_t  port, size_t  message_size, double  success_ratio  )

inline

Definition at line 34 of file test_benchmark_streaming.cpp.

References _server, and carla::streaming::Server::SetSynchronousMode().

Member Function Documentation

AddStream()

void Benchmark::AddStream ( )

inline

Definition at line 45 of file test_benchmark_streaming.cpp.

References _client, _server, carla::streaming::Server::MakeStream(), carla::streaming::Client::Subscribe(), and carla::streaming::detail::Stream< StreamStateT >::token().

AddStreams()

void Benchmark::AddStreams ( size_t  count )

inline

Definition at line 60 of file test_benchmark_streaming.cpp.

Referenced by benchmark_image().

Run()

void Benchmark::Run ( size_t  number_of_messages )

inline

Definition at line 66 of file test_benchmark_streaming.cpp.

References CARLA_PROFILE_SCOPE, and carla::log_warning().

Referenced by benchmark_image().

Member Data Documentation

_client

Client Benchmark::_client

private

Definition at line 120 of file test_benchmark_streaming.cpp.

Referenced by AddStream().

_client_callback

boost::asio::io_context Benchmark::_client_callback

private

Definition at line 124 of file test_benchmark_streaming.cpp.

_message

const carla::SharedBufferView Benchmark::_message

private

Definition at line 122 of file test_benchmark_streaming.cpp.

_number_of_messages_received

std::atomic_size_t Benchmark::_number_of_messages_received {0u}

private

Definition at line 132 of file test_benchmark_streaming.cpp.

_server

Server Benchmark::_server

private

Definition at line 118 of file test_benchmark_streaming.cpp.

Referenced by AddStream(), and Benchmark().

_streams

std::vector<Stream> Benchmark::_streams

private

Definition at line 130 of file test_benchmark_streaming.cpp.

_success_ratio

const double Benchmark::_success_ratio

private

Definition at line 128 of file test_benchmark_streaming.cpp.

_threads

carla::ThreadGroup Benchmark::_threads

private

Definition at line 116 of file test_benchmark_streaming.cpp.

_work_to_do

boost::asio::executor_work_guard<boost::asio::io_context::executor_type> Benchmark::_work_to_do

private

Definition at line 126 of file test_benchmark_streaming.cpp.

---

The documentation for this class was generated from the following file:

• test_benchmark_streaming.cpp