summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_lookup.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_lookup.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_lookup.cpp8
1 files changed, 3 insertions, 5 deletions
diff --git a/src/mongo/db/pipeline/document_source_lookup.cpp b/src/mongo/db/pipeline/document_source_lookup.cpp
index f14b3db0394..0c42c595cfe 100644
--- a/src/mongo/db/pipeline/document_source_lookup.cpp
+++ b/src/mongo/db/pipeline/document_source_lookup.cpp
@@ -53,7 +53,7 @@ constexpr size_t DocumentSourceLookUp::kMaxSubPipelineDepth;
DocumentSourceLookUp::DocumentSourceLookUp(NamespaceString fromNs,
std::string as,
const boost::intrusive_ptr<ExpressionContext>& expCtx)
- : DocumentSource(expCtx),
+ : DocumentSource(kStageName, expCtx),
_fromNs(std::move(fromNs)),
_as(std::move(as)),
_variables(expCtx->variables),
@@ -161,7 +161,7 @@ REGISTER_DOCUMENT_SOURCE(lookup,
DocumentSourceLookUp::createFromBson);
const char* DocumentSourceLookUp::getSourceName() const {
- return "$lookup";
+ return kStageName.rawData();
}
StageConstraints DocumentSourceLookUp::constraints(Pipeline::SplitState) const {
@@ -227,9 +227,7 @@ BSONObj buildEqualityOrQuery(const std::string& fieldName, const BSONArray& valu
} // namespace
-DocumentSource::GetNextResult DocumentSourceLookUp::getNext() {
- pExpCtx->checkForInterrupt();
-
+DocumentSource::GetNextResult DocumentSourceLookUp::doGetNext() {
if (_unwindSrc) {
return unwindResult();
}