blob: 36e5fc75468d6821f7db196fbf00e07f9fb5cf30 (
plain)
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
|
(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;
const 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
if (TestData.configShard) {
rs.add({'configsvr': ''});
} else {
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();
})();
|
