mirror/mongoose
1
0
Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2025-08-06 13:37:34 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Merge pull request #2441 from cesanta/mqttst

Browse Source 
improve MQTT test speed
This commit is contained in:
Sergey Lyubka 2023-10-30 23:12:30 +00:00 committed by GitHub
commit d6d2d7575a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
test/unit_test.c
View File

@ -521,17 +521,16 @@ static void check_mqtt_message(struct mg_mqtt_opts *opts,
} }
} }
static void test_mqtt_ver(uint8_t mqtt_version) { static void test_mqtt_basic(void) {
char tbuf[16], mbuf[50] = {0}, client_id[16], topic[16]; char tbuf[16], mbuf[50] = {0}, topic[16];
struct mqtt_data test_data = {tbuf, mbuf, 16, 50, 0}; struct mqtt_data test_data = {tbuf, mbuf, 16, 50, 0};
struct mg_mgr mgr; struct mg_mgr mgr;
struct mg_connection *c; struct mg_connection *c;
struct mg_mqtt_opts opts; struct mg_mqtt_opts opts;
struct mg_mqtt_prop properties[5];
const char *url = "mqtt://broker.hivemq.com:1883"; const char *url = "mqtt://broker.hivemq.com:1883";
int i, retries; int i, retries;
// Connect with empty client ID, no options, ergo no MQTT != 3.1.1 // Connect with empty client ID, no options, ergo MQTT = 3.1.1
mg_mgr_init(&mgr); mg_mgr_init(&mgr);
c = mg_mqtt_connect(&mgr, url, NULL, mqtt_cb, &test_data); c = mg_mqtt_connect(&mgr, url, NULL, mqtt_cb, &test_data);
for (i = 0; i < 300 && mbuf[0] == 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 300 && mbuf[0] == 0; i++) mg_mgr_poll(&mgr, 10);
@ -571,13 +570,24 @@ static void test_mqtt_ver(uint8_t mqtt_version) {
memset(mbuf + 1, 0, sizeof(mbuf) - 1); memset(mbuf + 1, 0, sizeof(mbuf) - 1);
test_data.flags = 0; test_data.flags = 0;
// Disconnect ! // Clean Disconnect !
mg_mqtt_disconnect(c, NULL); mg_mqtt_disconnect(c, NULL);
for (i = 0; i < 10 && mbuf[0] != 0; i++) mg_mgr_poll(&mgr, 10); for (i = 0; i < 10 && mbuf[0] != 0; i++) mg_mgr_poll(&mgr, 10);
mg_mgr_free(&mgr); mg_mgr_free(&mgr);
ASSERT(mgr.conns == NULL); ASSERT(mgr.conns == NULL);
}
// (Re-)connect with options: version, clean session, last will, keepalive static void test_mqtt_ver(uint8_t mqtt_version) {
char tbuf[16], mbuf[50] = {0}, client_id[16], topic[16];
struct mqtt_data test_data = {tbuf, mbuf, 16, 50, 0};
struct mg_mgr mgr;
struct mg_connection *c;
struct mg_mqtt_opts opts;
struct mg_mqtt_prop properties[5];
const char *url = "mqtt://broker.hivemq.com:1883";
int i, retries;
// Connect with options: version, clean session, last will, keepalive
// time. Don't set retain, some runners are not random // time. Don't set retain, some runners are not random
test_data.flags = 0; test_data.flags = 0;
memset(mbuf, 0, sizeof(mbuf)); memset(mbuf, 0, sizeof(mbuf));
@ -659,6 +669,7 @@ static void test_mqtt_ver(uint8_t mqtt_version) {
static void test_mqtt(void) { static void test_mqtt(void) {
test_mqtt_base(); test_mqtt_base();
test_mqtt_basic();
test_mqtt_ver(4); test_mqtt_ver(4);
test_mqtt_ver(5); test_mqtt_ver(5);
} }