From bd964e5f79dd0d2349b505caabfbd2a4483f48dd Mon Sep 17 00:00:00 2001
From: Rohan Verma <rohanverma2004@gmail.com>
Date: Mon, 26 Oct 2020 21:16:48 +0530
Subject: [PATCH] fix: open connection count (#527)

This commit releases back the connection in the special
case, so that correct count is always maintained.
---
 redis/pool.go      |  1 +
 redis/pool_test.go | 26 ++++++++++++++++++++++++++
 2 files changed, 27 insertions(+)

diff --git a/redis/pool.go b/redis/pool.go
index fbb8e5b7..b74e469d 100644
--- a/redis/pool.go
+++ b/redis/pool.go
@@ -377,6 +377,7 @@ func (p *Pool) waitVacantConn(ctx context.Context) (waited time.Duration, err er
 		// because `select` picks a random `case` if several of them are "ready".
 		select {
 		case <-ctx.Done():
+			p.ch <- struct{}{}
 			return 0, ctx.Err()
 		default:
 		}
diff --git a/redis/pool_test.go b/redis/pool_test.go
index a8efa515..b8cd3583 100644
--- a/redis/pool_test.go
+++ b/redis/pool_test.go
@@ -825,6 +825,32 @@ func TestWaitPoolGetContext(t *testing.T) {
 	defer c.Close()
 }
 
+func TestWaitPoolGetContextIssue520(t *testing.T) {
+	d := poolDialer{t: t}
+	p := &redis.Pool{
+		MaxIdle:   1,
+		MaxActive: 1,
+		Dial:      d.dial,
+		Wait:      true,
+	}
+	defer p.Close()
+	ctx1, cancel1 := context.WithTimeout(context.Background(), 1*time.Nanosecond)
+	defer cancel1()
+	c, err := p.GetContext(ctx1)
+	if err != context.DeadlineExceeded {
+		t.Fatalf("GetContext returned %v", err)
+	}
+	defer c.Close()
+
+	ctx2, cancel2 := context.WithCancel(context.Background())
+	defer cancel2()
+	c2, err := p.GetContext(ctx2)
+	if err != nil {
+		t.Fatalf("Get context returned %v", err)
+	}
+	defer c2.Close()
+}
+
 func TestWaitPoolGetContextWithDialContext(t *testing.T) {
 	d := poolDialer{t: t}
 	p := &redis.Pool{