|
size_t | sessionsRemainingActive () const |
| check how many recipient sessions are still active More...
|
|
| SendTransport (Config const &cfg, size_t maxMessageSize) |
| ctor More...
|
|
void | cancel (Timer &timer) |
| cancel a timer previously scheduled with the TimerManager More...
|
|
| Client () |
| trivial constructor
|
|
void | messageDispatchingStartedCb (uint16_t threadSerialNumber) override |
| called before any messages got dispatched - only once More...
|
|
void | stoppedCb (std::exception const &e) override |
| callback called when this Client is taken out of message dispatching More...
|
|
bool | droppedCb () override |
| callback called after the Client is safely taken out of the Context More...
|
|
void | invokedCb (uint16_t threadSerialNumber) override |
| this callback is called all the time (frequently) More...
|
|
char const * | hmbdcName () const |
| return the name of thread that runs this client, override if necessary More...
|
|
std::tuple< char const *, int > | schedSpec () const |
| an overrideable method. returns the schedule policy and priority, override if necessary priority is only used when policy is "SCHED_RR", or "SCHED_FIFO" More...
|
|
size_t | maxBatchMessageCount () const |
| an overridable method. client receives events in batches and the max batch size is controllable when running in direct mode Context. Here is to specify the max size. More...
|
|
void | handleRangeImpl (BufIt &it, BufIt const &end, uint16_t threadSerialNumber) override |
| internal use, don't change or override
|
|
size_t hmbdc::app::tcpcast::send_detail::SendTransportEngine::sessionsRemainingActive |
( |
| ) |
const |
|
inline |
check how many recipient sessions are still active
- Returns
- numeric_limits<size_t>::max() if the sending hasn't started due to minRecvToStart has not been met yet
The documentation for this struct was generated from the following file: