natas_hw
/
paho
mirror of https://github.com/eclipse/paho.mqtt.c
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add further poll debug

This commit is contained in:
Ian Craggs 2022-02-06 15:07:20 +00:00
parent 6a68f4420c
commit 8d1aa132c2
3 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Socket.c
View File

@ -237,8 +237,8 @@ int isReady(int index)
FUNC_ENTRY;
if (mod_s.saved.fds[index].revents & POLLHUP || mod_s.saved.fds[index].revents & POLLNVAL)
; /* signal work to be done if there is an error on the socket */
if ((mod_s.saved.fds[index].revents & POLLHUP) || (mod_s.saved.fds[index].revents & POLLNVAL))
printf("isReady error on socket %d\n", mod_s.saved.fds[index].revents); /* signal work to be done if there is an error on the socket */
else if (ListFindItem(mod_s.connect_pending, socket, intcompare) &&
(mod_s.saved.fds[index].revents & POLLOUT))
ListRemoveItem(mod_s.connect_pending, socket, intcompare);

5
test/test5.c
View File

@ -2715,7 +2715,10 @@ int main(int argc, char** argv)
}
else
{
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_PROTOCOL);
if (options.test_no == 10)
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_MINIMUM);
else
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_PROTOCOL);
rc = tests[options.test_no](options); /* run just the selected test */
}

5
test/test8.c
View File

@ -1372,7 +1372,10 @@ int main(int argc, char** argv)
}
else
{
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_PROTOCOL);
if (options.test_no == 8)
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_MINIMUM);
else
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_ERROR);
rc = tests[options.test_no](options); /* run just the selected test */
}