github
/
consul
mirror of https://github.com/hashicorp/consul
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix(peering): increase the gRPC limit to 50MB

pull/15503/head
cskh 2022-11-21 11:42:32 -05:00
parent 1153779677
commit 84b287cc3c
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
agent/consul/leader_peering.go
View File

@ -360,7 +360,7 @@ func (s *Server) establishStream(ctx context.Context,
// send keepalive pings even if there is no active streams // send keepalive pings even if there is no active streams
PermitWithoutStream: true, PermitWithoutStream: true,
}), }),
grpc.WithDefaultCallOptions(grpc.MaxCallSendMsgSize(50 * 1024 * 1024)), grpc.WithDefaultCallOptions(grpc.MaxCallSendMsgSize(50*1024*1024), grpc.MaxCallRecvMsgSize(50*1024*1024)),
} }
logger.Trace("dialing peer", "addr", addr) logger.Trace("dialing peer", "addr", addr)

4
agent/grpc-internal/client.go
View File

@ -148,7 +148,9 @@ func (c *ClientConnPool) dial(datacenter string, serverType string) (*grpc.Clien
grpc.WithKeepaliveParams(keepalive.ClientParameters{ grpc.WithKeepaliveParams(keepalive.ClientParameters{
Time: 30 * time.Second, Time: 30 * time.Second,
Timeout: 10 * time.Second, Timeout: 10 * time.Second,
})) }),
grpc.WithDefaultCallOptions(grpc.MaxCallSendMsgSize(50*1024*1024), grpc.MaxCallRecvMsgSize(50*1024*1024)),
)
if err != nil { if err != nil {
return nil, err return nil, err
} }