summaryrefslogtreecommitdiff
path: root/jstests/noPassthrough/wt_operation_stats.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthrough/wt_operation_stats.js')
-rw-r--r--jstests/noPassthrough/wt_operation_stats.js148
1 files changed, 74 insertions, 74 deletions
diff --git a/jstests/noPassthrough/wt_operation_stats.js b/jstests/noPassthrough/wt_operation_stats.js
index b9c84e356f3..e273dd34170 100644
--- a/jstests/noPassthrough/wt_operation_stats.js
+++ b/jstests/noPassthrough/wt_operation_stats.js
@@ -7,83 +7,83 @@
// @tags: [requires_profiling]
(function() {
- 'use strict';
-
- load("jstests/libs/profiler.js"); // For getLatestProfilerEntry.
-
- const readStatRegx = /storage:{ data: { bytesRead: ([0-9]+)/;
-
- let checkLogStats = function() {
- // Check if the log output contains the expected statistics.
- let mongodLogs = rawMongoProgramOutput();
- let lines = mongodLogs.split('\n');
- let match;
- let logLineCount = 0;
- for (let line of lines) {
- if ((match = readStatRegx.exec(line)) !== null) {
- jsTestLog(line);
- logLineCount++;
- }
- }
- assert.gte(logLineCount, 1);
- };
-
- let checkSystemProfileStats = function(profileObj, statName) {
- // Check that the profiled operation contains the expected statistics.
- assert(profileObj.hasOwnProperty("storage"), tojson(profileObj));
- assert(profileObj.storage.hasOwnProperty("data"), tojson(profileObj));
- assert(profileObj.storage.data.hasOwnProperty(statName), tojson(profileObj));
- };
-
- // This test can only be run if the storageEngine is wiredTiger
- if (jsTest.options().storageEngine && (jsTest.options().storageEngine !== "wiredTiger")) {
- jsTestLog("Skipping test because storageEngine is not wiredTiger");
- } else {
- let name = "wt_op_stat";
-
- jsTestLog("run mongod");
- let conn = MongoRunner.runMongod();
- assert.neq(null, conn, "mongod was unable to start up");
- let testDB = conn.getDB(name);
-
- // Insert 200 documents of size 1K each, spanning multiple pages in the btree.
- let value = 'a'.repeat(1024);
-
- jsTestLog("insert data");
- for (let i = 0; i < 200; i++) {
- assert.writeOK(testDB.foo.insert({x: value}));
+'use strict';
+
+load("jstests/libs/profiler.js"); // For getLatestProfilerEntry.
+
+const readStatRegx = /storage:{ data: { bytesRead: ([0-9]+)/;
+
+let checkLogStats = function() {
+ // Check if the log output contains the expected statistics.
+ let mongodLogs = rawMongoProgramOutput();
+ let lines = mongodLogs.split('\n');
+ let match;
+ let logLineCount = 0;
+ for (let line of lines) {
+ if ((match = readStatRegx.exec(line)) !== null) {
+ jsTestLog(line);
+ logLineCount++;
}
+ }
+ assert.gte(logLineCount, 1);
+};
+
+let checkSystemProfileStats = function(profileObj, statName) {
+ // Check that the profiled operation contains the expected statistics.
+ assert(profileObj.hasOwnProperty("storage"), tojson(profileObj));
+ assert(profileObj.storage.hasOwnProperty("data"), tojson(profileObj));
+ assert(profileObj.storage.data.hasOwnProperty(statName), tojson(profileObj));
+};
+
+// This test can only be run if the storageEngine is wiredTiger
+if (jsTest.options().storageEngine && (jsTest.options().storageEngine !== "wiredTiger")) {
+ jsTestLog("Skipping test because storageEngine is not wiredTiger");
+} else {
+ let name = "wt_op_stat";
+
+ jsTestLog("run mongod");
+ let conn = MongoRunner.runMongod();
+ assert.neq(null, conn, "mongod was unable to start up");
+ let testDB = conn.getDB(name);
+
+ // Insert 200 documents of size 1K each, spanning multiple pages in the btree.
+ let value = 'a'.repeat(1024);
+
+ jsTestLog("insert data");
+ for (let i = 0; i < 200; i++) {
+ assert.writeOK(testDB.foo.insert({x: value}));
+ }
- let connport = conn.port;
- MongoRunner.stopMongod(conn);
-
- // Restart the server
- conn = MongoRunner.runMongod({
- restart: true,
- port: connport,
- slowms: "0",
- });
-
- clearRawMongoProgramOutput();
-
- // Scan the collection and check the bytes read statistic in the slowop log and
- // system.profile.
- testDB = conn.getDB(name);
- testDB.setProfilingLevel(2);
- jsTestLog("read data");
- let cur = testDB.foo.find();
- while (cur.hasNext()) {
- cur.next();
- }
+ let connport = conn.port;
+ MongoRunner.stopMongod(conn);
+
+ // Restart the server
+ conn = MongoRunner.runMongod({
+ restart: true,
+ port: connport,
+ slowms: "0",
+ });
+
+ clearRawMongoProgramOutput();
+
+ // Scan the collection and check the bytes read statistic in the slowop log and
+ // system.profile.
+ testDB = conn.getDB(name);
+ testDB.setProfilingLevel(2);
+ jsTestLog("read data");
+ let cur = testDB.foo.find();
+ while (cur.hasNext()) {
+ cur.next();
+ }
- // Look for the storage statistics in the profiled output of the find command.
- let profileObj = getLatestProfilerEntry(testDB, {op: "query", ns: "wt_op_stat.foo"});
- checkSystemProfileStats(profileObj, "bytesRead");
+ // Look for the storage statistics in the profiled output of the find command.
+ let profileObj = getLatestProfilerEntry(testDB, {op: "query", ns: "wt_op_stat.foo"});
+ checkSystemProfileStats(profileObj, "bytesRead");
- // Stopping the mongod waits until all of its logs have been read by the mongo shell.
- MongoRunner.stopMongod(conn);
- checkLogStats();
+ // Stopping the mongod waits until all of its logs have been read by the mongo shell.
+ MongoRunner.stopMongod(conn);
+ checkLogStats();
- jsTestLog("Success!");
- }
+ jsTestLog("Success!");
+}
})();