#include <SMCommanderChannel.h>

Inheritance diagram for dds::CSMCommanderChannel:

Public Types
enum	EOutputID { Leader = 1 }

Public Types inherited from dds::protocol_api::CBaseSMChannelImpl< CSMCommanderChannel >
typedef std::shared_ptr< CSMCommanderChannel >	connectionPtr_t

typedef std::weak_ptr< CSMCommanderChannel >	weakConnectionPtr_t

Public Member Functions
	~CSMCommanderChannel ()

	BEGIN_SM_MSG_MAP (CSMCommanderChannel) SM_MESSAGE_HANDLER(cmdLOBBY_MEMBER_INFO_OK

on_cmdLOBBY_MEMBER_INFO_OK	SM_MESSAGE_HANDLER (cmdLOBBY_MEMBER_INFO_ERR, on_cmdLOBBY_MEMBER_INFO_ERR) SM_MESSAGE_HANDLER(cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK	SM_MESSAGE_HANDLER (cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR, on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR) SM_MESSAGE_HANDLER(cmdSIMPLE_MSG

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG	SM_MESSAGE_HANDLER (cmdGET_HOST_INFO, on_cmdGET_HOST_INFO) SM_MESSAGE_HANDLER(cmdSHUTDOWN

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN	SM_MESSAGE_HANDLER (cmdBINARY_ATTACHMENT_RECEIVED, on_cmdBINARY_ATTACHMENT_RECEIVED) SM_MESSAGE_HANDLER(cmdGET_ID

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID	SM_MESSAGE_HANDLER (cmdSET_ID, on_cmdSET_ID) SM_MESSAGE_HANDLER(cmdGET_LOG

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG	SM_MESSAGE_HANDLER (cmdASSIGN_USER_TASK, on_cmdASSIGN_USER_TASK) SM_MESSAGE_HANDLER(cmdACTIVATE_AGENT

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG on_cmdACTIVATE_AGENT	SM_MESSAGE_HANDLER (cmdSTOP_USER_TASK, on_cmdSTOP_USER_TASK) SM_MESSAGE_HANDLER(cmdUPDATE_KEY

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG on_cmdACTIVATE_AGENT on_cmdUPDATE_KEY	SM_MESSAGE_HANDLER (cmdUPDATE_KEY_ERROR, on_cmdUPDATE_KEY_ERROR) SM_MESSAGE_HANDLER(cmdDELETE_KEY

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG on_cmdACTIVATE_AGENT on_cmdUPDATE_KEY on_cmdDELETE_KEY SM_MESSAGE_HANDLER(cmdCUSTOM_CMD, on_cmdCUSTOM_CMD) END_SM_MSG_MAP() private bool	on_cmdLOBBY_MEMBER_INFO_ERR (protocol_api::SCommandAttachmentImpl< protocol_api::cmdLOBBY_MEMBER_INFO_ERR >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK (protocol_api::SCommandAttachmentImpl< protocol_api::cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR (protocol_api::SCommandAttachmentImpl< protocol_api::cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdSIMPLE_MSG (protocol_api::SCommandAttachmentImpl< protocol_api::cmdSIMPLE_MSG >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdGET_HOST_INFO (protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_HOST_INFO >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdSHUTDOWN (protocol_api::SCommandAttachmentImpl< protocol_api::cmdSHUTDOWN >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdBINARY_ATTACHMENT_RECEIVED (protocol_api::SCommandAttachmentImpl< protocol_api::cmdBINARY_ATTACHMENT_RECEIVED >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdGET_ID (protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_ID >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdSET_ID (protocol_api::SCommandAttachmentImpl< protocol_api::cmdSET_ID >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdGET_LOG (protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_LOG >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdASSIGN_USER_TASK (protocol_api::SCommandAttachmentImpl< protocol_api::cmdASSIGN_USER_TASK >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdACTIVATE_AGENT (protocol_api::SCommandAttachmentImpl< protocol_api::cmdACTIVATE_AGENT >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdSTOP_USER_TASK (protocol_api::SCommandAttachmentImpl< protocol_api::cmdSTOP_USER_TASK >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdUPDATE_KEY (protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdUPDATE_KEY_ERROR (protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY_ERROR >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdDELETE_KEY (protocol_api::SCommandAttachmentImpl< protocol_api::cmdDELETE_KEY >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

bool	on_cmdCUSTOM_CMD (protocol_api::SCommandAttachmentImpl< protocol_api::cmdCUSTOM_CMD >::ptr_t _attachment, protocol_api::SSenderInfo &_sender)

uint64_t	getTaskID () const

Public Member Functions inherited from dds::protocol_api::CBaseSMChannelImpl< CSMCommanderChannel >
	DDS_DECLARE_EVENT_HANDLER_CLASS (CChannelEventHandlersImpl) DDS_DECLARE_EVENT_HANDLER_CLASS(CChannelMessageHandlersImpl) protected

	~CBaseSMChannelImpl ()

uint64_t	getProtocolHeaderID () const

std::string	getInputName () const

void	addOutput (uint64_t _outputID, const std::string &_name, EMQOpenType _openType=EMQOpenType::OpenOnly)

bool	started () const

void	start ()

void	stop ()

void	removeMessageQueue ()

void	pushMsg (CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd, uint64_t _outputID=0)

void	pushMsg (const A &_attachment, uint64_t _protocolHeaderID=0, uint64_t _outputID=0)

void	pushMsg (uint64_t _protocolHeaderID=0, uint64_t _outputID=0)

void	syncSendShutdownAll ()

Protected Member Functions
	CSMCommanderChannel (boost::asio::io_service &_service, const std::string &_inputName, const std::string &_outputName, uint64_t _protocolHeaderID, protocol_api::EMQOpenType _inputOpenType, protocol_api::EMQOpenType _outputOpenType)

Additional Inherited Members
Static Public Member Functions inherited from dds::protocol_api::CBaseSMChannelImpl< CSMCommanderChannel >
static connectionPtr_t	makeNew (boost::asio::io_service &_service, const std::string &_inputName, const std::string &_outputName, uint64_t _ProtocolHeaderID, EMQOpenType _inputOpenType=EMQOpenType::OpenOrCreate, EMQOpenType _outputOpenType=EMQOpenType::OpenOrCreate)

Protected Attributes inherited from dds::protocol_api::CBaseSMChannelImpl< CSMCommanderChannel >
std::atomic< bool >	m_isShuttingDown

std::atomic< bool >	m_started
	True if we were able to start the channel, False otherwise. More...

uint64_t	m_protocolHeaderID

Member Enumeration Documentation

◆ EOutputID

enum dds::CSMCommanderChannel::EOutputID

Enumerator
Leader

Constructor & Destructor Documentation

◆ CSMCommanderChannel()

CSMCommanderChannel::CSMCommanderChannel	(	boost::asio::io_service &	_service,
		const std::string &	_inputName,
		const std::string &	_outputName,
		uint64_t	_protocolHeaderID,
		protocol_api::EMQOpenType	_inputOpenType,
		protocol_api::EMQOpenType	_outputOpenType
	)

protected

◆ ~CSMCommanderChannel()

CSMCommanderChannel::~CSMCommanderChannel ( )

Member Function Documentation

◆ BEGIN_SM_MSG_MAP()

dds::CSMCommanderChannel::BEGIN_SM_MSG_MAP ( CSMCommanderChannel )

◆ getTaskID()

uint64_t dds::CSMCommanderChannel::getTaskID ( ) const

inline

◆ on_cmdACTIVATE_AGENT()

bool CSMCommanderChannel::on_cmdACTIVATE_AGENT	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdACTIVATE_AGENT >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdASSIGN_USER_TASK()

bool CSMCommanderChannel::on_cmdASSIGN_USER_TASK	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdASSIGN_USER_TASK >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdBINARY_ATTACHMENT_RECEIVED()

bool CSMCommanderChannel::on_cmdBINARY_ATTACHMENT_RECEIVED	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdBINARY_ATTACHMENT_RECEIVED >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdCUSTOM_CMD()

bool CSMCommanderChannel::on_cmdCUSTOM_CMD	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdCUSTOM_CMD >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdDELETE_KEY()

bool CSMCommanderChannel::on_cmdDELETE_KEY	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdDELETE_KEY >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdGET_HOST_INFO()

bool CSMCommanderChannel::on_cmdGET_HOST_INFO	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_HOST_INFO >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdGET_ID()

bool CSMCommanderChannel::on_cmdGET_ID	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_ID >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdGET_LOG()

bool CSMCommanderChannel::on_cmdGET_LOG	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdGET_LOG >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdLOBBY_MEMBER_INFO_ERR()

bool CSMCommanderChannel::on_cmdLOBBY_MEMBER_INFO_ERR	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdLOBBY_MEMBER_INFO_ERR >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR()

bool CSMCommanderChannel::on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK()

bool CSMCommanderChannel::on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdSET_ID()

bool CSMCommanderChannel::on_cmdSET_ID	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdSET_ID >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdSHUTDOWN()

bool CSMCommanderChannel::on_cmdSHUTDOWN	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdSHUTDOWN >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdSIMPLE_MSG()

bool CSMCommanderChannel::on_cmdSIMPLE_MSG	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdSIMPLE_MSG >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdSTOP_USER_TASK()

bool CSMCommanderChannel::on_cmdSTOP_USER_TASK	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdSTOP_USER_TASK >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdUPDATE_KEY()

bool CSMCommanderChannel::on_cmdUPDATE_KEY	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ on_cmdUPDATE_KEY_ERROR()

bool CSMCommanderChannel::on_cmdUPDATE_KEY_ERROR	(	protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY_ERROR >::ptr_t	_attachment,
		protocol_api::SSenderInfo &	_sender
	)

◆ SM_MESSAGE_HANDLER() [1/8]

on_cmdLOBBY_MEMBER_INFO_OK dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdLOBBY_MEMBER_INFO_ERR	,
		on_cmdLOBBY_MEMBER_INFO_ERR
	)

◆ SM_MESSAGE_HANDLER() [2/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR	,
		on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_ERR
	)

◆ SM_MESSAGE_HANDLER() [3/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdGET_HOST_INFO	,
		on_cmdGET_HOST_INFO
	)

◆ SM_MESSAGE_HANDLER() [4/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdBINARY_ATTACHMENT_RECEIVED	,
		on_cmdBINARY_ATTACHMENT_RECEIVED
	)

◆ SM_MESSAGE_HANDLER() [5/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdSET_ID	,
		on_cmdSET_ID
	)

◆ SM_MESSAGE_HANDLER() [6/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdASSIGN_USER_TASK	,
		on_cmdASSIGN_USER_TASK
	)

◆ SM_MESSAGE_HANDLER() [7/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG on_cmdACTIVATE_AGENT dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdSTOP_USER_TASK	,
		on_cmdSTOP_USER_TASK
	)

◆ SM_MESSAGE_HANDLER() [8/8]

on_cmdLOBBY_MEMBER_INFO_OK on_cmdREPLY_LOBBY_MEMBER_HANDSHAKE_OK on_cmdSIMPLE_MSG on_cmdSHUTDOWN on_cmdGET_ID on_cmdGET_LOG on_cmdACTIVATE_AGENT on_cmdUPDATE_KEY dds::CSMCommanderChannel::SM_MESSAGE_HANDLER	(	cmdUPDATE_KEY_ERROR	,
		on_cmdUPDATE_KEY_ERROR
	)

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

Public Types

Public Member Functions

Protected Member Functions

Additional Inherited Members