diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/multiVersion/3_upgrade_replset.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/multiVersion/3_upgrade_replset.js')
-rw-r--r-- | jstests/multiVersion/3_upgrade_replset.js | 83 |
1 files changed, 38 insertions, 45 deletions
diff --git a/jstests/multiVersion/3_upgrade_replset.js b/jstests/multiVersion/3_upgrade_replset.js index d713a59bb43..45d3a7f4844 100644 --- a/jstests/multiVersion/3_upgrade_replset.js +++ b/jstests/multiVersion/3_upgrade_replset.js @@ -2,84 +2,77 @@ // Tests upgrading a replica set // -load( './jstests/multiVersion/libs/multi_rs.js' ); -load( './jstests/libs/test_background_ops.js' ); +load('./jstests/multiVersion/libs/multi_rs.js'); +load('./jstests/libs/test_background_ops.js'); var oldVersion = "last-stable"; -var nodes = { n1 : { binVersion : oldVersion }, - n2 : { binVersion : oldVersion }, - a3 : { binVersion : oldVersion } }; +var nodes = { + n1: {binVersion: oldVersion}, + n2: {binVersion: oldVersion}, + a3: {binVersion: oldVersion} +}; -var rst = new ReplSetTest({ nodes : nodes }); +var rst = new ReplSetTest({nodes: nodes}); rst.startSet(); rst.initiate(); // Wait for a primary node... var primary = rst.getPrimary(); -var otherOpConn = new Mongo( rst.getURL() ); +var otherOpConn = new Mongo(rst.getURL()); var insertNS = "test.foo"; +jsTest.log("Starting parallel operations during upgrade..."); -jsTest.log( "Starting parallel operations during upgrade..." ); - -function findAndInsert( rsURL, coll ){ - - var coll = new Mongo( rsURL ).getCollection( coll + "" ); +function findAndInsert(rsURL, coll) { + var coll = new Mongo(rsURL).getCollection(coll + ""); var count = 0; - - jsTest.log( "Starting finds and inserts..." ); - - while( ! isFinished() ){ - - try{ - - coll.insert({ _id : count, hello : "world" }); - assert.eq( null, coll.getDB().getLastError() ); - assert.neq( null, coll.findOne({ _id : count }) ); - } - catch( e ){ - printjson( e ); + + jsTest.log("Starting finds and inserts..."); + + while (!isFinished()) { + try { + coll.insert({_id: count, hello: "world"}); + assert.eq(null, coll.getDB().getLastError()); + assert.neq(null, coll.findOne({_id: count})); + } catch (e) { + printjson(e); } - + count++; } - - jsTest.log( "Finished finds and inserts..." ); + + jsTest.log("Finished finds and inserts..."); return count; } -var joinFindInsert = - startParallelOps( primary, // The connection where the test info is passed and stored - findAndInsert, - [ rst.getURL(), insertNS ] ); - +var joinFindInsert = + startParallelOps(primary, // The connection where the test info is passed and stored + findAndInsert, + [rst.getURL(), insertNS]); -jsTest.log( "Upgrading replica set..." ); +jsTest.log("Upgrading replica set..."); -rst.upgradeSet({ binVersion: "latest" }); +rst.upgradeSet({binVersion: "latest"}); -jsTest.log( "Replica set upgraded." ); +jsTest.log("Replica set upgraded."); // Wait for primary var primary = rst.getPrimary(); -printjson( rst.status() ); - +printjson(rst.status()); // Allow more valid writes to go through -sleep( 10 * 1000 ); - +sleep(10 * 1000); joinFindInsert(); -var totalInserts = primary.getCollection( insertNS ).find().sort({ _id : -1 }).next()._id + 1; -var dataFound = primary.getCollection( insertNS ).count(); +var totalInserts = primary.getCollection(insertNS).find().sort({_id: -1}).next()._id + 1; +var dataFound = primary.getCollection(insertNS).count(); -jsTest.log( "Found " + dataFound + " docs out of " + tojson( totalInserts ) + " inserted." ); +jsTest.log("Found " + dataFound + " docs out of " + tojson(totalInserts) + " inserted."); -assert.gt( dataFound / totalInserts, 0.5 ); +assert.gt(dataFound / totalInserts, 0.5); rst.stopSet(); - |