#include <AgentChannel.h>
Inheritance diagram for dds::commander_cmd::CAgentChannel:
Public Member Functions | |
| BEGIN_MSG_MAP (CAgentChannel) MESSAGE_HANDLER(cmdREPLY_HOST_INFO | |
| on_cmdREPLY_HOST_INFO | MESSAGE_HANDLER (cmdSUBMIT, on_cmdSUBMIT) MESSAGE_HANDLER(cmdUSER_TASK_DONE |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE | MESSAGE_HANDLER (cmdGED_PID, on_cmdGED_PID) MESSAGE_HANDLER(cmdGET_AGENTS_INFO |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO | MESSAGE_HANDLER (cmdREPLY_ID, on_cmdREPLY_ID) MESSAGE_HANDLER(cmdBINARY_ATTACHMENT_RECEIVED |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED | MESSAGE_HANDLER (cmdTRANSPORT_TEST, on_cmdTRANSPORT_TEST) MESSAGE_HANDLER(cmdSIMPLE_MSG |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG | MESSAGE_HANDLER (cmdUPDATE_TOPOLOGY, on_cmdUPDATE_TOPOLOGY) MESSAGE_HANDLER(cmdGET_LOG |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG | MESSAGE_HANDLER (cmdUPDATE_KEY, on_cmdUPDATE_KEY) MESSAGE_HANDLER(cmdWATCHDOG_HEARTBEAT |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT | MESSAGE_HANDLER (cmdGET_PROP_LIST, on_cmdGET_PROP_LIST) MESSAGE_HANDLER(cmdGET_PROP_VALUES |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES | MESSAGE_HANDLER (cmdENABLE_STAT, on_cmdENABLE_STAT) MESSAGE_HANDLER(cmdDISABLE_STAT |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT | MESSAGE_HANDLER (cmdGET_STAT, on_cmdGET_STAT) MESSAGE_HANDLER(cmdCUSTOM_CMD |
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT on_cmdCUSTOM_CMD END_MSG_MAP() public void | setId (uint64_t _id) |
| const protocol_api::SHostInfoCmd & | getRemoteHostInfo () const |
| void | setRemoteHostInfo (const protocol_api::SHostInfoCmd &_hostInfo) |
| uint64_t | getTaskID () const |
| void | setTaskID (uint64_t _taskID) |
| std::chrono::milliseconds | getStartupTime () const |
| EAgentState | getState () const |
| void | setState (EAgentState _state) |
 Public Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
| ~CBaseChannelImpl () | |
| bool | isHanshakeOK () const |
| EChannelType | getChannelType () const |
| void | setChannelType (EChannelType _channelType) |
| void | start () |
| void | stop () |
| boost::asio::ip::tcp::socket & | socket () |
| void | dequeueMsg () |
| void | accumulativePushMsg (const A &_attachment) |
| void | accumulativePushMsg () |
| void | pushMsg (const A &_attachment) |
| void | pushMsg () |
| void | sendYourself (const A &_attachment) |
| void | sendYourself () |
| void | pushBinaryAttachmentCmd (const std::string &_srcFilePath, const std::string &_fileName, uint16_t _cmdSource) |
| void | pushBinaryAttachmentCmd (const MiscCommon::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource) |
| void | processBinaryAttachmentStartCmd (SCommandAttachmentImpl< cmdBINARY_ATTACHMENT_START >::ptr_t _attachment) |
| void | processBinaryAttachmentCmd (SCommandAttachmentImpl< cmdBINARY_ATTACHMENT >::ptr_t _attachment) |
| void | registerDisconnectEventHandler (handlerDisconnectEventFunction_t _handler) |
| bool | started () |
| std::string | remoteEndIDString () |
| Public Member Functions inherited from dds::protocol_api::CChannelEventsImpl< CAgentChannel > | |
| CChannelEventsImpl () | |
| ~CChannelEventsImpl () | |
| connection_t | subscribeOnEvent (EChannelEvents _type, typename signal_t::slot_function_type _subscriber) |
| void | onEvent (EChannelEvents _type) |
| Public Member Functions inherited from dds::protocol_api::CChannelMessageHandlersImpl | |
| template<ECmdType _cmd, typename Func > | |
| void | registerMessageHandler (Func _handler) |
| template<class... Args> | |
| void | dispatchMessageHandlers (ECmdType _cmd, Args &&... args) |
| template<ECmdType _cmd> | |
| size_t | getNofMessageHandlers () const |
| Public Member Functions inherited from dds::protocol_api::CStatImpl | |
| CStatImpl (boost::asio::io_service &_service) | |
| SReadStat | getReadStat () const |
| Return read statistics. More... | |
| SWriteStat | getWriteStat () const |
| Return write statistics. More... | |
| void | setStatEnabled (bool _statEnabled) |
| Enable/disable statistics accumulation. More... | |
| void | logReadMessage (CProtocolMessage::protocolMessagePtr_t _message) |
| void | logWriteMessages (const protocolMessagePtrQueue_t &_messageQueue) |
Additional Inherited Members | |
| Public Types inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
| typedef std::shared_ptr< CAgentChannel > | connectionPtr_t |
| typedef std::weak_ptr< CAgentChannel > | weakConnectionPtr_t |
| typedef std::vector< connectionPtr_t > | connectionPtrVector_t |
| typedef std::vector< weakConnectionPtr_t > | weakConnectionPtrVector_t |
| Public Types inherited from dds::protocol_api::CChannelEventsImpl< CAgentChannel > | |
| typedef boost::signals2::signal< void(CAgentChannel *)> | signal_t |
| typedef boost::signals2::connection | connection_t |
| Static Public Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
| static connectionPtr_t | makeNew (boost::asio::io_service &_service) |
| Protected Member Functions inherited from dds::protocol_api::CServerChannelImpl< CAgentChannel > | |
| CServerChannelImpl (boost::asio::io_service &_service, const channelTypeVector_t _requiredChannelTypes) | |
| ~CServerChannelImpl () | |
| Protected Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
| CBaseChannelImpl (boost::asio::io_service &_service) | |
| Protected Attributes inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel > | |
| bool | m_isHandshakeOK |
| EChannelType | m_channelType |
Member Function Documentation
◆ BEGIN_MSG_MAP()
| dds::commander_cmd::CAgentChannel::BEGIN_MSG_MAP | ( | CAgentChannel | ) |
◆ getRemoteHostInfo()
| const SHostInfoCmd & CAgentChannel::getRemoteHostInfo | ( | ) | const |
◆ getStartupTime()
| std::chrono::milliseconds CAgentChannel::getStartupTime | ( | ) | const |
◆ getState()
| EAgentState CAgentChannel::getState | ( | ) | const |
◆ getTaskID()
| uint64_t CAgentChannel::getTaskID | ( | ) | const |
◆ MESSAGE_HANDLER() [1/9]
| on_cmdREPLY_HOST_INFO dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdSUBMIT | , |
| on_cmdSUBMIT | |||
| ) |
◆ MESSAGE_HANDLER() [2/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdGED_PID | , |
| on_cmdGED_PID | |||
| ) |
◆ MESSAGE_HANDLER() [3/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdREPLY_ID | , |
| on_cmdREPLY_ID | |||
| ) |
◆ MESSAGE_HANDLER() [4/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdTRANSPORT_TEST | , |
| on_cmdTRANSPORT_TEST | |||
| ) |
◆ MESSAGE_HANDLER() [5/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdUPDATE_TOPOLOGY | , |
| on_cmdUPDATE_TOPOLOGY | |||
| ) |
◆ MESSAGE_HANDLER() [6/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdUPDATE_KEY | , |
| on_cmdUPDATE_KEY | |||
| ) |
◆ MESSAGE_HANDLER() [7/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdGET_PROP_LIST | , |
| on_cmdGET_PROP_LIST | |||
| ) |
◆ MESSAGE_HANDLER() [8/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdENABLE_STAT | , |
| on_cmdENABLE_STAT | |||
| ) |
◆ MESSAGE_HANDLER() [9/9]
| on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER | ( | cmdGET_STAT | , |
| on_cmdGET_STAT | |||
| ) |
◆ setId()
| void CAgentChannel::setId | ( | uint64_t | _id | ) |
◆ setRemoteHostInfo()
| void CAgentChannel::setRemoteHostInfo | ( | const protocol_api::SHostInfoCmd & | _hostInfo | ) |
◆ setState()
| void CAgentChannel::setState | ( | EAgentState | _state | ) |
◆ setTaskID()
| void CAgentChannel::setTaskID | ( | uint64_t | _taskID | ) |
The documentation for this class was generated from the following files:
