diff options
author | samantharitter <samantha.ritter@10gen.com> | 2017-06-08 18:18:28 -0400 |
---|---|---|
committer | samantharitter <samantha.ritter@10gen.com> | 2017-06-09 11:08:57 -0400 |
commit | fb22390ab04a55fcbd91eba673dde310cb938351 (patch) | |
tree | 7754063c492174dbd45084c61b228d59b704c02d /src/mongo/db/sessions_collection_mock.cpp | |
parent | ff412300b3688dad4938bb381ec3aba12a81024b (diff) | |
download | mongo-fb22390ab04a55fcbd91eba673dde310cb938351.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.cpp | 14 |
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); |