Commit 004eafb5 authored by Ian Craggs's avatar Ian Craggs

Add fix for pull request #183

parent b1de6625
...@@ -1728,10 +1728,11 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1728,10 +1728,11 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
if (rc == MQTTASYNC_SUCCESS) if (rc == MQTTASYNC_SUCCESS)
{ {
int onSuccess = 0;
if (m->serverURIcount > 0) if (m->serverURIcount > 0)
Log(TRACE_MIN, -1, "Connect succeeded to %s", Log(TRACE_MIN, -1, "Connect succeeded to %s",
m->serverURIs[m->connect.details.conn.currentURI]); m->serverURIs[m->connect.details.conn.currentURI]);
int onSuccess = (m->connect.onSuccess != NULL); /* save setting of onSuccess callback */ onSuccess = (m->connect.onSuccess != NULL); /* save setting of onSuccess callback */
if (m->connect.onSuccess) if (m->connect.onSuccess)
{ {
MQTTAsync_successData data; MQTTAsync_successData data;
...@@ -1748,8 +1749,8 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1748,8 +1749,8 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
} }
if (m->connected) if (m->connected)
{ {
Log(TRACE_MIN, -1, "Calling connected for client %s", m->c->clientID);
char* reason = (onSuccess) ? "connect onSuccess called" : "automatic reconnect"; char* reason = (onSuccess) ? "connect onSuccess called" : "automatic reconnect";
Log(TRACE_MIN, -1, "Calling connected for client %s", m->c->clientID);
(*(m->connected))(m->connected_context, reason); (*(m->connected))(m->connected_context, reason);
} }
} }
......
...@@ -48,6 +48,7 @@ ...@@ -48,6 +48,7 @@
#include <Windows.h> #include <Windows.h>
#define sleep Sleep #define sleep Sleep
#else #else
#include <unistd.h>
#include <sys/time.h> #include <sys/time.h>
#include <stdlib.h> #include <stdlib.h>
#endif #endif
......
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