capture the transportation mechanism
More...
#include <SendTransportEngine.hpp>
|
| SendTransport (Config const &cfg, size_t maxMessageSize, size_t minRecvToStart) |
| ctor More...
|
|
template<typename... Messages> |
void | queue (Topic const &t, Messages &&...msgs) |
|
template<typename... Messages> |
bool | tryQueue (Topic const &t, Messages &&...msgs) |
|
template<typename Message , typename... Args> |
void | queueInPlace (Topic const &t, Args &&...args) |
|
void | queueBytes (Topic const &t, uint16_t tag, void const *bytes, size_t len) |
|
void | stop () |
|
void | initInThread () |
|
bool | match (Topic const &t) const |
|
| Transport (Config const &cfg) |
|
void | initInThread () |
|
bool | operator== (Transport const &other) const |
|
bool | operator< (Transport const &other) const |
|
|
size_t | maxMessageSize_ |
|
size_t | minRecvToStart_ |
|
MonoLockFreeBuffer | buffer_ |
|
unique_ptr< mcast::SendTransport > | mcSendTransport_ |
|
Rater | rater_ |
|
Config | mcConfig_ |
|
Config const | config_ |
|
std::string | hmbdcName_ |
|
std::string | schedPolicy_ |
|
int | schedPriority_ |
|
boost::asio::ip::udp::endpoint | endpoint_ |
|
std::shared_ptr< boost::asio::io_service > | pIos_ |
|
Topic const | tcpcastAdTopic_ |
|
capture the transportation mechanism
hmbdc::app::tcpcast::send_detail::SendTransport::SendTransport |
( |
Config const & |
cfg, |
|
|
size_t |
maxMessageSize, |
|
|
size_t |
minRecvToStart |
|
) |
| |
|
inline |
ctor
- Parameters
-
cfg | jason specifing the transport - see example, perf-tcpcast.cpp |
maxMessageSize | max messafe size in bytes to be sent |
minRecvToStart | start send when there are that many recipient online, otherwise hold the message in buffer |
The documentation for this struct was generated from the following file: