summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_limit.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_limit.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_limit.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/document_source_limit.cpp b/src/mongo/db/pipeline/document_source_limit.cpp
index f8b2ca3c0aa..f5930738a41 100644
--- a/src/mongo/db/pipeline/document_source_limit.cpp
+++ b/src/mongo/db/pipeline/document_source_limit.cpp
@@ -44,7 +44,7 @@ using boost::intrusive_ptr;
DocumentSourceLimit::DocumentSourceLimit(const intrusive_ptr<ExpressionContext>& pExpCtx,
long long limit)
- : DocumentSource(pExpCtx), _limit(limit) {}
+ : DocumentSource(kStageName, pExpCtx), _limit(limit) {}
REGISTER_DOCUMENT_SOURCE(limit,
LiteParsedDocumentSourceDefault::parse,
@@ -70,9 +70,7 @@ Pipeline::SourceContainer::iterator DocumentSourceLimit::doOptimizeAt(
return std::next(itr);
}
-DocumentSource::GetNextResult DocumentSourceLimit::getNext() {
- pExpCtx->checkForInterrupt();
-
+DocumentSource::GetNextResult DocumentSourceLimit::doGetNext() {
if (_nReturned >= _limit) {
return GetNextResult::makeEOF();
}