#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_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

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED	MESSAGE_HANDLER_DISPATCH (cmdTRANSPORT_TEST) MESSAGE_HANDLER(cmdREPLY

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdREPLY	MESSAGE_HANDLER_DISPATCH (cmdUPDATE_TOPOLOGY) MESSAGE_HANDLER_DISPATCH(cmdGET_LOG) MESSAGE_HANDLER_DISPATCH(cmdUPDATE_KEY) MESSAGE_HANDLER(cmdWATCHDOG_HEARTBEAT

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdREPLY on_cmdWATCHDOG_HEARTBEAT	MESSAGE_HANDLER_DISPATCH (cmdGET_PROP_LIST) MESSAGE_HANDLER_DISPATCH(cmdGET_PROP_VALUES) MESSAGE_HANDLER_DISPATCH(cmdENABLE_STAT) MESSAGE_HANDLER_DISPATCH(cmdDISABLE_STAT) MESSAGE_HANDLER_DISPATCH(cmdGET_STAT) MESSAGE_HANDLER_DISPATCH(cmdCUSTOM_CMD) MESSAGE_HANDLER(cmdREPLY_ADD_SLOT

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdREPLY on_cmdWATCHDOG_HEARTBEAT on_cmdREPLY_ADD_SLOT END_MSG_MAP() public void	setId (uint64_t _id)

protocol_api::SHostInfoCmd	getRemoteHostInfo (const dds::protocol_api::SSenderInfo &_sender)

std::chrono::milliseconds	getStartupTime (const dds::protocol_api::SSenderInfo &_sender)

SAgentInfo &	getAgentInfo ()

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_context &_context)

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_context &_service, uint64_t _protocolHeaderID, Args &(... args))

Protected Member Functions inherited from dds::protocol_api::CServerChannelImpl< CAgentChannel >
	CServerChannelImpl (boost::asio::io_context &_service, const channelTypeVector_t _requiredChannelTypes)

	~CServerChannelImpl ()

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

EChannelType	m_channelType

std::string	m_sessionID

uint64_t	m_protocolHeaderID

boost::asio::io_context &	m_ioContext

Member Function Documentation

◆ BEGIN_MSG_MAP()

dds::commander_cmd::CAgentChannel::BEGIN_MSG_MAP ( CAgentChannel )

◆ getAgentInfo()

SAgentInfo & CAgentChannel::getAgentInfo ( )

◆ getRemoteHostInfo()

SHostInfoCmd CAgentChannel::getRemoteHostInfo ( const dds::protocol_api::SSenderInfo & _sender )

◆ getStartupTime()

chrono::milliseconds CAgentChannel::getStartupTime ( const dds::protocol_api::SSenderInfo & _sender )

◆ MESSAGE_HANDLER()

on_cmdREPLY_HOST_INFO dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdSUBMIT	,
		on_cmdSUBMIT
	)

◆ MESSAGE_HANDLER_DISPATCH() [1/3]

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER_DISPATCH ( cmdTRANSPORT_TEST )

◆ MESSAGE_HANDLER_DISPATCH() [2/3]

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdREPLY dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER_DISPATCH ( cmdUPDATE_TOPOLOGY )

◆ MESSAGE_HANDLER_DISPATCH() [3/3]

on_cmdREPLY_HOST_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdREPLY on_cmdWATCHDOG_HEARTBEAT dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER_DISPATCH ( cmdGET_PROP_LIST )

◆ setId()

void CAgentChannel::setId ( uint64_t _id )

The documentation for this class was generated from the following files:

Public Member Functions

Additional Inherited Members