Skip to content

P
paho.mqtt.c
Commit 0efbc529 authored by Al S-M's avatar Al S-M
Browse files
Options

Fix for 415667

parent 7ae71b96
Hide whitespace changes
Inline Side-by-side
Showing with 26 additions and 4 deletions
src/MQTTAsync.c
View file @ 0efbc529
...@@ -2448,8 +2448,17 @@ int MQTTAsync_connecting(MQTTAsyncs* m) ...@@ -2448,8 +2448,17 @@ int MQTTAsync_connecting(MQTTAsyncs* m)
rc = SOCKET_ERROR; rc = SOCKET_ERROR;
goto exit; goto exit;
} }
else if (rc == 1 && !m->c->cleansession && m->c->session == NULL) else if (rc == 1) {
m->c->session = SSL_get1_session(m->c->net.ssl); rc = MQTTCLIENT_SUCCESS;
m->c->connect_state = 3;
if (MQTTPacket_send_connect(m->c) == SOCKET_ERROR)
{
rc = SOCKET_ERROR;
goto exit;
}
if(!m->c->cleansession && m->c->session == NULL))
m->c->session = SSL_get1_session(m->c->net.ssl);
}
} }
else else
{ {
...@@ -2473,6 +2482,8 @@ int MQTTAsync_connecting(MQTTAsyncs* m) ...@@ -2473,6 +2482,8 @@ int MQTTAsync_connecting(MQTTAsyncs* m)
if ((rc = SSLSocket_connect(m->c->net.ssl, m->c->net.socket)) != 1) if ((rc = SSLSocket_connect(m->c->net.ssl, m->c->net.socket)) != 1)
goto exit; goto exit;
if(!m->c->cleansession && m->c->session == NULL))
m->c->session = SSL_get1_session(m->c->net.ssl);
m->c->connect_state = 3; /* SSL connect completed, in which case send the MQTT connect packet */ m->c->connect_state = 3; /* SSL connect completed, in which case send the MQTT connect packet */
if ((rc = MQTTPacket_send_connect(m->c)) == SOCKET_ERROR) if ((rc = MQTTPacket_send_connect(m->c)) == SOCKET_ERROR)
goto exit; goto exit;
......
src/MQTTClient.c
View file @ 0efbc529
...@@ -795,8 +795,17 @@ int MQTTClient_connectURI(MQTTClient handle, MQTTClient_connectOptions* options, ...@@ -795,8 +795,17 @@ int MQTTClient_connectURI(MQTTClient handle, MQTTClient_connectOptions* options,
rc = SOCKET_ERROR; rc = SOCKET_ERROR;
goto exit; goto exit;
} }
else if (rc == 1 && !m->c->cleansession && m->c->session == NULL) else if (rc == 1) {
m->c->session = SSL_get1_session(m->c->net.ssl); rc = MQTTCLIENT_SUCCESS;
m->c->connect_state = 3;
if (MQTTPacket_send_connect(m->c) == SOCKET_ERROR)
{
rc = SOCKET_ERROR;
goto exit;
}
if(!m->c->cleansession && m->c->session == NULL))
m->c->session = SSL_get1_session(m->c->net.ssl);
}
} }
else else
{ {
...@@ -829,6 +838,8 @@ int MQTTClient_connectURI(MQTTClient handle, MQTTClient_connectOptions* options, ...@@ -829,6 +838,8 @@ int MQTTClient_connectURI(MQTTClient handle, MQTTClient_connectOptions* options,
rc = SOCKET_ERROR; rc = SOCKET_ERROR;
goto exit; goto exit;
} }
if(!m->c->cleansession && m->c->session == NULL))
m->c->session = SSL_get1_session(m->c->net.ssl);
m->c->connect_state = 3; /* TCP connect completed, in which case send the MQTT connect packet */ m->c->connect_state = 3; /* TCP connect completed, in which case send the MQTT connect packet */
if (MQTTPacket_send_connect(m->c) == SOCKET_ERROR) if (MQTTPacket_send_connect(m->c) == SOCKET_ERROR)
{ {
......
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