always attempt getConn to init the pool first so the following _withConn will have the valid conn to resolve hystrix

Author: runze.cui

redis.go

@@ -265,6 +265,16 @@ func (c *baseClient) withConn(
 		return err
 	}
 
+	// always attempt getConn to init the pool first so the following _withConn will have the valid conn for resolving hystrix
+	cn, connerr := c.getConn(ctx)
+	if connerr != nil {
+		return connerr
+	}
+
+	defer func() {
+		c.releaseConn(ctx, cn, connerr)
+	}()
+
 	err := limiter.Execute(func() error {
 		return c._withConn(ctx, fn)
 	})
@@ -668,26 +678,26 @@ func (c *Client) pubSub() *PubSub {
 // subscription may not be active immediately. To force the connection to wait,
 // you may call the Receive() method on the returned *PubSub like so:
 //
-//    sub := client.Subscribe(queryResp)
-//    iface, err := sub.Receive()
-//    if err != nil {
-//        // handle error
-//    }
+//	sub := client.Subscribe(queryResp)
+//	iface, err := sub.Receive()
+//	if err != nil {
+//	    // handle error
+//	}
 //
-//    // Should be *Subscription, but others are possible if other actions have been
-//    // taken on sub since it was created.
-//    switch iface.(type) {
-//    case *Subscription:
-//        // subscribe succeeded
-//    case *Message:
-//        // received first message
-//    case *Pong:
-//        // pong received
-//    default:
-//        // handle error
-//    }
+//	// Should be *Subscription, but others are possible if other actions have been
+//	// taken on sub since it was created.
+//	switch iface.(type) {
+//	case *Subscription:
+//	    // subscribe succeeded
+//	case *Message:
+//	    // received first message
+//	case *Pong:
+//	    // pong received
+//	default:
+//	    // handle error
+//	}
 //
-//    ch := sub.Channel()
+//	ch := sub.Channel()
 func (c *Client) Subscribe(ctx context.Context, channels ...string) *PubSub {
 	pubsub := c.pubSub()
 	if len(channels) > 0 {