This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new edf81af Fix closed connection leak (#716)
edf81af is described below
commit edf81af225d1573848584a7e48f090a558a9c620
Author: billowqiu <[email protected]>
AuthorDate: Sat Jan 22 11:15:48 2022 +0800
Fix closed connection leak (#716)
Fix closed connection leak
---
pulsar/internal/connection_pool.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/pulsar/internal/connection_pool.go
b/pulsar/internal/connection_pool.go
index cadeed1..4787ba1 100644
--- a/pulsar/internal/connection_pool.go
+++ b/pulsar/internal/connection_pool.go
@@ -81,6 +81,7 @@ func (p *connectionPool) GetConnection(logicalAddr *url.URL,
physicalAddr *url.U
// remove stale/failed connection
if conn.closed() {
delete(p.connections, key)
+ conn.Close()
p.log.Infof("Removed connection from pool key=%s
logical_addr=%+v physical_addr=%+v",
key, conn.logicalAddr, conn.physicalAddr)
conn = nil // set to nil so we create a new one
