From 82e7a907e3459cf6ce2b00dfe00300a18f93c3f1 Mon Sep 17 00:00:00 2001
From: fengzero <fengzero@fengzero.com>
Date: Wed, 6 Jul 2022 07:08:35 +0000
Subject: [PATCH] mqtt: del sleep 1s

---
 src/connection/mqtt_c_client.c | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/connection/mqtt_c_client.c b/src/connection/mqtt_c_client.c
index 5752c4f3..4e478f2a 100644
--- a/src/connection/mqtt_c_client.c
+++ b/src/connection/mqtt_c_client.c
@@ -536,6 +536,7 @@ neu_err_code_e mqtt_c_client_is_connected(mqtt_c_client_t *client);
 static void *client_refresher(void *context)
 {
     assert(NULL != context);
+    int error_count = 0;
 
     mqtt_c_client_t *       client = (mqtt_c_client_t *) context;
     struct mqtt_client *    mqtt   = &client->mqtt;
@@ -561,14 +562,12 @@ static void *client_refresher(void *context)
             int rc = mqtt_c_client_is_connected(client);
             client->state_update_func(client->user_data, rc);
 
-            if (0 != rc) {
-                if (NULL != client->log) {
-                    zlog_error(client->log, "connect to %s:%s erorr, retry...",
-                               client->state.hostname, client->state.port);
-                }
-                usleep(INTERVAL * 10);
+            if (0 != rc && error_count % 100 == 0) {
+                zlog_error(client->log, "connect to %s:%s erorr, retry...",
+                           client->state.hostname, client->state.port);
             }
         }
+        error_count++;
     }
 
     reconnect_state_uninit(state);