dds::protocol_api::CConnectionManagerImpl< T, A > Class Template Reference

Base class for connection managers. More...

#include <ConnectionManagerImpl.h>

Public Member Functions
	CConnectionManagerImpl (size_t _minPort, size_t _maxPort, bool _useUITransport)
	~CConnectionManagerImpl ()
void	start (bool _join=true, unsigned int _nThreads=0)
void	runService (short _counter, boost::asio::io_service &_io_service)
void	stop ()
void	addDisconnectedChannelsStatToStat (SReadStat &_readStat, SWriteStat &_writeStat)

Protected Member Functions
T::weakConnectionPtr_t	getWeakPtr (T *_client)
T::weakConnectionPtrVector_t	getChannels (std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)
template<ECmdType _cmd, class AttachmentType >
void	broadcastMsg (const AttachmentType &_attachment, std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)
template<ECmdType _cmd, class AttachmentType >
void	accumulativeBroadcastMsg (const AttachmentType &_attachment, std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)
template<ECmdType _cmd>
void	broadcastSimpleMsg (std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)
void	broadcastBinaryAttachmentCmd (const MiscCommon::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)
size_t	countNofChannels (std::function< bool(typename T::connectionPtr_t, bool &)> _condition=nullptr)

Detailed Description

template<class T, class A>
class dds::protocol_api::CConnectionManagerImpl< T, A >

Base class for connection managers.

Constructor & Destructor Documentation

CConnectionManagerImpl()

template<class T, class A>

dds::protocol_api::CConnectionManagerImpl< T, A >::CConnectionManagerImpl ( size_t  _minPort, size_t  _maxPort, bool  _useUITransport  )

inline

~CConnectionManagerImpl()

template<class T, class A>

dds::protocol_api::CConnectionManagerImpl< T, A >::~CConnectionManagerImpl ( )

inline

Member Function Documentation

accumulativeBroadcastMsg()

template<class T, class A>

template<ECmdType _cmd, class AttachmentType >

void dds::protocol_api::CConnectionManagerImpl< T, A >::accumulativeBroadcastMsg ( const AttachmentType &  _attachment, std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr  )

inlineprotected

addDisconnectedChannelsStatToStat()

template<class T, class A>

void dds::protocol_api::CConnectionManagerImpl< T, A >::addDisconnectedChannelsStatToStat ( SReadStat &  _readStat, SWriteStat &  _writeStat  )

inline

broadcastBinaryAttachmentCmd()

template<class T, class A>

void dds::protocol_api::CConnectionManagerImpl< T, A >::broadcastBinaryAttachmentCmd ( const MiscCommon::BYTEVector_t &  _data, const std::string &  _fileName, uint16_t  _cmdSource, std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr  )

inlineprotected

broadcastMsg()

template<class T, class A>

template<ECmdType _cmd, class AttachmentType >

void dds::protocol_api::CConnectionManagerImpl< T, A >::broadcastMsg ( const AttachmentType &  _attachment, std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr  )

inlineprotected

broadcastSimpleMsg()

template<class T, class A>

template<ECmdType _cmd>

void dds::protocol_api::CConnectionManagerImpl< T, A >::broadcastSimpleMsg ( std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr )

inlineprotected

countNofChannels()

template<class T, class A>

size_t dds::protocol_api::CConnectionManagerImpl< T, A >::countNofChannels ( std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr )

inlineprotected

getChannels()

template<class T, class A>

T::weakConnectionPtrVector_t dds::protocol_api::CConnectionManagerImpl< T, A >::getChannels ( std::function< bool(typename T::connectionPtr_t, bool &)>  _condition = nullptr )

inlineprotected

getWeakPtr()

template<class T, class A>

T::weakConnectionPtr_t dds::protocol_api::CConnectionManagerImpl< T, A >::getWeakPtr ( T *  _client )

inlineprotected

runService()

template<class T, class A>

void dds::protocol_api::CConnectionManagerImpl< T, A >::runService ( short  _counter, boost::asio::io_service &  _io_service  )

inline

start()

template<class T, class A>

void dds::protocol_api::CConnectionManagerImpl< T, A >::start ( bool  _join = true, unsigned int  _nThreads = 0  )

inline

stop()

template<class T, class A>

void dds::protocol_api::CConnectionManagerImpl< T, A >::stop ( )

inline

---

The documentation for this class was generated from the following file:

• ConnectionManagerImpl.h