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
|
/**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
*/
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();
|
