diff options
Diffstat (limited to 'jstests/replsets/initial_sync_during_stepdown.js')
-rw-r--r-- | jstests/replsets/initial_sync_during_stepdown.js | 7 |
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."); |