一个低级的流媒体服务器。每个新流都有一个关联的令牌, 客户端可以使用这个令牌来订阅流。此服务器需要外部 io_context 运行。 更多...
#include <Server.h>
类 carla::streaming::low_level::Server< T > 继承关系图:
carla::streaming::low_level::Server< T > 的协作图:Public 类型 | |
| using | protocol_type = typename underlying_server::protocol_type |
| using | stream_id = carla::streaming::detail::stream_id_type |
| using | token_type = carla::streaming::detail::token_type |
| using | underlying_server = T |
Public 成员函数 | |
| void | CloseStream (carla::streaming::detail::stream_id_type id) |
| void | DisableForROS (stream_id sensor_id) |
| void | EnableForROS (stream_id sensor_id) |
| underlying_server::endpoint | GetLocalEndpoint () const |
| token_type | GetToken (stream_id sensor_id) |
| bool | IsEnabledForROS (stream_id sensor_id) |
| Stream | MakeStream () |
| template<typename InternalEPType > | |
| Server (boost::asio::io_context &io_context, detail::EndPoint< protocol_type, InternalEPType > internal_ep) | |
| template<typename InternalEPType , typename ExternalEPType > | |
| Server (boost::asio::io_context &io_context, detail::EndPoint< protocol_type, InternalEPType > internal_ep, detail::EndPoint< protocol_type, ExternalEPType > external_ep) | |
| template<typename... EPArgs> | |
| Server (boost::asio::io_context &io_context, EPArgs &&... args) | |
| void | SetSynchronousMode (bool is_synchro) |
| void | SetTimeout (time_duration timeout) |
Private 成员函数 | |
| void | StartServer () |
Private 属性 | |
| detail::Dispatcher | _dispatcher |
| underlying_server | _server |
一个低级的流媒体服务器。每个新流都有一个关联的令牌, 客户端可以使用这个令牌来订阅流。此服务器需要外部 io_context 运行。
在文件 streaming/low_level/Server.h 第 24 行定义.
| using carla::streaming::low_level::Server< T >::protocol_type = typename underlying_server::protocol_type |
在文件 streaming/low_level/Server.h 第 29 行定义.
| using carla::streaming::low_level::Server< T >::stream_id = carla::streaming::detail::stream_id_type |
在文件 streaming/low_level/Server.h 第 33 行定义.
| using carla::streaming::low_level::Server< T >::token_type = carla::streaming::detail::token_type |
在文件 streaming/low_level/Server.h 第 31 行定义.
| using carla::streaming::low_level::Server< T >::underlying_server = T |
在文件 streaming/low_level/Server.h 第 27 行定义.
|
inlineexplicit |
在文件 streaming/low_level/Server.h 第 37 行定义.
引用了 carla::streaming::low_level::Server< T >::StartServer().
函数调用图:
|
inlineexplicit |
在文件 streaming/low_level/Server.h 第 48 行定义.
引用了 carla::streaming::low_level::Server< T >::StartServer().
函数调用图:
|
inlineexplicit |
在文件 streaming/low_level/Server.h 第 58 行定义.
|
inline |
在文件 streaming/low_level/Server.h 第 77 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::CloseStream().
被这些函数引用 carla::streaming::Server::CloseStream().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 97 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::DisableForROS().
被这些函数引用 carla::streaming::Server::DisableForROS().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 92 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::EnableForROS().
被这些函数引用 carla::streaming::Server::EnableForROS().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 62 行定义.
引用了 carla::streaming::low_level::Server< T >::_server.
被这些函数引用 carla::streaming::Server::GetLocalEndpoint().
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 87 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::GetToken().
被这些函数引用 carla::streaming::Server::GetToken().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 102 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::IsEnabledForROS().
被这些函数引用 carla::streaming::Server::IsEnabledForROS().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 72 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher , 以及 carla::streaming::detail::Dispatcher::MakeStream().
被这些函数引用 carla::streaming::Server::MakeStream() , 以及 TEST().
函数调用图:
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 82 行定义.
引用了 carla::streaming::low_level::Server< T >::_server.
被这些函数引用 carla::streaming::Server::SetSynchronousMode().
这是这个函数的调用关系图:
|
inline |
在文件 streaming/low_level/Server.h 第 67 行定义.
引用了 carla::streaming::low_level::Server< T >::_server.
被这些函数引用 carla::streaming::Server::SetTimeout() , 以及 TEST().
这是这个函数的调用关系图:
|
inlineprivate |
在文件 streaming/low_level/Server.h 第 109 行定义.
引用了 carla::streaming::low_level::Server< T >::_dispatcher, carla::streaming::low_level::Server< T >::_server, carla::streaming::detail::Dispatcher::DeregisterSession(), carla::log_debug() , 以及 carla::streaming::detail::Dispatcher::RegisterSession().
被这些函数引用 carla::streaming::low_level::Server< T >::Server().
函数调用图:
这是这个函数的调用关系图:
|
private |
在文件 streaming/low_level/Server.h 第 126 行定义.
被这些函数引用 carla::streaming::low_level::Server< T >::CloseStream(), carla::streaming::low_level::Server< T >::DisableForROS(), carla::streaming::low_level::Server< T >::EnableForROS(), carla::streaming::low_level::Server< T >::GetToken(), carla::streaming::low_level::Server< T >::IsEnabledForROS(), carla::streaming::low_level::Server< T >::MakeStream() , 以及 carla::streaming::low_level::Server< T >::StartServer().
|
private |