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
|
/**
* Tests that sharding state is properly initialized on config servers that undergo startup
* recovery.
*
* @tags: [requires_persistence]
*/
(function() {
"use strict";
load("jstests/replsets/rslib.js"); // For getLatestOp()
load("jstests/sharding/libs/sharding_state_test.js");
const st = new ShardingTest({
config: 1,
shards: {rs0: {nodes: 1}},
useHostname: false,
});
const configRS = st.configRS;
let primary = configRS.getPrimary();
jsTestLog("Adding shards so we can force startup recovery on the config primary");
const rs1 = new ReplSetTest({name: "newShard1", host: 'localhost', nodes: 1});
rs1.startSet({shardsvr: ""});
rs1.initiate();
assert.commandWorked(st.s.adminCommand({addShard: rs1.getURL(), name: "newShard1"}));
const ts = getLatestOp(primary).ts;
configureFailPoint(primary, 'holdStableTimestampAtSpecificTimestamp', {timestamp: ts});
const rs2 = new ReplSetTest({name: "newShard2", host: 'localhost', nodes: 1});
rs2.startSet({shardsvr: ""});
rs2.initiate();
assert.commandWorked(st.s.adminCommand({addShard: rs2.getURL(), name: "newShard2"}));
jsTestLog("Restarting node. It should go into startup recovery.");
configRS.restart(primary);
configRS.waitForState(primary, ReplSetTest.State.PRIMARY);
jsTestLog("Ensuring node is up as a primary and checking sharding state");
ShardingStateTest.failoverToMember(configRS, primary);
ShardingStateTest.checkShardingState(st);
jsTestLog("Adding another shard to check state");
const rs3 = new ReplSetTest({name: "newShard3", host: 'localhost', nodes: 1});
rs3.startSet({shardsvr: ""});
rs3.initiate();
assert.commandWorked(st.s.adminCommand({addShard: rs3.getURL(), name: "newShard3"}));
const shards = primary.getDB("config").getCollection("shards").find().toArray();
assert.eq(4, shards.length, () => tojson(shards));
jsTestLog("Done with test");
st.stop();
rs1.stopSet();
rs2.stopSet();
rs3.stopSet();
})();
|
