|
| RecvTransportEngine (Config cfg, OutputBuffer &outputBuffer) |
| ctor More...
|
|
void | stoppedCb (std::exception const &e) override |
| should not htipsen ever unless an exception thrown More...
|
|
void | invokedCb (size_t) HMBDC_RESTRICT override |
| power the io_service and other things
|
|
size_t | sessionsRemainingActive () const |
| check how many other parties are sending to this engine More...
|
|
void | handleMessageCb (TypeTagSource const &t) |
| only used by MD
|
|
void | schedule (SysTime fireAt, Timer &timer) |
| schedule the timer to start at a specific time More...
|
|
void | cancel (Timer &timer) |
| cancel a timer previously scheduled with the TimerManager 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...
|
|
virtual void | messageDispatchingStartedCb (size_t const *pClientDispatchingStarted) |
| called before any messages got dispatched - only once More...
|
|
virtual bool | droppedCb () |
| callback called after the Client is safely taken out of the Context More...
|
|
virtual | ~Client () |
| trivial
|
|
void | stopped (std::exception const &e) noexcept |
| the following are for internal use, don't change or override
|
|
|
void | batchDone () |
| the derived user's Client has the option to stop the current batch of event dispatching. More...
|
|
◆ RecvTransportEngine()
template<typename OutputBuffer , typename AttachmentAllocator >
ctor
io_service could be passed in by user, in this case NO more than two threads should power this io_service instance since that would violate the thread garantee of Client, which is no callbacks are called in parallel
- Parameters
-
cfg | specify the details of the tcpcast transport |
outputBuffer | holding the results |
◆ sessionsRemainingActive()
template<typename OutputBuffer , typename AttachmentAllocator >
check how many other parties are sending to this engine
- Returns
- recipient session count are still active
◆ stoppedCb()
template<typename OutputBuffer , typename AttachmentAllocator >
The documentation for this struct was generated from the following file: