1 files changed, 75 insertions, 0 deletions
diff --git a/jstests/replsets/sessions_collection_reaping.js b/jstests/replsets/sessions_collection_reaping.js
new file mode 100644
index 00000000000..ec6e60bbf40
--- /dev/null
+++ b/jstests/replsets/sessions_collection_reaping.js
@@ -0,0 +1,75 @@
+(function() {
+"use strict";
+
+// This test makes assertions about the number of sessions, which are not compatible with
+// implicit sessions.
+TestData.disableImplicitSessions = true;
+
+let replTest = new ReplSetTest({
+    name: 'reaping',
+    nodes: [
+        {/* primary */},
+        {/* secondary */ rsConfig: {priority: 0}},
+        {/* arbiter */ rsConfig: {arbiterOnly: true}}
+    ],
+    nodeOptions: {setParameter: {TransactionRecordMinimumLifetimeMinutes: 0}}
+});
+let nodes = replTest.startSet();
+
+replTest.initiate();
+let primary = replTest.getPrimary();
+let sessionsCollOnPrimary = primary.getDB("config").system.sessions;
+let transactionsCollOnPrimary = primary.getDB("config").transactions;
+
+replTest.awaitSecondaryNodes();
+let secondary = replTest.getSecondary();
+let arbiter = replTest.getArbiter();
+
+const dbName = jsTestName();
+const collName = "test";
+const reapErrorMsgRegex =
+    new RegExp("Sessions collection is not set up.*waiting until next sessions reap interval");
+
+// Set up a session with a retryable write.
+let session = primary.startSession({retryWrites: 1});
+assert.commandWorked(session.getDatabase(dbName)[collName].save({x: 1}));
+assert.commandWorked(primary.adminCommand({refreshLogicalSessionCacheNow: 1}));
+assert.eq(1, sessionsCollOnPrimary.count());
+assert.eq(1, transactionsCollOnPrimary.count());
+
+// Remove the session doc so the session gets reaped when reapLogicalSessionCacheNow is run.
+assert.commandWorked(sessionsCollOnPrimary.remove({}));
+
+// Test that a reap on a secondary does not lead to the on-disk state reaping of the session
+// since the session does not exist in the secondary's session catalog.
+{
+    assert.commandWorked(secondary.adminCommand({clearLog: 'global'}));
+    assert.commandWorked(secondary.adminCommand({reapLogicalSessionCacheNow: 1}));
+
+    assert.eq(1, transactionsCollOnPrimary.count());
+    assert.eq(false, checkLog.checkContainsOnce(secondary, reapErrorMsgRegex));
+}
+
+// Test that a reap on an arbiter does not lead to reaping of the session.
+{
+    assert.commandWorked(arbiter.adminCommand({clearLog: 'global'}));
+    assert.commandWorked(arbiter.adminCommand({reapLogicalSessionCacheNow: 1}));
+
+    assert.eq(1, transactionsCollOnPrimary.count());
+
+    if (!jsTest.options().useRandomBinVersionsWithinReplicaSet) {
+        // Verify that the arbiter did not try to reap the session.
+        assert.eq(false, checkLog.checkContainsOnce(arbiter, reapErrorMsgRegex));
+    }
+}
+
+// Test that a reap on the primary works as expected.
+{
+    assert.commandWorked(primary.adminCommand({clearLog: 'global'}));
+    assert.commandWorked(primary.adminCommand({reapLogicalSessionCacheNow: 1}));
+
+    assert.eq(0, transactionsCollOnPrimary.count());
+}
+
+replTest.stopSet();
+})();