jstests/replsets/tenant_migration_concurrent_writes_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 'targetNumBlockedWrites' 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 'targetNumBlockedWrites' 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 ' targetNumBlockedWrites ' and unpauses the migration .
function resumeMigrationAfterBlockingWrite(host, tenantId, targetNumBlockedWrites) {
    load("jstests/libs/fail_point_util.js");
    load("jstests/replsets/libs/tenant_migration_util.js");
    const primary = new Mongo(host);
    assert.soon(() => TenantMigrationUtil.getNumBlockedWrites(primary, tenantId) ==
                    targetNumBlockedWrites);
    assert.commandWorked(primary.adminCommand(
        {configureFailPoint: "pauseTenantMigrationBeforeLeavingBlockingState", mode: "off"}));
}
function resumeMigrationAfterBlockingWrite ( host , tenantId , targetNumBlockedWrites ) { load ( "jstests/libs/fail_point_util.js" ) ; load ( "jstests/replsets/libs/tenant_migration_util.js" ) ; const primary = new Mongo ( host ) ; assert . soon ( ( ) => TenantMigrationUtil . getNumBlockedWrites ( primary , tenantId ) == targetNumBlockedWrites ) ; 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 .