diff options
author | Christopher Caplinger <christopher.caplinger@mongodb.com> | 2022-04-06 15:39:11 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-04-06 18:22:40 +0000 |
commit | ddf7d937d4228b16d03935296480c345e4bdd171 (patch) | |
tree | 06061797473d7b73667a163c8d06f7e1c76cb8d9 /jstests/replsets/tenant_migration_fetch_committed_transactions_retry.js | |
parent | a6593ef1b2671c3ea126097bac3b9b6ab2138c2d (diff) | |
download | mongo-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.js | 24 |
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( |