mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 17:10:48 +01:00
Code Issues Releases Activity

SERVER-43773 Add log messages in ShardingTest to measure total duration of startup and initiation of shards and config server

Browse Source
This commit is contained in:
William Schultz 2019-11-26 16:34:39 +00:00 committed by evergreen
parent f1a5bc857c
commit e164e7d031
1 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/mongo/shell/shardingtest.js
View File

@ -1049,6 +1049,21 @@ var ShardingTest = function(params) {
return true; return true;
} }
/**
* Returns the total number of mongod nodes across all shards, excluding config server nodes.
* Used only for diagnostic logging.
*/
function totalNumShardNodes(shardsAsReplSets) {
// Standalone mongod shards.
if (!shardsAsReplSets) {
return self._connections.length;
}
// Replica set shards.
const numNodesPerReplSet = self._rs.map(r => r.test.nodes.length);
return numNodesPerReplSet.reduce((a, b) => a + b, 0);
}
// ShardingTest initialization // ShardingTest initialization
assert(isObject(params), 'ShardingTest configuration must be a JSON object'); assert(isObject(params), 'ShardingTest configuration must be a JSON object');
@ -1208,6 +1223,9 @@ var ShardingTest = function(params) {
randomSeedAlreadySet = true; randomSeedAlreadySet = true;
} }
// Should we start up shards as replica sets.
const shardsAsReplSets = (otherParams.rs || otherParams["rs" + i] || startShardsAsRS);
// Start the MongoD servers (shards) // Start the MongoD servers (shards)
let startTime = new Date(); // Measure the execution time of startup and initiate. let startTime = new Date(); // Measure the execution time of startup and initiate.
for (var i = 0; i < numShards; i++) { for (var i = 0; i < numShards; i++) {
@ -1449,7 +1467,8 @@ var ShardingTest = function(params) {
rstOptions.nodes = nodeOptions; rstOptions.nodes = nodeOptions;
startTime = new Date(); // Measure the execution time of config server startup and initiate. const configServerStartTime =
new Date(); // Measure the execution time of config server startup and initiate.
// Start the config server's replica set // Start the config server's replica set
this.configRS = new ReplSetTest(rstOptions); this.configRS = new ReplSetTest(rstOptions);
@ -1467,7 +1486,12 @@ var ShardingTest = function(params) {
var csrsPrimary = this.configRS.getPrimary(); var csrsPrimary = this.configRS.getPrimary();
print("ShardingTest startup and initiation for the config server took " + print("ShardingTest startup and initiation for the config server took " +
(new Date() - startTime) + "ms with " + this.configRS.nodeList().length + " nodes."); (new Date() - configServerStartTime) + "ms with " + this.configRS.nodeList().length +
" nodes.");
print("ShardingTest startup and initiation for all nodes took " + (new Date() - startTime) +
"ms with " + this.configRS.nodeList().length + " config server nodes and " +
totalNumShardNodes(shardsAsReplSets) + " total shard nodes.");
// If 'otherParams.mongosOptions.binVersion' is an array value, then we'll end up constructing a // If 'otherParams.mongosOptions.binVersion' is an array value, then we'll end up constructing a
// version iterator. // version iterator.