summaryrefslogtreecommitdiff
path: root/jstests/concurrency/fsm_workloads/explain_remove.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/concurrency/fsm_workloads/explain_remove.js')
-rw-r--r--jstests/concurrency/fsm_workloads/explain_remove.js43
1 files changed, 43 insertions, 0 deletions
diff --git a/jstests/concurrency/fsm_workloads/explain_remove.js b/jstests/concurrency/fsm_workloads/explain_remove.js
new file mode 100644
index 00000000000..02620a92bea
--- /dev/null
+++ b/jstests/concurrency/fsm_workloads/explain_remove.js
@@ -0,0 +1,43 @@
+'use strict';
+
+/**
+ * explain_remove.js
+ *
+ * Runs explain() and remove() on a collection.
+ */
+load('jstests/concurrency/fsm_libs/extend_workload.js'); // for extendWorkload
+load('jstests/concurrency/fsm_workloads/explain.js'); // for $config
+
+var $config = extendWorkload($config, function($config, $super) {
+
+ $config.states = Object.extend({
+ explainSingleRemove: function explainSingleRemove(db, collName) {
+ var res = db[collName].explain('executionStats')
+ .remove({ i: this.nInserted }, /* justOne */ true);
+ assertAlways.commandWorked(res);
+ assertWhenOwnColl(function() {
+ assertWhenOwnColl.eq(1, res.executionStats.totalDocsExamined);
+
+ // the document should not have been deleted.
+ assertWhenOwnColl.eq(1, db[collName].find({i: this.nInserted}).itcount());
+ }.bind(this));
+ },
+ explainMultiRemove: function explainMultiRemove(db, collName) {
+ var res = db[collName].explain('executionStats')
+ .remove({i: {$lte: this.nInserted / 2}});
+ assertAlways.commandWorked(res);
+ assertWhenOwnColl(function() {
+ assertWhenOwnColl.eq(this.nInserted / 2 + 1,
+ explain.executionStats.totalDocsExamined);
+ // no documents should have been deleted
+ assertWhenOwnColl.eq(this.nInserted, db[collName].itcount());
+ }.bind(this));
+ }
+ }, $super.states);
+
+ $config.transitions = Object.extend({
+ explain: $config.data.assignEqualProbsToTransitions($config.states)
+ }, $super.transitions);
+
+ return $config;
+});