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::io_context::work | _work_to_do |
Definition at line 30 of file test_benchmark_streaming.cpp.
|
inline |
Definition at line 33 of file test_benchmark_streaming.cpp.
|
inline |
Definition at line 41 of file test_benchmark_streaming.cpp.
References CARLA_PROFILE_FPS, carla::BufferView::CreateFrom(), DEBUG_ASSERT_EQ, and carla::streaming::detail::Stream< StreamStateT >::token().
|
inline |
Definition at line 56 of file test_benchmark_streaming.cpp.
Referenced by benchmark_image().
|
inline |
Definition at line 62 of file test_benchmark_streaming.cpp.
References CARLA_PROFILE_SCOPE, carla::log_warning(), and carla::logging::write_to_stream().
Referenced by benchmark_image().
|
private |
Definition at line 116 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 120 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 118 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 128 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 114 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 126 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 124 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 112 of file test_benchmark_streaming.cpp.
|
private |
Definition at line 122 of file test_benchmark_streaming.cpp.