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 2009/08/05 14:07:43 UTC
svn commit: r801157 -
/mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
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());