From da63cd68848da6d5b0b1a0efd1744f0eabcaa8ab Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 12 Nov 2024 20:17:31 +0100 Subject: [PATCH] confirm change --- synced-pool.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/synced-pool.go b/synced-pool.go index 34fd6db..8d23fb3 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -320,12 +320,12 @@ func (p *SyncedPool) RequestOwnership(id CartId) error { err := r.ConfirmChange(id, p.Hostname) all++ if err != nil { - r.MissedPings++ - if r.MissedPings > 3 { + if !r.IsHealthy() { p.RemoveHost(r) - continue + all-- + } else { + log.Printf("Error confirming change: %v from %s\n", err, p.Hostname) } - log.Printf("Error confirming change: %v from %s\n", err, p.Hostname) continue } ok++