svn commit: r1552095 - in /manifoldcf/branches/CONNECTORS-829/framework/core/src/main/java/org/apache/manifoldcf/core/throttler: ConnectionBin.java FetchBin.java

[kwright]

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();