diff options
Diffstat (limited to 'jstests/replsets/rollback_remote_cursor_retry.js')
-rw-r--r-- | jstests/replsets/rollback_remote_cursor_retry.js | 61 |
1 files changed, 30 insertions, 31 deletions
diff --git a/jstests/replsets/rollback_remote_cursor_retry.js b/jstests/replsets/rollback_remote_cursor_retry.js index 77d8fd5b58a..2e2db8c5df6 100644 --- a/jstests/replsets/rollback_remote_cursor_retry.js +++ b/jstests/replsets/rollback_remote_cursor_retry.js @@ -6,46 +6,45 @@ */ (function() { - "use strict"; - load("jstests/replsets/libs/rollback_test.js"); - load("jstests/libs/check_log.js"); +"use strict"; +load("jstests/replsets/libs/rollback_test.js"); +load("jstests/libs/check_log.js"); - const testName = "rollback_remote_cursor_retry"; - const dbName = testName; +const testName = "rollback_remote_cursor_retry"; +const dbName = testName; - const rollbackTest = new RollbackTest(testName); +const rollbackTest = new RollbackTest(testName); - const replSet = rollbackTest.getTestFixture(); +const replSet = rollbackTest.getTestFixture(); - replSet.awaitReplication(); +replSet.awaitReplication(); - const rollbackNode = rollbackTest.transitionToRollbackOperations(); - const syncSource = rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); +const rollbackNode = rollbackTest.transitionToRollbackOperations(); +const syncSource = rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); - // This failpoint is used to make sure that we have started rollback before turning on - // 'failCommand'. Otherwise, we would be failing the 'find' command that we issue against - // the sync source before we decide to go into rollback. - assert.commandWorked(rollbackNode.adminCommand( - {configureFailPoint: "rollbackHangBeforeStart", mode: "alwaysOn"})); +// This failpoint is used to make sure that we have started rollback before turning on +// 'failCommand'. Otherwise, we would be failing the 'find' command that we issue against +// the sync source before we decide to go into rollback. +assert.commandWorked( + rollbackNode.adminCommand({configureFailPoint: "rollbackHangBeforeStart", mode: "alwaysOn"})); - rollbackTest.transitionToSyncSourceOperationsDuringRollback(); +rollbackTest.transitionToSyncSourceOperationsDuringRollback(); - // Ensure that we've hit the failpoint before moving on. - checkLog.contains(rollbackNode, "rollback - rollbackHangBeforeStart fail point enabled"); +// Ensure that we've hit the failpoint before moving on. +checkLog.contains(rollbackNode, "rollback - rollbackHangBeforeStart fail point enabled"); - // Fail the 'find' command exactly twice. - jsTestLog("Failing the next two 'find' commands."); - assert.commandWorked(syncSource.adminCommand({ - configureFailPoint: "failCommand", - data: {errorCode: 279, failInternalCommands: true, failCommands: ["find"]}, - mode: {times: 2} - })); +// Fail the 'find' command exactly twice. +jsTestLog("Failing the next two 'find' commands."); +assert.commandWorked(syncSource.adminCommand({ + configureFailPoint: "failCommand", + data: {errorCode: 279, failInternalCommands: true, failCommands: ["find"]}, + mode: {times: 2} +})); - // Let rollback proceed. - assert.commandWorked( - rollbackNode.adminCommand({configureFailPoint: "rollbackHangBeforeStart", mode: "off"})); - - rollbackTest.transitionToSteadyStateOperations(); - rollbackTest.stop(); +// Let rollback proceed. +assert.commandWorked( + rollbackNode.adminCommand({configureFailPoint: "rollbackHangBeforeStart", mode: "off"})); +rollbackTest.transitionToSteadyStateOperations(); +rollbackTest.stop(); })(); |