Release the incoming message when the decoding failed

Related to #406
reactor · Aug 6, 2018 · c7c9132 · c7c9132
1 parent 88462b0
commit c7c9132
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/reactor/ipc/netty/http/server/HttpServerHandler.java b/src/main/java/reactor/ipc/netty/http/server/HttpServerHandler.java
@@ -91,6 +91,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
 				Throwable cause = decoderResult.cause();
 				HttpServerOperations.log.debug(format(ctx.channel(), "Decoding failed: " + msg + " : "),
 						cause);
+				ReferenceCountUtil.release(msg);
 
 				HttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_0,
 				        cause instanceof TooLongFrameException ? HttpResponseStatus.REQUEST_ENTITY_TOO_LARGE: