remote host if not connectable

2024-11-10 17:15:10 +01:00
parent 7e0a59bfe4
commit 0db23baf5c
1 changed files with 8 additions and 0 deletions
--- 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)
 }