jstests/replsets/tenant_migration_concurrent_reads_on_donor.js
/**
 * To be used to resume a migration that is paused after entering the blocking state. Waits for the
 * number of blocked reads to reach 'targetNumBlockedReads' and unpauses the migration.
 */
To be used to resume a migration that is paused after entering the blocking state. Waits for the
number of blocked reads to reach 'targetNumBlockedReads' and unpauses the migration.
To be used to resume a migration that is paused after entering the blocking state . Waits for the number of blocked reads to reach ' targetNumBlockedReads ' and unpauses the migration .
function resumeMigrationAfterBlockingRead(host, tenantId, targetNumBlockedReads) {
    load("jstests/libs/fail_point_util.js");
    load("jstests/replsets/libs/tenant_migration_util.js");
    const primary = new Mongo(host);
    assert.soon(() => TenantMigrationUtil.getNumBlockedReads(primary, tenantId) ==
                    targetNumBlockedReads);
    assert.commandWorked(primary.adminCommand(
        {configureFailPoint: "pauseTenantMigrationBeforeLeavingBlockingState", mode: "off"}));
}
function resumeMigrationAfterBlockingRead ( host , tenantId , targetNumBlockedReads ) { load ( "jstests/libs/fail_point_util.js" ) ; load ( "jstests/replsets/libs/tenant_migration_util.js" ) ; const primary = new Mongo ( host ) ; assert . soon ( ( ) => TenantMigrationUtil . getNumBlockedReads ( primary , tenantId ) == targetNumBlockedReads ) ; assert . commandWorked ( primary . adminCommand ( { configureFailPoint : "pauseTenantMigrationBeforeLeavingBlockingState" , mode : "off" } ) ) ; }
To be used to resume a migration that is paused after entering the blocking state.
To be used to resume a migration that is paused after entering the blocking state .