#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: