diff options
author | Misha Tyulenev <misha@mongodb.com> | 2018-08-28 14:11:04 -0400 |
---|---|---|
committer | Misha Tyulenev <misha@mongodb.com> | 2018-08-28 14:11:23 -0400 |
commit | a3d17a55ca68ba37eb59620e04258f61f133b21f (patch) | |
tree | 8a65697acc08f83d75e1383614a1867ec8aa2255 /src/mongo/db/sessions_collection.cpp | |
parent | 0add763d724f409cc4e90d86e0047a8810929d6d (diff) | |
download | mongo-a3d17a55ca68ba37eb59620e04258f61f133b21f.tar.gz |
SERVER-36332 write to primary from secondary in LogicalSessionsCache for ReplicaSet
Diffstat (limited to 'src/mongo/db/sessions_collection.cpp')
-rw-r--r-- | src/mongo/db/sessions_collection.cpp | 25 |
1 files changed, 0 insertions, 25 deletions
diff --git a/src/mongo/db/sessions_collection.cpp b/src/mongo/db/sessions_collection.cpp index cf8e0349a30..fe60b747c55 100644 --- a/src/mongo/db/sessions_collection.cpp +++ b/src/mongo/db/sessions_collection.cpp @@ -225,24 +225,6 @@ Status SessionsCollection::doRefresh(const NamespaceString& ns, return runBulkCmd("updates", init, add, send, sessions); } -Status SessionsCollection::doRefreshExternal(const NamespaceString& ns, - const LogicalSessionRecordSet& sessions, - SendBatchFn send) { - auto makeT = [] { return std::vector<LogicalSessionRecord>{}; }; - - auto add = [](std::vector<LogicalSessionRecord>& batch, const LogicalSessionRecord& record) { - batch.push_back(record); - }; - - auto sendLocal = [&](std::vector<LogicalSessionRecord>& batch) { - RefreshSessionsCmdFromClusterMember idl; - idl.setRefreshSessionsInternal(batch); - return send(idl.toBSON()); - }; - - return runBulkGeneric(makeT, add, sendLocal, sessions); -} - Status SessionsCollection::doRemove(const NamespaceString& ns, const LogicalSessionIdSet& sessions, SendBatchFn send) { @@ -259,13 +241,6 @@ Status SessionsCollection::doRemove(const NamespaceString& ns, return runBulkCmd("deletes", init, add, send, sessions); } -Status SessionsCollection::doRemoveExternal(const NamespaceString& ns, - const LogicalSessionIdSet& sessions, - SendBatchFn send) { - // TODO SERVER-28335 Implement endSessions, with internal counterpart. - return Status::OK(); -} - StatusWith<LogicalSessionIdSet> SessionsCollection::doFetch(const NamespaceString& ns, const LogicalSessionIdSet& sessions, FindBatchFn send) { |