From 5c9846c7d72ef15c0fa317aa81321f26e507637c Mon Sep 17 00:00:00 2001 From: Alex Rousskov Date: Fri, 21 Jun 2013 17:19:44 -0600 Subject: [PATCH] Added debugging to allow automated store entry tracking during CF notifications. Polished "queue overflow" error reporting. --- src/CollapsedForwarding.cc | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/CollapsedForwarding.cc b/src/CollapsedForwarding.cc index d1b108828d..c501393693 100644 --- a/src/CollapsedForwarding.cc +++ b/src/CollapsedForwarding.cc @@ -62,8 +62,9 @@ CollapsedForwarding::Broadcast(const cache_key *key) if (workerId != KidIdentifier && queue->push(workerId, msg)) Notify(workerId); } catch (const Queue::Full &) { - debugs(17, DBG_IMPORTANT, "Worker collapsed forwarding push queue " - "overflow: " << workerId); // TODO: report queue len + debugs(17, DBG_IMPORTANT, "ERROR: Collapsed forwarding " << + "queue overflow for kid" << workerId << + " at " << queue->outSize(workerId) << " items"); // TODO: grow queue size } } @@ -96,7 +97,10 @@ CollapsedForwarding::HandleNewData(const char *const when) " != " << msg.sender); } - Store::Root().syncCollapsed(reinterpret_cast(msg.key)); + const cache_key *key = reinterpret_cast(msg.key); + debugs(17, 7, "hadling " << storeKeyText(key)); + Store::Root().syncCollapsed(key); + debugs(17, 7, "handled " << storeKeyText(key)); // XXX: stop and schedule an async call to continue assert(++poppedCount < SQUID_MAXFD); -- 2.47.2