blob: 7a44d00bf9ee144b8c7c29c4712d8e45dd464ea3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
/**
* This tests that rollback has the ability to retry the 'find' command on the sync source's
* oplog, which may fail due to transient network errors. It uses the 'failCommand' failpoint
* to simulate exactly two network failures, so that common point resolution can succeed on the
* third attempt.
*/
(function() {
"use strict";
load("jstests/libs/fail_point_util.js");
load("jstests/replsets/libs/rollback_test.js");
const testName = "rollback_remote_cursor_retry";
const dbName = testName;
const rollbackTest = new RollbackTest(testName);
const replSet = rollbackTest.getTestFixture();
replSet.awaitReplication();
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.
const rollbackHangBeforeStartFailPoint =
configureFailPoint(rollbackNode, "rollbackHangBeforeStart");
rollbackTest.transitionToSyncSourceOperationsDuringRollback();
// Ensure that we've hit the failpoint before moving on.
rollbackHangBeforeStartFailPoint.wait();
// Fail the 'find' command exactly twice.
jsTestLog("Failing the next two 'find' commands.");
configureFailPoint(syncSource,
"failCommand",
{errorCode: 279, failInternalCommands: true, failCommands: ["find"]},
{times: 2});
// Let rollback proceed.
rollbackHangBeforeStartFailPoint.off();
rollbackTest.transitionToSteadyStateOperations();
rollbackTest.stop();
})();
|