hmbdc
simplify-high-performance-messaging-programming
Public Member Functions | List of all members
hmbdc::app::tcpcast::send_detail::SendTransportEngine Struct Reference
Inheritance diagram for hmbdc::app::tcpcast::send_detail::SendTransportEngine:
hmbdc::app::tcpcast::send_detail::SendTransport hmbdc::time::TimerManager hmbdc::time::ReoccuringTimer hmbdc::app::single_thread_powered_client hmbdc::app::Client< SendTransportEngine > hmbdc::app::tcpcast::Transport hmbdc::time::Timer hmbdc::app::MessageHandler< SendTransportEngine, Messages... > hmbdc::pattern::PoolConsumer

Public Member Functions

size_t sessionsRemainingActive () const
 check how many recipient sessions are still active More...
 
- Public Member Functions inherited from hmbdc::app::tcpcast::send_detail::SendTransport
 SendTransport (Config const &cfg, size_t maxMessageSize)
 ctor More...
 
- Public Member Functions inherited from hmbdc::time::TimerManager
void cancel (Timer &timer)
 cancel a timer previously scheduled with the TimerManager More...
 
- Public Member Functions inherited from hmbdc::app::Client< SendTransportEngine >
 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
 

Member Function Documentation

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: