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
|
/*
* Tests various combinations of the configsvr field in replica set configurations and the
* command line options that control whether a node can function as a member of a CSRS.
*
* This test requires mmapv1.
* @tags: [requires_mmapv1]
*/
function expectState(rst, state) {
assert.soon(function() {
var status = rst.status();
if (status.myState != state) {
print("Waiting for state " + state + " in replSetGetStatus output: " + tojson(status));
}
return status.myState == state;
});
}
(function() {
"use strict";
(function() {
// Test that node with --configsvr cmd line and configsvr in replset config goes
// into REMOVED state if storage engine is not WiredTiger
jsTestLog("configsvr in rs config and --configsvr cmd line, but mmapv1");
var rst = new ReplSetTest({
name: "configrs3",
nodes: 1,
nodeOptions: {configsvr: "", journal: "", storageEngine: "mmapv1"}
});
rst.startSet();
var conf = rst.getReplSetConfig();
conf.configsvr = true;
try {
rst.nodes[0].adminCommand({replSetInitiate: conf});
} catch (e) {
// expected since we close all connections after going into REMOVED
}
expectState(rst, ReplSetTest.State.REMOVED);
rst.stopSet();
})();
(function() {
// Test that node with --configsvr cmd line and configsvr in replset config and using
// wiredTiger
// does NOT go into REMOVED state.
jsTestLog("configsvr in rs config and --configsvr cmd line, normal case");
var rst = new ReplSetTest({
name: "configrs5",
nodes: 1,
nodeOptions: {configsvr: "", journal: "", storageEngine: "wiredTiger"}
});
rst.startSet();
var conf = rst.getReplSetConfig();
conf.configsvr = true;
assert.commandWorked(rst.nodes[0].adminCommand({replSetInitiate: conf}));
rst.getPrimary();
expectState(rst, ReplSetTest.State.PRIMARY);
var conf = rst.getPrimary().getDB('local').system.replset.findOne();
assert(conf.configsvr, tojson(conf));
rst.stopSet();
})();
(function() {
// Test that node with --configsvr cmd line and initiated with an empty replset config
// will result in configsvr:true getting automatically added to the config (SERVER-20247).
jsTestLog("--configsvr cmd line, empty config to replSetInitiate");
var rst = new ReplSetTest({
name: "configrs6",
nodes: 1,
nodeOptions: {configsvr: "", journal: "", storageEngine: "wiredTiger"}
});
rst.startSet();
assert.commandWorked(rst.nodes[0].adminCommand({replSetInitiate: 1}));
rst.getPrimary();
expectState(rst, ReplSetTest.State.PRIMARY);
rst.stopSet();
})();
(function() {
// Test that a set initialized without --configsvr but then restarted with --configsvr will
// fail to
// start up and won't automatically add "configsvr" to the replset config (SERVER-21236).
jsTestLog("set initiated without configsvr, restarted adding --configsvr cmd line");
var rst = new ReplSetTest({
name: "configrs7",
nodes: 1,
nodeOptions: {journal: "", storageEngine: "wiredTiger"}
});
rst.startSet();
var conf = rst.getReplSetConfig();
assert.commandWorked(rst.nodes[0].adminCommand({replSetInitiate: conf}));
rst.getPrimary();
expectState(rst, ReplSetTest.State.PRIMARY);
assert.throws(function() {
rst.restart(0, {configsvr: ""});
});
rst.stopSet();
})();
(function() {
// Test that a set initialized with --configsvr but then restarted without --configsvr will
// fail to
// start up.
jsTestLog("set initiated with configsvr, restarted without --configsvr cmd line");
var rst = new ReplSetTest({
name: "configrs8",
nodes: 1,
nodeOptions: {configsvr: "", journal: "", storageEngine: "wiredTiger"}
});
rst.startSet();
var conf = rst.getReplSetConfig();
conf.configsvr = true;
assert.commandWorked(rst.nodes[0].adminCommand({replSetInitiate: conf}));
rst.getPrimary();
expectState(rst, ReplSetTest.State.PRIMARY);
var node = rst.nodes[0];
var options = node.savedOptions;
delete options.configsvr;
options.noCleanData = true;
options.waitForConnect = false;
MongoRunner.stopMongod(node);
var mongod = MongoRunner.runMongod(options);
var exitCode = waitProgram(mongod.pid);
assert.eq(
MongoRunner.EXIT_ABRUPT, exitCode, "Mongod should have failed to start, but didn't");
rst.stopSet();
})();
})();
|
