hmbdc
simplify-high-performance-messaging-programming
Public Member Functions | List of all members
hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > Struct Template Reference
Inheritance diagram for hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >:
hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator > hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > > hmbdc::app::mcast::RecvTransport hmbdc::app::MessageHandler< RecvTransportImpl< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe > hmbdc::app::MessageHandler< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, Messages... > hmbdc::app::mcast::Transport hmbdc::app::mcast::EpollFd hmbdc::app::utils::EpollFd

Public Member Functions

void invokedCb (uint16_t) HMBDC_RESTRICT override
 power the io_service and other things
 
void messageDispatchingStartedCb (uint16_t threadSerialNumber) override
 start the show by schedule the mesage recv
 
void stoppedCb (std::exception const &e) override
 should not happen ever unless an exception thrown More...
 
- Public Member Functions inherited from hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >
 RecvTransportImpl (Config const &cfg, OutputBuffer &outputBuffer, MsgArbitrator arb=NoOpArb())
 ctor More...
 
void start ()
 start the show by schedule the mesage recv
 
void handleMessageCb (Subscribe const &t)
 only used by MH
 
void handleMessageCb (Unsubscribe const &t)
 only used by MH
 
- Public Member Functions inherited from hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >
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 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
 internal use, don't change or override
 

Member Function Documentation

template<typename OutputBuffer, typename MsgArbitrator = RecvTransport::NoOpArb>
void hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >::stoppedCb ( std::exception const &  e)
inlineoverridevirtual

should not happen ever unless an exception thrown

Parameters
eexception thown

Reimplemented from hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >.


The documentation for this struct was generated from the following file: