ping buffer size 128

bilibili · Dec 15, 2018 · a1960e6 · a1960e6
1 parent 70aea49
commit a1960e6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/proto/memcache/pinger.go b/proto/memcache/pinger.go
@@ -12,7 +12,7 @@ import (
 )
 
 const (
-	pingBufferSize = 8
+	pingBufferSize = 128
 )
 
 var (
@@ -32,8 +32,8 @@ type mcPinger struct {
 func NewPinger(nc *libnet.Conn) proto.Pinger {
 	return &mcPinger{
 		conn: nc,
-		bw:   bufio.NewWriter(nc),
 		br:   bufio.NewReader(nc, bufio.NewBuffer(pingBufferSize)),
+		bw:   bufio.NewWriter(nc),
 	}
 }
 

diff --git a/proto/redis/pinger.go b/proto/redis/pinger.go
@@ -12,6 +12,10 @@ import (
 	"github.com/pkg/errors"
 )
 
+const (
+	pingBufferSize = 128
+)
+
 // errors
 var (
 	ErrPingClosed = errs.New("ping interface has been closed")
@@ -36,7 +40,7 @@ type pinger struct {
 func NewPinger(conn *libnet.Conn) proto.Pinger {
 	return &pinger{
 		conn:  conn,
-		br:    bufio.NewReader(conn, bufio.NewBuffer(7)),
+		br:    bufio.NewReader(conn, bufio.NewBuffer(pingBufferSize)),
 		bw:    bufio.NewWriter(conn),
 		state: opened,
 	}