aboutsummaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/agent-base/index.js
diff options
context:
space:
mode:
authorKat Marchán <kzm@zkat.tech>2019-04-05 15:17:30 -0400
committerMyles Borins <mylesborins@google.com>2019-04-06 20:56:17 -0400
commit033f6b566ebe9689ab1e6e3bbec5f649e6d14896 (patch)
treee1e849ac11da1dec4b910c3dfa38b4585b364d90 /deps/npm/node_modules/agent-base/index.js
parent58aaf58406ab52599d51d4e91249776b260487cc (diff)
downloadandroid-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.js12
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();
+};