DDS  ver. 3.5.3.8.g5fe284b
Public Member Functions | List of all members
dds::test_cmd::CTestChannel Class Reference

#include <TestChannel.h>

Inheritance diagram for dds::test_cmd::CTestChannel:
dds::protocol_api::CClientChannelImpl< CTestChannel > dds::protocol_api::CBaseChannelImpl< CTestChannel > dds::protocol_api::CChannelEventHandlersImpl dds::protocol_api::CChannelMessageHandlersImpl dds::protocol_api::CStatImpl dds::protocol_api::CBaseEventHandlersImpl< EChannelEvents > dds::protocol_api::CBaseEventHandlersImpl< ECmdType >

Public Member Functions

 BEGIN_MSG_MAP (CTestChannel) MESSAGE_HANDLER(cmdSIMPLE_MSG
 
on_cmdSIMPLE_MSG MESSAGE_HANDLER (cmdSHUTDOWN, on_cmdSHUTDOWN) MESSAGE_HANDLER(cmdPROGRESS
 
on_cmdSIMPLE_MSG on_cmdPROGRESS END_MSG_MAP () void setOptions(const SOptions &_options)
 
- Public Member Functions inherited from dds::protocol_api::CClientChannelImpl< CTestChannel >
void reconnect ()
 
void connect (boost::asio::ip::tcp::resolver::iterator _endpoint_iterator)
 
- Public Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CTestChannel >
 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< CTestChannel >
typedef std::shared_ptr< CTestChannel > connectionPtr_t
 
typedef std::weak_ptr< CTestChannel > weakConnectionPtr_t
 
typedef std::vector< connectionPtr_tconnectionPtrVector_t
 
typedef std::vector< weakConnectionPtr_tweakConnectionPtrVector_t
 
- Static Public Member Functions inherited from dds::protocol_api::CBaseChannelImpl< CTestChannel >
static connectionPtr_t makeNew (boost::asio::io_context &_service, uint64_t _protocolHeaderID, Args &(... args))
 
- Protected Member Functions inherited from dds::protocol_api::CClientChannelImpl< CTestChannel >
 CClientChannelImpl (boost::asio::io_context &_service, EChannelType _channelType, uint64_t _protocolHeaderID)
 
 ~CClientChannelImpl ()
 
- Protected Attributes inherited from dds::protocol_api::CBaseChannelImpl< CTestChannel >
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::test_cmd::CTestChannel::BEGIN_MSG_MAP ( CTestChannel  )

◆ END_MSG_MAP()

on_cmdSIMPLE_MSG on_cmdPROGRESS dds::test_cmd::CTestChannel::END_MSG_MAP ( ) const &
inline

◆ MESSAGE_HANDLER()

on_cmdSIMPLE_MSG dds::test_cmd::CTestChannel::MESSAGE_HANDLER ( cmdSHUTDOWN  ,
on_cmdSHUTDOWN   
)

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