summaryrefslogtreecommitdiff
path: root/tests/http/agent.js
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2015-11-02 12:31:34 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2015-11-02 12:31:34 -0800
commite53ef9642e0201880672699ca12edd50d103be9e (patch)
treea3c1a66fba8f5a7628a3ceea830537f2f286471e /tests/http/agent.js
parent29249db5d295b72cd28f73550ff7727b34fd5c9a (diff)
downloadinfinitytier-e53ef9642e0201880672699ca12edd50d103be9e.tar.gz
infinitytier-e53ef9642e0201880672699ca12edd50d103be9e.zip
test stuff.
Diffstat (limited to 'tests/http/agent.js')
-rw-r--r--tests/http/agent.js26
1 files changed, 18 insertions, 8 deletions
diff --git a/tests/http/agent.js b/tests/http/agent.js
index d0c33917..e11fed60 100644
--- a/tests/http/agent.js
+++ b/tests/http/agent.js
@@ -214,12 +214,22 @@ app.get('/',function(req,res) {
});
var expressServer = app.listen(AGENT_PORT,function () {
- registerAndGetPeers(function(err,peers) {
- if (err) {
- console.error('FATAL: unable to contact or query server: '+err.toString());
- process.exit(1);
- }
- doTestsAndReport();
- setInterval(doTestsAndReport,TEST_INTERVAL);
- });
+ var serverUp = false;
+ async.whilst(
+ function() { return (!serverUp); },
+ function(nextTry) {
+ registerAndGetPeers(function(err,peers) {
+ if ((err)||(!peers)) {
+ setTimeout(nextTry,1000);
+ } else {
+ serverUp = true;
+ return nextTry(null);
+ }
+ });
+ },
+ function(err) {
+ console.log('Server up, starting!');
+ doTestsAndReport();
+ setInterval(doTestsAndReport,TEST_INTERVAL);
+ });
});