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

(function() {
    'use strict';

    // init with one shard with one node rs
    var st = new ShardingTest({shards: 1, rs: {nodes: 1}, mongos: 1});
    var mongos = st.s;
    var rs = st.rs0;

    assert.commandWorked(st.s0.adminCommand({enablesharding: "test"}));

    var db = mongos.getDB("test");
    db.foo.save({_id: 1, x: 1});
    assert.eq(db.foo.find({_id: 1}).next().x, 1);

    // prevent RSM on all nodes to update config shard
    mongos.adminCommand({configureFailPoint: "failAsyncConfigChangeHook", mode: "alwaysOn"});
    rs.nodes.forEach(function(node) {
        node.adminCommand({configureFailPoint: "failAsyncConfigChangeHook", mode: "alwaysOn"});
    });

    // add a node to shard rs
    rs.add({'shardsvr': ''});
    rs.reInitiate();
    rs.awaitSecondaryNodes();

    jsTest.log("Reload ShardRegistry");
    // force SR reload with flushRouterConfig
    mongos.getDB("admin").runCommand({flushRouterConfig: 1});

    // issue a read from mongos with secondaryOnly read preference to force it use just added node
    jsTest.log("Issue find");
    assert.eq(db.foo.find({_id: 1}).readPref('secondary').next().x, 1);

    st.stop();
})();