You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hc.apache.org by ol...@apache.org on 2010/12/23 13:18:56 UTC

svn commit: r1052237 - /httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java

Author: olegk
Date: Thu Dec 23 12:18:55 2010
New Revision: 1052237

URL: http://svn.apache.org/viewvc?rev=1052237&view=rev
Log:
Moved session buffer check inside try-catch

Modified:
    httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java

Modified: httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java?rev=1052237&r1=1052236&r2=1052237&view=diff
==============================================================================
--- httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java (original)
+++ httpcomponents/httpcore/trunk/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/BaseIOReactor.java Thu Dec 23 12:18:55 2010
@@ -159,15 +159,15 @@ public class BaseIOReactor extends Abstr
 
         try {
             this.eventDispatch.inputReady(session);
+            if (session.hasBufferedInput()) {
+                this.bufferingSessions.add(session);
+            }
         } catch (CancelledKeyException ex) {
             queueClosedSession(session);
             key.attach(null);
         } catch (RuntimeException ex) {
             handleRuntimeException(ex);
         }
-        if (session.hasBufferedInput()) {
-            this.bufferingSessions.add(session);
-        }
     }
 
     /**