summaryrefslogtreecommitdiff
path: root/lib/http.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/http.js')
-rw-r--r--lib/http.js12
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();
}