A streaming server. More...
#include <Server.h>
Public Member Functions | |
void | AsyncRun (size_t worker_threads) |
void | CloseStream (carla::streaming::detail::stream_id_type id) |
auto | GetLocalEndpoint () const |
carla::streaming::detail::token_type | GetToken (carla::streaming::detail::stream_id_type sensor_id) |
Stream | MakeStream () |
void | Run () |
Server (uint16_t port) | |
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) | |
void | SetSynchronousMode (bool is_synchro) |
void | SetTimeout (time_duration timeout) |
~Server () | |
Private Types | |
using | protocol_type = low_level::Server< detail::tcp::Server >::protocol_type |
using | underlying_server = low_level::Server< detail::tcp::Server > |
Private Attributes | |
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.
Definition at line 21 of file streaming/Server.h.
|
private |
Definition at line 23 of file streaming/Server.h.
Definition at line 22 of file streaming/Server.h.
|
inlineexplicit |
Definition at line 26 of file streaming/Server.h.
|
inlineexplicit |
Definition at line 29 of file streaming/Server.h.
|
inlineexplicit |
Definition at line 32 of file streaming/Server.h.
|
inline |
Definition at line 40 of file streaming/Server.h.
References _pool, and carla::ThreadPool::Stop().
|
inline |
Definition at line 64 of file streaming/Server.h.
References _pool, and carla::ThreadPool::AsyncRun().
|
inline |
Definition at line 56 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::CloseStream().
|
inline |
Definition at line 44 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::GetLocalEndpoint().
|
inline |
Definition at line 72 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::GetToken().
Referenced by FCarlaServer::FPimpl::BindActions(), and FCarlaEngine::NotifyInitGame().
|
inline |
Definition at line 52 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::MakeStream().
|
inline |
Definition at line 60 of file streaming/Server.h.
References _pool, and carla::ThreadPool::Run().
|
inline |
Definition at line 68 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::SetSynchronousMode().
Referenced by FCarlaServer::FPimpl::BindActions().
|
inline |
Definition at line 48 of file streaming/Server.h.
References _server, and carla::streaming::low_level::Server< T >::SetTimeout().
|
private |
Definition at line 80 of file streaming/Server.h.
Referenced by AsyncRun(), Run(), and ~Server().
|
private |
Definition at line 82 of file streaming/Server.h.
Referenced by CloseStream(), GetLocalEndpoint(), GetToken(), MakeStream(), SetSynchronousMode(), and SetTimeout().