summaryrefslogtreecommitdiff
path: root/jstests/replsets/initial_sync_during_stepdown.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/initial_sync_during_stepdown.js')
-rw-r--r--jstests/replsets/initial_sync_during_stepdown.js7
1 files changed, 5 insertions, 2 deletions
diff --git a/jstests/replsets/initial_sync_during_stepdown.js b/jstests/replsets/initial_sync_during_stepdown.js
index fe5d1a79587..ecc76114d34 100644
--- a/jstests/replsets/initial_sync_during_stepdown.js
+++ b/jstests/replsets/initial_sync_during_stepdown.js
@@ -51,7 +51,9 @@ function setupTest({
// Skip clearing initial sync progress after a successful initial sync attempt so that we
// can check initialSyncStatus fields after initial sync is complete.
secondaryStartupParams['failpoint.skipClearInitialSyncState'] = tojson({mode: 'alwaysOn'});
- rst.start(secondary, {startClean: true, setParameter: secondaryStartupParams});
+ secondary = rst.start(secondary, {startClean: true, setParameter: secondaryStartupParams});
+ secondaryDB = secondary.getDB(dbName);
+ secondaryColl = secondaryDB[collName];
// Wait until secondary reaches RS_STARTUP2 state.
rst.waitForState(secondary, ReplSetTest.State.STARTUP_2);
@@ -141,7 +143,8 @@ setupTest({
});
jsTestLog("Waiting for collection cloning to complete.");
-checkLog.contains(secondary, "initialSyncHangAfterDataCloning fail point enabled");
+assert.commandWorked(
+ secondary.adminCommand({waitForFailPoint: "initialSyncHangAfterDataCloning", timesEntered: 1}));
// Insert more data so that these are replicated to secondary node via oplog fetcher.
jsTestLog("Inserting more data on primary.");