svn commit: r593405 - /mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java

[trustin]

Author: trustin
Date: Thu Nov  8 18:47:27 2007
New Revision: 593405

URL: http://svn.apache.org/viewvc?rev=593405&view=rev
Log:
Fixed a problem that resumeRead is not called sometimes

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java?rev=593405&r1=593404&r2=593405&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilter.java
 Thu Nov  8 18:47:27 2007
@@ -32,7 +32,6 @@
 import org.apache.mina.common.IoSessionLogger;
 import org.apache.mina.common.TrafficMask;
 import org.apache.mina.filter.executor.ExecutorFilter;
-import org.apache.mina.filter.executor.ExecutorFilter;
 import org.apache.mina.util.CopyOnWriteMap;
 import org.slf4j.Logger;
 
@@ -455,8 +454,7 @@
                 state.sessionBufferSize = sessionBufferSize = 0;
                 throw new IllegalStateException("sessionBufferSize < 0");
             }
-            if (state.suspendedRead &&
-                (maxGlobalBufferSize == 0 || globalBufferSize < 
maxGlobalBufferSize) &&
+            if ((maxGlobalBufferSize == 0 || globalBufferSize < 
maxGlobalBufferSize) &&
                 (maxServiceBufferSize == 0 || serviceBufferSize < 
maxServiceBufferSize) &&
                 (maxSessionBufferSize == 0 || sessionBufferSize < 
maxSessionBufferSize)) {
                 state.suspendedRead = false;
@@ -524,8 +522,7 @@
         int maxSessionBufferSize = this.maxSessionBufferSize;
         boolean resume = false;
         synchronized (state) {
-            if (state.suspendedRead &&
-                (maxSessionBufferSize == 0 || state.sessionBufferSize < 
maxSessionBufferSize)) {
+            if ((maxSessionBufferSize == 0 || state.sessionBufferSize < 
maxSessionBufferSize)) {
                 state.suspendedRead = false;
                 resume = true;
             }