diff options
Diffstat (limited to 'jstests/replsets/initial_sync4.js')
-rw-r--r-- | jstests/replsets/initial_sync4.js | 52 |
1 files changed, 25 insertions, 27 deletions
diff --git a/jstests/replsets/initial_sync4.js b/jstests/replsets/initial_sync4.js index c25bc94c4ed..c2fcede9969 100644 --- a/jstests/replsets/initial_sync4.js +++ b/jstests/replsets/initial_sync4.js @@ -4,7 +4,7 @@ load("jstests/replsets/rslib.js"); basename = "jstests_initsync4"; print("1. Bring up set"); -replTest = new ReplSetTest( {name: basename, nodes: 1} ); +replTest = new ReplSetTest({name: basename, nodes: 1}); replTest.startSet(); replTest.initiate(); @@ -14,10 +14,10 @@ mc = m.getDB("d")["c"]; print("2. Insert some data"); N = 5000; -mc.ensureIndex({x:1}); +mc.ensureIndex({x: 1}); var bulk = mc.initializeUnorderedBulkOp(); -for( i = 0; i < N; ++i ) { - bulk.insert({ _id: i, x: i, a: {} }); +for (i = 0; i < N; ++i) { + bulk.insert({_id: i, x: i, a: {}}); } assert.writeOK(bulk.execute()); @@ -31,11 +31,10 @@ s = MongoRunner.runMongod({replSet: basename, oplogSize: 2}); var config = replTest.getReplSetConfig(); config.version = 2; -config.members.push({_id:2, host:hostname+":"+s.port}); +config.members.push({_id: 2, host: hostname + ":" + s.port}); try { - m.getDB("admin").runCommand({replSetReconfig:config}); -} -catch(e) { + m.getDB("admin").runCommand({replSetReconfig: config}); +} catch (e) { print(e); } reconnect(s); @@ -45,39 +44,38 @@ print("5. Wait for new node to start cloning"); s.setSlaveOk(); sc = s.getDB("d")["c"]; -wait( function() { printjson( sc.stats() ); return sc.stats().count > 0; } ); +wait(function() { + printjson(sc.stats()); + return sc.stats().count > 0; +}); print("6. Start updating documents on primary"); -for( i = N-1; i >= N-10000; --i ) { +for (i = N - 1; i >= N - 10000; --i) { // If the document is cloned as {a:1}, the {$set:{'a.b':1}} modifier will uassert. - mc.update( {_id:i}, {$set:{'a.b':1}} ); - mc.update( {_id:i}, {$set:{a:1}} ); + mc.update({_id: i}, {$set: {'a.b': 1}}); + mc.update({_id: i}, {$set: {a: 1}}); } -for ( i = N; i < N*2; i++ ) { - mc.insert( { _id : i, x : i } ); +for (i = N; i < N * 2; i++) { + mc.insert({_id: i, x: i}); } -assert.eq( N*2, mc.count() ); +assert.eq(N * 2, mc.count()); print("7. Wait for new node to become SECONDARY"); wait(function() { - var status = s.getDB("admin").runCommand({replSetGetStatus:1}); - printjson(status); - return status.members && - (status.members[1].state == 2); - }); + var status = s.getDB("admin").runCommand({replSetGetStatus: 1}); + printjson(status); + return status.members && (status.members[1].state == 2); +}); print("8. Wait for new node to have all the data"); wait(function() { return sc.count() == mc.count(); -} ); - +}); -assert.eq( mc.getIndexKeys().length, - sc.getIndexKeys().length ); +assert.eq(mc.getIndexKeys().length, sc.getIndexKeys().length); -assert.eq( mc.find().sort( { x : 1 } ).itcount(), - sc.find().sort( { x : 1 } ).itcount() ); +assert.eq(mc.find().sort({x: 1}).itcount(), sc.find().sort({x: 1}).itcount()); -replTest.stopSet( 15 ); +replTest.stopSet(15); |