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

Merge pull request #2090 from cesanta/tcp

Browse Source 
mark we consumed data
This commit is contained in:
Sergio R. Caprile authored and GitHub committed 2023-02-23 14:38:14 -03:00
2 parents d0e5690bfd 99e28b639d
commit b85aa7b084
1 file changed
+6 -2
Download Patch File Download Diff File Expand all files Collapse all files
examples/tcp/main.c
+6 -2
View File
@@ -19,14 +19,16 @@ static void cfn(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
MG_INFO(("CLIENT has been initialized")); MG_INFO(("CLIENT has been initialized"));
} else if (ev == MG_EV_CONNECT) { } else if (ev == MG_EV_CONNECT) {
MG_INFO(("CLIENT connected")); MG_INFO(("CLIENT connected"));
#if (MG_ENABLE_MBEDTLS == 1) || (MG_ENABLE_OPENSSL == 1) #if MG_ENABLE_MBEDTLS || MG_ENABLE_OPENSSL
struct mg_tls_opts opts = {.ca = "ss_ca.pem"}; struct mg_tls_opts opts = {.ca = "ss_ca.pem"};
mg_tls_init(c, &opts); mg_tls_init(c, &opts);
MG_INFO(("CLIENT initialized TLS"));
#endif #endif
*i = 1; // do something *i = 1; // do something
} else if (ev == MG_EV_READ) { } else if (ev == MG_EV_READ) {
struct mg_iobuf *r = &c->recv; struct mg_iobuf *r = &c->recv;
MG_INFO(("CLIENT got data: %.*s", r->len, r->buf)); MG_INFO(("CLIENT got data: %.*s", r->len, r->buf));
r->len = 0; // Tell Mongoose we've consumed data
} else if (ev == MG_EV_CLOSE) { } else if (ev == MG_EV_CLOSE) {
MG_INFO(("CLIENT disconnected")); MG_INFO(("CLIENT disconnected"));
// signal we are done // signal we are done
@@ -53,18 +55,20 @@ static void sfn(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
MG_INFO(("SERVER is listening")); MG_INFO(("SERVER is listening"));
} else if (ev == MG_EV_ACCEPT) { } else if (ev == MG_EV_ACCEPT) {
MG_INFO(("SERVER accepted a connection")); MG_INFO(("SERVER accepted a connection"));
#if (MG_ENABLE_MBEDTLS == 1) || (MG_ENABLE_OPENSSL == 1) #if MG_ENABLE_MBEDTLS || MG_ENABLE_OPENSSL
struct mg_tls_opts opts = { struct mg_tls_opts opts = {
//.ca = "ss_ca.pem", // Uncomment to enable two-way SSL //.ca = "ss_ca.pem", // Uncomment to enable two-way SSL
.cert = "ss_server.pem", // Certificate PEM file .cert = "ss_server.pem", // Certificate PEM file
.certkey = "ss_server.pem", // This pem contains both cert and key .certkey = "ss_server.pem", // This pem contains both cert and key
}; };
mg_tls_init(c, &opts); mg_tls_init(c, &opts);
MG_INFO(("SERVER initialized TLS"));
#endif #endif
} else if (ev == MG_EV_READ) { } else if (ev == MG_EV_READ) {
struct mg_iobuf *r = &c->recv; struct mg_iobuf *r = &c->recv;
MG_INFO(("SERVER got data: %.*s", r->len, r->buf)); MG_INFO(("SERVER got data: %.*s", r->len, r->buf));
mg_send(c, r->buf, r->len); // echo it back mg_send(c, r->buf, r->len); // echo it back
r->len = 0; // Tell Mongoose we've consumed data
} else if (ev == MG_EV_CLOSE) { } else if (ev == MG_EV_CLOSE) {
MG_INFO(("SERVER disconnected")); MG_INFO(("SERVER disconnected"));
} else if (ev == MG_EV_ERROR) { } else if (ev == MG_EV_ERROR) {