http: cleanup cork logic

Author: ronag

lib/_http_outgoing.js

@@ -211,7 +211,7 @@ ObjectDefineProperty(OutgoingMessage.prototype, 'writableHighWaterMark', {
 ObjectDefineProperty(OutgoingMessage.prototype, 'writableCorked', {
   __proto__: null,
   get() {
-    return this[kCorked];
+    return this[kSocket] ? this[kSocket].writableCorked : this[kCorked];
   },
 });
 
@@ -252,6 +252,9 @@ ObjectDefineProperty(OutgoingMessage.prototype, 'socket', {
     return this[kSocket];
   },
   set: function(val) {
+    for (let n = 0; n < this[kCorked]; n++) {
+      val?.cork();
+    }
     for (let n = 0; n < this[kCorked]; n++) {
       val?.cork();
       this[kSocket]?.uncork();
@@ -1000,9 +1003,9 @@ function write_(msg, chunk, encoding, callback, fromEnd) {
     }
   }
 
-  if (!fromEnd && msg.socket && !msg.socket.writableCorked) {
-    msg.socket.cork();
-    process.nextTick(connectionCorkNT, msg.socket);
+  if (!fromEnd && !msg.writableCorked) {
+    msg.cork();
+    process.nextTick(connectionUncorkNT, msg);
   }
 
   let ret;
@@ -1027,8 +1030,8 @@ function write_(msg, chunk, encoding, callback, fromEnd) {
 }
 
 
-function connectionCorkNT(conn) {
-  conn.uncork();
+function connectionUncorkNT(msg) {
+  msg.uncork();
 }
 
 OutgoingMessage.prototype.addTrailers = function addTrailers(headers) {
@@ -1143,9 +1146,9 @@ OutgoingMessage.prototype.end = function end(chunk, encoding, callback) {
     // Fully uncork connection on end().
     this[kSocket]._writableState.corked = 1;
     this[kSocket].uncork();
+  } else {
+    this[kCorked] = 0;
   }
-  this[kCorked] = 1;
-  this.uncork();
 
   this.finished = true;