From c4e46c50a11802b38a232a805db5964328aa0257 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sat, 4 Dec 2021 19:02:12 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0GRPC=E6=9C=80=E5=A4=A7?= =?UTF-8?q?=E8=83=BD=E6=8E=A5=E6=94=B6=E7=9A=84=E6=B6=88=E6=81=AF=E5=B0=BA?= =?UTF-8?q?=E5=AF=B8=E4=B8=BA128M?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/api_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/nodes/api_node.go b/internal/nodes/api_node.go index 54d78fc1..dc78e935 100644 --- a/internal/nodes/api_node.go +++ b/internal/nodes/api_node.go @@ -207,10 +207,10 @@ func (this *APINode) listenRPC(listener net.Listener, tlsConfig *tls.Config) err var rpcServer *grpc.Server if tlsConfig == nil { remotelogs.Println("API_NODE", "listening GRPC http://"+listener.Addr().String()+" ...") - rpcServer = grpc.NewServer() + rpcServer = grpc.NewServer(grpc.MaxRecvMsgSize(128 * 1024 * 1024)) } else { logs.Println("[API_NODE]listening GRPC https://" + listener.Addr().String() + " ...") - rpcServer = grpc.NewServer(grpc.Creds(credentials.NewTLS(tlsConfig))) + rpcServer = grpc.NewServer(grpc.Creds(credentials.NewTLS(tlsConfig)), grpc.MaxRecvMsgSize(128*1024*1024)) } this.registerServices(rpcServer) err := rpcServer.Serve(listener)