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), ), }