forked from mirror/redis
cluster: user ClusterInfo instead of Ping to find live node.
This commit is contained in:
parent
368e3ce853
commit
84cd16e214
|
@ -97,7 +97,7 @@ func (c *ClusterClient) slotAddrs(slot int) []string {
|
||||||
return addrs
|
return addrs
|
||||||
}
|
}
|
||||||
|
|
||||||
// randomClient returns a Client for the first pingable node.
|
// randomClient returns a Client for the first live node.
|
||||||
func (c *ClusterClient) randomClient() (client *Client, err error) {
|
func (c *ClusterClient) randomClient() (client *Client, err error) {
|
||||||
for i := 0; i < 10; i++ {
|
for i := 0; i < 10; i++ {
|
||||||
n := rand.Intn(len(c.addrs))
|
n := rand.Intn(len(c.addrs))
|
||||||
|
@ -105,7 +105,7 @@ func (c *ClusterClient) randomClient() (client *Client, err error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
err = client.Ping().Err()
|
err = client.ClusterInfo().Err()
|
||||||
if err == nil {
|
if err == nil {
|
||||||
return client, nil
|
return client, nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue