cancel(Timer &timer) | hmbdc::time::TimerManager | inline |
Client() | hmbdc::app::Client< RecvTransportEngine< OutputBuffer, MsgArbitrator > > | inline |
droppedCb() override | hmbdc::app::Client< RecvTransportEngine< OutputBuffer, MsgArbitrator > > | inlinevirtual |
handleMessageCb(Subscribe const &t) | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inline |
handleMessageCb(Unsubscribe const &t) | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inline |
handleMessageCb(TopicSource const &t) | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inline |
handleRangeImpl(BufIt &it, BufIt const &end, uint16_t threadSerialNumber) override | hmbdc::app::Client< RecvTransportEngine< OutputBuffer, MsgArbitrator > > | inlinevirtual |
invokedCb(uint16_t threadSerialNumber) HMBDC_RESTRICT override | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inlinevirtual |
maxBatchMessageCount() const | hmbdc::app::Client< RecvTransportEngine< OutputBuffer, MsgArbitrator > > | inline |
messageDispatchingStartedCb(uint16_t threadSerialNumber) override | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inlinevirtual |
RecvTransportEngine(Config const &cfg, OutputBuffer &outputBuffer, MsgArbitrator arb=NoOpArb()) | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inline |
stoppedCb(std::exception const &e) override | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inlinevirtual |
tryTopicSource(TopicSource const &s) | hmbdc::app::tcpcast::recvtransportengine_detail::RecvTransportEngine< OutputBuffer, MsgArbitrator > | inline |