jstests/replsets/tenant_migration_mtab_blocks_writes.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

/**
 *
 * @tags: [requires_fcv_46]
 */

(function() {
"use strict";
const runDonorStartMigrationCommand =
    (primaryConnection, migrationId, recipientConnectionString, dbPrefix, readPreference) => {
        return primaryConnection.adminCommand({
            donorStartMigration: 1,
            migrationId,
            recipientConnectionString,
            databasePrefix: dbPrefix,
            readPreference
        });
    };

// the value of the access enum in MigratingTenantAccessBlocker for the 'kBlockWritesAndReads'
// access state.
const kBlockReadsAndWrites = 2;
const rst = new ReplSetTest({nodes: 1});
rst.startSet();
rst.initiate();

const donorPrimary = rst.getPrimary();

const kMigrationId = new UUID();
const kRecipientConnectionString = new ReplSetTest({nodes: 1}).getURL();

const kReadPreference = {
    mode: "primary"
};
const kDBPrefixes = 'databaseABC';

jsTest.log('Running donorStartMigration command.');
assert.commandWorked(runDonorStartMigrationCommand(
    donorPrimary, kMigrationId, kRecipientConnectionString, kDBPrefixes, kReadPreference));

jsTest.log('Running the serverStatus command.');
const migratingTenantServerStatus =
    donorPrimary.adminCommand({serverStatus: 1}).migratingTenantAccessBlocker;

assert.eq(migratingTenantServerStatus.access, kBlockReadsAndWrites);
assert(migratingTenantServerStatus.blockTimestamp);

rst.stopSet();
})();