[FAB-8858] Set max message size to be same as fabric

Change-Id: Ic3be6df8d338ddf3ec581e75373d5772eec7dad1
Signed-off-by: Troy Ronda <troy@troyronda.com>

Author: troyronda

pkg/fab/comm/connection.go

@@ -25,6 +25,12 @@ import (
 
 var logger = logging.NewLogger("fabsdk/fab")
 
+const (
+	// GRPC max message size (same as Fabric)
+	maxCallRecvMsgSize = 100 * 1024 * 1024
+	maxCallSendMsgSize = 100 * 1024 * 1024
+)
+
 // StreamProvider creates a GRPC stream
 type StreamProvider func(conn *grpc.ClientConn) (grpc.ClientStream, error)
 
@@ -154,5 +160,8 @@ func newDialOpts(config core.Config, url string, params *params) ([]grpc.DialOpt
 		dialOpts = append(dialOpts, grpc.WithInsecure())
 	}
 
+	dialOpts = append(dialOpts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxCallRecvMsgSize),
+		grpc.MaxCallSendMsgSize(maxCallSendMsgSize)))
+
 	return dialOpts, nil
 }

pkg/fab/orderer/orderer.go

@@ -31,6 +31,12 @@ import (
 
 var logger = logging.NewLogger("fabsdk/fab")
 
+const (
+	// GRPC max message size (same as Fabric)
+	maxCallRecvMsgSize = 100 * 1024 * 1024
+	maxCallSendMsgSize = 100 * 1024 * 1024
+)
+
 // Orderer allows a client to broadcast a transaction.
 type Orderer struct {
 	config         core.Config
@@ -78,6 +84,9 @@ func New(config core.Config, opts ...Option) (*Orderer, error) {
 		grpcOpts = append(grpcOpts, grpc.WithInsecure())
 	}
 
+	grpcOpts = append(grpcOpts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxCallRecvMsgSize),
+		grpc.MaxCallSendMsgSize(maxCallSendMsgSize)))
+
 	orderer.dialTimeout = config.TimeoutOrDefault(core.OrdererConnection)
 	orderer.url = endpoint.ToAddress(orderer.url)
 	orderer.grpcDialOption = grpcOpts

pkg/fab/peer/peerendorser.go

@@ -26,6 +26,12 @@ import (
 	pb "github.com/hyperledger/fabric-sdk-go/third_party/github.com/hyperledger/fabric/protos/peer"
 )
 
+const (
+	// GRPC max message size (same as Fabric)
+	maxCallRecvMsgSize = 100 * 1024 * 1024
+	maxCallSendMsgSize = 100 * 1024 * 1024
+)
+
 // peerEndorser enables access to a GRPC-based endorser for running transaction proposal simulations
 type peerEndorser struct {
 	grpcDialOption []grpc.DialOption
@@ -67,6 +73,9 @@ func newPeerEndorser(endorseReq *peerEndorserRequest) (*peerEndorser, error) {
 		grpcOpts = append(grpcOpts, grpc.WithInsecure())
 	}
 
+	grpcOpts = append(grpcOpts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(maxCallRecvMsgSize),
+		grpc.MaxCallSendMsgSize(maxCallSendMsgSize)))
+
 	timeout := endorseReq.config.TimeoutOrDefault(core.EndorserConnection)
 
 	pc := &peerEndorser{