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
36
37

(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: "failReplicaSetChangeConfigServerUpdateHook", mode: "alwaysOn"});
rs.nodes.forEach(function(node) {
    node.adminCommand(
        {configureFailPoint: "failUpdateShardIdentityConfigString", 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();
})();