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 2013/12/18 21:59:02 UTC
svn commit: r1552095 - in
/manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler:
ConnectionBin.java FetchBin.java
Author: kwright
Date: Wed Dec 18 20:59:01 2013
New Revision: 1552095
URL: http://svn.apache.org/r1552095
Log:
Add a couple of missing notifyAll() statements.
Modified:
manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java
manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java
Modified: manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java?rev=1552095&r1=1552094&r2=1552095&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java (original)
+++ manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java Wed Dec 18 20:59:01 2013
@@ -234,6 +234,7 @@ public class ConnectionBin
public synchronized void undoPooledConnectionDecision(AtomicInteger poolCount)
{
poolCount.set(poolCount.get() + 1);
+ notifyAll();
}
/** Note a connection returned to the pool.
Modified: manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java?rev=1552095&r1=1552094&r2=1552095&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java (original)
+++ manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java Wed Dec 18 20:59:01 2013
@@ -123,6 +123,7 @@ public class FetchBin
if (!reserveNextFetch)
throw new IllegalStateException("Can't clear a fetch reservation we don't have");
reserveNextFetch = false;
+ notifyAll();
}
/** Wait the necessary time to do the fetch. Presumes we've reserved the next fetch
@@ -243,6 +244,7 @@ public class FetchBin
// But in order to update the next time, we have to update the last time.
if (target == localMinimum && earliestTargetTime == lastFetchTime)
return;
+ //System.out.println(binName+":Setting localMinimum="+target+"; last fetch time="+earliestTargetTime);
localMinimum = target;
lastFetchTime = earliestTargetTime;
notifyAll();