svn commit: r1517553 - /roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java

[gmazza]

Author: gmazza
Date: Mon Aug 26 15:12:05 2013
New Revision: 1517553

URL: http://svn.apache.org/r1517553
Log:
ROL-1021 provide total # of referrers and max referrer queue size in 
ReferrerQueueManagerImpl.

Modified:
    
roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java

Modified: 
roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java
URL: 
http://svn.apache.org/viewvc/roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java?rev=1517553&r1=1517552&r2=1517553&view=diff
==============================================================================
--- 
roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java
 (original)
+++ 
roller/trunk/app/src/main/java/org/apache/roller/weblogger/business/referrers/ReferrerQueueManagerImpl.java
 Mon Aug 26 15:12:05 2013
@@ -65,8 +65,9 @@ public class ReferrerQueueManagerImpl im
     private int sleepTime = 10000;
     private List workers = null;
     private List referrerQueue = null;
+    private int referrerCount = 0;
+    private int maxAsyncQueueSize = 0;
 
-    
     // private because we are a singleton
     @com.google.inject.Inject
     protected ReferrerQueueManagerImpl(Weblogger roller) {
@@ -129,7 +130,8 @@ public class ReferrerQueueManagerImpl im
      * now.
      */
     public void processReferrer(IncomingReferrer referrer) {
-        
+        referrerCount++;
+
         if(this.asyncMode) {
             mLogger.debug("QUEUING: "+referrer.getRequestUrl());
             
@@ -163,8 +165,12 @@ public class ReferrerQueueManagerImpl im
      */
     public void enqueue(IncomingReferrer referrer) {
         this.referrerQueue.add(referrer);
-        
-        if(this.referrerQueue.size() > 250) {
+
+        int currentSize = this.referrerQueue.size();
+        if (currentSize > maxAsyncQueueSize) {
+            maxAsyncQueueSize = currentSize;
+        }
+        if (currentSize > 250) {
             mLogger.warn("Referrer queue is rather full. 
queued="+this.referrerQueue.size());
         }
     }
@@ -190,7 +196,10 @@ public class ReferrerQueueManagerImpl im
         
         if(this.workers != null && this.workers.size() > 0) {
             mLogger.info("stopping all ReferrerQueue worker threads");
-            
+            mLogger.info("Total referrers received: " + referrerCount);
+            if (this.asyncMode) {
+                mLogger.info("Max Async Referrer queue size: " + 
maxAsyncQueueSize);
+            }
             // kill all of our threads
             WorkerThread worker = null;
             Iterator it = this.workers.iterator();