diff options
| author | Christopher Caplinger <christopher.caplinger@mongodb.com> | 2023-04-07 22:51:27 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-04-08 01:42:39 +0000 |
| commit | 636ad08bdb6fb5c9ad98ee4cdde8f52929c29830 (patch) | |
| tree | 78c2500a32ad6d85d788a06688f05c04cf8375d7 /jstests/replsets | |
| parent | 78d2ed6f81cd561f6a195981abc4f1e290cd3ec0 (diff) | |
| download | mongo-636ad08bdb6fb5c9ad98ee4cdde8f52929c29830.tar.gz | |
SERVER-72622: Track TenantOplogApplier progress in replicated collection
Diffstat (limited to 'jstests/replsets')
| -rw-r--r-- | jstests/replsets/libs/tenant_migration_util.js | 1 | ||||
| -rw-r--r-- | jstests/replsets/tenant_migration_resume_oplog_application.js | 4 |
2 files changed, 3 insertions, 2 deletions
diff --git a/jstests/replsets/libs/tenant_migration_util.js b/jstests/replsets/libs/tenant_migration_util.js index 611ca24fb66..633fb3c536d 100644 --- a/jstests/replsets/libs/tenant_migration_util.js +++ b/jstests/replsets/libs/tenant_migration_util.js @@ -154,6 +154,7 @@ export async function runMigrationAsync(migrationOpts, donorRstArgs, opts = {}) migrationId: UUID(migrationOpts.migrationIdString), tenantId: migrationOpts.tenantId, tenantIds: eval(migrationOpts.tenantIds), + protocol: migrationOpts.protocol, recipientConnectionString: migrationOpts.recipientConnString, readPreference: migrationOpts.readPreference || {mode: "primary"}, donorCertificateForRecipient: migrationOpts.donorCertificateForRecipient || diff --git a/jstests/replsets/tenant_migration_resume_oplog_application.js b/jstests/replsets/tenant_migration_resume_oplog_application.js index 70849750914..50a9bedbbc5 100644 --- a/jstests/replsets/tenant_migration_resume_oplog_application.js +++ b/jstests/replsets/tenant_migration_resume_oplog_application.js @@ -63,10 +63,10 @@ const migrationOpts = { // Configure fail point to have the recipient primary hang after the cloner completes and the oplog // applier has started. -let waitAfterDatabaseClone = configureFailPoint( +const waitAfterDatabaseClone = configureFailPoint( recipientPrimary, "fpAfterStartingOplogApplierMigrationRecipientInstance", {action: "hang"}); // Configure fail point to hang the tenant oplog applier after it applies the first batch. -let waitInOplogApplier = configureFailPoint(recipientPrimary, "hangInTenantOplogApplication"); +const waitInOplogApplier = configureFailPoint(recipientPrimary, "hangInTenantOplogApplication"); // Start a migration and wait for recipient to hang in the tenant database cloner. const donorRstArgs = createRstArgs(donorRst); |