Commit add9bb0a authored by Ian Craggs's avatar Ian Craggs

Remove temp change from MQTTAsync.c - point test4 at 1883 for debug

parent e27d9b9a
...@@ -101,7 +101,7 @@ ...@@ -101,7 +101,7 @@
<else> <else>
<exec executable="./${aTest}" failonerror="true" dir="${output.folder}/test" > <exec executable="./${aTest}" failonerror="true" dir="${output.folder}/test" >
<arg value="--connection" /> <arg value="--connection" />
<arg value="tcp://${test.hostname}:${test.port}" /> <arg value="tcp://${test.hostname}:1883" />
<env key="LD_LIBRARY_PATH" path="${output.folder}" /> <env key="LD_LIBRARY_PATH" path="${output.folder}" />
<env key="DYLD_LIBRARY_PATH" path="${output.folder}" /> <env key="DYLD_LIBRARY_PATH" path="${output.folder}" />
<arg value="--verbose" /> <arg value="--verbose" />
......
...@@ -1487,8 +1487,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1487,8 +1487,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
} }
if (rc == SOCKET_ERROR) if (rc == SOCKET_ERROR)
{ {
Log(TRACE_MINIMUM, -1, "Error from MQTTAsync_cycle() - not removing socket %d", sock); Log(TRACE_MINIMUM, -1, "Error from MQTTAsync_cycle() - 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);
...@@ -1497,7 +1496,6 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1497,7 +1496,6 @@ 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