diff options
Diffstat (limited to 'jstests/concurrency/fsm_libs/cluster.js')
-rw-r--r-- | jstests/concurrency/fsm_libs/cluster.js | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/jstests/concurrency/fsm_libs/cluster.js b/jstests/concurrency/fsm_libs/cluster.js index b848fa355ed..1b24c9bbdbb 100644 --- a/jstests/concurrency/fsm_libs/cluster.js +++ b/jstests/concurrency/fsm_libs/cluster.js @@ -53,8 +53,8 @@ var Cluster = function(options) { getObjectKeys(options).forEach(function(option) { assert.contains(option, allowedKeys, - 'invalid option: ' + tojson(option) + '; valid options are: ' + - tojson(allowedKeys)); + 'invalid option: ' + tojson(option) + + '; valid options are: ' + tojson(allowedKeys)); }); options.replication = options.replication || {}; @@ -271,7 +271,7 @@ var Cluster = function(options) { this.executeOnMongodNodes = function executeOnMongodNodes(fn) { assert(initialized, 'cluster must be initialized first'); - if (!fn || typeof(fn) !== 'function' || fn.length !== 1) { + if (!fn || typeof (fn) !== 'function' || fn.length !== 1) { throw new Error('mongod function must be a function that takes a db as an argument'); } _conns.mongod.forEach(function(mongodConn) { @@ -282,7 +282,7 @@ var Cluster = function(options) { this.executeOnMongosNodes = function executeOnMongosNodes(fn) { assert(initialized, 'cluster must be initialized first'); - if (!fn || typeof(fn) !== 'function' || fn.length !== 1) { + if (!fn || typeof (fn) !== 'function' || fn.length !== 1) { throw new Error('mongos function must be a function that takes a db as an argument'); } _conns.mongos.forEach(function(mongosConn) { @@ -293,7 +293,7 @@ var Cluster = function(options) { this.executeOnConfigNodes = function executeOnConfigNodes(fn) { assert(initialized, 'cluster must be initialized first'); - if (!fn || typeof(fn) !== 'function' || fn.length !== 1) { + if (!fn || typeof (fn) !== 'function' || fn.length !== 1) { throw new Error('config function must be a function that takes a db as an argument'); } st._configServers.forEach(function(conn) { @@ -553,8 +553,8 @@ var Cluster = function(options) { var primaryInfo = replSetStatus.members.find(memberInfo => memberInfo.self); assert(primaryInfo !== undefined, - phase + ', failed to find self in replication status: ' + - tojson(replSetStatus)); + phase + + ', failed to find self in replication status: ' + tojson(replSetStatus)); // Wait for all previous workload operations to complete, with "getLastError". res = primary.getDB('test').runCommand({ @@ -565,7 +565,6 @@ var Cluster = function(options) { }); assert.commandWorked(res, phase + ', error awaiting replication'); } - }); }; |