From 880e05d9751c3eb080b4f195a6cbf774af747641 Mon Sep 17 00:00:00 2001
From: Vladimir Mihailenco <vladimir.webdev@gmail.com>
Date: Fri, 14 Jun 2019 16:00:03 +0300
Subject: [PATCH] Cleanup

---
 cluster.go                   |  2 +-
 internal/pool/conn.go        | 15 ++++-----------
 internal/pool/pool.go        |  8 ++++----
 internal/pool/pool_single.go |  2 +-
 internal/pool/pool_sticky.go |  2 +-
 redis.go                     |  6 +++---
 sentinel.go                  |  2 +-
 7 files changed, 15 insertions(+), 22 deletions(-)

diff --git a/cluster.go b/cluster.go
index bc453e3..c33b5bc 100644
--- a/cluster.go
+++ b/cluster.go
@@ -1445,7 +1445,7 @@ func (c *ClusterClient) pubSub() *PubSub {
 				return nil, err
 			}
 
-			cn, err := node.Client.newConn()
+			cn, err := node.Client.newConn(context.TODO())
 			if err != nil {
 				node = nil
 
diff --git a/internal/pool/conn.go b/internal/pool/conn.go
index acaa1b7..0b64ccf 100644
--- a/internal/pool/conn.go
+++ b/internal/pool/conn.go
@@ -95,7 +95,10 @@ func (cn *Conn) deadline(ctx context.Context, timeout time.Duration) time.Time {
 			if timeout == 0 {
 				return deadline
 			}
-			return minNonzeroTime(deadline, tm)
+			if deadline.Before(tm) {
+				return deadline
+			}
+			return tm
 		}
 	}
 
@@ -105,13 +108,3 @@ func (cn *Conn) deadline(ctx context.Context, timeout time.Duration) time.Time {
 
 	return noDeadline
 }
-
-func minNonzeroTime(a, b time.Time) time.Time {
-	if a.IsZero() {
-		return b
-	}
-	if b.IsZero() || a.Before(b) {
-		return a
-	}
-	return b
-}
diff --git a/internal/pool/pool.go b/internal/pool/pool.go
index 1094a5b..09fd5ce 100644
--- a/internal/pool/pool.go
+++ b/internal/pool/pool.go
@@ -34,7 +34,7 @@ type Stats struct {
 }
 
 type Pooler interface {
-	NewConn() (*Conn, error)
+	NewConn(context.Context) (*Conn, error)
 	CloseConn(*Conn) error
 
 	Get(context.Context) (*Conn, error)
@@ -115,7 +115,7 @@ func (p *ConnPool) checkMinIdleConns() {
 }
 
 func (p *ConnPool) addIdleConn() {
-	cn, err := p.newConn(nil, true)
+	cn, err := p.newConn(context.TODO(), true)
 	if err != nil {
 		return
 	}
@@ -126,8 +126,8 @@ func (p *ConnPool) addIdleConn() {
 	p.connsMu.Unlock()
 }
 
-func (p *ConnPool) NewConn() (*Conn, error) {
-	return p._NewConn(nil, false)
+func (p *ConnPool) NewConn(ctx context.Context) (*Conn, error) {
+	return p._NewConn(ctx, false)
 }
 
 func (p *ConnPool) _NewConn(ctx context.Context, pooled bool) (*Conn, error) {
diff --git a/internal/pool/pool_single.go b/internal/pool/pool_single.go
index 778b124..fda1c8a 100644
--- a/internal/pool/pool_single.go
+++ b/internal/pool/pool_single.go
@@ -14,7 +14,7 @@ func NewSingleConnPool(cn *Conn) *SingleConnPool {
 	}
 }
 
-func (p *SingleConnPool) NewConn() (*Conn, error) {
+func (p *SingleConnPool) NewConn(context.Context) (*Conn, error) {
 	panic("not implemented")
 }
 
diff --git a/internal/pool/pool_sticky.go b/internal/pool/pool_sticky.go
index 174dc9c..d2074d2 100644
--- a/internal/pool/pool_sticky.go
+++ b/internal/pool/pool_sticky.go
@@ -23,7 +23,7 @@ func NewStickyConnPool(pool *ConnPool, reusable bool) *StickyConnPool {
 	}
 }
 
-func (p *StickyConnPool) NewConn() (*Conn, error) {
+func (p *StickyConnPool) NewConn(context.Context) (*Conn, error) {
 	panic("not implemented")
 }
 
diff --git a/redis.go b/redis.go
index d47c2b3..54b8541 100644
--- a/redis.go
+++ b/redis.go
@@ -139,8 +139,8 @@ func (c *baseClient) String() string {
 	return fmt.Sprintf("Redis<%s db:%d>", c.getAddr(), c.opt.DB)
 }
 
-func (c *baseClient) newConn() (*pool.Conn, error) {
-	cn, err := c.connPool.NewConn()
+func (c *baseClient) newConn(ctx context.Context) (*pool.Conn, error) {
+	cn, err := c.connPool.NewConn(ctx)
 	if err != nil {
 		return nil, err
 	}
@@ -581,7 +581,7 @@ func (c *Client) pubSub() *PubSub {
 		opt: c.opt,
 
 		newConn: func(channels []string) (*pool.Conn, error) {
-			return c.newConn()
+			return c.newConn(context.TODO())
 		},
 		closeConn: c.connPool.CloseConn,
 	}
diff --git a/sentinel.go b/sentinel.go
index 3f13cf6..331d004 100644
--- a/sentinel.go
+++ b/sentinel.go
@@ -150,7 +150,7 @@ func (c *SentinelClient) pubSub() *PubSub {
 		opt: c.opt,
 
 		newConn: func(channels []string) (*pool.Conn, error) {
-			return c.newConn()
+			return c.newConn(context.TODO())
 		},
 		closeConn: c.connPool.CloseConn,
 	}