Browse Source

websocket buffer release fixed. #191

master
Nikita 10 years ago
parent
commit
20607b3e30
  1. 5
      src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java

5
src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java

@ -217,8 +217,9 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter {
if (log.isTraceEnabled()) { if (log.isTraceEnabled()) {
log.trace("Out message: {} sessionId: {}", out.toString(CharsetUtil.UTF_8), msg.getSessionId()); log.trace("Out message: {} sessionId: {}", out.toString(CharsetUtil.UTF_8), msg.getSessionId());
} }
ctx.channel().writeAndFlush(res);
if (!out.isReadable()) {
if (out.isReadable()) {
ctx.channel().writeAndFlush(res);
} else {
out.release(); out.release();
} }

Loading…
Cancel
Save