Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-15 17:41:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add interactive controller button to print connected peers

Browse Source
This commit is contained in:
Alexey Rybalchenko
2021-10-13 22:05:36 +02:00
committed by Dennis Klein
parent 406c5439b7
commit 9c424b496a
5 changed files with 31 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
fairmq/plugins/control/Control.cxx
View File

@@ -206,6 +206,10 @@ try {
cout << "\n --> [m] decrease log verbosity\n\n" << flush;
CycleLogVerbosityDown();
break;
case 'p':
cout << "\n --> [p] print number of connected peers for all channels\n\n" << flush;
PrintNumberOfConnectedPeers();
break;
case 'h':
cout << "\n --> [h] help\n\n" << flush;
if (color) {
@@ -248,7 +252,7 @@ auto Control::PrintInteractiveHelpColor() -> void
{
stringstream ss;
ss << "Following control commands are available:\n\n"
<< " [\033[01;32mh\033[0m] help, [\033[01;32mc\033[0m] check current device state,\n"
<< " [\033[01;32mh\033[0m] help, [\033[01;32mc\033[0m] check current device state, [\033[01;32mp\033[0m] print number of connected peers for channels,\n"
<< " [\033[01;32mi\033[0m] init device, [\033[01;32mb\033[0m] bind, [\033[01;32mx\033[0m] connect, [\033[01;32mj\033[0m] init task,"
<< " [\033[01;32mr\033[0m] run, [\033[01;32ms\033[0m] stop,\n"
<< " [\033[01;32mt\033[0m] reset task, [\033[01;32md\033[0m] reset device, [\033[01;32mq\033[0m] end,\n"
@@ -260,7 +264,7 @@ auto Control::PrintInteractiveHelp() -> void
{
stringstream ss;
ss << "Following control commands are available:\n\n"
<< " [h] help, [c] check current device state,\n"
<< " [h] help, [c] check current device state, [p] print number of connected peers for channels\n"
<< " [i] init device, [b] bind, [x] connect, [j] init task,\n"
<< " [r] run, [s] stop,\n"
<< " [t] reset task, [d] reset device, [q] end,\n"
@@ -344,6 +348,17 @@ void Control::PrintStateMachine()
cout << ss.str() << flush;
}
auto Control::PrintNumberOfConnectedPeers() -> void
{
unordered_map<string, int> channelInfo(GetChannelInfo());
for (const auto& c : channelInfo) {
for (int i = 0; i < c.second; ++i) {
LOG(info) << c.first << "[" << i << "]: " << GetNumberOfConnectedPeers(c.first, i) << " peers connected";
}
}
}
auto Control::StaticMode() -> void
try {
RunStartupSequence();

1
fairmq/plugins/control/Control.h
View File

@@ -41,6 +41,7 @@ class Control : public Plugin
static auto PrintInteractiveHelp() -> void;
static auto PrintStateMachineColor() -> void;
static auto PrintStateMachine() -> void;
auto PrintNumberOfConnectedPeers() -> void;
auto StaticMode() -> void;
auto SignalHandler() -> void;
auto RunShutdownSequence() -> void;