hmbdc
simplify-high-performance-messaging-programming
hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > Member List

This is the complete list of members for hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, including all inherited members.

asioSocket()hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
Buffer typedef (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
BufIt typedef (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumerprotected
Client()hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >inline
config_ (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
dropped() noexcept (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumer
droppedCb() overridehmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >inlinevirtual
handleMessage(MessageHead &w) (defined in hmbdc::app::MessageHandler< RecvTransportImpl< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe >)hmbdc::app::MessageHandler< RecvTransportImpl< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe >inline
handleMessage(MessageHead &w) (defined in hmbdc::app::MessageHandler< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, Messages... >)hmbdc::app::MessageHandler< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, Messages... >inline
handleMessageCb(Subscribe const &t)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
handleMessageCb(Unsubscribe const &t)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
handleRangeImpl(BufIt &it, BufIt const &end, uint16_t threadSerialNumber) overridehmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >inlinevirtual
hmbdcName() const (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >inline
hmbdcName_ (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
initInThread() (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
invoked(uint16_t threadId) (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumer
invokedCb(uint16_t) HMBDC_RESTRICT overridehmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >inlinevirtual
listenTo(Topic const &t) override (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inlinevirtual
maxBatchMessageCount() consthmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >inline
messageDispatchingStarted(uint16_t threadId) (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumerinline
messageDispatchingStartedCb(uint16_t threadSerialNumber) overridehmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >inlinevirtual
MH typedef (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >
operator<(Transport const &other) const (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportinline
operator==(Transport const &other) const (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportinline
pIos_ (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
PoolConsumer(bool interestedInMessages=true) (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumerexplicit
ptr typedef (defined in hmbdc::app::mcast::RecvTransport)hmbdc::app::mcast::RecvTransport
RecvTransportImpl(Config const &cfg, OutputBuffer &outputBuffer, MsgArbitrator arb=NoOpArb())hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
REGISTERED_MESSAGE_SIZE enum value (defined in hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >)hmbdc::app::Client< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > >
runOnce() HMBDC_RESTRICThmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
schedPolicy_ (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
schedPriority_ (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportprotected
schedSpec() const (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >inline
SELF typedef (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >
start()hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
stopListenTo(Topic const &t) override (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inlinevirtual
stopped(std::exception const &) noexcept (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumer
stoppedCb(std::exception const &e) overridehmbdc::app::mcast::recvtransportengine_detail::RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >inlinevirtual
Transport(Config const &cfg) (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportinline
tryDispatch(RecvTransportImpl< OutputBuffer, MsgArbitrator > *p, MessageHead &w) (defined in hmbdc::app::MessageHandler< RecvTransportImpl< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe >)hmbdc::app::MessageHandler< RecvTransportImpl< OutputBuffer, MsgArbitrator >, Subscribe, Unsubscribe >inlinestatic
tryDispatch(RecvTransportEngineImpl< OutputBuffer, MsgArbitrator > *p, MessageHead &w) (defined in hmbdc::app::MessageHandler< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, Messages... >)hmbdc::app::MessageHandler< RecvTransportEngineImpl< OutputBuffer, MsgArbitrator >, Messages... >inlinestatic
~PoolConsumer() (defined in hmbdc::pattern::PoolConsumer)hmbdc::pattern::PoolConsumervirtual
~RecvTransport() (defined in hmbdc::app::mcast::RecvTransport)hmbdc::app::mcast::RecvTransportinlinevirtual
~RecvTransportImpl() (defined in hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >)hmbdc::app::mcast::recvtransportengine_detail::RecvTransportImpl< OutputBuffer, MsgArbitrator >inline
~Transport() (defined in hmbdc::app::mcast::Transport)hmbdc::app::mcast::Transportinlinevirtual