summaryrefslogtreecommitdiff
path: root/jstests/concurrency/fsm_libs/thread_mgr.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/concurrency/fsm_libs/thread_mgr.js')
-rw-r--r--jstests/concurrency/fsm_libs/thread_mgr.js20
1 files changed, 8 insertions, 12 deletions
diff --git a/jstests/concurrency/fsm_libs/thread_mgr.js b/jstests/concurrency/fsm_libs/thread_mgr.js
index 145fb57146e..9680e22435b 100644
--- a/jstests/concurrency/fsm_libs/thread_mgr.js
+++ b/jstests/concurrency/fsm_libs/thread_mgr.js
@@ -211,22 +211,18 @@ workerThread.fsm = function(workloads, args, options) {
load('jstests/concurrency/fsm_libs/worker_thread.js'); // for workerThread.main
load('jstests/concurrency/fsm_libs/fsm.js'); // for fsm.run
- return workerThread.main(workloads,
- args,
- function(configs) {
- var workloads = Object.keys(configs);
- assert.eq(1, workloads.length);
- fsm.run(configs[workloads[0]]);
- });
+ return workerThread.main(workloads, args, function(configs) {
+ var workloads = Object.keys(configs);
+ assert.eq(1, workloads.length);
+ fsm.run(configs[workloads[0]]);
+ });
};
workerThread.composed = function(workloads, args, options) {
load('jstests/concurrency/fsm_libs/worker_thread.js'); // for workerThread.main
load('jstests/concurrency/fsm_libs/composer.js'); // for composer.run
- return workerThread.main(workloads,
- args,
- function(configs) {
- composer.run(workloads, configs, options);
- });
+ return workerThread.main(workloads, args, function(configs) {
+ composer.run(workloads, configs, options);
+ });
};