|
| 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 _protocolHeaderID=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 MiscCommon::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, uint64_t _protocolHeaderID) |
|
void | processBinaryAttachmentStartCmd (const SSenderInfo &_sender, 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 |
|
| CStatImpl (boost::asio::io_context &_context) |
|
SReadStat | getReadStat () const |
| Return read statistics. More...
|
|
SWriteStat | getWriteStat () const |
| Return write statistics. More...
|
|
void | setStatEnabled (bool _statEnabled) |
| Enable/disable statistics accumulation. More...
|
|
void | logReadMessage (CProtocolMessage::protocolMessagePtr_t _message) |
|
void | logWriteMessages (const protocolMessagePtrQueue_t &_messageQueue) |
|