From 2f82eb4f09fe7e64dfcb5f000b1e0ec1b310c71b Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Sun, 30 Jan 2022 21:40:37 +0100 Subject: [PATCH] shm: monitor: disable number of msgs in the ack queue output --- fairmq/shmem/Monitor.cxx | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/fairmq/shmem/Monitor.cxx b/fairmq/shmem/Monitor.cxx index d09e4a98..582cf2ec 100644 --- a/fairmq/shmem/Monitor.cxx +++ b/fairmq/shmem/Monitor.cxx @@ -269,12 +269,12 @@ bool Monitor::PrintShm(const ShmId& shmId) ss << "\n [" << r.first << "]: " << (r.second.fDestroyed ? "destroyed" : "alive"); ss << ", size: " << r.second.fSize; - try { - boost::interprocess::message_queue q(open_only, std::string("fmq_" + std::string(shmId) + "_rgq_" + to_string(r.first)).c_str()); - ss << ", ack queue: " << q.get_num_msg() << " messages"; - } catch (bie&) { - ss << ", ack queue: not found"; - } + // try { + // boost::interprocess::message_queue q(open_only, std::string("fmq_" + std::string(shmId) + "_rgq_" + to_string(r.first)).c_str()); + // ss << ", ack queue: " << q.get_num_msg() << " messages"; + // } catch (bie&) { + // ss << ", ack queue: not found"; + // } } } LOGV(info, user1) << ss.str(); @@ -680,7 +680,6 @@ void Monitor::ResetContent(const ShmId& shmIdT, bool verbose /* = true */) Remove("fmq_" + shmId + "_rgq_" + to_string(id), verbose); } } - } catch (bie& e) { if (verbose) { cout << "Could not find '" << managementSegmentName << "' segment. Nothing to cleanup." << endl;