Skip to content

Commit

Permalink
This is an automated cherry-pick of #56278
Browse files Browse the repository at this point in the history
Signed-off-by: ti-chi-bot <[email protected]>
  • Loading branch information
rleungx authored and ti-chi-bot committed Jan 21, 2025
1 parent e9a1f7f commit e25e4ae
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions store/driver/tikv_driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,11 @@ import (
"context"
"crypto/tls"
"fmt"
<<<<<<< HEAD:store/driver/tikv_driver.go
"math/rand"
=======
"math"
>>>>>>> a5e07a2ed36 (store/driver: set `MaxCallRecvMsgSize` to `MaxInt32` for pd client (#56278)):pkg/store/driver/tikv_driver.go
"net/url"
"strings"
"sync"
Expand Down Expand Up @@ -149,6 +153,9 @@ func (d TiKVDriver) OpenWithOptions(path string, options ...Option) (resStore kv
KeyPath: d.security.ClusterSSLKey,
},
pd.WithGRPCDialOptions(
// keep the same with etcd, see
// https://github.com/etcd-io/etcd/blob/5704c6148d798ea444db26a966394406d8c10526/server/etcdserver/api/v3rpc/grpc.go#L34
grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(math.MaxInt32)),
grpc.WithKeepaliveParams(keepalive.ClientParameters{
Time: time.Duration(d.tikvConfig.GrpcKeepAliveTime) * time.Second,
Timeout: time.Duration(d.tikvConfig.GrpcKeepAliveTimeout) * time.Second,
Expand Down

0 comments on commit e25e4ae

Please sign in to comment.