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
|
/**
* Shuts down config server and shard replica set nodes one by one and ensures correct behaviour.
*/
// Checking UUID and index consistency involves talking to the config servers, which are shut down
// in this test.
TestData.skipCheckingUUIDsConsistentAcrossCluster = true;
TestData.skipCheckingIndexesConsistentAcrossCluster = true;
TestData.skipCheckOrphans = true;
(function() {
'use strict';
var st = new ShardingTest({shards: {rs0: {nodes: 2}}});
jsTest.log('Config nodes up: 3 of 3, shard nodes up: 2 of 2: ' +
'Insert test data to work with');
assert.commandWorked(st.s0.getDB('TestDB').TestColl.update(
{_id: 0}, {$inc: {count: 1}}, {upsert: true, writeConcern: {w: 2, wtimeout: 30000}}));
assert.eq([{_id: 0, count: 1}], st.s0.getDB('TestDB').TestColl.find().toArray());
jsTest.log('Config nodes up: 2 of 3, shard nodes up: 2 of 2: ' +
'Inserts and queries must work');
st.configRS.stop(0);
st.restartMongos(0);
assert.commandWorked(st.s0.getDB('TestDB').TestColl.update(
{_id: 0}, {$inc: {count: 1}}, {upsert: true, writeConcern: {w: 2, wtimeout: 30000}}));
assert.eq([{_id: 0, count: 2}], st.s0.getDB('TestDB').TestColl.find().toArray());
jsTest.log('Config nodes up: 1 of 3, shard nodes up: 2 of 2: ' +
'Inserts and queries must work');
st.configRS.stop(1);
st.restartMongos(0);
assert.commandWorked(st.s0.getDB('TestDB').TestColl.update(
{_id: 0}, {$inc: {count: 1}}, {upsert: true, writeConcern: {w: 2, wtimeout: 30000}}));
assert.eq([{_id: 0, count: 3}], st.s0.getDB('TestDB').TestColl.find().toArray());
jsTest.log('Config nodes up: 1 of 3, shard nodes up: 1 of 2: ' +
'Only queries will work (no shard primary)');
st.rs0.stop(0);
st.restartMongos(0);
st.s0.setSlaveOk(true);
assert.eq([{_id: 0, count: 3}], st.s0.getDB('TestDB').TestColl.find().toArray());
jsTest.log('Config nodes up: 1 of 3, shard nodes up: 0 of 2: ' +
'MongoS must start, but no operations will work (no shard nodes available)');
st.rs0.stop(1);
st.restartMongos(0);
assert.throws(function() {
st.s0.getDB('TestDB').TestColl.find().toArray();
});
jsTest.log('Config nodes up: 0 of 3, shard nodes up: 0 of 2: ' +
'Metadata cannot be loaded at all, no operations will work');
st.configRS.stop(1);
// Instead of restarting mongos, ensure it has no metadata
assert.commandWorked(st.s0.adminCommand({flushRouterConfig: 1}));
// Throws transport error first and subsequent times when loading config data, not no primary
for (var i = 0; i < 2; i++) {
try {
st.s0.getDB('TestDB').TestColl.findOne();
// Must always throw
assert(false);
} catch (e) {
printjson(e);
// Make sure we get a transport error, and not a no-primary error
assert(e.code == 10276 || // Transport error
e.code == 13328 || // Connect error
e.code == ErrorCodes.HostUnreachable ||
e.code == ErrorCodes.FailedToSatisfyReadPreference ||
e.code == ErrorCodes.ReplicaSetNotFound);
}
}
st.stop();
}());
|
