From ddae41dbe22a60a9a4ce799833e606bfbbad7ba1 Mon Sep 17 00:00:00 2001 From: hebo Date: Sun, 22 Nov 2020 20:26:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20mysql=20packet=E6=9C=80?= =?UTF-8?q?=E5=A4=A7=E5=85=81=E8=AE=B8=E5=80=BC=E8=AE=BE=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- session-dealer/mysql/config.go | 4 +++- session-dealer/mysql/const.go | 7 ------- 2 files changed, 3 insertions(+), 8 deletions(-) diff --git a/session-dealer/mysql/config.go b/session-dealer/mysql/config.go index a12eeed..6215386 100644 --- a/session-dealer/mysql/config.go +++ b/session-dealer/mysql/config.go @@ -16,7 +16,8 @@ var ( strictMode bool adminUser string adminPasswd string - + // MaxMysqlPacketLen is the max packet payload length. + MaxMysqlPacketLen int coverRangePool = NewCoveragePool() localStmtCache = util.NewSliceBufferPool("statement cache", MaxMysqlPacketLen) @@ -27,6 +28,7 @@ func init() { flag.BoolVar(&strictMode,"strict_mode", false, "strict mode. Default is false") flag.StringVar(&adminUser,"admin_user", "", "admin user name. When set strict mode, must set admin user to query session info") flag.StringVar(&adminPasswd,"admin_passwd", "", "admin user passwd. When use strict mode, must set admin user to query session info") + flag.IntVar(&MaxMysqlPacketLen, "max_packet_length", 128 * 1024, "max mysql packet length. Default is 128 * 1024") } func CheckParams() { diff --git a/session-dealer/mysql/const.go b/session-dealer/mysql/const.go index adc4780..6bd5a29 100644 --- a/session-dealer/mysql/const.go +++ b/session-dealer/mysql/const.go @@ -91,13 +91,6 @@ const ( GlobalStatusTable = "GLOBAL_STATUS" ) - -// Identifier length limitations. -const ( - // MaxMysqlPacketLen is the max packet payload length. - MaxMysqlPacketLen = 128 * 1024 -) - const ( millSecondUnit = int64(time.Millisecond) )