Merge pull request #452 from minjatJ/fix-cluster-latency_v4

Setting node latency can take a while

cluster.go

@@ -435,7 +435,11 @@ func (c *ClusterClient) reloadSlots() {
 
 func (c *ClusterClient) setNodesLatency() {
 	const n = 10
+	wg := &sync.WaitGroup{}
 	for _, node := range c.getNodes() {
+		wg.Add(1)
+		go func(node *clusterNode) {
+			defer wg.Done()
 			var latency time.Duration
 			for i := 0; i < n; i++ {
 				t1 := time.Now()
@@ -443,7 +447,9 @@ func (c *ClusterClient) setNodesLatency() {
 				latency += time.Since(t1)
 			}
 			node.Latency = latency / n
+		}(node)
 	}
+	wg.Wait()
 }
 
 // reaper closes idle connections to the cluster.