From 74f9f4f7a0b559fa6b3da4912f32a36a8358c3d0 Mon Sep 17 00:00:00 2001 From: Vladimir Mihailenco Date: Tue, 16 Jun 2015 10:46:46 +0300 Subject: [PATCH] ring: ignore pool timeout when pinging shards. --- ring.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ring.go b/ring.go index 2124357..4b620da 100644 --- a/ring.go +++ b/ring.go @@ -203,7 +203,7 @@ func (ring *Ring) heartbeat() { for _, shard := range ring.shards { err := shard.Client.Ping().Err() - if shard.Vote(err == nil) { + if shard.Vote(err == nil || err == errPoolTimeout) { log.Printf("redis: ring shard state changed: %s", shard) rebalance = true }