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/06/17 11:45:28 UTC
svn commit: r668591 -
/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractPollingIoProcessor.java
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;