summaryrefslogtreecommitdiff
path: root/jstests/replsets/rollback_remote_cursor_retry.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/rollback_remote_cursor_retry.js')
-rw-r--r--jstests/replsets/rollback_remote_cursor_retry.js61
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();
})();