wt/mongoose
1
0 Fork 0
mirror of https://github.com/cesanta/mongoose.git synced 2026-10-29 12:41:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better cleanup

Browse Source
This commit is contained in:
Sergey Lyubka committed 2022-01-05 11:45:22 +00:00
1 parent 030b1d9826
commit 6ad4d242c2
1 file changed
+7 -4
Download Patch File Download Diff File Expand all files Collapse all files
examples/http-reverse-proxy/main.c
+7 -4
View File
@@ -33,10 +33,13 @@ static void forward_request(struct mg_http_message *hm,
} }
static void fn2(struct mg_connection *c, int ev, void *ev_data, void *fn_data) { static void fn2(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
if (ev == MG_EV_READ && fn_data != NULL) { struct mg_connection *c2 = fn_data;
if (ev == MG_EV_READ) {
// All incoming data from the backend, forward to the client // All incoming data from the backend, forward to the client
mg_send((struct mg_connection *) fn_data, c->recv.buf, c->recv.len); if (c2 != NULL) mg_send(c2, c->recv.buf, c->recv.len);
mg_iobuf_del(&c->recv, 0, c->recv.len); mg_iobuf_del(&c->recv, 0, c->recv.len);
} else if (ev == MG_EV_CLOSE) {
if (c2 != NULL) c2->fn_data = NULL;
} }
(void) ev_data; (void) ev_data;
} }
@@ -57,11 +60,11 @@ static void fn(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
} }
c->fn_data = c2; c->fn_data = c2;
forward_request(hm, c2); forward_request(hm, c2);
// c2->is_hexdumping = 1; c2->is_hexdumping = 1;
} }
} else if (ev == MG_EV_CLOSE) { } else if (ev == MG_EV_CLOSE) {
if (c2 != NULL) c2->is_closing = 1; if (c2 != NULL) c2->is_closing = 1;
c->fn_data = NULL; if (c2 != NULL) c2->fn_data = NULL;
} }
} }