From cc55696afec400dbdc6de63ec310b345be58d0aa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Ber=C4=8Di=C4=8D?= Date: Wed, 28 Apr 2021 21:10:40 +0200 Subject: [PATCH] worker/storage: Fix heartbeat stall --- go/worker/storage/committee/node.go | 2 -- go/worker/storage/committee/utils.go | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/go/worker/storage/committee/node.go b/go/worker/storage/committee/node.go index 6b7eda4b9ac..16ccd2eda28 100644 --- a/go/worker/storage/committee/node.go +++ b/go/worker/storage/committee/node.go @@ -419,12 +419,10 @@ func (n *Node) WaitForRound(round uint64, root *storageApi.Root) (<-chan uint64, } func (n *Node) PauseCheckpointer(pause bool) error { - n.logger.Info("TRYING to pause checkpointer") if !commonFlags.DebugDontBlameOasis() { return api.ErrCantPauseCheckpointer } n.checkpointer.Pause(pause) - n.logger.Info("PAUSED checkpointer") return nil } diff --git a/go/worker/storage/committee/utils.go b/go/worker/storage/committee/utils.go index 7eb45870752..6fd61770b31 100644 --- a/go/worker/storage/committee/utils.go +++ b/go/worker/storage/committee/utils.go @@ -97,5 +97,6 @@ func (h *heartbeat) reset() { boff := backoff.NewExponentialBackOff() boff.InitialInterval = 5 * time.Second + boff.MaxElapsedTime = 0 h.Ticker = backoff.NewTicker(boff) }