diff --git a/grpcclientmdl/grpcclientmdl.go b/grpcclientmdl/grpcclientmdl.go index 75b3565c09f091176da8569ca3b8e860bcf3c42b..ae96cfff3d5312562c119091a7068b3955cc6116 100644 --- a/grpcclientmdl/grpcclientmdl.go +++ b/grpcclientmdl/grpcclientmdl.go @@ -65,7 +65,12 @@ func ByteHandler(req *grpcbuildermdl.GRPCRequest, grpcServerURL string) ([]byte, func CreateConnection(serverURL string, grpcClientName string) { var factory grpcpool.Factory factory = func() (*grpc.ClientConn, error) { - conn, err := grpc.Dial(serverURL, grpc.WithInsecure()) + maxMsgSize := 50 * 1024 * 1024 + conn, err := grpc.Dial( + serverURL, + grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxMsgSize), grpc.MaxCallSendMsgSize(maxMsgSize)), + grpc.WithInsecure(), + ) if err != nil { loggermdl.LogError("Failed to start gRPC connection: %v", err) } diff --git a/routebuildermdl/grpcservermdl.go b/routebuildermdl/grpcservermdl.go index 247b579b4db4a2936224dac66483d6bd518ddc8e..7e16a4d6288a042dc1e90177e1f1eb88f908d4d3 100644 --- a/routebuildermdl/grpcservermdl.go +++ b/routebuildermdl/grpcservermdl.go @@ -21,7 +21,8 @@ type Server struct{} // GRPCInit init func GRPCInit(GRPCPort net.Listener) { loggermdl.LogInfo("In GRPCInit") - s := grpc.NewServer() + maxMsgSize := 50 * 1024 * 1024 + s := grpc.NewServer(grpc.MaxRecvMsgSize(maxMsgSize), grpc.MaxSendMsgSize(maxMsgSize)) grpcbuildermdl.RegisterGRPCCheckServer(s, &Server{}) grpcbuildermdl.RegisterGRPCServiceServer(s, &Server{}) if err := s.Serve(GRPCPort); err != nil {