From: Alex Rousskov <rousskov@measurement-factory.com>
Date: Fri, 21 Jun 2013 23:19:44 +0000 (-0600)
Subject: Added debugging to allow automated store entry tracking during CF notifications.
X-Git-Tag: SQUID_3_5_0_1~444^2~56
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=5c9846c7d72ef15c0fa317aa81321f26e507637c;p=thirdparty%2Fsquid.git

Added debugging to allow automated store entry tracking during CF notifications.

Polished "queue overflow" error reporting.
---

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<const cache_key*>(msg.key));
+        const cache_key *key = reinterpret_cast<const cache_key*>(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);