#include <SMIntercomChannel.h>
|
| | ~CSMIntercomChannel () |
| |
| | 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) |
| |
|
| typedef std::shared_ptr< CSMIntercomChannel > | connectionPtr_t |
| |
| typedef std::weak_ptr< CSMIntercomChannel > | weakConnectionPtr_t |
| |
| 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 |
| |
◆ CSMIntercomChannel()
| CSMIntercomChannel::CSMIntercomChannel |
( |
boost::asio::io_context & |
_service, |
|
|
const std::vector< std::string > & |
_inputNames, |
|
|
const std::string & |
_outputName, |
|
|
uint64_t |
_protocolHeaderID, |
|
|
protocol_api::EMQOpenType |
_inputOpenType, |
|
|
protocol_api::EMQOpenType |
_outputOpenType |
|
) |
| |
|
protected |
◆ ~CSMIntercomChannel()
| CSMIntercomChannel::~CSMIntercomChannel |
( |
| ) |
|
The documentation for this class was generated from the following files: