diff --git a/cluster.go b/cluster.go index e28af5b45..6ffdfbfde 100644 --- a/cluster.go +++ b/cluster.go @@ -643,6 +643,10 @@ func (cluster *mongoCluster) AcquireSocket(mode Mode, slaveOk bool, syncTimeout cluster.syncServers() time.Sleep(100 * time.Millisecond) continue + } else { + server.Lock() + server.abended = false + server.Unlock() } } return s, nil