Author: markt
Date: Tue Feb 23 14:55:54 2016
New Revision: 1731872
URL: http://svn.apache.org/viewvc?rev=1731872&view=rev
Log:
Correct r1731867
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java?rev=1731872&r1=1731871&r2=1731872&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
Tue Feb 23 14:55:54 2016
@@ -268,7 +268,8 @@ public abstract class WsRemoteEndpointIm
// trigger a session close and depending on timing the client
// session may close before we can read the timeout.
long timeout = getBlockingSendTimeout();
- FutureToSendHandler f2sh = new FutureToSendHandler(wsSession, true);
+ FutureToSendHandler f2sh =
+ new FutureToSendHandler(wsSession, opCode ==
Constants.OPCODE_CLOSE);
startMessage(opCode, payload, last, f2sh);
try {
if (timeout == -1) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
