Keeps the mapping between streams and sessions. 更多...
#include <Dispatcher.h>
Public 成员函数 | |
void | CloseStream (carla::streaming::detail::stream_id_type id) |
void | DeregisterSession (std::shared_ptr< Session > session) |
void | DisableForROS (stream_id_type sensor_id) |
template<typename Protocol , typename EndPointType > | |
Dispatcher (const EndPoint< Protocol, EndPointType > &ep) | |
void | EnableForROS (stream_id_type sensor_id) |
token_type | GetToken (stream_id_type sensor_id) |
bool | IsEnabledForROS (stream_id_type sensor_id) |
carla::streaming::Stream | MakeStream () |
bool | RegisterSession (std::shared_ptr< Session > session) |
~Dispatcher () | |
Private 属性 | |
token_type | _cached_token |
std::mutex | _mutex |
StreamMap | _stream_map |
Keeps the mapping between streams and sessions.
在文件 Dispatcher.h 第 27 行定义.
|
inlineexplicit |
在文件 Dispatcher.h 第 31 行定义.
carla::streaming::detail::Dispatcher::~Dispatcher | ( | ) |
void carla::streaming::detail::Dispatcher::CloseStream | ( | carla::streaming::detail::stream_id_type | id | ) |
在文件 Dispatcher.cpp 第 60 行定义.
引用了 _mutex, _stream_map , 以及 carla::log_debug().
被这些函数引用 carla::streaming::low_level::Server< T >::CloseStream().
void carla::streaming::detail::Dispatcher::DeregisterSession | ( | std::shared_ptr< Session > | session | ) |
在文件 Dispatcher.cpp 第 91 行定义.
引用了 _mutex, _stream_map, DEBUG_ASSERT , 以及 carla::log_debug().
被这些函数引用 carla::streaming::low_level::Server< T >::StartServer().
|
inline |
在文件 Dispatcher.h 第 53 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::DisableForROS().
|
inline |
在文件 Dispatcher.h 第 46 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::EnableForROS().
token_type carla::streaming::detail::Dispatcher::GetToken | ( | stream_id_type | sensor_id | ) |
在文件 Dispatcher.cpp 第 106 行定义.
引用了 _cached_token, _mutex, _stream_map, carla::streaming::detail::token_type::get_port(), carla::streaming::detail::token_type::get_stream_id(), carla::log_debug() , 以及 carla::streaming::detail::token_type::set_stream_id().
被这些函数引用 carla::streaming::low_level::Server< T >::GetToken().
|
inline |
在文件 Dispatcher.h 第 60 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::IsEnabledForROS().
carla::streaming::Stream carla::streaming::detail::Dispatcher::MakeStream | ( | ) |
在文件 Dispatcher.cpp 第 37 行定义.
引用了 _cached_token, _mutex, _stream_map, carla::streaming::detail::token_type::_token, carla::streaming::detail::token_type::get_stream_id(), carla::log_debug(), carla::streaming::detail::token_data::stream_id , 以及 carla::throw_exception().
被这些函数引用 carla::streaming::low_level::Server< T >::MakeStream() , 以及 TEST().
bool carla::streaming::detail::Dispatcher::RegisterSession | ( | std::shared_ptr< Session > | session | ) |
在文件 Dispatcher.cpp 第 74 行定义.
引用了 _mutex, _stream_map, DEBUG_ASSERT, carla::log_debug() , 以及 carla::log_error().
被这些函数引用 carla::streaming::low_level::Server< T >::StartServer().
|
private |
在文件 Dispatcher.h 第 74 行定义.
被这些函数引用 GetToken() , 以及 MakeStream().
|
private |
在文件 Dispatcher.h 第 72 行定义.
被这些函数引用 CloseStream(), DeregisterSession(), GetToken(), MakeStream() , 以及 RegisterSession().
|
private |
在文件 Dispatcher.h 第 76 行定义.
被这些函数引用 CloseStream(), DeregisterSession(), DisableForROS(), EnableForROS(), GetToken(), IsEnabledForROS(), MakeStream(), RegisterSession() , 以及 ~Dispatcher().