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 2010/02/19 16:08:12 UTC
svn commit: r911833 -
/mina/trunk/core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java
Author: elecharny
Date: Fri Feb 19 15:08:11 2010
New Revision: 911833
URL: http://svn.apache.org/viewvc?rev=911833&view=rev
Log:
Removed the totally useless and CPU consuming WRITE_SPIN_COUNT.
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=911833&r1=911832&r2=911833&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 Fri Feb 19 15:08:11 2010
@@ -922,13 +922,7 @@
length = buf.remaining();
}
- for (int i = WRITE_SPIN_COUNT; i > 0; i--) {
- localWrittenBytes = write(session, buf, length);
-
- if (localWrittenBytes != 0) {
- break;
- }
- }
+ localWrittenBytes = write(session, buf, length);
}
session.increaseWrittenBytes(localWrittenBytes, currentTime);
@@ -937,6 +931,7 @@
// Buffer has been sent, clear the current request.
int pos = buf.position();
buf.reset();
+
fireMessageSent(session, req);
// And set it back to its position