From 6a1c3f02bd4e5d40d2366efda135de8bdbb498d4 Mon Sep 17 00:00:00 2001
From: hebo <xiaobiao@jd.com>
Date: Fri, 11 Oct 2019 17:59:08 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E6=8A=93=E5=8C=85=E7=8E=87?=
 =?UTF-8?q?=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 communicator/config.go     |  2 +-
 model/mysql_query_piece.go |  2 +-
 model/query_piece.go       | 16 ++++++++--------
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/communicator/config.go b/communicator/config.go
index 73806a2..bffc27e 100644
--- a/communicator/config.go
+++ b/communicator/config.go
@@ -27,7 +27,7 @@ func init() {
 	catpurePacketRate = newCapturePacketRateConfig()
 
 	flag.IntVar(&communicatePort, "communicate_port", 8088, "http server port. Default is 8088")
-	flag.Float64Var(&catpurePacketRateVal, CAPTURE_PACKET_RATE, 0.01, "capture packet rate. Default is 0.01")
+	flag.Float64Var(&catpurePacketRateVal, CAPTURE_PACKET_RATE, 1.0, "capture packet rate. Default is 1.0")
 
 	configMap = make(map[string]configItem)
 }
diff --git a/model/mysql_query_piece.go b/model/mysql_query_piece.go
index 6998835..8c75060 100644
--- a/model/mysql_query_piece.go
+++ b/model/mysql_query_piece.go
@@ -41,7 +41,7 @@ func NewPooledMysqlQueryPiece(
 	mqp.VisitUser = visitUser
 	mqp.VisitDB = visitDB
 	mqp.SyncSend = false
-	mqp.ThrowPacketRate = throwPacketRate
+	mqp.CapturePacketRate = throwPacketRate
 	mqp.BeginTime = stmtBeginTime
 	mqp.CostTimeInMS = nowInMS - stmtBeginTime
 	mqp.recoverPool = mqpp
diff --git a/model/query_piece.go b/model/query_piece.go
index 80f207d..d6ee3e2 100644
--- a/model/query_piece.go
+++ b/model/query_piece.go
@@ -20,12 +20,12 @@ type QueryPiece interface {
 
 // BaseQueryPiece 查询信息
 type BaseQueryPiece struct {
-	SyncSend        bool    `json:"-"`
-	ServerIP        *string `json:"sip"`
-	ServerPort      int     `json:"sport"`
-	ThrowPacketRate float64 `json:"tpr"`
-	BeginTime       int64   `json:"bt"`
-	jsonContent     []byte  `json:"-"`
+	SyncSend          bool    `json:"-"`
+	ServerIP          *string `json:"sip"`
+	ServerPort        int     `json:"sport"`
+	CapturePacketRate float64 `json:"cpr"`
+	BeginTime         int64   `json:"bt"`
+	jsonContent       []byte  `json:"-"`
 }
 
 const (
@@ -40,13 +40,13 @@ var (
 var commonBaseQueryPiece = &BaseQueryPiece{}
 
 func NewBaseQueryPiece(
-	serverIP *string, serverPort int, throwPacketRate float64) (
+	serverIP *string, serverPort int, capturePacketRate float64) (
 	bqp *BaseQueryPiece) {
 	bqp = commonBaseQueryPiece
 	bqp.ServerIP = serverIP
 	bqp.ServerPort = serverPort
 	bqp.SyncSend = false
-	bqp.ThrowPacketRate = throwPacketRate
+	bqp.CapturePacketRate = capturePacketRate
 	bqp.BeginTime = time.Now().UnixNano() / millSecondUnit
 
 	return