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++