From f397afa4fa9c154fded67a34c5b8bbdcd787a85c Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Thu, 7 Dec 2023 03:06:11 +0000
Subject: [PATCH] fix(conn): block link abnormal connection

---
 src/connection/connection.c | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

diff --git a/src/connection/connection.c b/src/connection/connection.c
index 368e794c..3afef18b 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -347,8 +347,8 @@ ssize_t neu_conn_send(neu_conn_t *conn, uint8_t *buf, ssize_t len)
                     break;
                 }
             } else {
-                if (rc == -1 && errno == EAGAIN) {
-                    if (retry > 50) {
+                if (!conn->block && rc == -1 && errno == EAGAIN) {
+                    if (retry > 10) {
                         zlog_error(conn->param.log,
                                    "conn fd: %d, send buf len: %zd, ret: %zd, "
                                    "errno: %s(%d)",
@@ -830,7 +830,14 @@ static void conn_connect(neu_conn_t *conn)
             return;
         }
 
-        if (ret != 0 && errno != EINPROGRESS) {
+        if ((conn->block && ret == 0) ||
+            (!conn->block && ret != 0 && errno == EINPROGRESS)) {
+            zlog_notice(conn->param.log, "connect %s:%d success",
+                        conn->param.params.tcp_client.ip,
+                        conn->param.params.tcp_client.port);
+            conn->is_connected = true;
+            conn->fd           = fd;
+        } else {
             close(fd);
             zlog_error(conn->param.log, "connect %s:%d error: %s(%d)",
                        conn->param.params.tcp_client.ip,
@@ -838,13 +845,8 @@ static void conn_connect(neu_conn_t *conn)
                        errno);
             conn->is_connected = false;
             return;
-        } else {
-            zlog_notice(conn->param.log, "connect %s:%d success",
-                        conn->param.params.tcp_client.ip,
-                        conn->param.params.tcp_client.port);
-            conn->is_connected = true;
-            conn->fd           = fd;
         }
+
         break;
     }
     case NEU_CONN_UDP: {