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
|
/**
* Tests server status has correct fault/facet information.
*
* @tags: [multiversion_incompatible]
*/
(function() {
'use strict';
function changeObserverIntensity(observer, intensity) {
let paramValue = {"values": [{"type": observer, "intensity": intensity}]};
assert.commandWorked(
st.s0.adminCommand({"setParameter": 1, healthMonitoringIntensities: paramValue}));
}
const params = {
setParameter: {
healthMonitoringIntensities: tojson({
values: [
{type: "test", intensity: "off"},
{type: "ldap", intensity: "off"},
{type: "dns", intensity: "off"}
]
}),
featureFlagHealthMonitoring: true
}
};
let st = new ShardingTest({
mongos: [params],
shards: 1,
});
// Check server status after initial health check is complete.
let result = assert.commandWorked(st.s0.adminCommand({serverStatus: 1})).health;
print("---RESULT 1---");
print(tojson(result));
assert.eq(result.state, "Ok");
assert(result.enteredStateAtTime);
changeObserverIntensity('test', 'critical');
// Check server status after test health observer enabled and failpoint returns fault.
assert.commandWorked(st.s0.adminCommand({
"configureFailPoint": 'testHealthObserver',
"data": {"code": "InternalError", "msg": "test msg"},
"mode": "alwaysOn"
}));
assert.soon(() => {
result = assert.commandWorked(st.s0.adminCommand({serverStatus: 1})).health;
return result.state == "TransientFault";
});
print("---RESULT 2---");
print(tojson(result));
assert(result.enteredStateAtTime);
assert(result.faultInformation);
const faultInformation = result.faultInformation;
// TODO: SERVER-60973 check fault severity
assert(faultInformation.duration);
assert(faultInformation.facets);
assert.eq(faultInformation.numFacets, 1);
assert(faultInformation.facets.kTestObserver);
const kTestObserverFacet = faultInformation.facets.kTestObserver;
assert.eq(kTestObserverFacet.duration, faultInformation.duration);
assert(kTestObserverFacet.description.includes("InternalError: test msg"));
// Check server status after test health observer enabled and failpoint returns success.
assert.commandWorked(
st.s0.adminCommand({"configureFailPoint": 'testHealthObserver', "mode": "alwaysOn"}));
assert.soon(() => {
result = assert.commandWorked(st.s0.adminCommand({serverStatus: 1})).health;
return result.state == "Ok";
});
result = assert.commandWorked(st.s0.adminCommand({serverStatus: 1})).health;
print("---RESULT 3---");
print(tojson(result));
assert.eq(result.state, "Ok");
assert(result.enteredStateAtTime);
st.stop();
})();
|
