diff --git a/consul/pool.go b/consul/pool.go index 91f53a677..804a900f5 100644 --- a/consul/pool.go +++ b/consul/pool.go @@ -288,7 +288,7 @@ func (p *ConnPool) clearConn(conn *Conn) { p.Unlock() // Close down immediately if idle - if refCount := atomic.LoadInt32(&conn.shouldClose); refCount == 0 { + if refCount := atomic.LoadInt32(&conn.refCount); refCount == 0 { conn.Close() } }