summaryrefslogtreecommitdiff
path: root/src/mongo/db/sessions_collection_mock.cpp
diff options
context:
space:
mode:
authorsamantharitter <samantha.ritter@10gen.com>2017-06-02 15:38:06 -0400
committersamantharitter <samantha.ritter@10gen.com>2017-06-07 17:14:56 -0400
commit4c3337abe512a37c8e4cb22e16eafcd04bc5bd3a (patch)
tree14e7ec8f979dcde59a77b48bdde9c607fb19e5fe /src/mongo/db/sessions_collection_mock.cpp
parentcb187547d18723d1b4e18ffdb069c8cdc53769a8 (diff)
downloadmongo-4c3337abe512a37c8e4cb22e16eafcd04bc5bd3a.tar.gz
SERVER-28346 Add more unit tests for the logical session cache
Diffstat (limited to 'src/mongo/db/sessions_collection_mock.cpp')
-rw-r--r--src/mongo/db/sessions_collection_mock.cpp14
1 files changed, 6 insertions, 8 deletions
diff --git a/src/mongo/db/sessions_collection_mock.cpp b/src/mongo/db/sessions_collection_mock.cpp
index a56f6dec21a..4abc5a326d1 100644
--- a/src/mongo/db/sessions_collection_mock.cpp
+++ b/src/mongo/db/sessions_collection_mock.cpp
@@ -73,12 +73,11 @@ Status MockSessionsCollectionImpl::insertRecord(LogicalSessionRecord record) {
return _insert(std::move(record));
}
-MockSessionsCollectionImpl::SessionList MockSessionsCollectionImpl::refreshSessions(
- SessionList sessions) {
+LogicalSessionIdSet MockSessionsCollectionImpl::refreshSessions(LogicalSessionIdSet sessions) {
return _refresh(std::move(sessions));
}
-void MockSessionsCollectionImpl::removeRecords(SessionList sessions) {
+void MockSessionsCollectionImpl::removeRecords(LogicalSessionIdSet sessions) {
_remove(std::move(sessions));
}
@@ -131,16 +130,15 @@ Status MockSessionsCollectionImpl::_insertRecord(LogicalSessionRecord record) {
return Status::OK();
}
-MockSessionsCollectionImpl::SessionList MockSessionsCollectionImpl::_refreshSessions(
- SessionList sessions) {
- SessionList notFound{};
+LogicalSessionIdSet MockSessionsCollectionImpl::_refreshSessions(LogicalSessionIdSet sessions) {
+ LogicalSessionIdSet notFound{};
{
stdx::unique_lock<stdx::mutex> lk(_mutex);
for (auto& lsid : sessions) {
auto it = _sessions.find(lsid);
if (it == _sessions.end()) {
- notFound.push_back(lsid);
+ notFound.insert(lsid);
}
}
}
@@ -148,7 +146,7 @@ MockSessionsCollectionImpl::SessionList MockSessionsCollectionImpl::_refreshSess
return notFound;
}
-void MockSessionsCollectionImpl::_removeRecords(SessionList sessions) {
+void MockSessionsCollectionImpl::_removeRecords(LogicalSessionIdSet sessions) {
stdx::unique_lock<stdx::mutex> lk(_mutex);
for (auto& lsid : sessions) {
_sessions.erase(lsid);