In tests, wait for 'listening' before connecting

This commit is contained in:
Ryan Dahl 2010-04-05 11:32:18 -07:00
parent b0d1d6c2b9
commit 0301adf9b4
2 changed files with 28 additions and 24 deletions

View File

@ -42,16 +42,18 @@ function runAb(opts, callback) {
}); });
} }
runAb("-k -c 100 -t 2", function (reqSec, keepAliveRequests) { server.addListener('listening', function () {
keepAliveReqSec = reqSec; runAb("-k -c 100 -t 2", function (reqSec, keepAliveRequests) {
assert.equal(true, keepAliveRequests > 0); keepAliveReqSec = reqSec;
puts("keep-alive: " + keepAliveReqSec + " req/sec"); assert.equal(true, keepAliveRequests > 0);
puts("keep-alive: " + keepAliveReqSec + " req/sec");
runAb("-c 100 -t 2", function (reqSec, keepAliveRequests) { runAb("-c 100 -t 2", function (reqSec, keepAliveRequests) {
normalReqSec = reqSec; normalReqSec = reqSec;
assert.equal(0, keepAliveRequests); assert.equal(0, keepAliveRequests);
puts("normal: " + normalReqSec + " req/sec"); puts("normal: " + normalReqSec + " req/sec");
server.close(); server.close();
});
}); });
}); });

View File

@ -16,22 +16,24 @@ server.listen(PORT);
var got_good_server_content = false; var got_good_server_content = false;
var bad_server_got_error = false; var bad_server_got_error = false;
http.cat("http://localhost:"+PORT+"/", "utf8", function (err, content) { server.addListener('listening', function () {
if (err) { http.cat("http://localhost:"+PORT+"/", "utf8", function (err, content) {
throw err; if (err) {
} else { throw err;
puts("got response"); } else {
got_good_server_content = true; puts("got response");
assert.equal(body, content); got_good_server_content = true;
server.close(); assert.equal(body, content);
} server.close();
}); }
});
http.cat("http://localhost:12312/", "utf8", function (err, content) { http.cat("http://localhost:12312/", "utf8", function (err, content) {
if (err) { if (err) {
puts("got error (this should happen)"); puts("got error (this should happen)");
bad_server_got_error = true; bad_server_got_error = true;
} }
});
}); });
process.addListener("exit", function () { process.addListener("exit", function () {