summaryrefslogtreecommitdiff
path: root/jstests/replsets/initial_sync4.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/initial_sync4.js')
-rw-r--r--jstests/replsets/initial_sync4.js52
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);