|
typedef std::shared_ptr< T > | connectionPtr_t |
|
typedef std::weak_ptr< T > | weakConnectionPtr_t |
|
typedef std::vector< connectionPtr_t > | connectionPtrVector_t |
|
typedef std::vector< weakConnectionPtr_t > | weakConnectionPtrVector_t |
|
| 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 () |
|
template<ECmdType _cmd> |
void | dequeueMsg () |
|
void | accumulativePushMsg (CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd) |
|
template<ECmdType _cmd, class A > |
void | accumulativePushMsg (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
template<ECmdType _cmd> |
void | accumulativePushMsg (uint64_t _protocolHeaderID=0) |
|
void | pushMsg (CProtocolMessage::protocolMessagePtr_t _msg, ECmdType _cmd, uint64_t=0) |
|
template<ECmdType _cmd, class A > |
void | pushMsg (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
template<ECmdType _cmd> |
void | pushMsg (uint64_t _protocolHeaderID=0) |
|
template<ECmdType _cmd, class A > |
void | sendYourself (const A &_attachment, uint64_t _protocolHeaderID=0) |
|
template<ECmdType _cmd> |
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 dds::misc::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) |
|
void | processBinaryAttachmentStartCmd (const SSenderInfo &, 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 |
|
template<class... Args> |
static connectionPtr_t | makeNew (boost::asio::io_context &_service, uint64_t _protocolHeaderID, Args &(... args)) |
|
bool | m_isHandshakeOK |
|
EChannelType | m_channelType |
|
std::string | m_sessionID |
|
uint64_t | m_protocolHeaderID |
|
boost::asio::io_context & | m_ioContext |
|