diff options
Diffstat (limited to 'src/mongo/db/pipeline/document_source_limit.cpp')
-rw-r--r-- | src/mongo/db/pipeline/document_source_limit.cpp | 6 |
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(); } |