diff options
Diffstat (limited to 'jstests/concurrency/fsm_workloads/yield_fetch.js')
-rw-r--r-- | jstests/concurrency/fsm_workloads/yield_fetch.js | 35 |
1 files changed, 18 insertions, 17 deletions
diff --git a/jstests/concurrency/fsm_workloads/yield_fetch.js b/jstests/concurrency/fsm_workloads/yield_fetch.js index ddec0529e50..0e1073f774a 100644 --- a/jstests/concurrency/fsm_workloads/yield_fetch.js +++ b/jstests/concurrency/fsm_workloads/yield_fetch.js @@ -6,26 +6,27 @@ * Intersperse queries which use the FETCH stage with updates and deletes of documents they may * match. */ -load('jstests/concurrency/fsm_libs/extend_workload.js'); // for extendWorkload -load('jstests/concurrency/fsm_workloads/yield_rooted_or.js'); // for $config +load('jstests/concurrency/fsm_libs/extend_workload.js'); // for extendWorkload +load('jstests/concurrency/fsm_workloads/yield_rooted_or.js'); // for $config -var $config = extendWorkload($config, function($config, $super) { +var $config = extendWorkload( + $config, + function($config, $super) { - /* - * Issue a query that will use the FETCH stage. - */ - $config.states.query = function fetch(db, collName) { - var nMatches = 100; + /* + * Issue a query that will use the FETCH stage. + */ + $config.states.query = function fetch(db, collName) { + var nMatches = 100; - var cursor = db[collName].find({ c: { $lt: nMatches } }) - .batchSize(this.batchSize); + var cursor = db[collName].find({c: {$lt: nMatches}}).batchSize(this.batchSize); - var verifier = function fetchVerifier(doc, prevDoc) { - return doc.c < nMatches; - }; + var verifier = function fetchVerifier(doc, prevDoc) { + return doc.c < nMatches; + }; - this.advanceCursor(cursor, verifier); - }; + this.advanceCursor(cursor, verifier); + }; - return $config; -}); + return $config; + }); |