dom.on('error', function(er) {
serverCaught++;
- console.log('server error', er);
+ console.log('horray! got a server error', er);
// try to send a 500. If that fails, oh well.
res.writeHead(500, {'content-type':'text/plain'});
res.end(er.stack || er.message || 'Unknown error');
dom.on('error', function(er) {
clientCaught++;
console.log('client error', er);
- // kill everything.
- dom.dispose();
- });
-
- dom.on('dispose', function() {
- disposeEmit += 1;
+ req.socket.destroy();
});
var req = http.get({ host: 'localhost', port: common.PORT, path: p });
d += c;
});
res.on('end', function() {
+ console.error('trying to parse json', d);
d = JSON.parse(d);
console.log('json!', d);
});
process.on('exit', function() {
assert.equal(serverCaught, 2);
assert.equal(clientCaught, 2);
- assert.equal(disposeEmit, 2);
console.log('ok');
});
setTimeout(function() {
for (var j = 0; j < M; j++) {
http.get({ port: common.PORT, path: '/' }, function(res) {
- console.log(res.statusCode);
- if (++responses == N * M) server.close();
+ console.log('%d %d', responses, res.statusCode);
+ if (++responses == N * M) {
+ console.error('Received all responses, closing server');
+ server.close();
+ }
+ res.resume();
}).on('error', function(e) {
- console.log(e.message);
+ console.log('Error!', e);
process.exit(1);
});
}
server.close();
process.exit();
});
+ res.resume();
});
req.end();
});
method: 'POST'
}, function(res) {
console.log(res.statusCode);
+ res.resume();
}).on('error', function(e) {
console.log(e.message);
process.exit(1);
response.on('end', function() {
s.close();
});
+ response.resume();
});
}
var counter = 0;
- function cb() {
+ function cb(res) {
counter--;
console.log('back from http request. counter = ' + counter);
if (counter === 0) {
httpServer.close();
testHttps();
}
+ res.resume();
}
httpServer.listen(common.PORT, function(er) {
var counter = 0;
- function cb() {
+ function cb(res) {
counter--;
console.log('back from https request. counter = ' + counter);
if (counter === 0) {
httpsServer.close();
console.log('ok');
}
+ res.resume();
}
httpsServer.listen(common.PORT, function(er) {
headers: headers,
port: common.PORT,
agent: agent
- }, function() {
+ }, function(res) {
assert.equal(1, agent.sockets['localhost:' + common.PORT].length);
+ res.resume();
});
request.on('socket', function(s) {
s.on('connect', function() {
headers: headers,
port: common.PORT,
agent: agent
- }, function() {
+ }, function(res) {
assert.equal(1, agent.sockets['localhost:' + common.PORT].length);
+ res.resume();
});
request.on('socket', function(s) {
s.on('connect', function() {
assert.equal(1, agent.sockets['localhost:' + common.PORT].length);
server.close();
});
+ response.resume();
});
request.on('socket', function(s) {
s.on('connect', function() {
}, function(response) {
assert.equal(agent.sockets[name].length, 1);
assert.equal(agent.requests[name].length, 2);
+ response.resume();
});
http.get({
}, function(response) {
assert.equal(agent.sockets[name].length, 1);
assert.equal(agent.requests[name].length, 1);
+ response.resume();
});
http.get({
assert(!agent.requests.hasOwnProperty(name));
server.close();
});
+ response.resume();
});
});
server.close();
}
});
+ res.resume();
}).on('error', function(e) {
console.log(e.message);
process.exit(1);
if (++responses === N) {
server.close();
}
+ res.resume();
});
})(i);
}
assert.ok(!req.end());
server.close();
});
+ res.resume();
});
});
method: 'POST'
}, function(res) {
console.log(res.statusCode);
+ res.resume();
}).on('error', function(e) {
console.log(e.message);
process.exit(1);
server.listen(common.PORT, function() {
// just make a request, other tests handle responses
- http.get({port: common.PORT}, function() {
+ http.get({port: common.PORT}, function(res) {
+ res.resume();
// lazy serial test, becuase we can only call end once per request
test += 1;
// do it again to test .end(Buffer);
- http.get({port: common.PORT}, function() {
+ http.get({port: common.PORT}, function(res) {
+ res.resume();
server.close();
});
});
assert.equal(res.readable, false, 'res.readable set to false after end');
testServer.close();
});
+ res.resume();
});
});
process.exit();
}
});
+ res.resume();
});
outstanding_reqs++;
});
testIdx += 1;
nextTest();
});
+ response.resume();
});
}
server.close();
}
})
+
+ res.resume();
});
req.setTimeout(1000, callback);
port: common.PORT,
rejectUnauthorized: false
}, function(res) {
+ res.resume();
console.log(res.statusCode);
if (++responses == N * M) server.close();
}).on('error', function(e) {
rejectUnauthorized: false
}, function(res) {
server_http.close();
+ res.resume();
});
// These methods should exist on the request and get passed down to the socket
req.setNoDelay(true);
rejectUnauthorized: false
}, function(res) {
server_https.close();
+ res.resume();
});
// These methods should exist on the request and get passed down to the socket
req.setNoDelay(true);
server2.close();
server3.close();
}
+ res.resume();
})
}
if (++responses == N) {
server.close();
}
+ res.resume();
});
assert.equal(req.agent, agent);