summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp b/src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp
index 9195d0aa0aa..535d4ebb1e2 100644
--- a/src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp
+++ b/src/mongo/db/pipeline/document_source_list_cached_and_active_users.cpp
@@ -42,11 +42,7 @@ REGISTER_TEST_DOCUMENT_SOURCE(listCachedAndActiveUsers,
DocumentSourceListCachedAndActiveUsers::LiteParsed::parse,
DocumentSourceListCachedAndActiveUsers::createFromBson);
-const char* DocumentSourceListCachedAndActiveUsers::kStageName = "$listCachedAndActiveUsers";
-
-DocumentSource::GetNextResult DocumentSourceListCachedAndActiveUsers::getNext() {
- pExpCtx->checkForInterrupt();
-
+DocumentSource::GetNextResult DocumentSourceListCachedAndActiveUsers::doGetNext() {
if (!_users.empty()) {
const auto info = std::move(_users.back());
_users.pop_back();
@@ -75,7 +71,7 @@ boost::intrusive_ptr<DocumentSource> DocumentSourceListCachedAndActiveUsers::cre
DocumentSourceListCachedAndActiveUsers::DocumentSourceListCachedAndActiveUsers(
const boost::intrusive_ptr<ExpressionContext>& pExpCtx)
- : DocumentSource(pExpCtx), _users() {
+ : DocumentSource(kStageName, pExpCtx), _users() {
auto authMgr = AuthorizationManager::get(pExpCtx->opCtx->getServiceContext());
_users = authMgr->getUserCacheInfo();
}