Keeps the mapping between streams and sessions. 更多...
#include <Dispatcher.h>
carla::streaming::detail::Dispatcher 的协作图: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 第 30 行定义.
|
inlineexplicit |
在文件 Dispatcher.h 第 34 行定义.
| carla::streaming::detail::Dispatcher::~Dispatcher | ( | ) |
| void carla::streaming::detail::Dispatcher::CloseStream | ( | carla::streaming::detail::stream_id_type | id | ) |
在文件 Dispatcher.cpp 第 71 行定义.
引用了 _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 第 125 行定义.
引用了 _mutex, _stream_map, DEBUG_ASSERT , 以及 carla::log_debug().
被这些函数引用 carla::streaming::low_level::Server< T >::StartServer().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 Dispatcher.h 第 56 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::DisableForROS().
这是这个函数的调用关系图:
|
inline |
在文件 Dispatcher.h 第 49 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::EnableForROS().
这是这个函数的调用关系图:| token_type carla::streaming::detail::Dispatcher::GetToken | ( | stream_id_type | sensor_id | ) |
在文件 Dispatcher.cpp 第 149 行定义.
引用了 _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 第 63 行定义.
引用了 _stream_map.
被这些函数引用 carla::streaming::low_level::Server< T >::IsEnabledForROS().
这是这个函数的调用关系图:| carla::streaming::Stream carla::streaming::detail::Dispatcher::MakeStream | ( | ) |
在文件 Dispatcher.cpp 第 42 行定义.
引用了 _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 第 95 行定义.
引用了 _mutex, _stream_map, DEBUG_ASSERT, carla::log_debug() , 以及 carla::log_error().
被这些函数引用 carla::streaming::low_level::Server< T >::StartServer().
函数调用图:
这是这个函数的调用关系图:
|
private |
在文件 Dispatcher.h 第 77 行定义.
被这些函数引用 GetToken() , 以及 MakeStream().
|
private |
在文件 Dispatcher.h 第 75 行定义.
被这些函数引用 CloseStream(), DeregisterSession(), GetToken(), MakeStream() , 以及 RegisterSession().
|
private |
在文件 Dispatcher.h 第 79 行定义.
被这些函数引用 CloseStream(), DeregisterSession(), DisableForROS(), EnableForROS(), GetToken(), IsEnabledForROS(), MakeStream(), RegisterSession() , 以及 ~Dispatcher().