summaryrefslogtreecommitdiffstats
path: root/vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go
diff options
context:
space:
mode:
authorChristopher Speller <crspeller@gmail.com>2018-06-21 13:10:40 -0700
committerHarrison Healey <harrisonmhealey@gmail.com>2018-06-21 16:10:40 -0400
commit8526739066ccb00ccd24b74650a7d7b284442985 (patch)
tree282512ae2ad95c98a9ca82de304a410b6b56685c /vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go
parenta59ccaa8b3844895dde3980e6224fef46ff4a1c8 (diff)
downloadchat-8526739066ccb00ccd24b74650a7d7b284442985.tar.gz
chat-8526739066ccb00ccd24b74650a7d7b284442985.tar.bz2
chat-8526739066ccb00ccd24b74650a7d7b284442985.zip
MM-10934 Update server dependencies. (#8981)
* Changing throttled import path. * Upgrading dependencies.
Diffstat (limited to 'vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go')
-rw-r--r--vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go54
1 files changed, 20 insertions, 34 deletions
diff --git a/vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go b/vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go
index 17f163858..91bd91333 100644
--- a/vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go
+++ b/vendor/github.com/go-redis/redis/internal/pool/pool_sticky.go
@@ -28,55 +28,40 @@ func (p *StickyConnPool) CloseConn(*Conn) error {
panic("not implemented")
}
-func (p *StickyConnPool) Get() (*Conn, bool, error) {
+func (p *StickyConnPool) Get() (*Conn, error) {
p.mu.Lock()
defer p.mu.Unlock()
if p.closed {
- return nil, false, ErrClosed
+ return nil, ErrClosed
}
if p.cn != nil {
- return p.cn, false, nil
+ return p.cn, nil
}
- cn, _, err := p.pool.Get()
+ cn, err := p.pool.Get()
if err != nil {
- return nil, false, err
+ return nil, err
}
+
p.cn = cn
- return cn, true, nil
+ return cn, nil
}
-func (p *StickyConnPool) putUpstream() (err error) {
- err = p.pool.Put(p.cn)
+func (p *StickyConnPool) putUpstream() {
+ p.pool.Put(p.cn)
p.cn = nil
- return err
}
-func (p *StickyConnPool) Put(cn *Conn) error {
- p.mu.Lock()
- defer p.mu.Unlock()
-
- if p.closed {
- return ErrClosed
- }
- return nil
-}
+func (p *StickyConnPool) Put(cn *Conn) {}
-func (p *StickyConnPool) removeUpstream() error {
- err := p.pool.Remove(p.cn)
+func (p *StickyConnPool) removeUpstream() {
+ p.pool.Remove(p.cn)
p.cn = nil
- return err
}
-func (p *StickyConnPool) Remove(cn *Conn) error {
- p.mu.Lock()
- defer p.mu.Unlock()
-
- if p.closed {
- return nil
- }
- return p.removeUpstream()
+func (p *StickyConnPool) Remove(cn *Conn) {
+ p.removeUpstream()
}
func (p *StickyConnPool) Len() int {
@@ -89,7 +74,7 @@ func (p *StickyConnPool) Len() int {
return 1
}
-func (p *StickyConnPool) FreeLen() int {
+func (p *StickyConnPool) IdleLen() int {
p.mu.Lock()
defer p.mu.Unlock()
@@ -111,13 +96,14 @@ func (p *StickyConnPool) Close() error {
return ErrClosed
}
p.closed = true
- var err error
+
if p.cn != nil {
if p.reusable {
- err = p.putUpstream()
+ p.putUpstream()
} else {
- err = p.removeUpstream()
+ p.removeUpstream()
}
}
- return err
+
+ return nil
}