Author: markt Date: Tue Mar 31 17:08:55 2015 New Revision: 1670395 URL: http://svn.apache.org/r1670395 Log: Correctly fix blocking writes and perMessageDeflate (or any transformation that may generate multiple output messages per input message).
Modified: tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java Modified: tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java?rev=1670395&r1=1670394&r2=1670395&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java (original) +++ tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java Tue Mar 31 17:08:55 2015 @@ -305,6 +305,10 @@ public abstract class WsRemoteEndpointIm if (!bsh.getSendResult().isOK()) { throw new IOException (bsh.getSendResult().getException()); } + // The BlockingSendHandler doesn't call end message so update the + // flags. + fragmented = nextFragmented; + text = nextText; } if (payload != null) { --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org