carla::streaming::Server类 参考

A streaming server. 更多...

#include <Server.h>

carla::streaming::Server 的协作图:

Public 成员函数
void	AsyncRun (size_t worker_threads)
void	CloseStream (carla::streaming::detail::stream_id_type id)
void	DisableForROS (stream_id sensor_id)
void	EnableForROS (stream_id sensor_id)
auto	GetLocalEndpoint () const
token_type	GetToken (stream_id sensor_id)
bool	IsEnabledForROS (stream_id sensor_id)
Stream	MakeStream ()
void	Run ()
	Server (const std::string &address, uint16_t port)
	Server (const std::string &address, uint16_t port, const std::string &external_address, uint16_t external_port)
	Server (uint16_t port)
void	SetSynchronousMode (bool is_synchro)
void	SetTimeout (time_duration timeout)
	~Server ()

Private 类型
using	protocol_type = low_level::Server<detail::tcp::Server>::protocol_type
using	stream_id = carla::streaming::detail::stream_id_type
using	token_type = carla::streaming::detail::token_type
using	underlying_server = low_level::Server<detail::tcp::Server>

Private 属性
ThreadPool	_pool
underlying_server	_server

详细描述

A streaming server.

Each new stream has a token associated, this token can be used by a client to subscribe to the stream.

在文件 streaming/Server.h 第 21 行定义.

成员类型定义说明

protocol_type

using carla::streaming::Server::protocol_type = low_level::Server<detail::tcp::Server>::protocol_type

private

在文件 streaming/Server.h 第 23 行定义.

stream_id

using carla::streaming::Server::stream_id = carla::streaming::detail::stream_id_type

private

在文件 streaming/Server.h 第 25 行定义.

token_type

using carla::streaming::Server::token_type = carla::streaming::detail::token_type

private

在文件 streaming/Server.h 第 24 行定义.

underlying_server

using carla::streaming::Server::underlying_server = low_level::Server<detail::tcp::Server>

private

在文件 streaming/Server.h 第 22 行定义.

构造及析构函数说明

Server() [1/3]

carla::streaming::Server::Server ( uint16_t port )

inlineexplicit

在文件 streaming/Server.h 第 28 行定义.

Server() [2/3]

carla::streaming::Server::Server ( const std::string & address, uint16_t port )

inlineexplicit

在文件 streaming/Server.h 第 31 行定义.

Server() [3/3]

carla::streaming::Server::Server ( const std::string & address, uint16_t port, const std::string & external_address, uint16_t external_port )

inlineexplicit

在文件 streaming/Server.h 第 34 行定义.

~Server()

carla::streaming::Server::~Server ( )

inline

在文件 streaming/Server.h 第 42 行定义.

引用了 _pool , 以及 carla::ThreadPool::Stop().

函数调用图:

成员函数说明

AsyncRun()

void carla::streaming::Server::AsyncRun ( size_t worker_threads )

inline

在文件 streaming/Server.h 第 66 行定义.

引用了 _pool , 以及 carla::ThreadPool::AsyncRun().

被这些函数引用 TEST() , 以及 TEST().

函数调用图:

这是这个函数的调用关系图:

CloseStream()

void carla::streaming::Server::CloseStream ( carla::streaming::detail::stream_id_type id )

inline

在文件 streaming/Server.h 第 58 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::CloseStream().

函数调用图:

DisableForROS()

void carla::streaming::Server::DisableForROS ( stream_id sensor_id )

inline

在文件 streaming/Server.h 第 82 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::DisableForROS().

被这些函数引用 FCarlaServer::FPimpl::BindActions() , 以及 FCarlaEngine::NotifyInitGame().

函数调用图:

这是这个函数的调用关系图:

EnableForROS()

void carla::streaming::Server::EnableForROS ( stream_id sensor_id )

inline

在文件 streaming/Server.h 第 78 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::EnableForROS().

被这些函数引用 FCarlaServer::FPimpl::BindActions() , 以及 FCarlaEngine::NotifyInitGame().

函数调用图:

这是这个函数的调用关系图:

GetLocalEndpoint()

auto carla::streaming::Server::GetLocalEndpoint ( ) const

inline

在文件 streaming/Server.h 第 46 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::GetLocalEndpoint().

函数调用图:

GetToken()

token_type carla::streaming::Server::GetToken ( stream_id sensor_id )

inline

在文件 streaming/Server.h 第 74 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::GetToken().

被这些函数引用 FCarlaServer::FPimpl::BindActions() , 以及 FCarlaEngine::NotifyInitGame().

函数调用图:

这是这个函数的调用关系图:

IsEnabledForROS()

bool carla::streaming::Server::IsEnabledForROS ( stream_id sensor_id )

inline

在文件 streaming/Server.h 第 86 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::IsEnabledForROS().

被这些函数引用 FCarlaServer::FPimpl::BindActions() , 以及 FCarlaEngine::NotifyInitGame().

函数调用图:

这是这个函数的调用关系图:

MakeStream()

Stream carla::streaming::Server::MakeStream ( )

inline

在文件 streaming/Server.h 第 54 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::MakeStream().

被这些函数引用 Benchmark::AddStream(), TEST() , 以及 TEST().

函数调用图:

这是这个函数的调用关系图:

Run()

void carla::streaming::Server::Run ( )

inline

在文件 streaming/Server.h 第 62 行定义.

引用了 _pool , 以及 carla::ThreadPool::Run().

函数调用图:

SetSynchronousMode()

void carla::streaming::Server::SetSynchronousMode ( bool is_synchro )

inline

在文件 streaming/Server.h 第 70 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::SetSynchronousMode().

被这些函数引用 FCarlaServer::FPimpl::BindActions().

函数调用图:

这是这个函数的调用关系图:

SetTimeout()

void carla::streaming::Server::SetTimeout ( time_duration timeout )

inline

在文件 streaming/Server.h 第 50 行定义.

引用了 _server , 以及 carla::streaming::low_level::Server< T >::SetTimeout().

函数调用图:

类成员变量说明

_pool

ThreadPool carla::streaming::Server::_pool

private

在文件 streaming/Server.h 第 94 行定义.

被这些函数引用 AsyncRun(), Run() , 以及 ~Server().

_server

underlying_server carla::streaming::Server::_server

private

在文件 streaming/Server.h 第 96 行定义.

被这些函数引用 CloseStream(), DisableForROS(), EnableForROS(), GetLocalEndpoint(), GetToken(), IsEnabledForROS(), MakeStream(), SetSynchronousMode() , 以及 SetTimeout().

---

该类的文档由以下文件生成:

• streaming/Server.h