(inlong) branch master updated: [INLONG-11660][SDK] Close exist conns if initConns() failed in Golang SDK (#11664)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 305f359636 [INLONG-11660][SDK] Close exist conns if initConns() failed 
in Golang SDK (#11664)
305f359636 is described below

commit 305f359636f367ffd83275d7d2b1fbf680292bcd
Author: gunli <24350...@qq.com>
AuthorDate: Wed Jan 15 11:44:23 2025 +0800

    [INLONG-11660][SDK] Close exist conns if initConns() failed in Golang SDK 
(#11664)
---
 .../dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go 
b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go
index 1054041cb4..636f9049e5 100755
--- a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go
+++ b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go
@@ -275,6 +275,9 @@ func (p *connPool) initConns(count int) error {
 
        for err := range errs {
                if err != nil {
+                       for conn := range conns {
+                               _ = conn.Close()
+                       }
                        return err
                }
        }