blob: 9c2b888cd765ede0c2e5ac65b25d4c3bbec37d50 (
plain)
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
|
/**
* Test that the telemetry store can be cleared when the cache size is reset to 0.
* @tags: [featureFlagQueryStats]
*/
load("jstests/libs/telemetry_utils.js"); // For verifyMetrics.
(function() {
"use strict";
// Turn on the collecting of telemetry metrics.
let options = {
setParameter: {internalQueryStatsSamplingRate: -1, internalQueryStatsCacheSize: "10MB"},
};
const conn = MongoRunner.runMongod(options);
const testDB = conn.getDB('test');
var coll = testDB[jsTestName()];
coll.drop();
let query = {};
for (var j = 0; j < 10; ++j) {
query["foo.field.xyz." + j] = 1;
query["bar.field.xyz." + j] = 2;
query["baz.field.xyz." + j] = 3;
coll.aggregate([{$match: query}]).itcount();
}
// Confirm number of entries in the store and that none have been evicted.
let telemetryResults = testDB.getSiblingDB("admin").aggregate([{$queryStats: {}}]).toArray();
assert.eq(telemetryResults.length, 10, telemetryResults);
assert.eq(testDB.serverStatus().metrics.queryStats.numEvicted, 0);
// Command to clear the cache.
assert.commandWorked(testDB.adminCommand({setParameter: 1, internalQueryStatsCacheSize: "0MB"}));
// 10 regular queries plus the $queryStats query, means 11 entries evicted when the cache is
// cleared.
assert.eq(testDB.serverStatus().metrics.queryStats.numEvicted, 11);
// Calling $queryStats should fail when the telemetry store size is 0 bytes.
assert.throwsWithCode(() => testDB.getSiblingDB("admin").aggregate([{$queryStats: {}}]), 6579000);
MongoRunner.stopMongod(conn);
}());
|
