DDS  ver. 2.0
Public Member Functions | Protected Member Functions | List of all members
dds::internal_api::CSMAgentChannel Class Reference

#include <SMAgentChannel.h>

Inheritance diagram for dds::internal_api::CSMAgentChannel:
dds::protocol_api::CBaseSMChannelImpl< CSMAgentChannel > dds::protocol_api::CChannelEventHandlersImpl dds::protocol_api::CChannelMessageHandlersImpl dds::protocol_api::CBaseEventHandlersImpl< EChannelEvents > dds::protocol_api::CBaseEventHandlersImpl< ECmdType >

Public Member Functions

 BEGIN_SM_MSG_MAP (CSMAgentChannel) SM_MESSAGE_HANDLER(cmdCUSTOM_CMD
 
on_cmdCUSTOM_CMD SM_MESSAGE_HANDLER (cmdUPDATE_KEY, on_cmdUPDATE_KEY) SM_MESSAGE_HANDLER(cmdUPDATE_KEY_ERROR
 
on_cmdCUSTOM_CMD on_cmdUPDATE_KEY_ERROR SM_MESSAGE_HANDLER (cmdDELETE_KEY, on_cmdDELETE_KEY) SM_MESSAGE_HANDLER(cmdSIMPLE_MSG
 
on_cmdCUSTOM_CMD on_cmdUPDATE_KEY_ERROR on_cmdSIMPLE_MSG END_SM_MSG_MAP() private bool on_cmdUPDATE_KEY (protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY >::ptr_t _attachment, const protocol_api::SSenderInfo &_sender)
 
bool on_cmdUPDATE_KEY_ERROR (protocol_api::SCommandAttachmentImpl< protocol_api::cmdUPDATE_KEY_ERROR >::ptr_t _attachment, const protocol_api::SSenderInfo &_sender)
 
bool on_cmdDELETE_KEY (protocol_api::SCommandAttachmentImpl< protocol_api::cmdDELETE_KEY >::ptr_t _attachment, const protocol_api::SSenderInfo &_sender)
 
bool on_cmdSIMPLE_MSG (protocol_api::SCommandAttachmentImpl< protocol_api::cmdSIMPLE_MSG >::ptr_t _attachment, const protocol_api::SSenderInfo &_sender)
 
- Public Member Functions inherited from dds::protocol_api::CBaseSMChannelImpl< CSMAgentChannel >
 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

 CSMAgentChannel (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

- Public Types inherited from dds::protocol_api::CBaseSMChannelImpl< CSMAgentChannel >
typedef std::shared_ptr< CSMAgentChannel > connectionPtr_t
 
typedef std::weak_ptr< CSMAgentChannel > weakConnectionPtr_t
 
- Static Public Member Functions inherited from dds::protocol_api::CBaseSMChannelImpl< CSMAgentChannel >
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< CSMAgentChannel >
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
 

Constructor & Destructor Documentation

◆ CSMAgentChannel()

dds::internal_api::CSMAgentChannel::CSMAgentChannel ( boost::asio::io_service &  _service,
const std::string &  _inputName,
const std::string &  _outputName,
uint64_t  _ProtocolHeaderID,
protocol_api::EMQOpenType  _inputOpenType,
protocol_api::EMQOpenType  _outputOpenType 
)
inlineprotected

Member Function Documentation

◆ BEGIN_SM_MSG_MAP()

dds::internal_api::CSMAgentChannel::BEGIN_SM_MSG_MAP ( CSMAgentChannel  )

◆ on_cmdDELETE_KEY()

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

◆ on_cmdSIMPLE_MSG()

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

◆ on_cmdUPDATE_KEY()

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

◆ on_cmdUPDATE_KEY_ERROR()

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

◆ SM_MESSAGE_HANDLER() [1/2]

on_cmdCUSTOM_CMD dds::internal_api::CSMAgentChannel::SM_MESSAGE_HANDLER ( cmdUPDATE_KEY  ,
on_cmdUPDATE_KEY   
)

◆ SM_MESSAGE_HANDLER() [2/2]

on_cmdCUSTOM_CMD on_cmdUPDATE_KEY_ERROR dds::internal_api::CSMAgentChannel::SM_MESSAGE_HANDLER ( cmdDELETE_KEY  ,
on_cmdDELETE_KEY   
)

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