summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_list_local_sessions.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_list_local_sessions.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_list_local_sessions.cpp8
1 files changed, 2 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/document_source_list_local_sessions.cpp b/src/mongo/db/pipeline/document_source_list_local_sessions.cpp
index 53beab31a77..b388ee0e688 100644
--- a/src/mongo/db/pipeline/document_source_list_local_sessions.cpp
+++ b/src/mongo/db/pipeline/document_source_list_local_sessions.cpp
@@ -41,11 +41,7 @@ REGISTER_DOCUMENT_SOURCE(listLocalSessions,
DocumentSourceListLocalSessions::LiteParsed::parse,
DocumentSourceListLocalSessions::createFromBson);
-const char* DocumentSourceListLocalSessions::kStageName = "$listLocalSessions";
-
-DocumentSource::GetNextResult DocumentSourceListLocalSessions::getNext() {
- pExpCtx->checkForInterrupt();
-
+DocumentSource::GetNextResult DocumentSourceListLocalSessions::doGetNext() {
while (!_ids.empty()) {
const auto& id = _ids.back();
_ids.pop_back();
@@ -75,7 +71,7 @@ boost::intrusive_ptr<DocumentSource> DocumentSourceListLocalSessions::createFrom
DocumentSourceListLocalSessions::DocumentSourceListLocalSessions(
const boost::intrusive_ptr<ExpressionContext>& pExpCtx, const ListSessionsSpec& spec)
- : DocumentSource(pExpCtx), _spec(spec) {
+ : DocumentSource(kStageName, pExpCtx), _spec(spec) {
const auto& opCtx = pExpCtx->opCtx;
_cache = LogicalSessionCache::get(opCtx);
if (_spec.getAllUsers()) {