|
| CCommanderChannel (boost::asio::io_context &_service, uint64_t _ProtocolHeaderID, boost::asio::io_context &_intercomService) |
|
REGISTER_DEFAULT_REMOTE_ID_STRING | BEGIN_MSG_MAP (CCommanderChannel) MESSAGE_HANDLER(cmdREPLY |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY | MESSAGE_HANDLER (cmdSIMPLE_MSG, on_cmdSIMPLE_MSG) MESSAGE_HANDLER(cmdGET_HOST_INFO |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO | MESSAGE_HANDLER (cmdSHUTDOWN, on_cmdSHUTDOWN) MESSAGE_HANDLER(cmdBINARY_ATTACHMENT_RECEIVED |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED | MESSAGE_HANDLER (cmdGET_ID, on_cmdGET_ID) MESSAGE_HANDLER(cmdSET_ID |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSET_ID | MESSAGE_HANDLER (cmdGET_LOG, on_cmdGET_LOG) MESSAGE_HANDLER(cmdASSIGN_USER_TASK |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSET_ID on_cmdASSIGN_USER_TASK | MESSAGE_HANDLER (cmdACTIVATE_USER_TASK, on_cmdACTIVATE_USER_TASK) MESSAGE_HANDLER(cmdSTOP_USER_TASK |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSET_ID on_cmdASSIGN_USER_TASK on_cmdSTOP_USER_TASK | MESSAGE_HANDLER (cmdUPDATE_KEY, on_cmdUPDATE_KEY) MESSAGE_HANDLER(cmdCUSTOM_CMD |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSET_ID on_cmdASSIGN_USER_TASK on_cmdSTOP_USER_TASK on_cmdCUSTOM_CMD | MESSAGE_HANDLER (cmdADD_SLOT, on_cmdADD_SLOT) MESSAGE_HANDLER(cmdUSER_TASK_DONE |
|
REGISTER_DEFAULT_REMOTE_ID_STRING on_cmdREPLY on_cmdGET_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSET_ID on_cmdASSIGN_USER_TASK on_cmdSTOP_USER_TASK on_cmdCUSTOM_CMD on_cmdUSER_TASK_DONE END_MSG_MAP() public void | setNumberOfSlots (size_t _nSlots) |
|
void | reconnect () |
|
void | connect (boost::asio::ip::tcp::resolver::iterator _endpoint_iterator) |
|
| DDS_DECLARE_EVENT_HANDLER_CLASS (CChannelEventHandlersImpl) DDS_DECLARE_EVENT_HANDLER_CLASS(CChannelMessageHandlersImpl) protected |
|
| ~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 (CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd) |
|
void | accumulativePushMsg (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
void | accumulativePushMsg (uint64_t _protocolHeaderID=0) |
|
void | pushMsg (CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd, uint64_t=0) |
|
void | pushMsg (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
void | pushMsg (uint64_t _protocolHeaderID=0) |
|
void | sendYourself (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
void | sendYourself (uint64_t _protocolHeaderID=0) |
|
void | pushBinaryAttachmentCmd (const std::string &_srcFilePath, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) |
|
void | pushBinaryAttachmentCmd (const dds::misc::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) |
|
void | processBinaryAttachmentStartCmd (const SSenderInfo &, SCommandAttachmentImpl< cmdBINARY_ATTACHMENT_START >::ptr_t _attachment) |
|
void | processBinaryAttachmentCmd (const SSenderInfo &_sender, SCommandAttachmentImpl< cmdBINARY_ATTACHMENT >::ptr_t _attachment) |
|
bool | started () |
|
std::string | remoteEndIDString () |
|
uint64_t | getProtocolHeaderID () const |
|