From 45cdef5554b4304b1587009f6f037f04fa4597d0 Mon Sep 17 00:00:00 2001 From: Sergi Rene Date: Fri, 8 Nov 2024 11:34:51 +0100 Subject: [PATCH] rename func --- block/fraud.go | 2 +- block/manager.go | 2 +- block/p2p.go | 2 +- block/sync.go | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/block/fraud.go b/block/fraud.go index f7d1ebc58..9933c808f 100644 --- a/block/fraud.go +++ b/block/fraud.go @@ -19,7 +19,7 @@ type FreezeHandler struct { } func (f FreezeHandler) HandleFault(ctx context.Context, fault error) { - f.m.setNodeAsUnhealthy(ctx, fault) + f.m.freezeNode(ctx, fault) } func NewFreezeHandler(manager *Manager) *FreezeHandler { diff --git a/block/manager.go b/block/manager.go index ae4a37c48..c45397a28 100644 --- a/block/manager.go +++ b/block/manager.go @@ -374,7 +374,7 @@ func (m *Manager) setFraudHandler(handler *FreezeHandler) { m.FraudHandler = handler } -func (m *Manager) setNodeAsUnhealthy(ctx context.Context, err error) { +func (m *Manager) freezeNode(ctx context.Context, err error) { uevent.MustPublish(ctx, m.Pubsub, &events.DataHealthStatus{Error: err}, events.HealthStatusList) m.unsubscribeFullNodeEvents(ctx) } diff --git a/block/p2p.go b/block/p2p.go index 0741b830c..2a795456c 100644 --- a/block/p2p.go +++ b/block/p2p.go @@ -58,7 +58,7 @@ func (m *Manager) OnReceivedBlock(event pubsub.Message) { err := m.attemptApplyCachedBlocks() if err != nil { - m.setNodeAsUnhealthy(context.Background(), err) + m.freezeNode(context.Background(), err) m.logger.Error("Attempt apply cached blocks.", "err", err) } } diff --git a/block/sync.go b/block/sync.go index d0fed46a0..dbeab068f 100644 --- a/block/sync.go +++ b/block/sync.go @@ -75,7 +75,7 @@ func (m *Manager) SettlementSyncLoop(ctx context.Context) error { err = m.ApplyBatchFromSL(settlementBatch.Batch) if err != nil { - m.setNodeAsUnhealthy(context.Background(), err) + m.freezeNode(context.Background(), err) m.logger.Error("process next DA batch", "err", err) break } @@ -87,7 +87,7 @@ func (m *Manager) SettlementSyncLoop(ctx context.Context) error { err = m.attemptApplyCachedBlocks() if err != nil { - m.setNodeAsUnhealthy(context.Background(), err) + m.freezeNode(context.Background(), err) m.logger.Error("Attempt apply cached blocks.", "err", err) }