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

Base class for connection managers. More...

#include <ConnectionManagerImpl.h>

Public Types
typedef SChannelInfo< T >	channelInfo_t
typedef SWeakChannelInfo< T >	weakChannelInfo_t
typedef std::function< bool(const channelInfo_t &_channelInfo, bool &)>	conditionFunction_t

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
weakChannelInfo_t::container_t	getChannels (conditionFunction_t _condition=nullptr)
template<ECmdType _cmd, class AttachmentType >
void	broadcastMsg (const AttachmentType &_attachment, conditionFunction_t _condition=nullptr)
template<ECmdType _cmd, class AttachmentType >
void	accumulativeBroadcastMsg (const AttachmentType &_attachment, conditionFunction_t _condition=nullptr)
template<ECmdType _cmd>
void	broadcastSimpleMsg (conditionFunction_t _condition=nullptr)
void	broadcastBinaryAttachmentCmd (const MiscCommon::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, conditionFunction_t _condition=nullptr)
size_t	countNofChannels (conditionFunction_t _condition=nullptr)

Detailed Description

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

Base class for connection managers.

Member Typedef Documentation

channelInfo_t

template<class T, class A>

typedef SChannelInfo<T> dds::protocol_api::CConnectionManagerImpl< T, A >::channelInfo_t

conditionFunction_t

template<class T, class A>

typedef std::function<bool(const channelInfo_t& _channelInfo, bool& )> dds::protocol_api::CConnectionManagerImpl< T, A >::conditionFunction_t

weakChannelInfo_t

template<class T, class A>

typedef SWeakChannelInfo<T> dds::protocol_api::CConnectionManagerImpl< T, A >::weakChannelInfo_t

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, conditionFunction_t  _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, conditionFunction_t  _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, conditionFunction_t  _condition = nullptr  )

inlineprotected

broadcastSimpleMsg()

template<class T, class A>

template<ECmdType _cmd>

void dds::protocol_api::CConnectionManagerImpl< T, A >::broadcastSimpleMsg ( conditionFunction_t  _condition = nullptr )

inlineprotected

countNofChannels()

template<class T, class A>

size_t dds::protocol_api::CConnectionManagerImpl< T, A >::countNofChannels ( conditionFunction_t  _condition = nullptr )

inlineprotected

getChannels()

template<class T, class A>

weakChannelInfo_t::container_t dds::protocol_api::CConnectionManagerImpl< T, A >::getChannels ( conditionFunction_t  _condition = nullptr )

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