summaryrefslogtreecommitdiff
path: root/jstests/replsets/initial_sync_fail_insert_once.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/initial_sync_fail_insert_once.js')
-rw-r--r--jstests/replsets/initial_sync_fail_insert_once.js46
1 files changed, 23 insertions, 23 deletions
diff --git a/jstests/replsets/initial_sync_fail_insert_once.js b/jstests/replsets/initial_sync_fail_insert_once.js
index d85f97f5a63..0a1f0a11a8a 100644
--- a/jstests/replsets/initial_sync_fail_insert_once.js
+++ b/jstests/replsets/initial_sync_fail_insert_once.js
@@ -5,33 +5,33 @@
*/
(function() {
- var name = 'initial_sync_fail_insert_once';
- var replSet = new ReplSetTest(
- {name: name, nodes: 2, nodeOptions: {setParameter: "numInitialSyncAttempts=3"}});
+var name = 'initial_sync_fail_insert_once';
+var replSet = new ReplSetTest(
+ {name: name, nodes: 2, nodeOptions: {setParameter: "numInitialSyncAttempts=3"}});
- replSet.startSet();
- replSet.initiate();
- var primary = replSet.getPrimary();
- var secondary = replSet.getSecondary();
+replSet.startSet();
+replSet.initiate();
+var primary = replSet.getPrimary();
+var secondary = replSet.getSecondary();
- var coll = primary.getDB('test').getCollection(name);
- assert.writeOK(coll.insert({_id: 0, x: 1}, {writeConcern: {w: 2}}));
+var coll = primary.getDB('test').getCollection(name);
+assert.writeOK(coll.insert({_id: 0, x: 1}, {writeConcern: {w: 2}}));
- jsTest.log("Enabling Failpoint failCollectionInserts on " + tojson(secondary));
- assert.commandWorked(secondary.getDB("admin").adminCommand({
- configureFailPoint: "failCollectionInserts",
- mode: {times: 2},
- data: {collectionNS: coll.getFullName()}
- }));
+jsTest.log("Enabling Failpoint failCollectionInserts on " + tojson(secondary));
+assert.commandWorked(secondary.getDB("admin").adminCommand({
+ configureFailPoint: "failCollectionInserts",
+ mode: {times: 2},
+ data: {collectionNS: coll.getFullName()}
+}));
- jsTest.log("Re-syncing " + tojson(secondary));
- secondary = replSet.restart(secondary, {startClean: true});
- replSet.awaitReplication();
- replSet.awaitSecondaryNodes();
+jsTest.log("Re-syncing " + tojson(secondary));
+secondary = replSet.restart(secondary, {startClean: true});
+replSet.awaitReplication();
+replSet.awaitSecondaryNodes();
- assert.eq(1, secondary.getDB("test")[name].count());
- assert.docEq({_id: 0, x: 1}, secondary.getDB("test")[name].findOne());
+assert.eq(1, secondary.getDB("test")[name].count());
+assert.docEq({_id: 0, x: 1}, secondary.getDB("test")[name].findOne());
- jsTest.log("Stopping repl set test; finished.");
- replSet.stopSet();
+jsTest.log("Stopping repl set test; finished.");
+replSet.stopSet();
})();