diff options
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.cpp | 8 |
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()) { |