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
|
/**
* Test that the operation latencies reported in current op for a getMore on an awaitData cursor
* include time spent blocking for the await time.
* @tags: [requires_capped]
*/
(function() {
"use test";
// This test runs a getMore in a parallel shell, which will not inherit the implicit session of
// the cursor establishing command.
TestData.disableImplicitSessions = true;
const conn = MongoRunner.runMongod({});
assert.neq(null, conn, "mongod was unable to start up");
const testDB = conn.getDB("test");
const coll = testDB.currentop_includes_await_time;
coll.drop();
assert.commandWorked(testDB.createCollection(coll.getName(), {capped: true, size: 1024}));
assert.writeOK(coll.insert({_id: 1}));
let cmdRes = assert.commandWorked(
testDB.runCommand({find: coll.getName(), tailable: true, awaitData: true}));
TestData.commandResult = cmdRes;
let cleanupShell = startParallelShell(function() {
db.getSiblingDB("test").runCommand({
getMore: TestData.commandResult.cursor.id,
collection: "currentop_includes_await_time",
maxTimeMS: 5 * 60 * 1000,
});
}, conn.port);
assert.soon(function() {
// This filter ensures that the getMore 'secs_running' and 'microsecs_running' fields are
// sufficiently large that they appear to include time spent blocking waiting for capped
// inserts.
let ops = testDB.currentOp({
"command.getMore": {$exists: true},
"ns": coll.getFullName(),
secs_running: {$gte: 2},
microsecs_running: {$gte: 2 * 1000 * 1000}
});
return ops.inprog.length === 1;
}, printjson(testDB.currentOp()));
// A capped insertion should unblock the getMore, allowing the test to complete before the
// getMore's awaitData time expires.
assert.writeOK(coll.insert({_id: 2}));
cleanupShell();
MongoRunner.stopMongod(conn);
}());
|
