http: preserve socket cork count during flush

Signed-off-by: GetThatCookie <NimmenKeks@gmx.de>

Author: GetThatCookie

lib/_http_outgoing.js

@@ -305,46 +305,47 @@ OutgoingMessage.prototype.cork = function cork() {
 OutgoingMessage.prototype.uncork = function uncork() {
   this[kCorked]--;
   const socket = this[kSocket];
-  if (this[kCorked] || this[kChunkedBuffer].length === 0) {
-    socket?.uncork();
-    return;
-  }
+  try {
+    if (this[kCorked] || this[kChunkedBuffer].length === 0) {
+      return;
+    }
 
-  const len = this[kChunkedLength];
-  const buf = this[kChunkedBuffer];
-  if (this.destroyed || socket?.destroyed) {
-    const error = this[kErrored] || socket?._writableState?.errored || new ERR_STREAM_DESTROYED('write');
-    for (let n = 2; n < buf.length; n += 3) {
-      if (buf[n] !== nop) {
-        process.nextTick(buf[n], error);
+    const len = this[kChunkedLength];
+    const buf = this[kChunkedBuffer];
+    if (this.destroyed || socket?.destroyed) {
+      const error = this[kErrored] || socket?._writableState?.errored || new ERR_STREAM_DESTROYED('write');
+      for (let n = 2; n < buf.length; n += 3) {
+        if (buf[n] !== nop) {
+          process.nextTick(buf[n], error);
+        }
+      }
+      buf.length = 0;
+      this[kChunkedLength] = 0;
+      return;
+    }
+    assert(this.chunkedEncoding);
+
+    let callbacks;
+    this._send(len.toString(16), 'latin1', null);
+    this._send(crlf_buf, null, null);
+    for (let n = 0; n < buf.length; n += 3) {
+      this._send(buf[n + 0], buf[n + 1], null);
+      if (buf[n + 2]) {
+        callbacks ??= [];
+        callbacks.push(buf[n + 2]);
       }
     }
-    buf.length = 0;
+    this._send(crlf_buf, null, callbacks.length ? (err) => {
+      for (const callback of callbacks) {
+        callback(err);
+      }
+    } : null);
+
+    this[kChunkedBuffer].length = 0;
     this[kChunkedLength] = 0;
+  } finally {
     socket?.uncork();
-    return;
   }
-  assert(this.chunkedEncoding);
-
-  let callbacks;
-  this._send(len.toString(16), 'latin1', null);
-  this._send(crlf_buf, null, null);
-  for (let n = 0; n < buf.length; n += 3) {
-    this._send(buf[n + 0], buf[n + 1], null);
-    if (buf[n + 2]) {
-      callbacks ??= [];
-      callbacks.push(buf[n + 2]);
-    }
-  }
-  this._send(crlf_buf, null, callbacks.length ? (err) => {
-    for (const callback of callbacks) {
-      callback(err);
-    }
-  } : null);
-
-  this[kChunkedBuffer].length = 0;
-  this[kChunkedLength] = 0;
-  socket?.uncork();
 
   // If we had a pending drain and flushed all data, emit the drain event.
   if (this[kNeedDrain] && this.writableLength === 0) {