summaryrefslogtreecommitdiff
path: root/jstests/replsets/initial_sync_update_missing_doc2.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/initial_sync_update_missing_doc2.js')
-rw-r--r--jstests/replsets/initial_sync_update_missing_doc2.js67
1 files changed, 34 insertions, 33 deletions
diff --git a/jstests/replsets/initial_sync_update_missing_doc2.js b/jstests/replsets/initial_sync_update_missing_doc2.js
index 0d4878ea01c..bd3b2d8957a 100644
--- a/jstests/replsets/initial_sync_update_missing_doc2.js
+++ b/jstests/replsets/initial_sync_update_missing_doc2.js
@@ -13,49 +13,50 @@
*/
(function() {
- load("jstests/replsets/libs/initial_sync_update_missing_doc.js");
- load("jstests/libs/check_log.js");
+load("jstests/replsets/libs/initial_sync_update_missing_doc.js");
+load("jstests/libs/check_log.js");
- var name = 'initial_sync_update_missing_doc2';
- var replSet = new ReplSetTest({
- name: name,
- nodes: 1,
- });
+var name = 'initial_sync_update_missing_doc2';
+var replSet = new ReplSetTest({
+ name: name,
+ nodes: 1,
+});
- replSet.startSet();
- replSet.initiate();
+replSet.startSet();
+replSet.initiate();
- const primary = replSet.getPrimary();
- const dbName = 'test';
+const primary = replSet.getPrimary();
+const dbName = 'test';
- var coll = primary.getDB(dbName).getCollection(name);
- assert.commandWorked(coll.insert({_id: 0, x: 1}));
+var coll = primary.getDB(dbName).getCollection(name);
+assert.commandWorked(coll.insert({_id: 0, x: 1}));
- // Add a secondary node with priority: 0 and votes: 0 so that we prevent elections while
- // it is syncing from the primary.
- const secondaryConfig = {rsConfig: {votes: 0, priority: 0}};
- const secondary = reInitiateSetWithSecondary(replSet, secondaryConfig);
+// Add a secondary node with priority: 0 and votes: 0 so that we prevent elections while
+// it is syncing from the primary.
+const secondaryConfig = {
+ rsConfig: {votes: 0, priority: 0}
+};
+const secondary = reInitiateSetWithSecondary(replSet, secondaryConfig);
- // Update and remove document on primary.
- updateRemove(coll, {_id: 0});
+// Update and remove document on primary.
+updateRemove(coll, {_id: 0});
- turnOffHangBeforeCopyingDatabasesFailPoint(secondary);
+turnOffHangBeforeCopyingDatabasesFailPoint(secondary);
- // Re-insert deleted document on the sync source. The secondary should be able to fetch and
- // insert this document after failing to apply the udpate.
- assert.commandWorked(coll.insert({_id: 0, x: 3}));
+// Re-insert deleted document on the sync source. The secondary should be able to fetch and
+// insert this document after failing to apply the udpate.
+assert.commandWorked(coll.insert({_id: 0, x: 3}));
- var res = assert.commandWorked(secondary.adminCommand({replSetGetStatus: 1}));
- assert.eq(res.initialSyncStatus.fetchedMissingDocs, 0);
- var firstOplogEnd = res.initialSyncStatus.initialSyncOplogEnd;
+var res = assert.commandWorked(secondary.adminCommand({replSetGetStatus: 1}));
+assert.eq(res.initialSyncStatus.fetchedMissingDocs, 0);
+var firstOplogEnd = res.initialSyncStatus.initialSyncOplogEnd;
- // Temporarily increase log levels so that we can see the 'Inserted missing document' log line.
- secondary.getDB('test').setLogLevel(1, 'replication');
- turnOffHangBeforeGettingMissingDocFailPoint(primary, secondary, name, 1 /* numInserted */);
- secondary.getDB('test').setLogLevel(0, 'replication');
+// Temporarily increase log levels so that we can see the 'Inserted missing document' log line.
+secondary.getDB('test').setLogLevel(1, 'replication');
+turnOffHangBeforeGettingMissingDocFailPoint(primary, secondary, name, 1 /* numInserted */);
+secondary.getDB('test').setLogLevel(0, 'replication');
- finishAndValidate(replSet, name, firstOplogEnd, 1 /* numInserted */, 1 /* numDocuments */);
-
- replSet.stopSet();
+finishAndValidate(replSet, name, firstOplogEnd, 1 /* numInserted */, 1 /* numDocuments */);
+replSet.stopSet();
})();