DDS  ver. 3.6
Public Member Functions | List of all members
dds::commander_cmd::CConnectionManager Class Reference

#include <ConnectionManager.h>

Inheritance diagram for dds::commander_cmd::CConnectionManager:
dds::protocol_api::CConnectionManagerImpl< CAgentChannel, CConnectionManager >

Public Member Functions

 CConnectionManager (const SOptions_t &_options)
 
 ~CConnectionManager ()
 
void newClientCreated (CAgentChannel::connectionPtr_t _newClient)
 
void _start ()
 
void _stop ()
 
void _createInfoFile (const std::vector< size_t > &_ports) const
 
void _deleteInfoFile () const
 
template<protocol_api::ECmdType _cmd>
void broadcastUpdateTopologyAndWait_impl (size_t index, weakChannelInfo_t _agent, const vector< typename SCommandAttachmentImpl< _cmd >::ptr_t > &_attachments)
 
- Public Member Functions inherited from dds::protocol_api::CConnectionManagerImpl< CAgentChannel, CConnectionManager >
 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_context &_io_context)
 
void stop ()
 

Additional Inherited Members

- Public Types inherited from dds::protocol_api::CConnectionManagerImpl< CAgentChannel, CConnectionManager >
typedef SChannelInfo< CAgentChannel > channelInfo_t
 
typedef SWeakChannelInfo< CAgentChannel > weakChannelInfo_t
 
typedef std::function< bool(const channelInfo_t &_channelInfo, bool &)> conditionFunction_t
 
using channelContainerCache_t = std::map< uint64_t, weakChannelInfo_t >
 
- Protected Member Functions inherited from dds::protocol_api::CConnectionManagerImpl< CAgentChannel, CConnectionManager >
void updateChannelProtocolHeaderID (const weakChannelInfo_t &_channelInfo)
 
weakChannelInfo_t getChannelByID (uint64_t _protocolHeaderID)
 
weakChannelInfo_t::container_t getChannels (conditionFunction_t _condition=nullptr)
 
void broadcastMsg (const AttachmentType &_attachment, conditionFunction_t _condition=nullptr)
 
void accumulativeBroadcastMsg (const AttachmentType &_attachment, conditionFunction_t _condition=nullptr)
 
void broadcastSimpleMsg (conditionFunction_t _condition=nullptr)
 
void broadcastBinaryAttachmentCmd (const std::string &_srcFilePath, const std::string &_fileName, uint16_t _cmdSource, conditionFunction_t _condition=nullptr)
 
void broadcastBinaryAttachmentCmd (const dds::misc::BYTEVector_t &_data, const std::string &_fileName, uint16_t _cmdSource, conditionFunction_t _condition=nullptr)
 
size_t countNofChannels (conditionFunction_t _condition=nullptr)
 

Constructor & Destructor Documentation

◆ CConnectionManager()

CConnectionManager::CConnectionManager ( const SOptions_t _options)

◆ ~CConnectionManager()

CConnectionManager::~CConnectionManager ( )

Member Function Documentation

◆ _createInfoFile()

void CConnectionManager::_createInfoFile ( const std::vector< size_t > &  _ports) const

◆ _deleteInfoFile()

void CConnectionManager::_deleteInfoFile ( ) const

◆ _start()

void CConnectionManager::_start ( )

◆ _stop()

void CConnectionManager::_stop ( )

◆ broadcastUpdateTopologyAndWait_impl()

template<protocol_api::ECmdType _cmd>
void dds::commander_cmd::CConnectionManager::broadcastUpdateTopologyAndWait_impl ( size_t  index,
weakChannelInfo_t  _agent,
const vector< typename SCommandAttachmentImpl< _cmd >::ptr_t > &  _attachments 
)

◆ newClientCreated()

void CConnectionManager::newClientCreated ( CAgentChannel::connectionPtr_t  _newClient)

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