summaryrefslogtreecommitdiff
path: root/src/mongo/db/sessions_collection_standalone.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/sessions_collection_standalone.cpp')
-rw-r--r--src/mongo/db/sessions_collection_standalone.cpp18
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