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

Posted to commits@mina.apache.org by el...@apache.org on 2008/09/15 00:02:34 UTC

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

Author: elecharny
Date: Sun Sep 14 15:02:34 2008
New Revision: 695300

URL: http://svn.apache.org/viewvc?rev=695300&view=rev
Log:
Added some very preliminary javadoc

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=695300&r1=695299&r2=695300&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 Sun Sep 14 15:02:34 2008
@@ -72,6 +72,7 @@
     private final String threadName;
     private final Executor executor;
 
+    /** A Session queue containing the newly created sessions */
     private final Queue<T> newSessions = new ConcurrentLinkedQueue<T>();
     private final Queue<T> removingSessions = new ConcurrentLinkedQueue<T>();
     private final Queue<T> flushingSessions = new ConcurrentLinkedQueue<T>();
@@ -316,6 +317,7 @@
             throw new IllegalStateException("Already disposed.");
         }
 
+        // Adds the session to the newSession queue and starts the worker
         newSessions.add(session);
         startupWorker();
     }