Skip to content

N
nebula
Commit 56f994c9 authored by Tei Im's avatar Tei Im
Browse files
Options

Add l2 pending safe head metric

parent 59d40347
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
op-node/rollup/derive/engine_queue.go
View file @ 56f994c9
...@@ -615,6 +615,7 @@ func (eq *EngineQueue) consolidateNextSafeAttributes(ctx context.Context) error ...@@ -615,6 +615,7 @@ func (eq *EngineQueue) consolidateNextSafeAttributes(ctx context.Context) error
return NewResetError(fmt.Errorf("failed to decode L2 block ref from payload: %w", err)) return NewResetError(fmt.Errorf("failed to decode L2 block ref from payload: %w", err))
} }
eq.pendingSafeHead = ref eq.pendingSafeHead = ref
eq.metrics.RecordL2Ref("l2_pending_safe", ref)
if eq.safeAttributes.isLastInSpan { if eq.safeAttributes.isLastInSpan {
eq.safeHead = ref eq.safeHead = ref
eq.needForkchoiceUpdate = true eq.needForkchoiceUpdate = true
...@@ -829,6 +830,7 @@ func (eq *EngineQueue) Reset(ctx context.Context, _ eth.L1BlockRef, _ eth.System ...@@ -829,6 +830,7 @@ func (eq *EngineQueue) Reset(ctx context.Context, _ eth.L1BlockRef, _ eth.System
eq.sysCfg = l1Cfg eq.sysCfg = l1Cfg
eq.metrics.RecordL2Ref("l2_finalized", finalized) eq.metrics.RecordL2Ref("l2_finalized", finalized)
eq.metrics.RecordL2Ref("l2_safe", safe) eq.metrics.RecordL2Ref("l2_safe", safe)
eq.metrics.RecordL2Ref("l2_pending_safe", eq.pendingSafeHead)
eq.metrics.RecordL2Ref("l2_unsafe", unsafe) eq.metrics.RecordL2Ref("l2_unsafe", unsafe)
eq.metrics.RecordL2Ref("l2_engineSyncTarget", unsafe) eq.metrics.RecordL2Ref("l2_engineSyncTarget", unsafe)
eq.logSyncProgress("reset derivation work") eq.logSyncProgress("reset derivation work")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment