confirm change
This commit is contained in:
@@ -320,12 +320,12 @@ func (p *SyncedPool) RequestOwnership(id CartId) error {
|
|||||||
err := r.ConfirmChange(id, p.Hostname)
|
err := r.ConfirmChange(id, p.Hostname)
|
||||||
all++
|
all++
|
||||||
if err != nil {
|
if err != nil {
|
||||||
r.MissedPings++
|
if !r.IsHealthy() {
|
||||||
if r.MissedPings > 3 {
|
|
||||||
p.RemoveHost(r)
|
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
|
continue
|
||||||
}
|
}
|
||||||
ok++
|
ok++
|
||||||
|
|||||||
Reference in New Issue
Block a user