Author: elecharny
Date: Sun Sep 14 15:02:34 2008
New Revision: 695300
URL:
http://svn.apache.org/viewvc?rev=695300&view=revLog:
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();
}