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 |
|
capture the transportation mechanism
hmbdc::app::tcpcast::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: