blob: 7cbb733c30630503abc08dbc72b2ad5de9bc960d (
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
/*
* Test that replSetReconfig can add and remove arbiters.
*/
// hello fails on the arbiter once it's removed, which blocks all checks.
TestData.skipCheckDBHashes = true;
(function() {
'use strict';
load('jstests/replsets/rslib.js');
const replTest = new ReplSetTest({nodes: 2});
replTest.startSet();
replTest.initiate();
const primary = replTest.getPrimary();
// This test performs a reconfig that will change the implicit default write concern
// from {w: "majority"} to {w: 1}. In order for this reconfig to succeed, we must first
// set the cluster-wide write concern.
assert.commandWorked(primary.adminCommand(
{setDefaultRWConcern: 1, defaultWriteConcern: {w: "majority"}, writeConcern: {w: "majority"}}));
jsTestLog('Start arbiter');
const arbiterConn = replTest.add();
const admin = primary.getDB('admin');
const conf = replTest.getReplSetConfigFromNode();
conf.members.push({_id: 2, host: arbiterConn.host, arbiterOnly: true});
conf.version++;
jsTestLog('Add arbiter');
assert.commandWorked(admin.runCommand({replSetReconfig: conf}));
replTest.waitForState(arbiterConn, ReplSetTest.State.ARBITER);
jsTestLog(`Wait for ${arbiterConn} to enter state ARBITER in primary's replSetGetStatus`);
assert.soon(() => {
let status = assert.commandWorked(admin.runCommand({replSetGetStatus: 1}));
return ReplSetTest.State.ARBITER === status.members[2].state;
});
conf.members.pop();
conf.version++;
jsTestLog('Remove arbiter');
assert.commandWorked(admin.runCommand({replSetReconfig: conf}));
assert.soonNoExcept(
() => {
// The arbiter dropped connections when it was removed.
reconnect(arbiterConn);
let status = arbiterConn.getDB('admin').runCommand({replSetGetStatus: 1});
print(`replSetGetStatus: ${tojson(status)}`);
return status.code === ErrorCodes.InvalidReplicaSetConfig;
},
"waiting for arbiter's replSetGetStatus to show that the arbiter was removed",
undefined /* timeout */,
1000 /* intervalMS */);
replTest.stopSet();
})();
|
