fixup

nodejs · Feb 27, 2021 · 0066a62 · 0066a62
1 parent 3fecee9
commit 0066a62
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 94 deletions.
diff --git a/lib/core/client.js b/lib/core/client.js
@@ -411,7 +411,7 @@ class Parser extends HTTPParser {
       }
       this.resuming = false
 
-      socketResume(this.socket)
+      this.socket.resume()
     }
 
     this._pause = () => {
@@ -421,7 +421,7 @@ class Parser extends HTTPParser {
 
       this.paused = true
 
-      socketPause(this.socket)
+      this.socket.pause()
     }
 
     socket.on('data', onSocketData)
@@ -891,26 +891,6 @@ function connect (client) {
     .on('close', onSocketClose)
 }
 
-function socketPause (socket) {
-  if (socket._handle && socket._handle.reading) {
-    socket._handle.reading = false
-    const err = socket._handle.readStop()
-    if (err) {
-      socket.destroy(util.errnoException(err, 'read'))
-    }
-  }
-}
-
-function socketResume (socket) {
-  if (socket._handle && !socket._handle.reading) {
-    socket._handle.reading = true
-    const err = socket._handle.readStart()
-    if (err) {
-      socket.destroy(util.errnoException(err, 'read'))
-    }
-  }
-}
-
 function emitDrain (client) {
   client[kNeedDrain] = 0
   client.emit('drain')

diff --git a/test/socket-handle-error.js b/test/socket-handle-error.js