dds::commander_cmd::CAgentChannel Class Reference

#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(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=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

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:

• dds-commander/src/AgentChannel.h
• dds-commander/src/AgentChannel.cpp