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
|
/**
* Tests the server status metrics of awaitable hello/isMaster.
* @tags: [requires_replication]
*/
(function() {
"use strict";
load("jstests/libs/parallel_shell_helpers.js");
load("jstests/libs/fail_point_util.js");
function runAwaitCmd(cmd, maxAwaitTimeMS) {
const res = assert.commandWorked(db.runCommand({[cmd]: 1}));
assert(res.hasOwnProperty("topologyVersion"), res);
const topologyVersionField = res.topologyVersion;
assert.commandWorked(db.runCommand(
{[cmd]: 1, topologyVersion: topologyVersionField, maxAwaitTimeMS: maxAwaitTimeMS}));
}
function runTest(db, cmd, failPoint) {
const res = assert.commandWorked(db.runCommand({[cmd]: 1}));
assert(res.hasOwnProperty("topologyVersion"), res);
const topologyVersionField = res.topologyVersion;
assert(topologyVersionField.hasOwnProperty("processId"), topologyVersionField);
assert(topologyVersionField.hasOwnProperty("counter"), topologyVersionField);
// Test that metrics are properly updated when there are command requests that are waiting.
let awaitCmdFailPoint = configureFailPoint(failPoint.conn, failPoint.failPointName);
let singleAwaitCmd =
startParallelShell(funWithArgs(runAwaitCmd, cmd, 100), failPoint.conn.port);
// Ensure the command requests have started waiting before checking the metrics.
awaitCmdFailPoint.wait();
// awaitingTopologyChanges should increment once.
let numAwaitingTopologyChange = db.serverStatus().connections.awaitingTopologyChanges;
assert.eq(1, numAwaitingTopologyChange);
configureFailPoint(failPoint.conn, failPoint.failPointName, {}, "off");
// The awaitingTopologyChanges metric should decrement once the waiting command has returned.
singleAwaitCmd();
numAwaitingTopologyChange = db.serverStatus().connections.awaitingTopologyChanges;
assert.eq(0, numAwaitingTopologyChange);
// Refresh the number of times we have entered the failpoint.
awaitCmdFailPoint = configureFailPoint(failPoint.conn, failPoint.failPointName);
let firstAwaitCmd = startParallelShell(funWithArgs(runAwaitCmd, cmd, 100), failPoint.conn.port);
let secondAwaitCmd =
startParallelShell(funWithArgs(runAwaitCmd, cmd, 100), failPoint.conn.port);
assert.commandWorked(db.runCommand({
waitForFailPoint: failPoint.failPointName,
// Each failpoint will be entered twice. Once for the 'shouldFail' check and again for the
// 'pauseWhileSet'.
timesEntered: awaitCmdFailPoint.timesEntered + 4,
maxTimeMS: kDefaultWaitForFailPointTimeout
}));
numAwaitingTopologyChange = db.serverStatus().connections.awaitingTopologyChanges;
assert.eq(2, numAwaitingTopologyChange);
configureFailPoint(failPoint.conn, failPoint.failPointName, {}, "off");
firstAwaitCmd();
secondAwaitCmd();
numAwaitingTopologyChange = db.serverStatus().connections.awaitingTopologyChanges;
assert.eq(0, numAwaitingTopologyChange);
}
const conn = MongoRunner.runMongod({});
assert.neq(null, conn, "mongod was unable to start up");
// A failpoint signalling that the standalone server has received the command request and is
// waiting for maxAwaitTimeMS.
let failPoint = configureFailPoint(conn, "hangWaitingForHelloResponseOnStandalone");
runTest(conn.getDB("admin"), "hello", failPoint);
runTest(conn.getDB("admin"), "isMaster", failPoint);
runTest(conn.getDB("admin"), "ismaster", failPoint);
MongoRunner.stopMongod(conn);
const replTest = new ReplSetTest({nodes: 1});
replTest.startSet();
replTest.initiate();
const primary = replTest.getPrimary();
// A failpoint signalling that the server has received the command request and is waiting for a
// topology change or maxAwaitTimeMS.
failPoint = configureFailPoint(primary, "hangWhileWaitingForHelloResponse");
runTest(primary.getDB("admin"), "hello", failPoint);
runTest(primary.getDB("admin"), "isMaster", failPoint);
runTest(primary.getDB("admin"), "ismaster", failPoint);
replTest.stopSet();
const st = new ShardingTest({mongos: 1, shards: [{nodes: 1}], config: 1});
failPoint = configureFailPoint(st.s, "hangWhileWaitingForHelloResponse");
runTest(st.s.getDB("admin"), "hello", failPoint);
runTest(st.s.getDB("admin"), "isMaster", failPoint);
runTest(st.s.getDB("admin"), "ismaster", failPoint);
st.stop();
})();
|
