You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2015/01/15 10:21:35 UTC
svn commit: r1652006 -
/tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java
Author: markt
Date: Thu Jan 15 09:21:35 2015
New Revision: 1652006
URL: http://svn.apache.org/r1652006
Log:
Trivial
- rename
- add a TODO
Modified:
tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java?rev=1652006&r1=1652005&r2=1652006&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java Thu Jan 15 09:21:35 2015
@@ -735,7 +735,7 @@ public class Nio2Endpoint extends Abstra
private boolean writeInterest = true; // Guarded by writeCompletionHandler
private boolean writeNotify = false;
- private CompletionHandler<Integer, SocketWrapperBase<Nio2Channel>> awaitBytes
+ private CompletionHandler<Integer, SocketWrapperBase<Nio2Channel>> awaitBytesHandler
= new CompletionHandler<Integer, SocketWrapperBase<Nio2Channel>>() {
@Override
@@ -1300,7 +1300,9 @@ public class Nio2Endpoint extends Abstra
if (readPending.tryAcquire()) {
getSocket().getBufHandler().configureReadBufferForWrite();
getSocket().read(getSocket().getBufHandler().getReadBuffer(),
- getTimeout(), TimeUnit.MILLISECONDS, this, awaitBytes);
+ getTimeout(), TimeUnit.MILLISECONDS, this, awaitBytesHandler);
+ // TODO Figure out why moving this to the awaitBytesHandler
+ // causes test failures.
readPending.release();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org