From 8ac7c71678d298dc706a6e41cd1ddb46f37e3a90 Mon Sep 17 00:00:00 2001 From: Patrick Donnelly Date: Wed, 20 Aug 2025 12:22:50 -0400 Subject: [PATCH] msg/DispatchQueue: add debugging for queue discard Signed-off-by: Patrick Donnelly --- src/msg/DispatchQueue.cc | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/msg/DispatchQueue.cc b/src/msg/DispatchQueue.cc index 23ace18f4bd..ad172590cb3 100644 --- a/src/msg/DispatchQueue.cc +++ b/src/msg/DispatchQueue.cc @@ -216,15 +216,20 @@ void DispatchQueue::entry() } void DispatchQueue::discard_queue(uint64_t id) { + uint64_t dropped = 0; + ldout(cct,10) << __func__ << " discarding id=" << id << dendl; std::lock_guard l{lock}; std::list removed; mqueue.remove_by_class(id, &removed); for (auto i = removed.begin(); i != removed.end(); ++i) { ceph_assert(!(i->is_code())); // We don't discard id 0, ever! const ref_t& m = i->get_message(); + ldout(cct,15) << __func__ << " removing " << *m << dendl; remove_arrival(*i); dispatch_throttle_release(m->get_dispatch_throttle_size()); + ++dropped; } + ldout(cct,10) << __func__ << " dropped " << dropped << " messages" << dendl; } void DispatchQueue::start() -- 2.47.3