Skip to content

Commit

Permalink
shm: monitor: disable number of msgs in the ack queue output
Browse files Browse the repository at this point in the history
  • Loading branch information
rbx committed Feb 2, 2022
1 parent 92a56c2 commit 2f82eb4
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions fairmq/shmem/Monitor.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down Expand Up @@ -680,7 +680,6 @@ void Monitor::ResetContent(const ShmId& shmIdT, bool verbose /* = true */)
Remove<bipc::message_queue>("fmq_" + shmId + "_rgq_" + to_string(id), verbose);
}
}

} catch (bie& e) {
if (verbose) {
cout << "Could not find '" << managementSegmentName << "' segment. Nothing to cleanup." << endl;
Expand Down

0 comments on commit 2f82eb4

Please sign in to comment.