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

Add test debug and lengthen some timeouts

This commit is contained in:
Ian Craggs 2022-02-06 13:07:36 +00:00
parent 333bc57ffe
commit 6a68f4420c
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
test/test5.c
View File

@ -529,6 +529,7 @@ void asyncTestOnUnsubscribe(void* context, MQTTAsync_successData* response)
MyLog(LOGA_DEBUG, "In asyncTestOnUnsubscribe callback, %s", tc->clientid);
opts.onSuccess = asyncTestOnDisconnect;
opts.context = tc;
opts.timeout = 1000;
rc = MQTTAsync_disconnect(tc->client, &opts);
}
@ -2294,7 +2295,7 @@ int test7(struct Options options)
tc.subscribed = 0;
tc.testFinished = 0;
opts.keepAliveInterval = 20;
opts.keepAliveInterval = 60;
opts.cleansession = 1;
//opts.username = "testuser";
//opts.password = "testpassword";
@ -2326,7 +2327,7 @@ int test7(struct Options options)
if (rc != MQTTASYNC_SUCCESS)
goto exit;
while (test7OnUnsubscribed == 0 && test7OnPublishSuccessCount < options.message_count)
while (tc.testFinished == 0 && test7OnUnsubscribed == 0 && test7OnPublishSuccessCount < options.message_count)
#if defined(_WIN32)
Sleep(100);
#else
@ -2714,7 +2715,7 @@ int main(int argc, char** argv)
}
else
{
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_ERROR);
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_PROTOCOL);
rc = tests[options.test_no](options); /* run just the selected test */
}

3
test/test8.c
View File

@ -525,6 +525,7 @@ void test3_onUnsubscribe(void* context, MQTTAsync_successData* response)
MyLog(LOGA_DEBUG, "In onUnsubscribe onSuccess callback \"%s\"", cd->clientid);
opts.onSuccess = test3_onDisconnect;
opts.context = cd;
opts.timeout = 1000;
rc = MQTTAsync_disconnect(cd->c, &opts);
assert("Disconnect successful", rc == MQTTASYNC_SUCCESS, "rc was %d", rc);
@ -1371,7 +1372,7 @@ int main(int argc, char** argv)
}
else
{
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_ERROR);
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_PROTOCOL);
rc = tests[options.test_no](options); /* run just the selected test */
}