mirror of https://github.com/mongodb/mongo
36 lines
1.3 KiB
JavaScript
36 lines
1.3 KiB
JavaScript
/*
|
|
* Tests that the 'forceSyncSourceCandidate' failpoint correctly forces a sync source.
|
|
*
|
|
* @tags: [requires_replication]
|
|
*/
|
|
import {configureFailPoint} from "jstests/libs/fail_point_util.js";
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
|
|
const failpointName = "forceSyncSourceCandidate";
|
|
|
|
const rst = new ReplSetTest({
|
|
nodes: [{}, {rsConfig: {priority: 0}}, {rsConfig: {priority: 0}}, {rsConfig: {priority: 0}}],
|
|
// Allow many initial sync attempts. Initial sync may fail if the sync source does not have
|
|
// an oplog yet because it has not conducted its own initial sync yet.
|
|
// We turn on the noop writer to encourage successful sync source selection.
|
|
nodeOptions: {setParameter: {numInitialSyncAttempts: 100, writePeriodicNoops: true}},
|
|
});
|
|
const nodes = rst.startSet();
|
|
|
|
function getDataObj(syncSource) {
|
|
return {hostAndPort: syncSource.host};
|
|
}
|
|
|
|
configureFailPoint(nodes[1], failpointName, getDataObj(nodes[0]));
|
|
configureFailPoint(nodes[2], failpointName, getDataObj(nodes[1]));
|
|
configureFailPoint(nodes[3], failpointName, getDataObj(nodes[2]));
|
|
|
|
rst.initiate();
|
|
const primary = rst.getPrimary();
|
|
|
|
rst.awaitSyncSource(nodes[1], nodes[0]);
|
|
rst.awaitSyncSource(nodes[2], nodes[1]);
|
|
rst.awaitSyncSource(nodes[3], nodes[2]);
|
|
|
|
rst.stopSet();
|