|
DDS
ver. 2.0
|
#include <BaseSMChannelImpl.h>
Public Types | |
| typedef std::shared_ptr< T > | connectionPtr_t |
| typedef std::weak_ptr< T > | weakConnectionPtr_t |
Public Member Functions | |
| 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) |
| template<ECmdType _cmd, class A > | |
| void | pushMsg (const A &_attachment, uint64_t _protocolHeaderID=0, uint64_t _outputID=0) |
| template<ECmdType _cmd> | |
| void | pushMsg (uint64_t _protocolHeaderID=0, uint64_t _outputID=0) |
| void | syncSendShutdownAll () |
Static Public Member Functions | |
| 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 | |
| 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 |
| typedef std::shared_ptr<T> dds::protocol_api::CBaseSMChannelImpl< T >::connectionPtr_t |
| typedef std::weak_ptr<T> dds::protocol_api::CBaseSMChannelImpl< T >::weakConnectionPtr_t |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inlinestatic |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
protected |
|
protected |
|
protected |
True if we were able to start the channel, False otherwise.
1.8.13