for apache#750 read out the bytes before decoding twice

tuohai666 · tuohai666 · commit 36cf366f5b59 · 2018-04-24T09:28:44.000+08:00
diff --git a/sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/codec/MySQLPacketCodec.java b/sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/codec/MySQLPacketCodec.java
@@ -45,11 +45,7 @@ protected void doDecode(final ChannelHandlerContext context, final ByteBuf in, f
             in.resetReaderIndex();
             return;
         }
-        if (readableBytes > realPacketLength) {
-            out.add(in.readRetainedSlice(payloadLength + MySQLPacket.SEQUENCE_LENGTH));
-            return;
-        }
-        out.add(in);
+        out.add(in.readRetainedSlice(payloadLength + MySQLPacket.SEQUENCE_LENGTH));
     }
     
     @Override

Original file line number	Diff line number	Diff line change
`@@ -45,11 +45,7 @@ protected void doDecode(final ChannelHandlerContext context, final ByteBuf in, f`
`45`	`45`	`in.resetReaderIndex();`
`46`	`46`	`return;`
`47`	`47`	`}`
`48`		`- if (readableBytes > realPacketLength) {`
`49`		`- out.add(in.readRetainedSlice(payloadLength + MySQLPacket.SEQUENCE_LENGTH));`
`50`		`- return;`
`51`		`- }`
`52`		`- out.add(in);`
	`48`	`+ out.add(in.readRetainedSlice(payloadLength + MySQLPacket.SEQUENCE_LENGTH));`
`53`	`49`	`}`
`54`	`50`
`55`	`51`	`@Override`