Skip to content

P
paho.mqtt.c
Commit bed5c09a authored by Juergen Kosel's avatar Juergen Kosel
Browse files
Options

Modified number of connect iterations and messages send per second 

Signed-off-by: 's avatarJuergen Kosel <juergen.kosel@softing.com>
parent 2ceffbc7
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
test/test_issue373.c
View file @ bed5c09a
...@@ -286,7 +286,7 @@ int test_373(struct Options options) ...@@ -286,7 +286,7 @@ int test_373(struct Options options)
goto exit; goto exit;
} }
MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_ERROR); MQTTAsync_setTraceLevel(MQTTASYNC_TRACE_ERROR);
while (connectCnt < 10) while (connectCnt < 5)
{ {
MyLog(LOGA_INFO, "Connected %d connectCnt %d\n",connected,connectCnt); MyLog(LOGA_INFO, "Connected %d connectCnt %d\n",connected,connectCnt);
mqtt_mem = Heap_get_info(); mqtt_mem = Heap_get_info();
...@@ -313,9 +313,9 @@ int test_373(struct Options options) ...@@ -313,9 +313,9 @@ int test_373(struct Options options)
} }
else else
{ {
/* while connected send 100 message per second */ /* while connected send 1000 message per second */
int topicId; int topicId;
for(topicId=0; topicId < 100; topicId++) for(topicId=0; topicId < 1000; topicId++)
{ {
rc = test373SendPublishMessage(mqttasyncContext,topicId); rc = test373SendPublishMessage(mqttasyncContext,topicId);
if (rc != MQTTASYNC_SUCCESS) break; if (rc != MQTTASYNC_SUCCESS) break;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment