From a3a84ed0aa956c5bb5a42e38d947fcdc5bb60385 Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Tue, 19 Aug 2025 09:57:53 +0000
Subject: [PATCH] fix: close invalid fd

---
 src/connection/connection.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/connection/connection.c b/src/connection/connection.c
index ce69a8f32..fbf821b0e 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -858,6 +858,7 @@ static void conn_connect(neu_conn_t *conn)
         } else {
             zlog_error(conn->param.log, "invalid ip: %s",
                        conn->param.params.tcp_server.ip);
+            close(fd);
             return;
         }
 
@@ -926,6 +927,7 @@ static void conn_connect(neu_conn_t *conn)
             ret = bind(fd, (struct sockaddr *) &local,
                        sizeof(struct sockaddr_in6));
         } else {
+            close(fd);
             zlog_error(conn->param.log, "invalid ip: %s",
                        conn->param.params.tcp_server.ip);
             return;
@@ -1028,6 +1030,7 @@ static void conn_connect(neu_conn_t *conn)
             ret = bind(fd, (struct sockaddr *) &local,
                        sizeof(struct sockaddr_in6));
         } else {
+            close(fd);
             zlog_error(conn->param.log, "invalid ip: %s",
                        conn->param.params.tcp_server.ip);
             return;