Skip to content

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

Fix for 3.1.1 support

parent 34df18e7
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
src/MQTTAsync.c
View file @ 0410d2e5
...@@ -1499,6 +1499,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1499,6 +1499,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
{ {
if (pack->header.bits.type == CONNACK) if (pack->header.bits.type == CONNACK)
{ {
int sessionPresent = ((Connack*)pack)->flags.bits.sessionPresent;
int rc = MQTTAsync_completeConnection(m, pack); int rc = MQTTAsync_completeConnection(m, pack);
if (rc == MQTTASYNC_SUCCESS) if (rc == MQTTASYNC_SUCCESS)
...@@ -1517,7 +1518,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n) ...@@ -1517,7 +1518,7 @@ thread_return_type WINAPI MQTTAsync_receiveThread(void* n)
else else
data.alt.connect.serverURI = m->serverURI; data.alt.connect.serverURI = m->serverURI;
data.alt.connect.MQTTVersion = m->connect.details.conn.MQTTVersion; data.alt.connect.MQTTVersion = m->connect.details.conn.MQTTVersion;
data.alt.connect.sessionPresent = ((Connack*)pack)->flags.bits.sessionPresent; data.alt.connect.sessionPresent = sessionPresent;
(*(m->connect.onSuccess))(m->connect.context, &data); (*(m->connect.onSuccess))(m->connect.context, &data);
} }
} }
......
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