diff --git a/common/version/version.go b/common/version/version.go index df8616eb6..a811fa3f3 100644 --- a/common/version/version.go +++ b/common/version/version.go @@ -5,7 +5,7 @@ import ( "runtime/debug" ) -var tag = "v3.0.9" +var tag = "v3.0.10" var commit = func() string { if info, ok := debug.ReadBuildInfo(); ok { diff --git a/coordinator/manager.go b/coordinator/manager.go index 87b54d345..e0e68e2b4 100644 --- a/coordinator/manager.go +++ b/coordinator/manager.go @@ -299,6 +299,7 @@ func (m *Manager) handleZkProof(pk string, msg *message.ProofDetail) error { if msg.Status != message.StatusOk { coordinatorProofsGeneratedFailedTimeTimer.Update(proofTime) + m.updateMetricRollerProofsGeneratedFailedTimeTimer(roller.PublicKey, proofTime) log.Info( "proof generated by roller failed", "proof id", msg.ID, diff --git a/coordinator/roller_metrics.go b/coordinator/roller_metrics.go index cfdacf28f..62c8ea3c8 100644 --- a/coordinator/roller_metrics.go +++ b/coordinator/roller_metrics.go @@ -58,3 +58,14 @@ func (m *Manager) updateMetricRollerProofsVerifiedFailedTimeTimer(pk string, d t } } } + +func (m *Manager) updateMetricRollerProofsGeneratedFailedTimeTimer(pk string, d time.Duration) { + if node, ok := m.rollerPool.Get(pk); ok { + rMs := node.(*rollerNode).rollerMetrics + if rMs != nil { + rMs.rollerProofsGeneratedFailedTimeTimer.Update(d) + } else { + log.Error("rollerProofsGeneratedFailedTimeTimer is nil", "roller pk", pk) + } + } +}