|
typedef std::shared_ptr< CSMAgentChannel > | connectionPtr_t |
|
typedef std::weak_ptr< CSMAgentChannel > | weakConnectionPtr_t |
|
| DDS_DECLARE_EVENT_HANDLER_CLASS (CChannelEventHandlersImpl) DDS_DECLARE_EVENT_HANDLER_CLASS(CChannelMessageHandlersImpl) protected |
|
| CBaseSMChannelImpl (boost::asio::io_context &_service, const std::vector< std::string > &_inputNames, const std::string &_outputName, uint64_t _protocolHeaderID, EMQOpenType _inputOpenType, EMQOpenType _outputOpenType) |
|
void | defaultInit (const std::vector< std::string > _inputNames, const std::string &_outputName, EMQOpenType _inputOpenType, EMQOpenType _outputOpenType) |
|
| ~CBaseSMChannelImpl () |
|
uint64_t | getProtocolHeaderID () const |
|
void | addOutput (uint64_t _outputID, const std::string &_name, EMQOpenType _openType=EMQOpenType::OpenOrCreate) |
|
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 | drainWriteQueue (bool _newVal, uint64_t _outputID) |
|
static connectionPtr_t | makeNew (boost::asio::io_context &_service, const std::string &_inputName, const std::string &_outputName, uint64_t _ProtocolHeaderID, EMQOpenType _inputOpenType=EMQOpenType::OpenOrCreate, EMQOpenType _outputOpenType=EMQOpenType::OpenOrCreate) |
|
static connectionPtr_t | makeNew (boost::asio::io_context &_service, const std::vector< std::string > &_inputNames, const std::string &_outputName, uint64_t _ProtocolHeaderID, EMQOpenType _inputOpenType=EMQOpenType::OpenOrCreate, EMQOpenType _outputOpenType=EMQOpenType::OpenOrCreate) |
|
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 |
|