GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-24 10:46:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #617 from fengzeroz/main

Browse Source 
mqtt: del sleep 1s
This commit is contained in:
fengzeroz
2022-07-06 15:17:21 +08:00
committed by GitHub
parent 6785d4ec85 82e7a907e3
commit 3e090dd972
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/connection/mqtt_c_client.c
+5 -6
View File
@@ -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);