summaryrefslogtreecommitdiff
path: root/jstests/noPassthrough/index_stepdown_during_scan.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthrough/index_stepdown_during_scan.js')
-rw-r--r--jstests/noPassthrough/index_stepdown_during_scan.js81
1 files changed, 40 insertions, 41 deletions
diff --git a/jstests/noPassthrough/index_stepdown_during_scan.js b/jstests/noPassthrough/index_stepdown_during_scan.js
index 5eebaa9f2d2..e8d003506e9 100644
--- a/jstests/noPassthrough/index_stepdown_during_scan.js
+++ b/jstests/noPassthrough/index_stepdown_during_scan.js
@@ -4,57 +4,56 @@
* @tags: [requires_replication]
*/
(function() {
- "use strict";
-
- load('jstests/noPassthrough/libs/index_build.js');
-
- const rst = new ReplSetTest({
- nodes: [
- {},
- {
- // Disallow elections on secondary.
- rsConfig: {
- priority: 0,
- votes: 0,
- },
+"use strict";
+
+load('jstests/noPassthrough/libs/index_build.js');
+
+const rst = new ReplSetTest({
+ nodes: [
+ {},
+ {
+ // Disallow elections on secondary.
+ rsConfig: {
+ priority: 0,
+ votes: 0,
},
- ]
- });
- const nodes = rst.startSet();
- rst.initiate();
+ },
+ ]
+});
+const nodes = rst.startSet();
+rst.initiate();
- const primary = rst.getPrimary();
- const testDB = primary.getDB('test');
- const coll = testDB.getCollection('test');
+const primary = rst.getPrimary();
+const testDB = primary.getDB('test');
+const coll = testDB.getCollection('test');
- assert.writeOK(coll.insert({a: 1}));
+assert.writeOK(coll.insert({a: 1}));
- IndexBuildTest.pauseIndexBuilds(primary);
+IndexBuildTest.pauseIndexBuilds(primary);
- const createIdx = IndexBuildTest.startIndexBuild(primary, coll.getFullName(), {a: 1});
+const createIdx = IndexBuildTest.startIndexBuild(primary, coll.getFullName(), {a: 1});
- // When the index build starts, find its op id.
- const opId = IndexBuildTest.waitForIndexBuildToScanCollection(testDB, coll.getName(), 'a_1');
+// When the index build starts, find its op id.
+const opId = IndexBuildTest.waitForIndexBuildToScanCollection(testDB, coll.getName(), 'a_1');
- IndexBuildTest.assertIndexBuildCurrentOpContents(testDB, opId);
+IndexBuildTest.assertIndexBuildCurrentOpContents(testDB, opId);
- try {
- // Step down the primary.
- assert.commandWorked(primary.adminCommand({replSetStepDown: 60, force: true}));
- } finally {
- IndexBuildTest.resumeIndexBuilds(primary);
- }
+try {
+ // Step down the primary.
+ assert.commandWorked(primary.adminCommand({replSetStepDown: 60, force: true}));
+} finally {
+ IndexBuildTest.resumeIndexBuilds(primary);
+}
- // Wait for the index build to stop.
- IndexBuildTest.waitForIndexBuildToStop(testDB);
+// Wait for the index build to stop.
+IndexBuildTest.waitForIndexBuildToStop(testDB);
- const exitCode = createIdx({checkExitSuccess: false});
- assert.neq(
- 0, exitCode, 'expected shell to exit abnormally due to index build being terminated');
+const exitCode = createIdx({checkExitSuccess: false});
+assert.neq(0, exitCode, 'expected shell to exit abnormally due to index build being terminated');
- // Check that no new index has been created. This verifies that the index build was aborted
- // rather than successfully completed.
- IndexBuildTest.assertIndexes(coll, 1, ['_id_']);
+// Check that no new index has been created. This verifies that the index build was aborted
+// rather than successfully completed.
+IndexBuildTest.assertIndexes(coll, 1, ['_id_']);
- rst.stopSet();
+rst.stopSet();
})();