5 #ifndef __DDS__ConnectionManager__ 6 #define __DDS__ConnectionManager__ 16 #include <condition_variable> 21 namespace commander_cmd
24 public std::enable_shared_from_this<CConnectionManager>
39 void on_cmdBINARY_ATTACHMENT_RECEIVED(
43 void on_cmdTRANSPORT_TEST(
53 void on_cmdUSER_TASK_DONE(
57 void on_cmdGET_PROP_LIST(
61 void on_cmdGET_PROP_VALUES(
68 void on_cmdENABLE_STAT(
72 void on_cmdDISABLE_STAT(
87 const std::string& _msg,
89 template <protocol_api::ECmdType _cmd>
91 template <protocol_api::ECmdType _cmd>
92 void broadcastUpdateTopologyAndWait_impl(
96 template <protocol_api::ECmdType _cmd>
97 void broadcastUpdateTopologyAndWait_impl(
size_t index,
99 const std::string& _filePath,
100 const std::string& _filename);
101 template <protocol_api::ECmdType _cmd>
102 void broadcastUpdateTopologyAndWait_impl(
size_t index,
104 const std::vector<std::string>& _filePaths,
105 const std::vector<std::string>& _filenames);
106 template <protocol_api::ECmdType _cmd>
107 void broadcastUpdateTopologyAndWait_impl(
113 void enableDisableStatForChannels(
bool _enable);
114 void _createWnPkg(
bool _needInlineBashScript,
bool _lightweightPkg, uint32_t _nSlots)
const;
124 const std::string& _msg,
126 void sendUICommanderInfo(
const dds::tools_api::SCommanderInfoRequestData& _info,
128 void sendUIAgentInfo(
const dds::tools_api::SAgentInfoRequestData& _info,
130 void sendUIAgentCount(
const dds::tools_api::SAgentCountRequestData& _info,
144 typedef std::map<uint64_t, weakChannelInfo_t> TaskIDToAgentChannelMap_t;
145 TaskIDToAgentChannelMap_t m_taskIDToAgentChannelMap;
146 std::mutex m_mapMutex;
148 std::mutex m_updateTopoMutex;
149 std::condition_variable m_updateTopoCondition;
void _start()
Definition: ConnectionManager.cpp:45
std::shared_ptr< CAgentChannel > connectionPtr_t
Definition: BaseChannelImpl.h:235
SWeakChannelInfo< CAgentChannel > weakChannelInfo_t
Definition: ConnectionManagerImpl.h:42
Definition: BaseEventHandlersImpl.h:48
void _stop()
Definition: ConnectionManager.cpp:66
std::shared_ptr< SEmptyCmd > ptr_t
Definition: CommandAttachmentImpl.h:64
void _createInfoFile(const std::vector< size_t > &_ports) const
Definition: ConnectionManager.cpp:206
Definition: UIChannelInfo.h:249
Definition: UIChannelInfo.h:288
Definition: ConnectionManager.h:23
std::weak_ptr< CAgentChannel > weakConnectionPtr_t
Definition: BaseChannelImpl.h:236
CConnectionManager(const SOptions_t &_options)
Definition: ConnectionManager.cpp:34
Definition: UIChannelInfo.h:338
Definition: AgentConnectionManager.h:13
void newClientCreated(CAgentChannel::connectionPtr_t _newClient)
Definition: ConnectionManager.cpp:70
Definition: TopoCore.h:25
dds-commander's container of options
Definition: dds-commander/src/Options.h:24
Definition: CustomCmdCmd.h:14
EMsgSeverity
Enumeration with message severity.
Definition: Intercom.h:126
Definition: SSHScheduler.h:20
void _deleteInfoFile() const
Definition: ConnectionManager.cpp:242
~CConnectionManager()
Definition: ConnectionManager.cpp:41
Base class for connection managers.
Definition: ConnectionManagerImpl.h:38
std::vector< SWeakChannelInfo > container_t
Definition: ChannelInfo.h:52
Definition: UIChannelInfo.h:391
ECmdType
Definition: ProtocolCommands.h:25