andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix memory leak

Browse Source
This commit is contained in:
Trustin Lee 2013-06-14 10:44:22 +09:00
parent a0c082497a
commit 30bfb989c1
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
codec/src/main/java/io/netty/handler/codec/MessageToByteEncoder.java
View File

@ -80,6 +80,7 @@ public abstract class MessageToByteEncoder<I> extends ChannelOutboundHandlerAdap
if (ctx.isRemoved()) { if (ctx.isRemoved()) {
if (buf != null && buf.isReadable()) { if (buf != null && buf.isReadable()) {
out.add(buf); out.add(buf);
buf = null;
} }
out.add(msgs, i, size - i); out.add(msgs, i, size - i);
break; break;
@ -110,11 +111,9 @@ public abstract class MessageToByteEncoder<I> extends ChannelOutboundHandlerAdap
} }
} }
if (buf != null) { if (buf != null && buf.isReadable()) {
if (buf.isReadable()) { out.add(buf);
out.add(buf); buf = null;
buf = null;
}
} }
success = true; success = true;