From 996ab75fd5a27214ce4daa6129383a12af3e0cb0 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 5aac94c183f..ab0083108ac 100644 --- a/src/msg/DispatchQueue.cc +++ b/src/msg/DispatchQueue.cc @@ -215,15 +215,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.39.5