diff --git a/synced-pool.go b/synced-pool.go index 7e46500..29411f9 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -365,6 +365,14 @@ func (p *SyncedPool) AddRemote(address string) error { Host: address, } + go func() { + for range client.Errors { + if client.ErrorCount > 3 { + p.RemoveHost(&remote) + } + } + }() + return p.addRemoteHost(address, &remote) }