diff options
author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2019-04-18 18:11:49 -0400 |
---|---|---|
committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2019-05-02 17:32:13 -0400 |
commit | dabbf059e6f96edb4898b42d532d460efd2510f2 (patch) | |
tree | 29de3211bc68c18526e200f63ba0fb5fc0cb42c4 /src/mongo/db/sessions_collection_rs.cpp | |
parent | 7b427c88142e9313242dd76e7ecf1dbf0375b40e (diff) | |
download | mongo-dabbf059e6f96edb4898b42d532d460efd2510f2.tar.gz |
SERVER-37837 Move `config.transactions` manipulation out of SessionsCollection
Diffstat (limited to 'src/mongo/db/sessions_collection_rs.cpp')
-rw-r--r-- | src/mongo/db/sessions_collection_rs.cpp | 22 |
1 files changed, 0 insertions, 22 deletions
diff --git a/src/mongo/db/sessions_collection_rs.cpp b/src/mongo/db/sessions_collection_rs.cpp index 1cabfb99af2..7abc9dfd1ae 100644 --- a/src/mongo/db/sessions_collection_rs.cpp +++ b/src/mongo/db/sessions_collection_rs.cpp @@ -262,26 +262,4 @@ StatusWith<LogicalSessionIdSet> SessionsCollectionRS::findRemovedSessions( }); } -Status SessionsCollectionRS::removeTransactionRecords(OperationContext* opCtx, - const LogicalSessionIdSet& sessions) { - return dispatch( - NamespaceString::kSessionTransactionsTableNamespace, - opCtx, - [&] { - DBDirectClient client(opCtx); - return doRemove(NamespaceString::kSessionTransactionsTableNamespace, - sessions, - makeSendFnForBatchWrite( - NamespaceString::kSessionTransactionsTableNamespace, &client)); - }, - [](DBClientBase*) { - return Status(ErrorCodes::NotMaster, "Not eligible to remove transaction records"); - }); -} - -Status SessionsCollectionRS::removeTransactionRecordsHelper(OperationContext* opCtx, - const LogicalSessionIdSet& sessions) { - return SessionsCollectionRS{}.removeTransactionRecords(opCtx, sessions); -} - } // namespace mongo |