svn commit: r1406121 - /mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java

[el...@apache.org]

Author: elecharny
Date: Tue Nov  6 13:05:49 2012
New Revision: 1406121

URL: http://svn.apache.org/viewvc?rev=1406121&view=rev
Log:
Called notifyAll() instead of notify() (see DIRMINA-738)

Modified:
    mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java

Modified: mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java
URL: http://svn.apache.org/viewvc/mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java?rev=1406121&r1=1406120&r2=1406121&view=diff
==============================================================================
--- mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java (original)
+++ mina/mina/branches/2.0/mina-core/src/main/java/org/apache/mina/filter/executor/IoEventQueueThrottle.java Tue Nov  6 13:05:49 2012
@@ -57,6 +57,7 @@ public class IoEventQueueThrottle implem
         if (eventSizeEstimator == null) {
             throw new IllegalArgumentException("eventSizeEstimator");
         }
+        
         this.eventSizeEstimator = eventSizeEstimator;
 
         setThreshold(threshold);
@@ -78,6 +79,7 @@ public class IoEventQueueThrottle implem
         if (threshold <= 0) {
             throw new IllegalArgumentException("threshold: " + threshold);
         }
+        
         this.threshold = threshold;
     }
 
@@ -108,10 +110,12 @@ public class IoEventQueueThrottle implem
 
     private int estimateSize(IoEvent event) {
         int size = getEventSizeEstimator().estimateSize(event);
+        
         if (size < 0) {
             throw new IllegalStateException(IoEventSizeEstimator.class.getSimpleName() + " returned "
                     + "a negative value (" + size + "): " + event);
         }
+        
         return size;
     }
 
@@ -147,7 +151,7 @@ public class IoEventQueueThrottle implem
     protected void unblock() {
         synchronized (lock) {
             if (waiters > 0) {
-                lock.notify();
+                lock.notifyAll();
             }
         }
     }