diff options
Diffstat (limited to 'src/mongo/db/sessions_collection_standalone.cpp')
-rw-r--r-- | src/mongo/db/sessions_collection_standalone.cpp | 18 |
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 |