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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
/*
* Test that a reconfig for a shard that would change the implicit default write concern to w:1
* fails if CWWC is not set.
*
* @tags: [requires_fcv_50, requires_majority_read_concern, requires_persistence]
*/
(function() {
'use strict';
load("jstests/replsets/rslib.js"); // For reconfig, isConfigCommitted and
// safeReconfigShouldFail.
const configurationIncompatibleMsg =
"config that would change the implicit default write concern on the shard to {w: 1}.";
const configServerUnreachableMsg = "the request to the config server is failing with error:";
let addNodeConfig = function(rst, nodeId, conn, arbiter) {
const config = rst.getReplSetConfigFromNode();
if (arbiter) {
config.members.push({_id: nodeId, host: conn.host, arbiterOnly: true});
} else {
config.members.push({_id: nodeId, host: conn.host});
}
return config;
};
let removeNodeConfig = function(rst, conn) {
const config = rst.getReplSetConfigFromNode();
for (var i = 0; i < config.members.length; i++) {
if (config.members[i].host == conn.host) {
config.members.splice(i, 1);
break;
}
}
return config;
};
function testReconfig(rst, config, shouldSucceed, errCode, errMsg) {
if (shouldSucceed) {
reconfig(rst, config);
assert.soon(() => isConfigCommitted(rst.getPrimary()));
rst.waitForConfigReplication(rst.getPrimary());
rst.awaitReplication();
} else {
safeReconfigShouldFail(rst, config, false /* force */, errCode, errMsg);
// A force reconfig should also fail.
safeReconfigShouldFail(rst, config, true /* force */, errCode, errMsg);
}
}
jsTestLog("Testing to reconfig a shard that is not yet added to a sharded cluster.");
let logPrefix = "While the shard is not part of a sharded cluster: ";
let shardServer = new ReplSetTest(
{name: "shardServer", nodes: 1, nodeOptions: {shardsvr: ""}, useHostName: true});
shardServer.startSet();
shardServer.initiate();
jsTestLog(logPrefix + "Adding an arbiter node that will change IDWC to (w:1) should succeed.");
let arbiter = shardServer.add();
testReconfig(shardServer,
addNodeConfig(shardServer, 1 /* nodeId */, arbiter /* conn */, true /* arbiter */),
true /* shouldSucceed */);
jsTestLog(logPrefix +
"Removing an arbiter node that will change IDWC to (w: 'Majority') should succeed.");
shardServer.remove(arbiter);
testReconfig(shardServer, removeNodeConfig(shardServer, arbiter), true /* shouldSucceed */);
shardServer.stopSet();
jsTestLog("Testing to reconfig a shard that is part of a sharded cluster.");
logPrefix = "While the shard is part of a sharded cluster: ";
shardServer = new ReplSetTest(
{name: "shardServer", nodes: 1, nodeOptions: {shardsvr: ""}, useHostName: true});
shardServer.startSet();
shardServer.initiate();
const st = new ShardingTest({shards: 0, mongos: 1});
var admin = st.getDB('admin');
jsTestLog("Adding the shard to the cluster should succeed.");
assert.commandWorked(admin.runCommand({addshard: shardServer.getURL()}));
jsTestLog(logPrefix +
"Adding an non-arbiter node that will keep IDWC set to (w: 'Majority') should succeed.");
testReconfig(
shardServer,
addNodeConfig(shardServer, 1 /* nodeId */, shardServer.add() /* conn */, false /* arbiter */),
true /* shouldSucceed */);
jsTestLog(logPrefix + "Adding an arbiter node that will change IDWC to (w:1) should fail.");
arbiter = shardServer.add();
testReconfig(shardServer,
addNodeConfig(shardServer, 2 /* nodeId */, arbiter /* conn */, true /* arbiter */),
false /* shouldSucceed */,
ErrorCodes.NewReplicaSetConfigurationIncompatible,
configurationIncompatibleMsg);
jsTestLog("Setting the CWWC on the cluster.");
logPrefix = "While CWWC is set on the sharded cluster: ";
assert.commandWorked(
st.s.adminCommand({setDefaultRWConcern: 1, defaultWriteConcern: {w: "majority", wtimeout: 0}}));
jsTestLog(logPrefix + "Adding an arbiter node that will change IDWC to (w:1) should succeed.");
testReconfig(shardServer,
addNodeConfig(shardServer, 2 /* nodeId */, arbiter /* conn */, true /* arbiter */),
true /* shouldSucceed */);
jsTestLog("Testing when the config server is unreachable.");
logPrefix = "While config server is unreachable: ";
jsTestLog("Shutting down all config servers");
for (var i = 0; i < st.configRS.nodes.length; i++) {
st.stopConfigServer(i);
}
st.configRS.awaitNoPrimary();
// The reason why this is okay is because CWWC had to have been set for the cluster to get to this
// point, even if we can't check the config servers for it.
jsTestLog(logPrefix +
"Removing an arbiter node that will change IDWC to (w: 'Majority') should succeed.");
shardServer.remove(arbiter);
testReconfig(shardServer, removeNodeConfig(shardServer, arbiter), true /* shouldSucceed */);
jsTestLog(logPrefix + "Adding an arbiter node that will change IDWC to (w: 1) should fail.");
testReconfig(shardServer,
addNodeConfig(shardServer, 2 /* nodeId */, arbiter /* conn */, true /* arbiter */),
false /* shouldSucceed */,
ErrorCodes.ConfigServerUnreachable,
configServerUnreachableMsg);
jsTestLog("Restarting the config servers.");
logPrefix = "While the config server is reachable: ";
for (var i = 0; i < st.configRS.nodes.length; i++) {
st.restartConfigServer(i, undefined, undefined, true /* wait */);
}
st.configRS.awaitNodesAgreeOnPrimary();
print("Sleeping for 60 seconds to let the other shards restart their ReplicaSetMonitors");
sleep(60000);
jsTestLog(logPrefix + "Adding an arbiter node will change IDWC to (w:1) should succeed.");
arbiter = shardServer.add();
testReconfig(shardServer,
addNodeConfig(shardServer, 2 /* nodeId */, arbiter /* conn */, true /* arbiter */),
true /* shouldSucceed */);
jsTestLog("Stopping the cluster.");
st.stop();
jsTestLog("Stopping the shard.");
shardServer.stopSet();
})();
|
