wt/mongoose
1
0 Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2026-11-08 16:11:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

do proper connect

Browse Source
This commit is contained in:
Sergio R. Caprile committed 2024-07-23 14:35:32 -03:00
1 parent 730f50f770
commit 9bdc910327
1 file changed
+12 -4
Download Patch File Download Diff File Expand all files Collapse all files
test/mip_tap_test.c
+12 -4
View File
@@ -84,12 +84,15 @@ static void eh1(struct mg_connection *c, int ev, void *ev_data) {
} }
struct fetch_data { struct fetch_data {
char *buf; char *buf;
int code, closed; int code, connected, closed;
}; };
static void fcb(struct mg_connection *c, int ev, void *ev_data) { static void fcb(struct mg_connection *c, int ev, void *ev_data) {
struct fetch_data *fd = (struct fetch_data *) c->fn_data; struct fetch_data *fd = (struct fetch_data *) c->fn_data;
if (ev == MG_EV_HTTP_MSG) { if (ev == MG_EV_CONNECT) {
MG_DEBUG(("CONNECT"));
fd->connected = 1;
} else if (ev == MG_EV_HTTP_MSG) {
struct mg_http_message *hm = (struct mg_http_message *) ev_data; struct mg_http_message *hm = (struct mg_http_message *) ev_data;
snprintf(fd->buf, FETCH_BUF_SIZE, "%.*s", (int) hm->message.len, hm->message.buf); snprintf(fd->buf, FETCH_BUF_SIZE, "%.*s", (int) hm->message.len, hm->message.buf);
fd->code = atoi(hm->uri.buf); fd->code = atoi(hm->uri.buf);
@@ -105,12 +108,17 @@ static void fcb(struct mg_connection *c, int ev, void *ev_data) {
static int fetch(struct mg_mgr *mgr, char *buf, const char *url, static int fetch(struct mg_mgr *mgr, char *buf, const char *url,
const char *fmt, ...) { const char *fmt, ...) {
struct fetch_data fd = {buf, 0, 0}; struct fetch_data fd = {buf, 0, 0, 0};
int i; int i;
struct mg_connection *c = NULL; struct mg_connection *c = NULL;
va_list ap; va_list ap;
c = mg_http_connect(mgr, url, fcb, &fd); c = mg_http_connect(mgr, url, fcb, &fd);
ASSERT(c != NULL); ASSERT(c != NULL);
for (i = 0; i < 500 && !fd.connected && !fd.closed; i++) {
mg_mgr_poll(mgr, 0);
usleep(10000); // 10 ms. Slow down poll loop to ensure packet transit
}
if (fd.closed) return 0;
if (c != NULL && mg_url_is_ssl(url)) { if (c != NULL && mg_url_is_ssl(url)) {
struct mg_tls_opts opts; struct mg_tls_opts opts;
memset(&opts, 0, sizeof(opts)); // read CA from packed_fs memset(&opts, 0, sizeof(opts)); // read CA from packed_fs
@@ -209,7 +217,7 @@ static void test_mqtt_connsubpub(struct mg_mgr *mgr) {
static void *poll_thread(void *p) { static void *poll_thread(void *p) {
struct mg_mgr *mgr = (struct mg_mgr *) p; struct mg_mgr *mgr = (struct mg_mgr *) p;
int i; int i;
for (i = 0; i < 500; i++) { for (i = 0; i < 300; i++) {
mg_mgr_poll(mgr, 0); mg_mgr_poll(mgr, 0);
usleep(10000); // 10 ms. Slow down poll loop to ensure packet transit usleep(10000); // 10 ms. Slow down poll loop to ensure packet transit
} }