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

Debug for Windows

This commit is contained in:
Ian Craggs 2022-02-15 11:24:33 +00:00
parent 1964b6697a
commit 655b87d22c
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
appveyor.yml
View File

@ -52,7 +52,7 @@ build_script:
nmake
ctest -T test -VV
ctest -T test -VV -R test95-5ws-offline-buffering-max-buffered
cd ..

9
src/MQTTAsyncUtils.c
View File

@ -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,