From 8d1aa132c25a119e97140afb6779e5731e7c1431 Mon Sep 17 00:00:00 2001 From: Ian Craggs Date: Sun, 6 Feb 2022 15:07:20 +0000 Subject: [PATCH] Add further poll debug --- src/Socket.c | 4 ++-- test/test5.c | 5 ++++- test/test8.c | 5 ++++- 3 files changed, 10 insertions(+), 4 deletions(-) diff --git a/src/Socket.c b/src/Socket.c index 6b4d7e34..ef901971 100644 --- a/src/Socket.c +++ b/src/Socket.c @@ -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); diff --git a/test/test5.c b/test/test5.c index 6f4012e2..ba62690a 100644 --- a/test/test5.c +++ b/test/test5.c @@ -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 */ } diff --git a/test/test8.c b/test/test8.c index e1b53a74..6b95afe0 100644 --- a/test/test8.c +++ b/test/test8.c @@ -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 */ }