set MaxRecvMsgSize of grpc as 64M

jackllh · May 21, 2018 · c8c992e · c8c992e
1 parent 3116fbf
commit c8c992e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/rpc/server.go b/rpc/server.go
@@ -25,6 +25,7 @@ var (
 // Const
 const (
 	DefaultConnectionLimits = 128
+	MaxRecvMsgSize          = 64 * 1024 * 1024
 )
 
 // Neblet interface breaks cycle import dependency and hides unused services.
@@ -68,7 +69,8 @@ func NewServer(neblet core.Neblet) *Server {
 		logging.CLog().Fatal("Failed to find rpc config in config file.")
 	}
 	rpc := grpc.NewServer(grpc.StreamInterceptor(grpc_middleware.ChainStreamServer(loggingStream)),
-		grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(loggingUnary)))
+		grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(loggingUnary)),
+		grpc.MaxRecvMsgSize(MaxRecvMsgSize))
 
 	srv := &Server{neblet: neblet, rpcServer: rpc, rpcConfig: cfg}
 	api := &APIService{server: srv}