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

Add some assertions to test5

This commit is contained in:
Ian Craggs 2022-06-30 19:31:24 +01:00
parent e065cd28d1
commit 17fd7a8446
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
test/test5.c
View File

@ -2178,6 +2178,7 @@ int test7MessageArrived(void* context, char* topicName, int topicLen,
opts.context = tc;
rc = MQTTAsync_sendMessage(tc->client, tc->topic, &pubmsg, &opts);
assert("Publish successful", rc == MQTTASYNC_SUCCESS, "rc was %d", rc);
}
else if (message_count < options.message_count)
{
@ -2192,6 +2193,7 @@ int test7MessageArrived(void* context, char* topicName, int topicLen,
opts.onFailure = test7OnPublishFailure;
opts.context = tc;
rc = MQTTAsync_sendMessage(tc->client, tc->topic, &pubmsg, &opts);
assert("Publish successful", rc == MQTTASYNC_SUCCESS, "rc was %d", rc);
}
else
{
@ -2237,6 +2239,7 @@ void test7OnSubscribe(void* context, MQTTAsync_successData* response)
rc = MQTTAsync_send(tc->client, tc->topic, pubmsg.payloadlen, pubmsg.payload,
pubmsg.qos, pubmsg.retained, &opts);
assert("Publish successful", rc == MQTTASYNC_SUCCESS, "rc was %d", rc);
}
void test7OnConnect(void* context, MQTTAsync_successData* response)