diff options
author | Kruti Shah <kruti139@gmail.com> | 2022-07-14 17:21:21 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-07-14 18:19:27 +0000 |
commit | f28a9f718268ca84644aa77e98ca7ee9651bd5b6 (patch) | |
tree | 1a336a4c3016c3459e21d8abac62bb019fbc348e /src/mongo/shell | |
parent | 44de5a44ab78ca252cf565d4175d3df10bf3d77d (diff) | |
download | mongo-f28a9f718268ca84644aa77e98ca7ee9651bd5b6.tar.gz |
SERVER-43776 replica sets shutdown in parallel
Diffstat (limited to 'src/mongo/shell')
-rw-r--r-- | src/mongo/shell/replsettest.js | 17 | ||||
-rw-r--r-- | src/mongo/shell/shardingtest.js | 146 |
2 files changed, 154 insertions, 9 deletions
diff --git a/src/mongo/shell/replsettest.js b/src/mongo/shell/replsettest.js index 5dd402a89d7..3f155db9ba0 100644 --- a/src/mongo/shell/replsettest.js +++ b/src/mongo/shell/replsettest.js @@ -3338,17 +3338,22 @@ var ReplSetTest = function(opts) { * Constructor, which instantiates the ReplSetTest object from existing nodes. */ function _constructFromExistingNodes( - {name, serverless, nodeHosts, nodeOptions, keyFile, host, waitForKeys}) { + {name, serverless, nodeHosts, nodeOptions, keyFile, host, waitForKeys, nodes = undefined}) { print('Recreating replica set from existing nodes ' + tojson(nodeHosts)); self.name = name; self.serverless = serverless; self.ports = nodeHosts.map(node => node.split(':')[1]); - self.nodes = nodeHosts.map((node) => { - const conn = Mongo(node); - conn.name = conn.host; - return conn; - }); + if (nodes) { + self.nodes = nodes; + } else { + self.nodes = nodeHosts.map((node) => { + const conn = Mongo(node); + conn.name = conn.host; + conn.port = node.split(':')[1]; + return conn; + }); + } self.host = host; self.waitForKeys = waitForKeys; self.keyFile = keyFile; diff --git a/src/mongo/shell/shardingtest.js b/src/mongo/shell/shardingtest.js index 465ee647492..b9465970890 100644 --- a/src/mongo/shell/shardingtest.js +++ b/src/mongo/shell/shardingtest.js @@ -364,10 +364,150 @@ var ShardingTest = function(params) { this.configRS.stopSet(undefined, forRestart, opts); }; - this.stopAllShards = function(opts, forRestart = undefined) { - this._rs.forEach((rs) => { - rs.test.stopSet(15, forRestart, opts); + /** + * Returns boolean for whether the sharding test is compatible to shutdown in parallel. + */ + function isShutdownParallelSupported(opts = {}) { + if (!tryLoadParallelTester()) { + return false; + } + + if (otherParams.useBridge) { + // Keep the current behavior of shutting down each replica set shard and the + // CSRS individually when otherParams.useBridge === true. There appear to only + // be 8 instances of {useBridge: true} with ShardingTest and the implementation + // complexity is too high + return false; + } + + if (otherParams.configOptions && otherParams.configOptions.clusterAuthMode === "x509") { + // The mongo shell performing X.509 authentication as a cluster member requires + // starting a parallel shell and using the server's (not the client's) + // certificate. The ReplSetTest instance constructed in a Thread wouldn't have + // copied the path to the server's certificate. We therefore fall back to + // initiating the CSRS and replica set shards sequentially when X.509 + // authentication is being used. + return false; + } + + if (otherParams.configOptions && otherParams.configOptions.tlsMode === "preferTLS") { + return false; + } + + if (otherParams.configOptions && otherParams.configOptions.sslMode === "requireSSL") { + return false; + } + + if (opts.parallelSupported !== undefined && opts.parallelSupported === false) { + // The test has chosen to opt out of parallel shutdown + return false; + } + + return true; + } + + /** + * Returns the replica sets args for sets that are to be terminated in parallel threads. + */ + function replicaSetsToTerminate(shardRS) { + const replicaSetsToTerminate = []; + [...(shardRS.map(obj => obj.test))].forEach(rst => { + // Generating a list of live nodes in the replica set + liveNodes = []; + rst.nodes.forEach(function(node) { + try { + node.getDB('admin')._helloOrLegacyHello(); + } catch (err) { + // Ignore since the node is not live + return; + } + + if (!node.pid) { + // Getting the pid for the node + rst.keyFile = rst.keyFile ? rst.keyFile : this.keyFile; + if (rst.keyFile) { + serverStatus = authutil.asCluster(node, rst.keyFile, () => { + return node.getDB("admin").serverStatus(); + }); + } else { + serverStatus = node.getDB("admin").serverStatus(); + } + + if (serverStatus["pid"]) { + node.pid = serverStatus["pid"].valueOf(); + } else { + // Shutdown requires PID values for every node. The case we are + // unable to obtain a PID value is rare, however, should it + // occur, the code will throw this error. + throw 'Could not obtain node PID value. Shutdown failed.'; + } + } + + liveNodes.push(node); + }); + + if (liveNodes.length > 0) { + replicaSetsToTerminate.push({ + // Arguments for each replica set within parallel threads. + rstArgs: { + name: rst.name, + nodeHosts: liveNodes.map(node => `${node.host}`), + nodeOptions: rst.nodeOptions, + // Mixed-mode SSL tests may specify a keyFile per replica set rather + // than one for the whole cluster. + keyFile: rst.keyFile ? rst.keyFile : this.keyFile, + host: otherParams.useHostname ? hostName : "localhost", + waitForKeys: false, + nodes: liveNodes + }, + }); + } }); + return replicaSetsToTerminate; + } + + this.stopAllShards = function(opts = {}, forRestart = undefined) { + if (isShutdownParallelSupported(opts)) { + const threads = []; + try { + for (let {rstArgs} of replicaSetsToTerminate(this._rs)) { + const thread = new Thread((rstArgs, signal, forRestart, opts) => { + try { + const rst = new ReplSetTest({rstArgs}); + rst.stopSet(signal, forRestart, opts); + return {ok: 1}; + } catch (e) { + return { + ok: 0, + hosts: rstArgs.nodeHosts, + name: rstArgs.name, + error: e.toString(), + stack: e.stack, + }; + } + }, rstArgs, 15, forRestart, opts); + + thread.start(); + threads.push(thread); + } + } finally { + // Wait for each thread to finish. Throw an error if any thread fails. + const returnData = threads.map(thread => { + thread.join(); + return thread.returnData(); + }); + + returnData.forEach(res => { + assert.commandWorked(res, + 'terminating shard or config server replica sets failed'); + }); + } + } else { + // The replica sets shutting down serially + this._rs.forEach((rs) => { + rs.test.stopSet(15, forRestart, opts); + }); + } }; this.stopAllMongos = function(opts) { |