From 655b87d22c1efa71901d21df6f6662a30a5e886b Mon Sep 17 00:00:00 2001 From: Ian Craggs Date: Tue, 15 Feb 2022 11:24:33 +0000 Subject: [PATCH] Debug for Windows --- appveyor.yml | 2 +- src/MQTTAsyncUtils.c | 9 +++++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/appveyor.yml b/appveyor.yml index 6ab1abb4..d11c269e 100644 --- a/appveyor.yml +++ b/appveyor.yml @@ -52,7 +52,7 @@ build_script: nmake - ctest -T test -VV + ctest -T test -VV -R test95-5ws-offline-buffering-max-buffered cd .. diff --git a/src/MQTTAsyncUtils.c b/src/MQTTAsyncUtils.c index a3e15271..7e310f87 100644 --- a/src/MQTTAsyncUtils.c +++ b/src/MQTTAsyncUtils.c @@ -665,7 +665,10 @@ int MQTTAsync_restoreCommands(MQTTAsyncs* client) client->command_seqno = max(client->command_seqno, cmd->seqno); commands_restored++; if (cmd->command.type == PUBLISH) + { client->noBufferedMessages++; + printf("2 Number of buffered messages now %d\n", client->noBufferedMessages); + } } } if (buffer) @@ -898,7 +901,10 @@ int MQTTAsync_addCommand(MQTTAsync_queuedCommand* command, int command_size) } } else + { command->client->noBufferedMessages++; + printf("1 Number of buffered messages now %d\n", command->client->noBufferedMessages); + } } } exit: @@ -1225,7 +1231,10 @@ static int MQTTAsync_processCommand(void) if (command) { if (command->command.type == PUBLISH) + { command->client->noBufferedMessages--; + printf("-- Number of buffered messages now %d\n", command->client->noBufferedMessages); + } ListDetach(MQTTAsync_commands, command); #if !defined(NO_PERSISTENCE) /*printf("outboundmsgs count %d max inflight %d qos %d %d %d\n", command->client->c->outboundMsgs->count, command->client->c->maxInflightMessages,