diff options
Diffstat (limited to 'jstests/noPassthrough/index_stepdown_during_scan.js')
-rw-r--r-- | jstests/noPassthrough/index_stepdown_during_scan.js | 81 |
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(); })(); |