Revert "fix: release on error & close"

This reverts commit 758429c.

Author: ronag

index.js

@@ -212,7 +212,6 @@ function createError (msg, code, statusCode) {
 
 class ErrorHandler {
   constructor () {
-    this.released = true
     this.hasError = false
     this.req = null
     this.resOrSocket = null
@@ -252,11 +251,6 @@ class ErrorHandler {
   }
 
   _release () {
-    if (this.released) {
-      return
-    }
-
-    this.released = true
     this.hasError = false
     this.req = null
     this.resOrSocket = null
@@ -267,21 +261,18 @@ class ErrorHandler {
 
   static create (req, resOrSocket, callback) {
     const handler = ErrorHandler.pool.pop() || new ErrorHandler()
-    handler.released = false
     handler.hasError = false
     handler.req = req
     handler.resOrSocket = resOrSocket
     handler.callback = callback
     handler.req.on('close', handler._release)
-    handler.req.on('error', handler._release)
     return handler._handle
   }
 }
 ErrorHandler.pool = []
 
 class ProxyErrorHandler {
   constructor () {
-    this.released = true
     this.hasError = false
     this.req = null
     this.proxyReq = null
@@ -332,13 +323,8 @@ class ProxyErrorHandler {
   }
 
   _release () {
-    if (this.released) {
-      return
-    }
-
     this._abort()
 
-    this.released = true
     this.hasError = false
     this.req = null
     this.proxyReq = null
@@ -349,20 +335,17 @@ class ProxyErrorHandler {
 
   static create (req, proxyReq, errorHandler) {
     const handler = ProxyErrorHandler.pool.pop() || new ProxyErrorHandler()
-    handler.released = false
     handler.req = req
     handler.proxyReq = proxyReq
     handler.errorHandler = errorHandler
     handler.req.on('close', handler._release)
-    handler.req.on('error', handler._release)
     return handler._handle
   }
 }
 ProxyErrorHandler.pool = []
 
 class ProxyResponseHandler {
   constructor () {
-    this.released = true
     this.req = null
     this.resOrSocket = null
     this.onRes = null
@@ -412,15 +395,10 @@ class ProxyResponseHandler {
   }
 
   _release () {
-    if (this.released) {
-      return
-    }
-
     if (this.proxyRes) {
       this.proxyRes.destroy()
     }
 
-    this.released = true
     this.req = null
     this.resOrSocket = null
     this.onRes = null
@@ -432,22 +410,19 @@ class ProxyResponseHandler {
 
   static create (req, resOrSocket, onRes, proxyErrorHandler) {
     const handler = ProxyResponseHandler.pool.pop() || new ProxyResponseHandler()
-    handler.released = false
     handler.req = req
     handler.resOrSocket = resOrSocket
     handler.onRes = onRes
     handler.proxyErrorHandler = proxyErrorHandler
     handler.proxyRes = null
     handler.req.on('close', handler._release)
-    handler.req.on('error', handler._release)
     return handler._handle
   }
 }
 ProxyResponseHandler.pool = []
 
 class ProxyUpgradeHandler {
   constructor () {
-    this.released = true
     this.req = null
     this.resOrSocket = null
     this.proxyErrorHandler = null
@@ -495,18 +470,13 @@ class ProxyUpgradeHandler {
   }
 
   _release () {
-    if (this.released) {
-      return
-    }
-
     if (this.proxyRes) {
       this.proxyRes.destroy()
     }
     if (this.proxySocket) {
       this.proxySocket.destroy()
     }
 
-    this.released = true
     this.req = null
     this.resOrSocket = null
     this.proxyErrorHandler = null
@@ -518,12 +488,10 @@ class ProxyUpgradeHandler {
 
   static create (req, resOrSocket, proxyErrorHandler) {
     const handler = ProxyUpgradeHandler.pool.pop() || new ProxyUpgradeHandler()
-    handler.released = false
     handler.req = req
     handler.resOrSocket = resOrSocket
     handler.proxyErrorHandler = proxyErrorHandler
     handler.req.on('close', handler._release)
-    handler.req.on('error', handler._release)
     return handler._handle
   }
 }