diff options
| author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2019-10-31 16:38:01 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2019-10-31 16:38:01 +0000 |
| commit | 1f94484d52064e12baedc7b586a8238d63560baf (patch) | |
| tree | 5bb03cebfcb2d3137321b4762a0500f8831463dd /src/mongo/db/sessions_collection_rs.cpp | |
| parent | 7a3d17ea6b73bc916d94e59a44d5c1a56cbcb2e5 (diff) | |
| download | mongo-1f94484d52064e12baedc7b586a8238d63560baf.tar.gz | |
SERVER-42508 Get rid of some additional unused code in SessionsCollection
... and also improve comments.
Diffstat (limited to 'src/mongo/db/sessions_collection_rs.cpp')
| -rw-r--r-- | src/mongo/db/sessions_collection_rs.cpp | 37 |
1 files changed, 19 insertions, 18 deletions
diff --git a/src/mongo/db/sessions_collection_rs.cpp b/src/mongo/db/sessions_collection_rs.cpp index 10c5c06125a..f043e30254a 100644 --- a/src/mongo/db/sessions_collection_rs.cpp +++ b/src/mongo/db/sessions_collection_rs.cpp @@ -175,20 +175,21 @@ void SessionsCollectionRS::refreshSessions(OperationContext* opCtx, const LogicalSessionRecordSet& sessions) { const std::vector<LogicalSessionRecord> sessionsVector(sessions.begin(), sessions.end()); - _dispatch( - NamespaceString::kLogicalSessionsNamespace, - opCtx, - [&] { - DBDirectClient client(opCtx); - doRefresh(NamespaceString::kLogicalSessionsNamespace, + _dispatch(NamespaceString::kLogicalSessionsNamespace, + opCtx, + [&] { + DBDirectClient client(opCtx); + _doRefresh( + NamespaceString::kLogicalSessionsNamespace, sessionsVector, makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, &client)); - }, - [&](DBClientBase* client) { - doRefresh(NamespaceString::kLogicalSessionsNamespace, + }, + [&](DBClientBase* client) { + _doRefresh( + NamespaceString::kLogicalSessionsNamespace, sessionsVector, makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, client)); - }); + }); } void SessionsCollectionRS::removeRecords(OperationContext* opCtx, @@ -200,14 +201,14 @@ void SessionsCollectionRS::removeRecords(OperationContext* opCtx, opCtx, [&] { DBDirectClient client(opCtx); - doRemove(NamespaceString::kLogicalSessionsNamespace, - sessionsVector, - makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, &client)); + _doRemove(NamespaceString::kLogicalSessionsNamespace, + sessionsVector, + makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, &client)); }, [&](DBClientBase* client) { - doRemove(NamespaceString::kLogicalSessionsNamespace, - sessionsVector, - makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, client)); + _doRemove(NamespaceString::kLogicalSessionsNamespace, + sessionsVector, + makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, client)); }); } @@ -220,13 +221,13 @@ LogicalSessionIdSet SessionsCollectionRS::findRemovedSessions(OperationContext* opCtx, [&] { DBDirectClient client(opCtx); - return doFindRemoved( + return _doFindRemoved( NamespaceString::kLogicalSessionsNamespace, sessionsVector, makeFindFnForCommand(NamespaceString::kLogicalSessionsNamespace, &client)); }, [&](DBClientBase* client) { - return doFindRemoved( + return _doFindRemoved( NamespaceString::kLogicalSessionsNamespace, sessionsVector, makeFindFnForCommand(NamespaceString::kLogicalSessionsNamespace, client)); |