From 67919ef2da698fba380d06a99faf8a0a44d38205 Mon Sep 17 00:00:00 2001 From: fanmin shi Date: Mon, 22 May 2017 16:57:40 -0700 Subject: [PATCH] v3rpc: change grpc max recv size as needed. --- etcdserver/api/v3rpc/grpc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/etcdserver/api/v3rpc/grpc.go b/etcdserver/api/v3rpc/grpc.go index 88174e3bac24..f93a44626c97 100644 --- a/etcdserver/api/v3rpc/grpc.go +++ b/etcdserver/api/v3rpc/grpc.go @@ -36,7 +36,7 @@ func Server(s *etcdserver.EtcdServer, tls *tls.Config) *grpc.Server { } opts = append(opts, grpc.UnaryInterceptor(newUnaryInterceptor(s))) opts = append(opts, grpc.StreamInterceptor(newStreamInterceptor(s))) - + opts = append(opts, grpc.MaxMsgSize(int(s.Cfg.MaxRequestBytes))) grpcServer := grpc.NewServer(opts...) pb.RegisterKVServer(grpcServer, NewQuotaKVServer(s)) pb.RegisterWatchServer(grpcServer, NewWatchServer(s))