From 35d5dcab5eaa08982c7e02e13e619567de7b4cf0 Mon Sep 17 00:00:00 2001 From: Soy Date: Wed, 2 Nov 2022 19:04:01 +0800 Subject: [PATCH] fix: Close connection when remove it Close deprecated connections from idle queue to avoid leaks. --- connection_pool.go | 1 + 1 file changed, 1 insertion(+) diff --git a/connection_pool.go b/connection_pool.go index 3b96779e..54cc3fcc 100644 --- a/connection_pool.go +++ b/connection_pool.go @@ -161,6 +161,7 @@ func (pool *ConnectionPool) getIdleConn() (*connection, error) { } else { tmpNextEle = ele.Next() pool.idleConnectionQueue.Remove(ele) + ele.Value.(*connection).close() } } if newConn == nil {