summaryrefslogtreecommitdiff
path: root/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
diff options
context:
space:
mode:
authorChristopher Caplinger <christopher.caplinger@mongodb.com>2022-04-06 15:39:11 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-04-06 18:22:40 +0000
commitddf7d937d4228b16d03935296480c345e4bdd171 (patch)
tree06061797473d7b73667a163c8d06f7e1c76cb8d9 /jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
parenta6593ef1b2671c3ea126097bac3b9b6ab2138c2d (diff)
downloadmongo-ddf7d937d4228b16d03935296480c345e4bdd171.tar.gz
SERVER-63122: Remove logical cloning procedure for shard merge protocol
Diffstat (limited to 'jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js')
-rw-r--r--jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js24
1 files changed, 12 insertions, 12 deletions
diff --git a/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js b/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
index 3c33072711d..d1bb969a219 100644
--- a/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
+++ b/jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js
@@ -103,10 +103,10 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
donorRst.restart(donorPrimary);
// Let the migration restart and hang before it tries to re-fetch committed transactions.
- const fpAfterCollectionClonerDone =
- configureFailPoint(recipientPrimary, "fpAfterCollectionClonerDone", {action: "hang"});
+ const fpBeforeFetchingTransactions = configureFailPoint(
+ recipientPrimary, "fpBeforeFetchingCommittedTransactions", {action: "hang"});
fpAfterFetchingCommittedTransactions.off();
- fpAfterCollectionClonerDone.wait();
+ fpBeforeFetchingTransactions.wait();
// The recipient should indicate that the migration has restarted.
let recipientDoc;
@@ -117,7 +117,7 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
// The state doc should indicate that the migration has already updated 'config.transaction'
// entries.
assert.eq(true, recipientDoc[0].completedUpdatingTransactionsBeforeStartOpTime);
- fpAfterCollectionClonerDone.off();
+ fpBeforeFetchingTransactions.off();
// Verify that the migration completes successfully.
TenantMigrationTest.assertCommitted(
@@ -171,10 +171,10 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
donorRst.restart(donorPrimary);
// Let the migration restart and hang before it tries to re-fetch committed transactions.
- const fpAfterCollectionClonerDone =
- configureFailPoint(recipientPrimary, "fpAfterCollectionClonerDone", {action: "hang"});
+ const fpBeforeFetchingTransactions = configureFailPoint(
+ recipientPrimary, "fpBeforeFetchingCommittedTransactions", {action: "hang"});
hangAfterUpdatingTransactionEntry.off();
- fpAfterCollectionClonerDone.wait();
+ fpBeforeFetchingTransactions.wait();
// The recipient should indicate that the migration has restarted.
let recipientDoc;
@@ -185,7 +185,7 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
// Verify that the 'completedUpdatingTransactionsBeforeStartOpTime' flag is false since the
// migration was forced to restart before it fully completed fetching.
assert.eq(false, recipientDoc[0].completedUpdatingTransactionsBeforeStartOpTime);
- fpAfterCollectionClonerDone.off();
+ fpBeforeFetchingTransactions.off();
// Verify that the migration completes successfully.
TenantMigrationTest.assertCommitted(
@@ -250,10 +250,10 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
donorRst.restart(donorPrimary);
// Let the migration restart and hang before it tries to re-fetch committed transactions.
- const fpAfterCollectionClonerDone =
- configureFailPoint(recipientPrimary, "fpAfterCollectionClonerDone", {action: "hang"});
+ const fpBeforeFetchingTransactions = configureFailPoint(
+ recipientPrimary, "fpBeforeFetchingCommittedTransactions", {action: "hang"});
hangAfterUpdatingTransactionEntry.off();
- fpAfterCollectionClonerDone.wait();
+ fpBeforeFetchingTransactions.wait();
// The recipient should indicate that the migration has restarted.
let recipientDoc;
@@ -264,7 +264,7 @@ const assertTransactionEntries = (donorTxnEntries, recipientTxnEntries) => {
// Verify that the 'completedUpdatingTransactionsBeforeStartOpTime' flag is false since the
// migration was forced to restart before it fully completed fetching.
assert.eq(false, recipientDoc[0].completedUpdatingTransactionsBeforeStartOpTime);
- fpAfterCollectionClonerDone.off();
+ fpBeforeFetchingTransactions.off();
// Verify that the migration completes successfully.
TenantMigrationTest.assertCommitted(