mirror/mongoose
1
0
Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2024-11-24 02:59:01 +08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Add test for MG_EV_POLL generation

Browse Source
This commit is contained in:
Sergio R. Caprile 2022-11-30 11:47:37 -03:00
parent 2553392e42
commit 59b69a3b3b
2 changed files with 35 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
test/mip_test.c
View File

@ -4,6 +4,7 @@
#define MG_ENABLE_PACKED_FS 0
#include <assert.h>
#include <sys/socket.h>
#include <linux/if.h>
#include <linux/if_tun.h>
#include <sys/ioctl.h>
@ -259,10 +260,26 @@ static void test_http_fetch(void) {
close(fd);
}
static void ph(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
if (ev == MG_EV_POLL) ++(*(int *) fn_data);
(void) c, (void) ev_data;
}
static void test_poll(void) {
int count = 0;
struct mg_mgr mgr;
mg_mgr_init(&mgr);
mg_http_listen(&mgr, "http://127.0.0.1:12346", ph, &count);
for (int i = 0; i < 10; i++) mg_mgr_poll(&mgr, 0);
ASSERT(count == 10);
mg_mgr_free(&mgr);
}
int main(void) {
test_queue();
test_statechange();
test_http_fetch();
test_poll();
printf("SUCCESS. Total tests: %d\n", s_num_tests);
return 0;
}

20
test/unit_test.c
View File

@ -333,7 +333,7 @@ static void test_sntp(void) {
ASSERT(mg_sntp_parse(NULL, 0) == -1);
// NOTE(cpq): temporarily disabled until Github Actions fix their NTP
// port blockage issue, https://github.com/actions/runner-images/issues/5615
//test_sntp_server("udp://time.apple.com:123");
// test_sntp_server("udp://time.apple.com:123");
test_sntp_server("udp://time.windows.com:123");
test_sntp_server(NULL);
}
@ -2304,7 +2304,7 @@ static void w2(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
} else if (ev == MG_EV_WS_MSG) {
struct mg_ws_message *wm = (struct mg_ws_message *) ev_data;
MG_INFO(("Got WS, %lu", wm->data.len));
//mg_hexdump(wm->data.ptr, wm->data.len);
// mg_hexdump(wm->data.ptr, wm->data.len);
if (wm->data.len == 9) {
ASSERT(mg_strcmp(wm->data, mg_str("hi there!")) == 0);
} else if (wm->data.len == 3) {
@ -2625,6 +2625,21 @@ static void test_rpc(void) {
ASSERT(head == NULL);
}
static void ph(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
if (ev == MG_EV_POLL) ++(*(int *) fn_data);
(void) c, (void) ev_data;
}
static void test_poll(void) {
int count = 0, i;
struct mg_mgr mgr;
mg_mgr_init(&mgr);
mg_http_listen(&mgr, "http://127.0.0.1:12346", ph, &count);
for (i = 0; i < 10; i++) mg_mgr_poll(&mgr, 0);
ASSERT(count == 10);
mg_mgr_free(&mgr);
}
int main(void) {
const char *debug_level = getenv("V");
if (debug_level == NULL) debug_level = "3";
@ -2666,6 +2681,7 @@ int main(void) {
test_http_range();
test_sntp();
test_mqtt();
test_poll();
printf("SUCCESS. Total tests: %d\n", s_num_tests);
return EXIT_SUCCESS;