Commit 211c61df authored by terrymanu's avatar terrymanu
Browse files

refactor MySQLPacketCodec

parent 386e80e7

sharding-jdbc-server/src/main/java/io/shardingjdbc/server/codec/MySQLPacketCodec.java

+1 −1
Original line number Diff line number Diff line
@@ -35,7 +35,7 @@ public final class MySQLPacketCodec extends ByteToMessageCodec<AbstractMySQLSent 
            return;

        }

        if (readableBytes > realPacketLength) {

            out.add(in.readRetainedSlice(payloadLength + 1));

            out.add(in.readRetainedSlice(payloadLength + AbstractMySQLPacket.SEQUENCE_LENGTH));

            return;

        }

        out.add(in);