From ba9ba967470b4f1f91306f69a0a7ff15ce953366 Mon Sep 17 00:00:00 2001 From: gaozhiwen Date: Wed, 23 Aug 2017 18:12:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86ProtocolBuffer=E6=94=B9?= =?UTF-8?q?=E6=88=90ProxyBuffer=E6=97=B6=E6=8C=81=E7=BB=AD=E8=AF=BB?= =?UTF-8?q?=E5=86=99=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/mycat/proxy/man/DefaultAdminSessionHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/src/main/java/io/mycat/proxy/man/DefaultAdminSessionHandler.java b/source/src/main/java/io/mycat/proxy/man/DefaultAdminSessionHandler.java index f409554..dee0ae2 100644 --- a/source/src/main/java/io/mycat/proxy/man/DefaultAdminSessionHandler.java +++ b/source/src/main/java/io/mycat/proxy/man/DefaultAdminSessionHandler.java @@ -38,7 +38,7 @@ public void onSocketRead(final AdminSession session) throws IOException { session.curAdminCommand.handlerPkg(session, pkgType); } // 下一个报文解析 -// session.readingBuffer.readIndex = session.curAdminPkgInf.startPos+session.curAdminPkgInf.length; + session.readingBuffer.readIndex = session.curAdminPkgInf.startPos+session.curAdminPkgInf.length; } // session.readingBuffer.writeIndex = bufferLimit;