# HG changeset patch
# User Olaf Wintermann <olaf.wintermann@gmail.com>
# Date 1667331975 -3600
# Node ID 78af44222463fb8f1d6ceab56292e2a2564848fe
# Parent  e5d96f6b930680c5d969778eaa68075fc35fc8db
close connection if content-length != number of bytes written

diff -r e5d96f6b9306 -r 78af44222463 src/server/daemon/httprequest.c
--- a/src/server/daemon/httprequest.c	Tue Nov 01 20:39:41 2022 +0100
+++ b/src/server/daemon/httprequest.c	Tue Nov 01 20:46:15 2022 +0100
@@ -614,6 +614,16 @@
         rq->rq.rq_attr.keep_alive = 0;
     }
     
+    char *response_content_length = pblock_findkeyval(pb_key_content_length, rq->rq.srvhdrs);
+    int64_t response_ctlen;
+    if(response_content_length && util_strtoint(response_content_length, &response_ctlen)) {
+        int64_t w = httpstream_written(sn->sn.csd);
+        if(w != response_ctlen) {
+            log_ereport(LOG_WARN, "nsapi_finish_request: content-length != number of bytes written");
+            rq->rq.rq_attr.keep_alive = 0; // fatal io error, we can not safely reuse the connection
+        }
+    }
+    
     if(rq->rq.rq_attr.keep_alive) {
         SessionHandler *sh = sn->connection->session_handler;
         sh->keep_alive(sh, sn->connection);
diff -r e5d96f6b9306 -r 78af44222463 src/server/util/io.c
--- a/src/server/util/io.c	Tue Nov 01 20:39:41 2022 +0100
+++ b/src/server/util/io.c	Tue Nov 01 20:46:15 2022 +0100
@@ -307,6 +307,11 @@
     return http->read_eof;
 }
 
+int64_t httpstream_written(IOStream *st) {
+    HttpStream *http = (HttpStream*)st;
+    return http->written;
+}
+
 ssize_t net_http_write(HttpStream *st, void *buf, size_t nbytes) {
     if(st->write_eof) return 0;
     IOStream *fd = st->fd;
diff -r e5d96f6b9306 -r 78af44222463 src/server/util/io.h
--- a/src/server/util/io.h	Tue Nov 01 20:39:41 2022 +0100
+++ b/src/server/util/io.h	Tue Nov 01 20:46:15 2022 +0100
@@ -171,6 +171,7 @@
 int httpstream_enable_chunked_write(IOStream *st);
 int httpstream_set_max_read(IOStream *st, int64_t maxread);
 WSBool httpstream_eof(IOStream *st);
+int64_t httpstream_written(IOStream *st);
 
 ssize_t net_http_write(HttpStream *st, void *buf, size_t nbytes);
 ssize_t net_http_writev(HttpStream *st, struct iovec *iovec, int iovcnt);