diff options
Diffstat (limited to 'jstests/noPassthrough/index_stepdown_after_init.js')
-rw-r--r-- | jstests/noPassthrough/index_stepdown_after_init.js | 105 |
1 files changed, 51 insertions, 54 deletions
diff --git a/jstests/noPassthrough/index_stepdown_after_init.js b/jstests/noPassthrough/index_stepdown_after_init.js index c27df900ce0..4289d18ec8a 100644 --- a/jstests/noPassthrough/index_stepdown_after_init.js +++ b/jstests/noPassthrough/index_stepdown_after_init.js @@ -4,73 +4,70 @@ * @tags: [requires_replication] */ (function() { - "use strict"; +"use strict"; - load('jstests/libs/check_log.js'); - load('jstests/noPassthrough/libs/index_build.js'); +load('jstests/libs/check_log.js'); +load('jstests/noPassthrough/libs/index_build.js'); - const rst = new ReplSetTest({ - nodes: [ - {}, - { - // Disallow elections on secondary. - rsConfig: { - priority: 0, - votes: 0, - }, +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'); - const enableIndexBuildsCoordinator = - assert - .commandWorked(primary.adminCommand( - {getParameter: 1, enableIndexBuildsCoordinatorForCreateIndexesCommand: 1})) - .enableIndexBuildsCoordinatorForCreateIndexesCommand; - if (!enableIndexBuildsCoordinator) { - jsTestLog( - 'IndexBuildsCoordinator not enabled for index creation on primary, skipping test.'); - rst.stopSet(); - return; - } +const enableIndexBuildsCoordinator = + assert + .commandWorked(primary.adminCommand( + {getParameter: 1, enableIndexBuildsCoordinatorForCreateIndexesCommand: 1})) + .enableIndexBuildsCoordinatorForCreateIndexesCommand; +if (!enableIndexBuildsCoordinator) { + jsTestLog('IndexBuildsCoordinator not enabled for index creation on primary, skipping test.'); + rst.stopSet(); + return; +} - assert.writeOK(coll.insert({a: 1})); +assert.writeOK(coll.insert({a: 1})); - assert.commandWorked(primary.adminCommand( - {configureFailPoint: 'hangAfterInitializingIndexBuild', mode: 'alwaysOn'})); +assert.commandWorked(primary.adminCommand( + {configureFailPoint: 'hangAfterInitializingIndexBuild', mode: 'alwaysOn'})); - const createIdx = IndexBuildTest.startIndexBuild(primary, coll.getFullName(), {a: 1}); +const createIdx = IndexBuildTest.startIndexBuild(primary, coll.getFullName(), {a: 1}); - checkLog.contains( - primary, - 'index build: starting on ' + coll.getFullName() + ' properties: { v: 2, key: { a:'); +checkLog.contains( + primary, 'index build: starting on ' + coll.getFullName() + ' properties: { v: 2, key: { a:'); - try { - // Step down the primary. - assert.commandWorked(primary.adminCommand({replSetStepDown: 60, force: true})); - } finally { - assert.commandWorked(primary.adminCommand( - {configureFailPoint: 'hangAfterInitializingIndexBuild', mode: 'off'})); - } +try { + // Step down the primary. + assert.commandWorked(primary.adminCommand({replSetStepDown: 60, force: true})); +} finally { + assert.commandWorked( + primary.adminCommand({configureFailPoint: 'hangAfterInitializingIndexBuild', mode: 'off'})); +} - // 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'); - checkLog.contains(primary, 'IndexBuildAborted: Index build aborted: '); +checkLog.contains(primary, 'IndexBuildAborted: Index build aborted: '); - // 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(); })(); |