diff options
author | Kat Marchán <kzm@zkat.tech> | 2019-04-05 15:17:30 -0400 |
---|---|---|
committer | Myles Borins <mylesborins@google.com> | 2019-04-06 20:56:17 -0400 |
commit | 033f6b566ebe9689ab1e6e3bbec5f649e6d14896 (patch) | |
tree | e1e849ac11da1dec4b910c3dfa38b4585b364d90 /deps/npm/node_modules/agent-base/index.js | |
parent | 58aaf58406ab52599d51d4e91249776b260487cc (diff) | |
download | android-node-v8-033f6b566ebe9689ab1e6e3bbec5f649e6d14896.tar.gz android-node-v8-033f6b566ebe9689ab1e6e3bbec5f649e6d14896.tar.bz2 android-node-v8-033f6b566ebe9689ab1e6e3bbec5f649e6d14896.zip |
deps: upgrade npm to 6.9.0
Co-authored-by: Myles Borins <mylesborins@google.com>
PR-URL: https://github.com/nodejs/node/pull/26244
Reviewed-By: Myles Borins <myles.borins@gmail.com>
Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
Diffstat (limited to 'deps/npm/node_modules/agent-base/index.js')
-rw-r--r-- | deps/npm/node_modules/agent-base/index.js | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/deps/npm/node_modules/agent-base/index.js b/deps/npm/node_modules/agent-base/index.js index b1f42e6317..0ee6b29699 100644 --- a/deps/npm/node_modules/agent-base/index.js +++ b/deps/npm/node_modules/agent-base/index.js @@ -94,6 +94,7 @@ Agent.prototype.addRequest = function addRequest(req, _opts) { let timeout; let timedOut = false; const timeoutMs = this.timeout; + const freeSocket = this.freeSocket; function onerror(err) { if (req._hadError) return; @@ -133,10 +134,14 @@ Agent.prototype.addRequest = function addRequest(req, _opts) { // responsibility for this `req` to the Agent from here on socket.addRequest(req, opts); } else if (socket) { + function onfree() { + freeSocket(socket, opts); + } + socket.on('free', onfree); req.onSocket(socket); } else { const err = new Error( - `no Duplex stream was returned to agent-base for \`${req.method} ${req.path}\`` + 'no Duplex stream was returned to agent-base for `' + req.method + ' ' + req.path + '`' ); onerror(err); } @@ -158,3 +163,8 @@ Agent.prototype.addRequest = function addRequest(req, _opts) { Promise.reject(err).catch(callbackError); } }; + +Agent.prototype.freeSocket = function freeSocket(socket, opts) { + // TODO reuse sockets + socket.destroy(); +}; |