Skip to content

P
paho.mqtt.c
Commit e27d9b9a authored by Ian Craggs's avatar Ian Craggs
Browse files
Options

Remove some socket removal code for testing

parent e378bc1e
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 1 deletion
src/MQTTAsync.c
View file @ e27d9b9a
...@@ -1487,7 +1487,8 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1487,7 +1487,8 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
} }
if (rc == SOCKET_ERROR) if (rc == SOCKET_ERROR)
{ {
Log(TRACE_MINIMUM, -1, "Error from MQTTAsync_cycle() - removing socket %d", sock); Log(TRACE_MINIMUM, -1, "Error from MQTTAsync_cycle() - not removing socket %d", sock);
#if 0
if (m->c->connected == 1) if (m->c->connected == 1)
{ {
MQTTAsync_unlock_mutex(mqttasync_mutex); MQTTAsync_unlock_mutex(mqttasync_mutex);
...@@ -1496,6 +1497,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1496,6 +1497,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
} }
else /* calling disconnect_internal won't have any effect if we're already disconnected */ else /* calling disconnect_internal won't have any effect if we're already disconnected */
MQTTAsync_closeOnly(m->c); MQTTAsync_closeOnly(m->c);
#endif
} }
else else
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment