diff options
Diffstat (limited to 'lib/http.js')
-rw-r--r-- | lib/http.js | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/lib/http.js b/lib/http.js index 4f9d61203..3bb24cbef 100644 --- a/lib/http.js +++ b/lib/http.js @@ -1152,12 +1152,6 @@ Agent.prototype.appendMessage = function(options) { this.queue.push(req); req._queue = this.queue; - /* - req.on('finish', function () { - self._cycle(); - }); - */ - this._cycle(); return req; @@ -1374,8 +1368,6 @@ Agent.prototype._cycle = function() { var first = this.queue[0]; if (!first) return; - var haveConnectingSocket = false; - // First try to find an available socket. for (var i = 0; i < this.sockets.length; i++) { var socket = this.sockets[i]; @@ -1395,13 +1387,11 @@ Agent.prototype._cycle = function() { self._cycle(); // try to dispatch another return; } - - if (socket._httpConnecting) haveConnectingSocket = true; } // If no sockets are connecting, and we have space for another we should // be starting a new connection to handle this request. - if (!haveConnectingSocket && this.sockets.length < this.maxSockets) { + if (this.sockets.length < this.maxSockets) { this._establishNewConnection(); } |