From 0235244e55414597bd2327da9767695cb8d46cbb Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Thu, 13 Feb 2014 18:11:54 -0800 Subject: [PATCH] Touch a ReferenceCounted while it traverses across a pipeline --- .../java/io/netty/channel/DefaultChannelHandlerContext.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java index 0c570b03c9..f2e5e5c564 100644 --- a/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelHandlerContext.java @@ -329,6 +329,7 @@ final class DefaultChannelHandlerContext implements ChannelHandlerContext { throw new NullPointerException("msg"); } + ReferenceCountUtil.touch(msg); final DefaultChannelHandlerContext next = findContextInbound(); EventExecutor executor = next.executor(); if (executor.inEventLoop()) { @@ -705,6 +706,7 @@ final class DefaultChannelHandlerContext implements ChannelHandlerContext { private void write(Object msg, boolean flush, ChannelPromise promise) { + ReferenceCountUtil.touch(msg); DefaultChannelHandlerContext next = findContextOutbound(); EventExecutor executor = next.executor(); if (executor.inEventLoop()) {