From f7a8f4e04bb4a3584c3042cbd3358d6508a04a65 Mon Sep 17 00:00:00 2001 From: lysu Date: Wed, 5 Jun 2019 10:39:13 +0800 Subject: [PATCH] ticlient: set max send/recv msg size match tikv's config (#10706) --- store/tikv/client.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/store/tikv/client.go b/store/tikv/client.go index eed1a7ed7a060..d4df0be5f4100 100644 --- a/store/tikv/client.go +++ b/store/tikv/client.go @@ -17,6 +17,7 @@ package tikv import ( "context" "io" + "math" "strconv" "sync" "sync/atomic" @@ -42,11 +43,11 @@ import ( // MaxSendMsgSize set max gRPC request message size sent to server. If any request message size is larger than // current value, an error will be reported from gRPC. -var MaxSendMsgSize = 1<<31 - 1 +var MaxSendMsgSize = 10 * 1024 * 1024 -// MaxCallMsgSize set max gRPC receive message size received from server. If any message size is larger than +// MaxRecvMsgSize set max gRPC receive message size received from server. If any message size is larger than // current value, an error will be reported from gRPC. -var MaxCallMsgSize = 1<<31 - 1 +var MaxRecvMsgSize = math.MaxInt64 // Timeout durations. const ( @@ -258,7 +259,7 @@ func (a *connArray) Init(addr string, security config.Security) error { grpc.WithInitialConnWindowSize(grpcInitialConnWindowSize), grpc.WithUnaryInterceptor(unaryInterceptor), grpc.WithStreamInterceptor(streamInterceptor), - grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(MaxCallMsgSize)), + grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(MaxRecvMsgSize)), grpc.WithDefaultCallOptions(grpc.MaxCallSendMsgSize(MaxSendMsgSize)), grpc.WithBackoffMaxDelay(time.Second*3), grpc.WithKeepaliveParams(keepalive.ClientParameters{