From 2e55df8b82e1f49e02c87d4f246d022f04814794 Mon Sep 17 00:00:00 2001 From: Ian Craggs Date: Mon, 10 Sep 2018 11:45:56 +0100 Subject: [PATCH] Fix for issue #523 --- src/MQTTAsync.c | 4 ---- 1 file changed, 4 deletions(-) diff --git a/src/MQTTAsync.c b/src/MQTTAsync.c index 0acfbdad..a5813b45 100644 --- a/src/MQTTAsync.c +++ b/src/MQTTAsync.c @@ -2099,11 +2099,7 @@ static thread_return_type WINAPI MQTTAsync_receiveThread(void* n) { Log(TRACE_MINIMUM, -1, "Error from MQTTAsync_cycle() - removing socket %d", sock); if (m->c->connected == 1) - { - MQTTAsync_unlock_mutex(mqttasync_mutex); MQTTAsync_disconnect_internal(m, 0); - MQTTAsync_lock_mutex(mqttasync_mutex); - } else if (m->c->connect_state != NOT_IN_PROGRESS) nextOrClose(m, rc, "socket error"); else /* calling disconnect_internal won't have any effect if we're already disconnected */