summaryrefslogtreecommitdiff
path: root/src/mongo/db/sessions_collection.cpp
diff options
context:
space:
mode:
authorMisha Tyulenev <misha@mongodb.com>2018-08-28 14:11:04 -0400
committerMisha Tyulenev <misha@mongodb.com>2018-08-28 14:11:23 -0400
commita3d17a55ca68ba37eb59620e04258f61f133b21f (patch)
tree8a65697acc08f83d75e1383614a1867ec8aa2255 /src/mongo/db/sessions_collection.cpp
parent0add763d724f409cc4e90d86e0047a8810929d6d (diff)
downloadmongo-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.cpp25
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) {