diff options
Diffstat (limited to 'jstests/replsets/startParallelShell.js')
-rw-r--r-- | jstests/replsets/startParallelShell.js | 52 |
1 files changed, 26 insertions, 26 deletions
diff --git a/jstests/replsets/startParallelShell.js b/jstests/replsets/startParallelShell.js index 0027c5600e3..cb1838c392f 100644 --- a/jstests/replsets/startParallelShell.js +++ b/jstests/replsets/startParallelShell.js @@ -3,34 +3,34 @@ var db; (function() { - 'use strict'; +'use strict'; - const setName = 'rs0'; - const replSet = new ReplSetTest({name: setName, nodes: 3}); - const nodes = replSet.nodeList(); - replSet.startSet(); - replSet.initiate(); +const setName = 'rs0'; +const replSet = new ReplSetTest({name: setName, nodes: 3}); +const nodes = replSet.nodeList(); +replSet.startSet(); +replSet.initiate(); - const url = replSet.getURL(); - print("* Connecting to " + url); - const mongo = new Mongo(url); - db = mongo.getDB('admin'); - assert.eq(url, mongo.host, "replSet.getURL() should match active connection string"); +const url = replSet.getURL(); +print("* Connecting to " + url); +const mongo = new Mongo(url); +db = mongo.getDB('admin'); +assert.eq(url, mongo.host, "replSet.getURL() should match active connection string"); - print("* Starting parallel shell on --host " + db.getMongo().host); - var awaitShell = startParallelShell('db.coll0.insert({test: "connString only"});'); - assert.soon(function() { - return db.coll0.find({test: "connString only"}).count() === 1; - }); - awaitShell(); +print("* Starting parallel shell on --host " + db.getMongo().host); +var awaitShell = startParallelShell('db.coll0.insert({test: "connString only"});'); +assert.soon(function() { + return db.coll0.find({test: "connString only"}).count() === 1; +}); +awaitShell(); - const uri = new MongoURI(url); - const port0 = uri.servers[0].port; - print("* Starting parallel shell w/ --port " + port0); - awaitShell = startParallelShell('db.coll0.insert({test: "explicit port"});', port0); - assert.soon(function() { - return db.coll0.find({test: "explicit port"}).count() === 1; - }); - awaitShell(); - replSet.stopSet(); +const uri = new MongoURI(url); +const port0 = uri.servers[0].port; +print("* Starting parallel shell w/ --port " + port0); +awaitShell = startParallelShell('db.coll0.insert({test: "explicit port"});', port0); +assert.soon(function() { + return db.coll0.find({test: "explicit port"}).count() === 1; +}); +awaitShell(); +replSet.stopSet(); })(); |