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
|
/**test removing a node from a replica set
*
* Start set with two nodes
* Initial sync
* Remove secondary
* Bring secondary back up
* Add it back as secondary
* Make sure both nodes are either primary or secondary
*
*
* SERVER-49428: Disable for ephemeralForTest, writeConcernMajorityJournalDefault is not off
* @tags: [
* incompatible_with_eft,
* ]
*/
load("jstests/replsets/rslib.js");
var name = "removeNodes";
var host = getHostName();
print("Start set with two nodes");
var replTest = new ReplSetTest({name: name, nodes: 2});
var nodes = replTest.startSet();
replTest.initiate();
var primary = replTest.getPrimary();
var secondary = replTest.getSecondary();
print("Initial sync");
primary.getDB("foo").bar.baz.insert({x: 1});
replTest.awaitReplication();
print("Remove secondary");
var config = replTest.getReplSetConfigFromNode(0);
for (var i = 0; i < config.members.length; i++) {
if (config.members[i].host == secondary.host) {
config.members.splice(i, 1);
break;
}
}
var nextVersion = replTest.getReplSetConfigFromNode().version + 1;
config.version = nextVersion;
assert.eq(secondary.getDB("admin").runCommand({ping: 1}).ok,
1,
"we should be connected to the secondary");
try {
primary.getDB("admin").runCommand({replSetReconfig: config});
} catch (e) {
print(e);
}
// This tests that the secondary disconnects us when it picks up the new config.
assert.soon(function() {
try {
secondary.getDB("admin").runCommand({ping: 1});
} catch (e) {
return true;
}
return false;
});
// Now we should successfully reconnect to the secondary.
assert.eq(
secondary.getDB("admin").runCommand({ping: 1}).ok, 1, "we aren't connected to the secondary");
reconnect(primary);
assert.soon(function() {
var c = primary.getDB("local").system.replset.findOne();
return c.version == nextVersion;
});
print("Add it back as a secondary");
config.members.push({_id: 2, host: secondary.host});
nextVersion++;
config.version = nextVersion;
// Need to keep retrying reconfig here, as it will not work at first due to the primary's
// perception that the secondary is still "down".
assert.soon(function() {
try {
assert.commandWorked(replTest.getPrimary().adminCommand({replSetReconfig: config}));
return true;
} catch (e) {
return false;
}
});
primary = replTest.getPrimary();
// Wait and account for 'newlyAdded' automatic reconfig.
nextVersion++;
replTest.waitForAllNewlyAddedRemovals();
secondary = replTest.getSecondary();
printjson(primary.getDB("admin").runCommand({replSetGetStatus: 1}));
var newConfig = primary.getDB("local").system.replset.findOne();
print("newConfig: " + tojson(newConfig));
assert.eq(newConfig.version, nextVersion);
print("reconfig with minority");
replTest.stop(secondary);
assert.soon(function() {
try {
return primary.getDB("admin").runCommand({hello: 1}).secondary;
} catch (e) {
print("trying to get primary: " + e);
}
}, "waiting for primary to step down", (60 * 1000), 1000);
nextVersion++;
config.version = nextVersion;
config.members = config.members.filter(node => node.host == primary.host);
try {
primary.getDB("admin").runCommand({replSetReconfig: config, force: true});
} catch (e) {
print(e);
}
reconnect(primary);
assert.soon(function() {
return primary.getDB("admin").runCommand({hello: 1}).isWritablePrimary;
}, "waiting for old primary to accept reconfig and step up", (60 * 1000), 1000);
config = primary.getDB("local").system.replset.findOne();
printjson(config);
assert.gt(config.version, nextVersion);
replTest.stopSet();
|
