Author: elecharny Date: Tue Jun 17 02:45:28 2008 New Revision: 668591 URL: http://svn.apache.org/viewvc?rev=668591&view=rev Log: Adding some few preliminary comments (almost useless ...)
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java?rev=668591&r1=668590&r2=668591&view=diff ============================================================================== --- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java (original) +++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java Tue Jun 17 02:45:28 2008 @@ -265,15 +265,20 @@ private int add() { int addedSessions = 0; - for (; ;) { + + // Loop on the new sessions blocking queue, to count + // the number of sessions who has been created + for (;;) { T session = newSessions.poll(); if (session == null) { + // We don't have anymore new sessions break; } if (addNow(session)) { + // The new session has been added to the addedSessions ++; } } @@ -712,6 +717,11 @@ } } + + /** + * + * + */ private class Worker implements Runnable { public void run() { int nSessions = 0;