accumulativePushMsg(CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
accumulativePushMsg(const A &_attachment, uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
accumulativePushMsg(uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
BEGIN_MSG_MAP(CAgentChannel) MESSAGE_HANDLER(cmdREPLY_HOST_INFO | dds::commander_cmd::CAgentChannel | |
connectionPtr_t typedef | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
connectionPtrVector_t typedef | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
CServerChannelImpl(boost::asio::io_context &_service, const channelTypeVector_t _requiredChannelTypes) | dds::protocol_api::CServerChannelImpl< CAgentChannel > | inlineprotected |
DDS_DECLARE_EVENT_HANDLER_CLASS(CChannelEventHandlersImpl) DDS_DECLARE_EVENT_HANDLER_CLASS(CChannelMessageHandlersImpl) protected | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
dequeueMsg() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
dispatchHandlersImpl(ECmdType _cmd, const SSenderInfo &_sender, Args &&... args) | dds::protocol_api::CBaseEventHandlersImpl< ECmdType > | inlineprotected |
getAgentInfo() | dds::commander_cmd::CAgentChannel | |
getChannelType() const | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
getProtocolHeaderID() const | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
getRemoteHostInfo(const dds::protocol_api::SSenderInfo &_sender) | dds::commander_cmd::CAgentChannel | |
getStartupTime(const dds::protocol_api::SSenderInfo &_sender) | dds::commander_cmd::CAgentChannel | |
handlerExistsImpl(ECmdType _cmd) const | dds::protocol_api::CBaseEventHandlersImpl< ECmdType > | inlineprotected |
isHanshakeOK() const | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
m_channelType | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | protected |
m_ioContext | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | protected |
m_isHandshakeOK | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | protected |
m_protocolHeaderID | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | protected |
m_sessionID | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | protected |
makeNew(boost::asio::io_context &_service, uint64_t _protocolHeaderID, Args &(... args)) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inlinestatic |
MESSAGE_HANDLER(cmdSUBMIT, on_cmdSUBMIT) MESSAGE_HANDLER_DISPATCH(cmdUSER_TASK_DONE) MESSAGE_HANDLER_DISPATCH(cmdGET_AGENTS_INFO) MESSAGE_HANDLER_DISPATCH(cmdGET_IDLE_AGENTS_COUNT) MESSAGE_HANDLER_DISPATCH(cmdREPLY_ID) MESSAGE_HANDLER(cmdBINARY_ATTACHMENT_RECEIVED | dds::commander_cmd::CAgentChannel | |
MESSAGE_HANDLER_DISPATCH(cmdTRANSPORT_TEST) MESSAGE_HANDLER(cmdREPLY | dds::commander_cmd::CAgentChannel | |
MESSAGE_HANDLER_DISPATCH(cmdUPDATE_TOPOLOGY) MESSAGE_HANDLER_DISPATCH(cmdGET_LOG) MESSAGE_HANDLER_DISPATCH(cmdUPDATE_KEY) MESSAGE_HANDLER(cmdWATCHDOG_HEARTBEAT | dds::commander_cmd::CAgentChannel | |
MESSAGE_HANDLER_DISPATCH(cmdGET_PROP_LIST) MESSAGE_HANDLER_DISPATCH(cmdGET_PROP_VALUES) MESSAGE_HANDLER_DISPATCH(cmdCUSTOM_CMD) MESSAGE_HANDLER(cmdREPLY_ADD_SLOT | dds::commander_cmd::CAgentChannel | |
processBinaryAttachmentCmd(const SSenderInfo &_sender, SCommandAttachmentImpl< cmdBINARY_ATTACHMENT >::ptr_t _attachment) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
processBinaryAttachmentStartCmd(const SSenderInfo &, SCommandAttachmentImpl< cmdBINARY_ATTACHMENT_START >::ptr_t _attachment) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
pushBinaryAttachmentCmd(const std::string &_srcFilePath, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
pushBinaryAttachmentCmd(const dds::misc::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
pushMsg(CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd, uint64_t=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
pushMsg(const A &_attachment, uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
pushMsg(uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
registerHandlerImpl(std::function< R(Args...)> _handler) | dds::protocol_api::CBaseEventHandlersImpl< ECmdType > | inlineprotected |
remoteEndIDString() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
sendYourself(const A &_attachment, uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
sendYourself(uint64_t _protocolHeaderID=0) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
setChannelType(EChannelType _channelType) | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
setId(uint64_t _id) | dds::commander_cmd::CAgentChannel | |
socket() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
start() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
started() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
stop() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
weakConnectionPtr_t typedef | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
weakConnectionPtrVector_t typedef | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
~CBaseChannelImpl() | dds::protocol_api::CBaseChannelImpl< CAgentChannel > | inline |
~CServerChannelImpl() | dds::protocol_api::CServerChannelImpl< CAgentChannel > | inlineprotected |