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

Merge pull request #3170 from cesanta/keepack

Browse Source 
Add Keep-Alive ACK
This commit is contained in:
Sergey Lyubka authored and GitHub committed 2025-06-12 08:37:00 +01:00
2 parents b0d0fbfd9f acf217601b
commit bfca233160
2 files changed
+10
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

mongoose.c
+5
View File
@@ -4869,6 +4869,11 @@ static void read_conn(struct mg_connection *c, struct pkt *pkt) {
if (pkt->pay.len == 0) return; // if no data, we're done
} else if (pkt->pay.len == 0) { // this is an ACK
if (s->fin_rcvd && s->ttype == MIP_TTYPE_FIN) s->twclosure = true;
if (mg_ntohl(pkt->tcp->seq) == s->ack - 1) { // this is a keepalive probe
MG_VERBOSE(("%lu keepalive ACK", c->id));
tx_tcp(c->mgr->ifp, s->mac, rem_ip, TH_ACK, c->loc.port, c->rem.port,
mg_htonl(s->seq), mg_htonl(s->ack), NULL, 0);
}
return; // no data to process
} else if (seq != s->ack) {
uint32_t ack = (uint32_t) (mg_htonl(pkt->tcp->seq) + pkt->pay.len);
src/net_builtin.c
+5
View File
@@ -703,6 +703,11 @@ static void read_conn(struct mg_connection *c, struct pkt *pkt) {
if (pkt->pay.len == 0) return; // if no data, we're done
} else if (pkt->pay.len == 0) { // this is an ACK
if (s->fin_rcvd && s->ttype == MIP_TTYPE_FIN) s->twclosure = true;
if (mg_ntohl(pkt->tcp->seq) == s->ack - 1) { // this is a keepalive probe
MG_VERBOSE(("%lu keepalive ACK", c->id));
tx_tcp(c->mgr->ifp, s->mac, rem_ip, TH_ACK, c->loc.port, c->rem.port,
mg_htonl(s->seq), mg_htonl(s->ack), NULL, 0);
}
return; // no data to process
} else if (seq != s->ack) {
uint32_t ack = (uint32_t) (mg_htonl(pkt->tcp->seq) + pkt->pay.len);