Commit 00f7e106 authored by Ajit Jagtap's avatar Ajit Jagtap
Browse files

Merge branch 'cherry-pick-0fbdf0f2' into 'devbranch'

gRPC: Send & Receive Message Size Changed

See merge request !228
parents 670c7ccc 5c9522ff
Branches feature-upsertID
Tags
2 merge requests!231Release v1.2.1,!228gRPC: Send & Receive Message Size Changed
Showing with 8 additions and 2 deletions
...@@ -65,7 +65,12 @@ func ByteHandler(req *grpcbuildermdl.GRPCRequest, grpcServerURL string) ([]byte, ...@@ -65,7 +65,12 @@ func ByteHandler(req *grpcbuildermdl.GRPCRequest, grpcServerURL string) ([]byte,
func CreateConnection(serverURL string, grpcClientName string) { func CreateConnection(serverURL string, grpcClientName string) {
var factory grpcpool.Factory var factory grpcpool.Factory
factory = func() (*grpc.ClientConn, error) { 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 { if err != nil {
loggermdl.LogError("Failed to start gRPC connection: %v", err) loggermdl.LogError("Failed to start gRPC connection: %v", err)
} }
......
...@@ -21,7 +21,8 @@ type Server struct{} ...@@ -21,7 +21,8 @@ type Server struct{}
// GRPCInit init // GRPCInit init
func GRPCInit(GRPCPort net.Listener) { func GRPCInit(GRPCPort net.Listener) {
loggermdl.LogInfo("In GRPCInit") 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.RegisterGRPCCheckServer(s, &Server{})
grpcbuildermdl.RegisterGRPCServiceServer(s, &Server{}) grpcbuildermdl.RegisterGRPCServiceServer(s, &Server{})
if err := s.Serve(GRPCPort); err != nil { if err := s.Serve(GRPCPort); err != nil {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment