Skip to content

P
paho.mqtt.c
Commit c06f3c19 authored by Juergen Kosel's avatar Juergen Kosel
Browse files
Options

Add tracing to track down issue 190 

Signed-off-by: 's avatarJuergen Kosel <juergen.kosel@softing.com>
parent 3ab7145a
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 0 deletions
src/MQTTAsync.c
View file @ c06f3c19
...@@ -1345,6 +1345,7 @@ void MQTTAsync_checkTimeouts() ...@@ -1345,6 +1345,7 @@ void MQTTAsync_checkTimeouts()
else else
{ {
MQTTAsync_closeSession(m->c); MQTTAsync_closeSession(m->c);
Log(TRACE_MIN, -1, "Connect failed with timeout, no to try");
if (m->connect.onFailure) if (m->connect.onFailure)
{ {
MQTTAsync_failureData data; MQTTAsync_failureData data;
...@@ -2849,6 +2850,7 @@ MQTTPacket* MQTTAsync_cycle(int* sock, unsigned long timeout, int* rc) ...@@ -2849,6 +2850,7 @@ MQTTPacket* MQTTAsync_cycle(int* sock, unsigned long timeout, int* rc)
m = (MQTTAsync)(handles->current->content); m = (MQTTAsync)(handles->current->content);
if (m != NULL) if (m != NULL)
{ {
Log(TRACE_MINIMUM, -1, "m->c->connect_state = %d",m->c->connect_state);
if (m->c->connect_state == 1 || m->c->connect_state == 2) if (m->c->connect_state == 1 || m->c->connect_state == 2)
*rc = MQTTAsync_connecting(m); *rc = MQTTAsync_connecting(m);
else else
...@@ -2885,6 +2887,11 @@ MQTTPacket* MQTTAsync_cycle(int* sock, unsigned long timeout, int* rc) ...@@ -2885,6 +2887,11 @@ MQTTPacket* MQTTAsync_cycle(int* sock, unsigned long timeout, int* rc)
MQTTAsync_startConnectRetry(m); MQTTAsync_startConnectRetry(m);
} }
} }
else
{
Log(TRACE_MINIMUM, -1, "m->c->connect_state = %d",m->c->connect_state);
Log(TRACE_MINIMUM, -1, "CONNECT sent, *rc is %d",*rc);
}
} }
if (pack) if (pack)
{ {
......
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