1 files changed, 89 insertions, 0 deletions
diff --git a/jstests/concurrency/fsm_workloads/dbhash_test.js b/jstests/concurrency/fsm_workloads/dbhash_test.js
new file mode 100644
index 00000000000..d2a1822f763
--- /dev/null
+++ b/jstests/concurrency/fsm_workloads/dbhash_test.js
@@ -0,0 +1,89 @@
+/**
+ * Tests dbHash collisions in WT with full validation.
+ * dbHash should not experience races on data, or EBUSY errors in the storage engine.
+ * @tags: [
+ *  requires_wiredtiger,
+ *  requires_replication,
+ * ]
+ */
+
+"use strict";
+
+load("jstests/concurrency/fsm_workload_helpers/state_transition_utils.js");
+
+const dbPrefix = jsTestName() + '_db_';
+
+var $config = (function() {
+    let states = {
+        init: function(db, collName) {
+            jsTestLog("init tid: " + this.tid);
+        },
+        dbHash: function(db, collName) {
+            jsTestLog("dbHash: " + db + "." + collName + " tid: " + this.tid);
+            jsTestLog("dbHash begin opTime:" + tojson(this.opTime));
+            let dbHashRes = assert.commandWorked(db.collName.runCommand({
+                dbHash: 1,
+                $_internalReadAtClusterTime: Timestamp(this.opTime['t'], this.opTime['i'])
+            }));
+            jsTestLog("dbHash done" + dbHashRes.timeMillis);
+        },
+        fullValidation: function(db, collName) {
+            jsTestLog("fullValidation: " + db + "." + collName + " tid: " + this.tid);
+            let res = assert.commandWorked(db.collName.validate({full: true}));
+            jsTestLog("fullValidation done: " + db + "." + collName + " " + this.tid);
+            assert(res.valid);
+        },
+    };
+
+    const setSyncDelay = function(db, delay) {
+        jsTestLog("setSyncDelay: ", delay);
+        assert.commandWorked(db.adminCommand({setParameter: 1, syncdelay: delay}));
+    };
+
+    const setup = function(db, collName) {
+        jsTestLog("Creating:" + db + "." + collName + " tid: " + this.tid);
+        let x = 'x'.repeat(20 * 1024);  // 20KB
+
+        let bulk = db.collName.initializeOrderedBulkOp();
+        for (let i = 0; i < 80; i++) {
+            bulk.insert({_id: x + i.toString()});
+        }
+        assertAlways.commandWorked(bulk.execute());
+
+        this.opTime =
+            assert
+                .commandWorked(db.runCommand(
+                    {insert: collName, documents: [{x: 1}], writeConcern: {w: "majority"}}))
+                .operationTime;
+        jsTestLog("dbHash opTime:" + tojson(this.opTime));
+
+        // Avoid filling the cache by flushing on a shorter interval
+        setSyncDelay(db, 10);
+
+        jsTestLog("Creating done:" + db + "." + collName);
+    };
+
+    const teardown = function(db, collName) {
+        setSyncDelay(db, 60);
+    };
+
+    const standardTransition = {
+        dbHash: 0.5,
+        fullValidation: 0.5,
+    };
+
+    const transitions = {
+        init: standardTransition,
+        dbHash: {dbHash: 0.8, fullValidation: 0.2},
+        fullValidation: {dbHash: 0.2, fullValidation: 0.8},
+    };
+
+    return {
+        threadCount: 5,
+        iterations: 2,
+        setup: setup,
+        states: states,
+        teardown: teardown,
+        transitions: transitions,
+    };
+})();