svn commit: r801157 - /mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java

[elecharny]

Author: elecharny
Date: Wed Aug  5 12:07:43 2009
New Revision: 801157

URL: http://svn.apache.org/viewvc?rev=801157&view=rev
Log:
Minor refactoring

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java?rev=801157&r1=801156&r2=801157&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
 Wed Aug  5 12:07:43 2009
@@ -377,6 +377,7 @@
 
     private boolean scheduleFlush(T session) {
         if (session.setScheduledForFlush(true)) {
+            // add the session to the queue
             flushingSessions.add(session);
             return true;
         }
@@ -645,6 +646,7 @@
                     }
                 }
             }
+            
             if (ret < 0) {
                 scheduleRemove(session);
             }
@@ -658,6 +660,7 @@
 
                     scheduleRemove(session);
             }
+            
             IoFilterChain filterChain = session.getFilterChain();
             filterChain.fireExceptionCaught(e);
         }
@@ -923,6 +926,9 @@
         }
     }
 
+    /**
+     * {...@inheritdoc}
+     */
     public void updateTrafficControl(T session) {
         try {
             setInterestedInRead(session, !session.isReadSuspended());