You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2014/12/09 17:39:24 UTC
svn commit: r1644118 -
/manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
Author: kwright
Date: Tue Dec 9 16:39:23 2014
New Revision: 1644118
URL: http://svn.apache.org/r1644118
Log:
Make minimum depth calculation be done once per group of references.
Modified:
manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
Modified: manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java?rev=1644118&r1=1644117&r2=1644118&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java (original)
+++ manifoldcf/branches/CONNECTORS-1118/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java Tue Dec 9 16:39:23 2014
@@ -1841,6 +1841,7 @@ public class WorkerThread extends Thread
long currentTime = System.currentTimeMillis();
+ double currentMinimumDepth = rt.getMinimumDepth();
rt.clearPreloadRequests();
for (int j = 0; j < docidHashes.length; j++)
{
@@ -1853,7 +1854,7 @@ public class WorkerThread extends Thread
// Calculate desired document priority based on current queuetracker status.
String[] bins = ManifoldCF.calculateBins(connector,dr.getLocalIdentifier());
- PriorityCalculator p = new PriorityCalculator(rt,connection,bins);
+ PriorityCalculator p = new PriorityCalculator(rt,currentMinimumDepth,connection,bins);
priorities[j] = p;
p.makePreloadRequest();
}