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(cmdUSER_TASK_DONE
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE	MESSAGE_HANDLER (cmdGED_PID, on_cmdGED_PID) MESSAGE_HANDLER(cmdGET_AGENTS_INFO
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO	MESSAGE_HANDLER (cmdREPLY_ID, on_cmdREPLY_ID) MESSAGE_HANDLER(cmdBINARY_ATTACHMENT_RECEIVED
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED	MESSAGE_HANDLER (cmdTRANSPORT_TEST, on_cmdTRANSPORT_TEST) MESSAGE_HANDLER(cmdSIMPLE_MSG
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG	MESSAGE_HANDLER (cmdUPDATE_TOPOLOGY, on_cmdUPDATE_TOPOLOGY) MESSAGE_HANDLER(cmdGET_LOG
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG	MESSAGE_HANDLER (cmdUPDATE_KEY, on_cmdUPDATE_KEY) MESSAGE_HANDLER(cmdWATCHDOG_HEARTBEAT
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT	MESSAGE_HANDLER (cmdGET_PROP_LIST, on_cmdGET_PROP_LIST) MESSAGE_HANDLER(cmdGET_PROP_VALUES
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES	MESSAGE_HANDLER (cmdENABLE_STAT, on_cmdENABLE_STAT) MESSAGE_HANDLER(cmdDISABLE_STAT
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT	MESSAGE_HANDLER (cmdGET_STAT, on_cmdGET_STAT) MESSAGE_HANDLER(cmdCUSTOM_CMD
on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT on_cmdCUSTOM_CMD END_MSG_MAP() public void	setId (const dds::protocol_api::SSenderInfo &_sender, uint64_t _id)
protocol_api::SHostInfoCmd	getRemoteHostInfo (const dds::protocol_api::SSenderInfo &_sender)
void	setRemoteHostInfo (const dds::protocol_api::SSenderInfo &_sender, const protocol_api::SHostInfoCmd &_hostInfo)
std::chrono::milliseconds	getStartupTime (const dds::protocol_api::SSenderInfo &_sender)
EAgentState	getState (const dds::protocol_api::SSenderInfo &_sender)
void	setState (const dds::protocol_api::SSenderInfo &_sender, EAgentState _state)
uint64_t	getTaskID (const dds::protocol_api::SSenderInfo &_sender)
void	setTaskID (const dds::protocol_api::SSenderInfo &_sender, uint64_t _taskID)
void	updateAgentInfo (const dds::protocol_api::SSenderInfo &_sender, const SAgentInfo &_info)
	add new or update existing Agent info More...
void	updateAgentInfo (uint64_t _protocolHeaderID, const SAgentInfo &_info)
SAgentInfo	getAgentInfo (const dds::protocol_api::SSenderInfo &_sender)
	Get a copy of the agent info. More...
SAgentInfo	getAgentInfo (uint64_t _protocolHeaderID)
LobbyProtocolHeaderIdContainer_t	getLobbyPHID () const
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::CServerChannelImpl< CAgentChannel >
	CServerChannelImpl (boost::asio::io_service &_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

Member Function Documentation

BEGIN_MSG_MAP()

dds::commander_cmd::CAgentChannel::BEGIN_MSG_MAP

(

CAgentChannel

)

getAgentInfo() [1/2]

SAgentInfo CAgentChannel::getAgentInfo

(

const dds::protocol_api::SSenderInfo &

_sender

)

Get a copy of the agent info.

getAgentInfo() [2/2]

SAgentInfo CAgentChannel::getAgentInfo

(

uint64_t

_protocolHeaderID

)

getLobbyPHID()

LobbyProtocolHeaderIdContainer_t CAgentChannel::getLobbyPHID

(

)

const

getRemoteHostInfo()

SHostInfoCmd CAgentChannel::getRemoteHostInfo

(

const dds::protocol_api::SSenderInfo &

_sender

)

getStartupTime()

chrono::milliseconds CAgentChannel::getStartupTime

(

const dds::protocol_api::SSenderInfo &

_sender

)

getState()

EAgentState CAgentChannel::getState

(

const dds::protocol_api::SSenderInfo &

_sender

)

getTaskID()

uint64_t CAgentChannel::getTaskID

(

const dds::protocol_api::SSenderInfo &

_sender

)

MESSAGE_HANDLER() [1/9]

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

MESSAGE_HANDLER() [2/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdGED_PID	,
		on_cmdGED_PID
	)

MESSAGE_HANDLER() [3/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdREPLY_ID	,
		on_cmdREPLY_ID
	)

MESSAGE_HANDLER() [4/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdTRANSPORT_TEST	,
		on_cmdTRANSPORT_TEST
	)

MESSAGE_HANDLER() [5/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdUPDATE_TOPOLOGY	,
		on_cmdUPDATE_TOPOLOGY
	)

MESSAGE_HANDLER() [6/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdUPDATE_KEY	,
		on_cmdUPDATE_KEY
	)

MESSAGE_HANDLER() [7/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdGET_PROP_LIST	,
		on_cmdGET_PROP_LIST
	)

MESSAGE_HANDLER() [8/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdENABLE_STAT	,
		on_cmdENABLE_STAT
	)

MESSAGE_HANDLER() [9/9]

on_cmdREPLY_HOST_INFO on_cmdUSER_TASK_DONE on_cmdGET_AGENTS_INFO on_cmdBINARY_ATTACHMENT_RECEIVED on_cmdSIMPLE_MSG on_cmdGET_LOG on_cmdWATCHDOG_HEARTBEAT on_cmdGET_PROP_VALUES on_cmdDISABLE_STAT dds::commander_cmd::CAgentChannel::MESSAGE_HANDLER	(	cmdGET_STAT	,
		on_cmdGET_STAT
	)

setId()

void CAgentChannel::setId	(	const dds::protocol_api::SSenderInfo &	_sender,
		uint64_t	_id
	)

setRemoteHostInfo()

void CAgentChannel::setRemoteHostInfo	(	const dds::protocol_api::SSenderInfo &	_sender,
		const protocol_api::SHostInfoCmd &	_hostInfo
	)

setState()

void CAgentChannel::setState	(	const dds::protocol_api::SSenderInfo &	_sender,
		EAgentState	_state
	)

setTaskID()

void CAgentChannel::setTaskID	(	const dds::protocol_api::SSenderInfo &	_sender,
		uint64_t	_taskID
	)

updateAgentInfo() [1/2]

void CAgentChannel::updateAgentInfo	(	const dds::protocol_api::SSenderInfo &	_sender,
		const SAgentInfo &	_info
	)

add new or update existing Agent info

updateAgentInfo() [2/2]

void CAgentChannel::updateAgentInfo	(	uint64_t	_protocolHeaderID,
		const SAgentInfo &	_info
	)

---

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

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