close socket connection when websocket connect failed to avoid potent…

…ial leak
Kong · Dec 19, 2024 · f472617 · f472617
1 parent f7f7a23
commit f472617
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/kong/clustering/rpc/manager.lua b/kong/clustering/rpc/manager.lua
@@ -559,6 +559,7 @@ function _M:connect(premature, node_id, host, path, cert, key)
   ::err::
 
   if not exiting() then
+    c:close()
     self:try_connect(reconnection_delay)
   end
 end

diff --git a/kong/clustering/utils.lua b/kong/clustering/utils.lua
@@ -106,6 +106,7 @@ function _M.connect_cp(dp, endpoint, protocols)
 
   local ok, err = c:connect(uri, opts)
   if not ok then
+    c:close()
     return nil, uri, err
   end
-Original file line number
+Diff line change
@@ Expand Up @@
       ::err::
       if not exiting() then
+        c:close()
         self:try_connect(reconnection_delay)
       end
     end
@@ Expand Down @@