| commit | eb1feaedf7e9428c07f5c1b7173c62c88d9f81cd | [log] [tgz] |
|---|---|---|
| author | Karl Wright <kwright@apache.org> | Wed Dec 18 20:59:01 2013 +0000 |
| committer | Karl Wright <kwright@apache.org> | Wed Dec 18 20:59:01 2013 +0000 |
| tree | bf66e230f9ff90bb50fc550deced0b3be65f97d9 | |
| parent | 1571f4768d377ff30fa96a9ae6166c7d07fb4374 [diff] |
Add a couple of missing notifyAll() statements. git-svn-id: https://svn.apache.org/repos/asf/manifoldcf/branches/CONNECTORS-829@1552095 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java b/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java index ab0bb56..32d64c2 100644 --- a/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java +++ b/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/ConnectionBin.java
@@ -234,6 +234,7 @@ public synchronized void undoPooledConnectionDecision(AtomicInteger poolCount) { poolCount.set(poolCount.get() + 1); + notifyAll(); } /** Note a connection returned to the pool.
diff --git a/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java b/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java index 747f4e5..c05b28c 100644 --- a/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java +++ b/framework/core/src/main/java/org/apache/manifoldcf/core/throttler/FetchBin.java
@@ -123,6 +123,7 @@ 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 @@ // 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();