From f0e99b42dc76a6bd757c4bac9540c1c80c4ff9eb Mon Sep 17 00:00:00 2001
From: Cassandra Heart <cassandra@quilibrium.com>
Date: Thu, 26 Oct 2023 19:19:19 -0500
Subject: [PATCH] [PROTO-55] adjust buffer sizes to stem bleed from overweight
 execution transforms in frames

---
 .../ceremony/ceremony_data_clock_consensus_engine.go      | 4 ++--
 node/consensus/ceremony/consensus_frames.go               | 6 +++---
 node/consensus/ceremony/peer_messaging.go                 | 8 ++++----
 node/rpc/rpc_server.go                                    | 8 ++++----
 4 files changed, 13 insertions(+), 13 deletions(-)

diff --git a/node/consensus/ceremony/ceremony_data_clock_consensus_engine.go b/node/consensus/ceremony/ceremony_data_clock_consensus_engine.go
index 1f1e7ad..40cbcc5 100644
--- a/node/consensus/ceremony/ceremony_data_clock_consensus_engine.go
+++ b/node/consensus/ceremony/ceremony_data_clock_consensus_engine.go
@@ -221,8 +221,8 @@ func (e *CeremonyDataClockConsensusEngine) Start(
 
 	go func() {
 		server := grpc.NewServer(
-			grpc.MaxSendMsgSize(400*1024*1024),
-			grpc.MaxRecvMsgSize(400*1024*1024),
+			grpc.MaxSendMsgSize(600*1024*1024),
+			grpc.MaxRecvMsgSize(600*1024*1024),
 		)
 		protobufs.RegisterCeremonyServiceServer(server, e)
 
diff --git a/node/consensus/ceremony/consensus_frames.go b/node/consensus/ceremony/consensus_frames.go
index 14e6bbc..9816b22 100644
--- a/node/consensus/ceremony/consensus_frames.go
+++ b/node/consensus/ceremony/consensus_frames.go
@@ -916,7 +916,7 @@ func (e *CeremonyDataClockConsensusEngine) reverseOptimisticSync(
 				Filter:          e.filter,
 				FromFrameNumber: maxFrame - 32,
 			},
-			grpc.MaxCallRecvMsgSize(400*1024*1024),
+			grpc.MaxCallRecvMsgSize(600*1024*1024),
 		)
 		if err != nil {
 			e.logger.Error(
@@ -984,7 +984,7 @@ func (e *CeremonyDataClockConsensusEngine) reverseOptimisticSync(
 				FromFrameNumber: from,
 				ToFrameNumber:   maxFrame,
 			},
-			grpc.MaxCallRecvMsgSize(400*1024*1024),
+			grpc.MaxCallRecvMsgSize(600*1024*1024),
 		)
 		if err != nil {
 			e.logger.Error(
@@ -1077,7 +1077,7 @@ func (e *CeremonyDataClockConsensusEngine) sync(
 				Filter:          e.filter,
 				FromFrameNumber: maxFrame - 16,
 			},
-			grpc.MaxCallRecvMsgSize(400*1024*1024),
+			grpc.MaxCallRecvMsgSize(600*1024*1024),
 		)
 		if err != nil {
 			e.logger.Error(
diff --git a/node/consensus/ceremony/peer_messaging.go b/node/consensus/ceremony/peer_messaging.go
index 1cbbce1..9273fa6 100644
--- a/node/consensus/ceremony/peer_messaging.go
+++ b/node/consensus/ceremony/peer_messaging.go
@@ -397,8 +397,8 @@ func (e *CeremonyDataClockConsensusEngine) GetPublicChannelForProvingKey(
 		after := time.After(20 * time.Second)
 		go func() {
 			server := grpc.NewServer(
-				grpc.MaxSendMsgSize(400*1024*1024),
-				grpc.MaxRecvMsgSize(400*1024*1024),
+				grpc.MaxSendMsgSize(600*1024*1024),
+				grpc.MaxRecvMsgSize(600*1024*1024),
 			)
 
 			s := &svr{
@@ -438,8 +438,8 @@ func (e *CeremonyDataClockConsensusEngine) GetPublicChannelForProvingKey(
 		client := protobufs.NewCeremonyServiceClient(cc)
 		s, err := client.GetPublicChannel(
 			context.Background(),
-			grpc.MaxCallSendMsgSize(400*1024*1024),
-			grpc.MaxCallRecvMsgSize(400*1024*1024),
+			grpc.MaxCallSendMsgSize(600*1024*1024),
+			grpc.MaxCallRecvMsgSize(600*1024*1024),
 		)
 		return s, errors.Wrap(err, "get public channel for proving key")
 	}
diff --git a/node/rpc/rpc_server.go b/node/rpc/rpc_server.go
index e6eef90..41e1e2c 100644
--- a/node/rpc/rpc_server.go
+++ b/node/rpc/rpc_server.go
@@ -229,8 +229,8 @@ func NewRPCServer(
 
 func (r *RPCServer) Start() error {
 	s := grpc.NewServer(
-		grpc.MaxRecvMsgSize(400*1024*1024),
-		grpc.MaxSendMsgSize(400*1024*1024),
+		grpc.MaxRecvMsgSize(600*1024*1024),
+		grpc.MaxSendMsgSize(600*1024*1024),
 	)
 	protobufs.RegisterNodeServiceServer(s, r)
 	reflection.Register(s)
@@ -272,8 +272,8 @@ func (r *RPCServer) Start() error {
 			opts := []grpc.DialOption{
 				grpc.WithTransportCredentials(insecure.NewCredentials()),
 				grpc.WithDefaultCallOptions(
-					grpc.MaxCallRecvMsgSize(400*1024*1024),
-					grpc.MaxCallSendMsgSize(400*1024*1024),
+					grpc.MaxCallRecvMsgSize(600*1024*1024),
+					grpc.MaxCallSendMsgSize(600*1024*1024),
 				),
 			}