diff --git a/pool/connection_manager.go b/pool/connection_manager.go index 5b9a08de..b142529a 100644 --- a/pool/connection_manager.go +++ b/pool/connection_manager.go @@ -297,7 +297,6 @@ func (cm connectionManager) Statistic() Statistic { stat := Statistic{} for _, inner := range cm.innerPools { nodes := make([]string, 0, len(inner.clients)) - inner.lock.RLock() for _, cl := range inner.clients { if cl.isHealthy() { nodes = append(nodes, cl.address()) @@ -311,7 +310,6 @@ func (cm connectionManager) Statistic() Statistic { stat.nodes = append(stat.nodes, node) stat.overallErrors += node.overallErrors } - inner.lock.RUnlock() if len(stat.currentNodes) == 0 { stat.currentNodes = nodes }