|
| RecvTransportEngine (Config const &cfg, OutputBuffer &outputBuffer, MsgArbitrator arb=NoOpArb()) |
| ctor More...
|
|
void | messageDispatchingStartedCb (uint16_t threadSerialNumber) override |
| start the show by schedule the message recv
|
|
char const * | hmbdcName () const |
|
std::tuple< char const *, int > | schedSpec () const |
|
void | stoppedCb (std::exception const &e) override |
| should not happen ever unless an exception thrown More...
|
|
void | invokedCb (uint16_t threadSerialNumber) __restrict__ override |
| power the io_service and other things
|
|
void | handleMessageCb (Subscribe const &t) |
| only used by MH
|
|
void | handleMessageCb (Unsubscribe const &t) |
| only used by MH
|
|
void | handleMessageCb (TopicSource const &t) |
| only used by MH
|
|
| Transport (Config const &cfg) |
|
void | initInThread () |
|
bool | operator== (Transport const &other) const |
|
bool | operator< (Transport const &other) const |
|
void | schedule (SysTime fireAt, Timer &timer) |
|
void | cancel (Timer &timer) |
| cancel a timer previously scheduled with the TimerManager More...
|
|
void | checkTimers (time::SysTime) |
|
| ReoccuringTimer (Duration const &interval, Callback callback=detail::noop) |
|
| Timer (Callback cb=detail::noop) |
|
void | setCallback (Callback cb) |
|
bool | operator< (Timer const &other) const |
|
bool | operator<= (SysTime const &t) const |
|
| 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
|
|
Public Member Functions inherited from hmbdc::app::MessageHandler< RecvTransportEngine< OutputBuffer, MsgArbitrator >, Messages... > |
void | handleMessage (MessageHead &w) |
|
| PoolConsumer (bool interestedInMessages=true) |
|
void | stopped (std::exception const &) noexcept |
|
bool | dropped () noexcept |
|
void | messageDispatchingStarted (uint16_t threadId) |
|
void | invoked (uint16_t threadId) |
|
Public Member Functions inherited from hmbdc::app::MessageHandler< RecvTransportEngine< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe, TopicSource > |
void | handleMessage (MessageHead &w) |
|
template<typename OutputBuffer, typename MsgArbitrator = RecvTransport::NoOpArb>
struct hmbdc::app::tcpcast::RecvTransportEngine< OutputBuffer, MsgArbitrator >
impl class
this needs to be created using NetContext and start in an app::Context
- Template Parameters
-
OutputBuffer | type of buffer to hold resulting network messages |