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-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
