#include <AgentChannel.h>
Inheritance diagram for dds::internal_api::CAgentChannel:
Public Member Functions | |
| BEGIN_MSG_MAP (CAgentChannel) MESSAGE_HANDLER(cmdSIMPLE_MSG | |
| on_cmdSIMPLE_MSG | MESSAGE_HANDLER (cmdSHUTDOWN, on_cmdSHUTDOWN) MESSAGE_HANDLER(cmdCUSTOM_CMD |
| void | reconnectAgentWithErrorHandler (const std::function< void(const std::string &)> &callback) |
 Public Member Functions inherited from dds::protocol_api::CClientChannelImpl< CAgentChannel > | |
| void | reconnect () |
| void | connect (boost::asio::ip::tcp::resolver::iterator _endpoint_iterator) |
| 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::CClientChannelImpl< CAgentChannel > | |
| CClientChannelImpl (boost::asio::io_service &_service, EChannelType _channelType) | |
| ~CClientChannelImpl () | |
| 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::internal_api::CAgentChannel::BEGIN_MSG_MAP | ( | CAgentChannel | ) |
◆ MESSAGE_HANDLER()
| on_cmdSIMPLE_MSG dds::internal_api::CAgentChannel::MESSAGE_HANDLER | ( | cmdSHUTDOWN | , |
| on_cmdSHUTDOWN | |||
| ) |
◆ reconnectAgentWithErrorHandler()
| void CAgentChannel::reconnectAgentWithErrorHandler | ( | const std::function< void(const std::string &)> & | callback | ) |
The documentation for this class was generated from the following files:
