mirror of
https://github.com/OffchainLabs/prysm.git
synced 2026-01-10 07:58:22 -05:00
feat: add blob arrival gossip metric (#12888)
Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com>
This commit is contained in:
@@ -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(
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user