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, ");