diff options
Diffstat (limited to 'jstests/multiVersion/minor_version_upgrade_replset.js')
-rw-r--r-- | jstests/multiVersion/minor_version_upgrade_replset.js | 64 |
1 files changed, 32 insertions, 32 deletions
diff --git a/jstests/multiVersion/minor_version_upgrade_replset.js b/jstests/multiVersion/minor_version_upgrade_replset.js index efabceffbf1..1c153a1e675 100644 --- a/jstests/multiVersion/minor_version_upgrade_replset.js +++ b/jstests/multiVersion/minor_version_upgrade_replset.js @@ -2,85 +2,85 @@ // 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' ); // 3.2.1 is the final version to use the old style replSetUpdatePosition command. var oldVersion = "3.2.1"; var nodes = { n1 : { binVersion : oldVersion }, n2 : { binVersion : oldVersion }, - a3 : { binVersion : oldVersion } } + a3 : { binVersion : oldVersion } }; -var rst = new ReplSetTest({ nodes : nodes }) +var rst = new ReplSetTest({ nodes : nodes }); -rst.startSet() -rst.initiate() +rst.startSet(); +rst.initiate(); // Wait for a primary node... -var primary = rst.getPrimary() -var otherOpConn = new Mongo( rst.getURL() ) -var insertNS = "test.foo" +var primary = rst.getPrimary(); +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 + "" ) - var count = 0 + var coll = new Mongo( rsURL ).getCollection( coll + "" ); + var count = 0; - jsTest.log( "Starting finds and inserts..." ) + 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 }) ) + coll.insert({ _id : count, hello : "world" }); + assert.eq( null, coll.getDB().getLastError() ); + assert.neq( null, coll.findOne({ _id : count }) ); } catch( e ){ - printjson( e ) + printjson( e ); } - count++ + count++; } - jsTest.log( "Finished finds and inserts..." ) - return count + 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 ] ) + [ rst.getURL(), insertNS ] ); -jsTest.log( "Upgrading replica set..." ) +jsTest.log( "Upgrading replica set..." ); rst.upgradeSet({ binVersion: "latest" }); -jsTest.log( "Replica set upgraded." ) +jsTest.log( "Replica set upgraded." ); // Wait for primary -var primary = rst.getPrimary() +var primary = rst.getPrimary(); -printjson( rst.status() ) +printjson( rst.status() ); // Allow more valid writes to go through -sleep( 10 * 1000 ) +sleep( 10 * 1000 ); -joinFindInsert() +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() +rst.stopSet(); |