From b7262ab3da124f4d2db297e33c117ebff6cf1964 Mon Sep 17 00:00:00 2001
From: Norman Maurer <nmaurer@redhat.com>
Date: Wed, 23 Oct 2013 13:55:53 +0200
Subject: [PATCH] [#1812] Rework ByteToMessageDecoder.channelRead(..) method to
 allow for inlining

---
 .../handler/codec/ByteToMessageDecoder.java   | 83 +++++++++----------
 1 file changed, 38 insertions(+), 45 deletions(-)

diff --git a/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java b/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java
index 5ce3350871..340f2ce32f 100644
--- a/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java
+++ b/codec/src/main/java/io/netty/handler/codec/ByteToMessageDecoder.java
@@ -121,62 +121,55 @@ public abstract class ByteToMessageDecoder extends ChannelInboundHandlerAdapter
 
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        RecyclableArrayList out = RecyclableArrayList.newInstance();
-        try {
-            if (msg instanceof ByteBuf) {
+        if (msg instanceof ByteBuf) {
+            RecyclableArrayList out = RecyclableArrayList.newInstance();
+            try {
                 ByteBuf data = (ByteBuf) msg;
                 if (cumulation == null) {
                     cumulation = data;
-                    try {
-                        callDecode(ctx, cumulation, out);
-                    } finally {
-                        if (cumulation != null && !cumulation.isReadable()) {
-                            cumulation.release();
-                            cumulation = null;
-                        }
-                    }
                 } else {
-                    try {
-                        if (cumulation.writerIndex() > cumulation.maxCapacity() - data.readableBytes()) {
-                            ByteBuf oldCumulation = cumulation;
-                            cumulation = ctx.alloc().buffer(oldCumulation.readableBytes() + data.readableBytes());
-                            cumulation.writeBytes(oldCumulation);
-                            oldCumulation.release();
-                        }
-                        cumulation.writeBytes(data);
-                        callDecode(ctx, cumulation, out);
-                    } finally {
-                        if (cumulation != null) {
-                            if (!cumulation.isReadable()) {
-                                cumulation.release();
-                                cumulation = null;
-                            } else {
-                                cumulation.discardSomeReadBytes();
-                            }
-                        }
-                        data.release();
+                    if (cumulation.writerIndex() > cumulation.maxCapacity() - data.readableBytes()) {
+                        expandCumulation(ctx, data.readableBytes());
+                    }
+                    cumulation.writeBytes(data);
+                    data.release();
+                }
+                callDecode(ctx, cumulation, out);
+            } catch (DecoderException e) {
+                throw e;
+            } catch (Throwable t) {
+                throw new DecoderException(t);
+            } finally {
+                if (cumulation != null) {
+                    if (!cumulation.isReadable()) {
+                        cumulation.release();
+                        cumulation = null;
+                    } else {
+                        cumulation.discardSomeReadBytes();
                     }
                 }
-            } else {
-                out.add(msg);
-            }
-        } catch (DecoderException e) {
-            throw e;
-        } catch (Throwable t) {
-            throw new DecoderException(t);
-        } finally {
-            int size = out.size();
-            if (size == 0) {
-                decodeWasNull = true;
-            } else {
-                for (int i = 0; i < size; i ++) {
-                    ctx.fireChannelRead(out.get(i));
+                int size = out.size();
+                if (size == 0) {
+                    decodeWasNull = true;
+                } else {
+                    for (int i = 0; i < size; i ++) {
+                        ctx.fireChannelRead(out.get(i));
+                    }
                 }
+                out.recycle();
             }
-            out.recycle();
+        } else {
+            ctx.fireChannelRead(msg);
         }
     }
 
+    private void expandCumulation(ChannelHandlerContext ctx, int readable) {
+        ByteBuf oldCumulation = cumulation;
+        cumulation = ctx.alloc().buffer(oldCumulation.readableBytes() + readable);
+        cumulation.writeBytes(oldCumulation);
+        oldCumulation.release();
+    }
+
     @Override
     public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
         if (decodeWasNull) {