diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:27:20 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:27:56 -0500 |
commit | 8c5ff5834ab1f61e68b7839cd99c3de1f87c2121 (patch) | |
tree | ef4d91cc230300a6a48eeeac696ca15df6db1212 /jstests/multiVersion/libs/multi_cluster.js | |
parent | 0875be78b405016736ff42e3a50166be7561c2f8 (diff) | |
download | mongo-8c5ff5834ab1f61e68b7839cd99c3de1f87c2121.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/multiVersion/libs/multi_cluster.js')
-rw-r--r-- | jstests/multiVersion/libs/multi_cluster.js | 156 |
1 files changed, 72 insertions, 84 deletions
diff --git a/jstests/multiVersion/libs/multi_cluster.js b/jstests/multiVersion/libs/multi_cluster.js index 44ac1f32bb4..998aa594be7 100644 --- a/jstests/multiVersion/libs/multi_cluster.js +++ b/jstests/multiVersion/libs/multi_cluster.js @@ -15,116 +15,105 @@ * upgradeMongos: <bool>, // defaults to true * } */ -ShardingTest.prototype.upgradeCluster = function( binVersion, options ){ - +ShardingTest.prototype.upgradeCluster = function(binVersion, options) { + options = options || {}; - if( options.upgradeShards == undefined ) options.upgradeShards = true; - if( options.upgradeConfigs == undefined ) options.upgradeConfigs = true; - if( options.upgradeMongos == undefined ) options.upgradeMongos = true; - - if( options.upgradeMongos ){ - + if (options.upgradeShards == undefined) + options.upgradeShards = true; + if (options.upgradeConfigs == undefined) + options.upgradeConfigs = true; + if (options.upgradeMongos == undefined) + options.upgradeMongos = true; + + if (options.upgradeMongos) { // Upgrade all mongos hosts if specified - + var numMongoses = this._mongos.length; - - for( var i = 0; i < numMongoses; i++ ){ - + + for (var i = 0; i < numMongoses; i++) { var mongos = this._mongos[i]; - - MongoRunner.stopMongos( mongos ); - - mongos = MongoRunner.runMongos({ restart : mongos, - binVersion : binVersion, - appendOptions : true }); - - this[ "s" + i ] = this._mongos[i] = mongos; - if( i == 0 ) this.s = mongos; + + MongoRunner.stopMongos(mongos); + + mongos = MongoRunner.runMongos( + {restart: mongos, binVersion: binVersion, appendOptions: true}); + + this["s" + i] = this._mongos[i] = mongos; + if (i == 0) + this.s = mongos; } - - this.config = this.s.getDB( "config" ); - this.admin = this.s.getDB( "admin" ); + + this.config = this.s.getDB("config"); + this.admin = this.s.getDB("admin"); } - + var upgradedSingleShards = []; - - if( options.upgradeShards ){ - + + if (options.upgradeShards) { var numShards = this._connections.length; - + // Upgrade shards - for( var i = 0; i < numShards; i++ ){ - - if( this._rs && this._rs[i] ){ - + for (var i = 0; i < numShards; i++) { + if (this._rs && this._rs[i]) { // Upgrade replica set var rst = this._rs[i].test; - - rst.upgradeSet({ binVersion: binVersion }); - } - else { - + + rst.upgradeSet({binVersion: binVersion}); + } else { // Upgrade shard var shard = this._connections[i]; - - MongoRunner.stopMongod( shard ); - - shard = MongoRunner.runMongod({ restart : shard, - binVersion : binVersion, - appendOptions : true }); - - upgradedSingleShards[ shard.host ] = shard; - - this[ "shard" + i ] = this[ "d" + i ] = this._connections[i] = shard; - } + + MongoRunner.stopMongod(shard); + + shard = MongoRunner.runMongod( + {restart: shard, binVersion: binVersion, appendOptions: true}); + + upgradedSingleShards[shard.host] = shard; + + this["shard" + i] = this["d" + i] = this._connections[i] = shard; + } } } - - if( options.upgradeConfigs ){ - - // Upgrade config servers if they aren't already upgraded shards + + if (options.upgradeConfigs) { + // Upgrade config servers if they aren't already upgraded shards var numConfigs = this._configServers.length; - - for( var i = 0; i < numConfigs; i++ ){ - + + for (var i = 0; i < numConfigs; i++) { var configSvr = this._configServers[i]; - - if( configSvr.host in upgradedSingleShards ){ - - configSvr = upgradedSingleShards[ configSvr.host ]; - } - else{ - - MongoRunner.stopMongod( configSvr ); - - configSvr = MongoRunner.runMongod({ restart : configSvr, - binVersion : binVersion, - appendOptions : true }); + + if (configSvr.host in upgradedSingleShards) { + configSvr = upgradedSingleShards[configSvr.host]; + } else { + MongoRunner.stopMongod(configSvr); + + configSvr = MongoRunner.runMongod( + {restart: configSvr, binVersion: binVersion, appendOptions: true}); } - - this[ "config" + i ] = this[ "c" + i ] = this._configServers[i] = configSvr; + + this["config" + i] = this["c" + i] = this._configServers[i] = configSvr; } } - + }; ShardingTest.prototype.restartMongoses = function() { - + var numMongoses = this._mongos.length; - + for (var i = 0; i < numMongoses; i++) { - var mongos = this._mongos[i]; - + MongoRunner.stopMongos(mongos); - mongos = MongoRunner.runMongos({ restart : mongos }); - - this[ "s" + i ] = this._mongos[i] = mongos; - if( i == 0 ) this.s = mongos; + mongos = MongoRunner.runMongos({restart: mongos}); + + this["s" + i] = this._mongos[i] = mongos; + if (i == 0) + this.s = mongos; } - - this.config = this.s.getDB( "config" ); - this.admin = this.s.getDB( "admin" ); + + this.config = this.s.getDB("config"); + this.admin = this.s.getDB("admin"); }; ShardingTest.prototype.getMongosAtVersion = function(binVersion) { @@ -135,8 +124,7 @@ ShardingTest.prototype.getMongosAtVersion = function(binVersion) { if (version.indexOf(binVersion) == 0) { return mongoses[i]; } - } - catch (e) { + } catch (e) { printjson(e); print(mongoses[i]); } |