jstests/sharding/movechunk_commit_changelog_stats.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

//
// Tests that the changelog entry for moveChunk.commit contains stats on the migration.
//

(function() {
    'use strict';

    var st = new ShardingTest({mongos: 1, shards: 2});
    var kDbName = 'db';

    var mongos = st.s0;
    var shard0 = st.shard0.shardName;
    var shard1 = st.shard1.shardName;

    assert.commandWorked(mongos.adminCommand({enableSharding: kDbName}));
    st.ensurePrimaryShard(kDbName, shard0);

    function assertCountsInChangelog() {
        let changeLog = st.s.getDB('config').changelog.find({what: 'moveChunk.commit'}).toArray();
        assert.gt(changeLog.length, 0);
        for (let i = 0; i < changeLog.length; i++) {
            assert(changeLog[i].details.hasOwnProperty('counts'));
        }
    }

    var ns = kDbName + '.fooHashed';
    assert.commandWorked(mongos.adminCommand({shardCollection: ns, key: {_id: 'hashed'}}));

    var aChunk = mongos.getDB('config').chunks.findOne({ns: ns, shard: shard0});
    assert(aChunk);

    // Assert counts field exists in the changelog entry for moveChunk.commit
    assert.commandWorked(
        mongos.adminCommand({moveChunk: ns, bounds: [aChunk.min, aChunk.max], to: shard1}));
    assertCountsInChangelog();

    mongos.getDB(kDbName).fooHashed.drop();

    st.stop();
})();