diff --git a/beacon-chain/sync/metrics.go b/beacon-chain/sync/metrics.go index 17ecd90454..04d2c6f785 100644 --- a/beacon-chain/sync/metrics.go +++ b/beacon-chain/sync/metrics.go @@ -138,6 +138,12 @@ var ( Help: "Time for gossiped blocks to arrive", }, ) + blobSidecarArrivalGossipSummary = promauto.NewSummary( + prometheus.SummaryOpts{ + Name: "gossip_blob_sidecar_arrival_milliseconds", + Help: "Time for gossiped blob sidecars to arrive", + }, + ) // Sync committee verification performance. syncMessagesForUnknownBlocks = promauto.NewCounter( diff --git a/beacon-chain/sync/validate_blob.go b/beacon-chain/sync/validate_blob.go index 1afc285410..c329298ab6 100644 --- a/beacon-chain/sync/validate_blob.go +++ b/beacon-chain/sync/validate_blob.go @@ -133,9 +133,13 @@ func (s *Service) validateBlob(ctx context.Context, pid peer.ID, msg *pubsub.Mes return pubsub.ValidationIgnore, err } fields := blobFields(blob) - fields["sinceSlotStartTime"] = receivedTime.Sub(startTime) + sinceSlotStartTime := receivedTime.Sub(startTime) + fields["sinceSlotStartTime"] = sinceSlotStartTime fields["validationTime"] = prysmTime.Now().Sub(receivedTime) log.WithFields(fields).Debug("Received blob sidecar gossip") + + blobSidecarArrivalGossipSummary.Observe(float64(sinceSlotStartTime.Milliseconds())) + msg.ValidatorData = sBlob return pubsub.ValidationAccept, nil