You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@nutch.apache.org by jn...@apache.org on 2014/04/18 19:33:08 UTC

svn commit: r1588523 - /nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java

Author: jnioche
Date: Fri Apr 18 17:33:07 2014
New Revision: 1588523

URL: http://svn.apache.org/r1588523
Log:
minor change : added count of waitng threads in status report

Modified:
    nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java

Modified: nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java
URL: http://svn.apache.org/viewvc/nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java?rev=1588523&r1=1588522&r2=1588523&view=diff
==============================================================================
--- nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java (original)
+++ nutch/trunk/src/java/org/apache/nutch/fetcher/Fetcher.java Fri Apr 18 17:33:07 2014
@@ -1116,7 +1116,7 @@ public class Fetcher extends Configured 
     float avgPagesSec =  (float) pages.get() / elapsed.floatValue();
     long avgBytesSec =  (bytes.get() /125l) / elapsed.longValue();
 
-    status.append(activeThreads).append(" threads, ");
+    status.append(activeThreads).append(" threads (").append(spinWaiting.get()).append(" waiting), ");
     status.append(fetchQueues.getQueueCount()).append(" queues, ");
     status.append(fetchQueues.getTotalSize()).append(" URLs queued, ");
     status.append(pages).append(" pages, ").append(errors).append(" errors, ");