From 39877185399da3b01db03ebcb33e75de48c47a0a Mon Sep 17 00:00:00 2001 From: kpdecker Date: Wed, 30 Apr 2014 09:20:25 -0400 Subject: [PATCH 1/2] http: Optimize queued client aborts Avoid sending unsent data and destroying otherwise legitimate sockets for requests that are aborted while still in the agent queue. This reduces stress on upstream systems who will likely respond to the request but client app already knows that it will be dropped on the floor and also helps avoid killing keep-alive connections. --- lib/_http_client.js | 19 +++-- test/simple/test-http-abort-queued.js | 103 ++++++++++++++++++++++++++ 2 files changed, 116 insertions(+), 6 deletions(-) create mode 100644 test/simple/test-http-abort-queued.js diff --git a/lib/_http_client.js b/lib/_http_client.js index 50f10d1684eb..dbdc410c287e 100644 --- a/lib/_http_client.js +++ b/lib/_http_client.js @@ -174,6 +174,8 @@ util.inherits(ClientRequest, OutgoingMessage); exports.ClientRequest = ClientRequest; +ClientRequest.prototype.aborted = false; + ClientRequest.prototype._finish = function() { DTRACE_HTTP_CLIENT_REQUEST(this, this.connection); COUNTER_HTTP_CLIENT_REQUEST(); @@ -186,6 +188,9 @@ ClientRequest.prototype._implicitHeader = function() { }; ClientRequest.prototype.abort = function() { + // Mark as aborting so we can avoid sending queued request data + this.aborted = true; + // If we're aborting, we don't care about any more response data. if (this.res) this.res._dump(); @@ -194,14 +199,11 @@ ClientRequest.prototype.abort = function() { res._dump(); }); + // In the event that we don't have a socket, we will pop out of + // the request queue through handling in onSocket. if (this.socket) { // in-progress this.socket.destroy(); - } else { - // haven't been assigned a socket yet. - // this could be more efficient, it could - // remove itself from the pending requests - this._deferToConnect('destroy', []); } }; @@ -485,7 +487,12 @@ ClientRequest.prototype.onSocket = function(socket) { var req = this; process.nextTick(function() { - tickOnSocket(req, socket); + if (req.aborted) { + // If we were aborted while waiting for a socket, skip the whole thing. + socket.emit('free'); + } else { + tickOnSocket(req, socket); + } }); }; diff --git a/test/simple/test-http-abort-queued.js b/test/simple/test-http-abort-queued.js new file mode 100644 index 000000000000..5d829155738b --- /dev/null +++ b/test/simple/test-http-abort-queued.js @@ -0,0 +1,103 @@ +// Copyright Joyent, Inc. and other Node contributors. +// +// Permission is hereby granted, free of charge, to any person obtaining a +// copy of this software and associated documentation files (the +// "Software"), to deal in the Software without restriction, including +// without limitation the rights to use, copy, modify, merge, publish, +// distribute, sublicense, and/or sell copies of the Software, and to permit +// persons to whom the Software is furnished to do so, subject to the +// following conditions: +// +// The above copyright notice and this permission notice shall be included +// in all copies or substantial portions of the Software. +// +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS +// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF +// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN +// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, +// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR +// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE +// USE OR OTHER DEALINGS IN THE SOFTWARE. + +var assert = require('assert'), + http = require('http'); + +var complete; + +var server = http.createServer(function (req, res) { + // We should not see the queued /thatotherone request within the server + // as it should be aborted before it is sent. + assert.equal(req.url, '/'); + + res.writeHead(200); + res.write('foo'); + + complete = complete || function () { + res.end(); + }; +}); + + +server.listen(0, function () { + console.log('listen', server.address().port); + + var agent = new http.Agent({maxSockets: 1}); + assert.equal(Object.keys(agent.sockets).length, 0); + + var options = { + hostname: 'localhost', + port: server.address().port, + method: 'GET', + path: '/', + agent: agent + }; + + var req1 = http.request(options); + req1.on('response', function(res1) { + assert.equal(Object.keys(agent.sockets).length, 1); + assert.equal(Object.keys(agent.requests).length, 0); + + var req2 = http.request({ + method: 'GET', + host: 'localhost', + port: server.address().port, + path: '/thatotherone', + agent: agent + }); + assert.equal(Object.keys(agent.sockets).length, 1); + assert.equal(Object.keys(agent.requests).length, 1); + + req2.on('error', function(err) { + // This is expected in response to our explicit abort call + assert.equal(err.code, 'ECONNRESET'); + }); + + req2.end(); + req2.abort(); + + assert.equal(Object.keys(agent.sockets).length, 1); + assert.equal(Object.keys(agent.requests).length, 1); + + console.log('Got res: ' + res1.statusCode); + console.dir(res1.headers); + + res1.on('data', function(chunk) { + console.log('Read ' + chunk.length + ' bytes'); + console.log(' chunk=%j', chunk.toString()); + complete(); + }); + + res1.on('end', function() { + console.log('Response ended.'); + + setTimeout(function() { + assert.equal(Object.keys(agent.sockets).length, 0); + assert.equal(Object.keys(agent.requests).length, 0); + + server.close(); + }, 1000); + }); + }); + + req1.end(); +}); From 3b69889c87a083ff4e9ad1cd6da17d703c430d81 Mon Sep 17 00:00:00 2001 From: kpdecker Date: Thu, 22 May 2014 11:58:22 -0500 Subject: [PATCH 2/2] http: Use Date.now for client aborted flag Adds truthy flag that can be used for debugging as well. Per review by @tjfontaine. --- lib/_http_client.js | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/_http_client.js b/lib/_http_client.js index dbdc410c287e..1dcf7f0273e5 100644 --- a/lib/_http_client.js +++ b/lib/_http_client.js @@ -174,7 +174,7 @@ util.inherits(ClientRequest, OutgoingMessage); exports.ClientRequest = ClientRequest; -ClientRequest.prototype.aborted = false; +ClientRequest.prototype.aborted = undefined; ClientRequest.prototype._finish = function() { DTRACE_HTTP_CLIENT_REQUEST(this, this.connection); @@ -189,7 +189,9 @@ ClientRequest.prototype._implicitHeader = function() { ClientRequest.prototype.abort = function() { // Mark as aborting so we can avoid sending queued request data - this.aborted = true; + // This is used as a truthy flag elsewhere. The use of Date.now is for debugging + // purposes only. + this.aborted = Date.now(); // If we're aborting, we don't care about any more response data. if (this.res)