3party/mongoose
0
0
Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2024-12-28 23:49:44 +08:00
Code Issues Projects Releases Wiki Activity

Increase mqtt timeouts

Browse Source
This commit is contained in:
Sergey Lyubka 2021-12-24 12:13:55 +00:00
parent 54b1716e77
commit 62411d039e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/unit_test.c
View File

@ -322,11 +322,11 @@ static void test_mqtt(void) {
// Connect with empty client ID // Connect with empty client ID
c = mg_mqtt_connect(&mgr, url, NULL, mqtt_cb, buf); c = mg_mqtt_connect(&mgr, url, NULL, mqtt_cb, buf);
for (i = 0; i < 100 && buf[0] == 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 200 && buf[0] == 0; i++) mg_mgr_poll(&mgr, 10);
ASSERT(buf[0] == 'X'); ASSERT(buf[0] == 'X');
mg_mqtt_sub(c, &topic, 1); mg_mqtt_sub(c, &topic, 1);
mg_mqtt_pub(c, &topic, &data, 1, false); mg_mqtt_pub(c, &topic, &data, 1, false);
for (i = 0; i < 100 && buf[1] == 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 300 && buf[1] == 0; i++) mg_mgr_poll(&mgr, 10);
// LOG(LL_INFO, ("[%s]", buf)); // LOG(LL_INFO, ("[%s]", buf));
ASSERT(strcmp(buf, "Xx/f12/hi") == 0); ASSERT(strcmp(buf, "Xx/f12/hi") == 0);
@ -341,11 +341,11 @@ static void test_mqtt(void) {
opts.will_topic = mg_str("mg_will_topic"); opts.will_topic = mg_str("mg_will_topic");
opts.will_message = mg_str("mg_will_messsage"); opts.will_message = mg_str("mg_will_messsage");
c = mg_mqtt_connect(&mgr, url, &opts, mqtt_cb, buf); c = mg_mqtt_connect(&mgr, url, &opts, mqtt_cb, buf);
for (i = 0; i < 200 && buf[0] == 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 300 && buf[0] == 0; i++) mg_mgr_poll(&mgr, 10);
ASSERT(buf[0] == 'X'); ASSERT(buf[0] == 'X');
mg_mqtt_sub(c, &topic, 1); mg_mqtt_sub(c, &topic, 1);
mg_mqtt_pub(c, &topic, &data, 1, false); mg_mqtt_pub(c, &topic, &data, 1, false);
for (i = 0; i < 200 && buf[1] == 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 500 && buf[1] == 0; i++) mg_mgr_poll(&mgr, 10);
ASSERT(strcmp(buf, "Xx/f12/hi") == 0); ASSERT(strcmp(buf, "Xx/f12/hi") == 0);
mg_mgr_free(&mgr); mg_mgr_free(&mgr);