SERVER-31011 Provide transaction record deletion hook

1 files changed, 15 insertions, 3 deletions

diff --git a/src/mongo/db/sessions_collection_standalone.cpp b/src/mongo/db/sessions_collection_standalone.cpp
index 8187b19ad06..ada3583bb26 100644
--- a/src/mongo/db/sessions_collection_standalone.cpp
+++ b/src/mongo/db/sessions_collection_standalone.cpp
@@ -48,19 +48,31 @@ Status SessionsCollectionStandalone::refreshSessions(OperationContext* opCtx,
                                                      const LogicalSessionRecordSet& sessions,
                                                      Date_t refreshTime) {
     DBDirectClient client(opCtx);
-    return doRefresh(sessions, refreshTime, makeSendFnForBatchWrite(&client));
+    return doRefresh(kSessionsNamespaceString,
+                     sessions,
+                     refreshTime,
+                     makeSendFnForBatchWrite(kSessionsNamespaceString, &client));
 }
 
 Status SessionsCollectionStandalone::removeRecords(OperationContext* opCtx,
                                                    const LogicalSessionIdSet& sessions) {
     DBDirectClient client(opCtx);
-    return doRemove(sessions, makeSendFnForBatchWrite(&client));
+    return doRemove(kSessionsNamespaceString,
+                    sessions,
+                    makeSendFnForBatchWrite(kSessionsNamespaceString, &client));
 }
 
 StatusWith<LogicalSessionIdSet> SessionsCollectionStandalone::findRemovedSessions(
     OperationContext* opCtx, const LogicalSessionIdSet& sessions) {
     DBDirectClient client(opCtx);
-    return doFetch(sessions, makeFindFnForCommand(&client));
+    return doFetch(kSessionsNamespaceString,
+                   sessions,
+                   makeFindFnForCommand(kSessionsNamespaceString, &client));
+}
+
+Status SessionsCollectionStandalone::removeTransactionRecords(OperationContext* opCtx,
+                                                              const LogicalSessionIdSet& sessions) {
+    MONGO_UNREACHABLE;
 }
 
 }  // namespace mongo