#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 >
	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 _protocolHeaderID=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 MiscCommon::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID)

void	processBinaryAttachmentStartCmd (const SSenderInfo &_sender, 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

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

Static Public Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel >
static connectionPtr_t	makeNew (boost::asio::io_service &_service, uint64_t _protocolHeaderID)

Protected Member Functions inherited from dds::protocol_api::CClientChannelImpl< CAgentChannel >
	CClientChannelImpl (boost::asio::io_service &_service, EChannelType _channelType, uint64_t _protocolHeaderID)

	~CClientChannelImpl ()

Protected Attributes inherited from dds::protocol_api::CBaseChannelImpl< CAgentChannel >
bool	m_isHandshakeOK

EChannelType	m_channelType

std::string	m_sessionID

uint64_t	m_protocolHeaderID

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:

Public Member Functions

Additional Inherited Members

Member Function Documentation

◆ BEGIN_MSG_MAP()

◆ MESSAGE_HANDLER()

◆ reconnectAgentWithErrorHandler()