From 5cfbf596085707a08aa33bf6d023eb5281527715 Mon Sep 17 00:00:00 2001 From: Jian Xiao Date: Tue, 2 Jul 2024 19:39:13 +0000 Subject: [PATCH] Log request serialization time --- disperser/batcher/grpc/dispatcher.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/disperser/batcher/grpc/dispatcher.go b/disperser/batcher/grpc/dispatcher.go index 533acb53e..ce224382e 100644 --- a/disperser/batcher/grpc/dispatcher.go +++ b/disperser/batcher/grpc/dispatcher.go @@ -125,13 +125,13 @@ func (c *dispatcher) sendChunks(ctx context.Context, blobs []*core.BlobMessage, gc := node.NewDispersalClient(conn) ctx, cancel := context.WithTimeout(ctx, c.Timeout) defer cancel() + start := time.Now() request, totalSize, err := GetStoreChunksRequest(blobs, batchHeader) if err != nil { return nil, err } - + c.logger.Debug("sending chunks to operator", "operator", op.Socket, "size", totalSize, "request message size", proto.Size(request), "num blobs", len(blobs), "request serialization time", time.Since(start)) opt := grpc.MaxCallSendMsgSize(60 * 1024 * 1024 * 1024) - 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 {