diff --git a/disperser/batcher/grpc/dispatcher.go b/disperser/batcher/grpc/dispatcher.go index 96f9fe12dc..533acb53ea 100644 --- a/disperser/batcher/grpc/dispatcher.go +++ b/disperser/batcher/grpc/dispatcher.go @@ -14,6 +14,7 @@ import ( "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" + "google.golang.org/protobuf/proto" ) type Config struct { @@ -130,7 +131,7 @@ func (c *dispatcher) sendChunks(ctx context.Context, blobs []*core.BlobMessage, } opt := grpc.MaxCallSendMsgSize(60 * 1024 * 1024 * 1024) - c.logger.Debug("sending chunks to operator", "operator", op.Socket, "size", totalSize) + c.logger.Debug("sending chunks to operator", "operator", op.Socket, "size", totalSize, "request message size", proto.Size(request)) reply, err := gc.StoreChunks(ctx, request, opt) if err != nil { diff --git a/node/grpc/server.go b/node/grpc/server.go index c2862ed156..73dabc436f 100644 --- a/node/grpc/server.go +++ b/node/grpc/server.go @@ -200,6 +200,8 @@ func (s *Server) validateStoreChunkRequest(in *pb.StoreChunksRequest) error { func (s *Server) StoreChunks(ctx context.Context, in *pb.StoreChunksRequest) (*pb.StoreChunksReply, error) { start := time.Now() + s.node.Logger.Info("StoreChunks RPC request recieved", "request message size", proto.Size(in)) + // Validate the request. if err := s.validateStoreChunkRequest(in); err != nil { return nil, err