diff options
| author | Charlie Swanson <cswanson310@gmail.com> | 2016-09-01 17:32:55 -0400 |
|---|---|---|
| committer | Charlie Swanson <cswanson310@gmail.com> | 2016-09-12 16:55:21 -0400 |
| commit | 8383c8731ba18b8443e424783c5aa63a8aed9202 (patch) | |
| tree | c8126726ac5255fc2f3410337627714944036c66 /src/mongo/db/pipeline/document_source_graph_lookup.cpp | |
| parent | ec61ddf3e46fdc4c5c960968d3766195cd3a2c34 (diff) | |
| download | mongo-8383c8731ba18b8443e424783c5aa63a8aed9202.tar.gz | |
SERVER-24153 Add unit tests for DocumentSource pausing behavior.
Diffstat (limited to 'src/mongo/db/pipeline/document_source_graph_lookup.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_graph_lookup.cpp | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/src/mongo/db/pipeline/document_source_graph_lookup.cpp b/src/mongo/db/pipeline/document_source_graph_lookup.cpp index b9f3d0aa4e8..daa51ad8294 100644 --- a/src/mongo/db/pipeline/document_source_graph_lookup.cpp +++ b/src/mongo/db/pipeline/document_source_graph_lookup.cpp @@ -450,6 +450,7 @@ void DocumentSourceGraphLookUp::doReattachToOperationContext(OperationContext* o } DocumentSourceGraphLookUp::DocumentSourceGraphLookUp( + const boost::intrusive_ptr<ExpressionContext>& expCtx, NamespaceString from, std::string as, std::string connectFromField, @@ -458,7 +459,7 @@ DocumentSourceGraphLookUp::DocumentSourceGraphLookUp( boost::optional<BSONObj> additionalFilter, boost::optional<FieldPath> depthField, boost::optional<long long> maxDepth, - const boost::intrusive_ptr<ExpressionContext>& expCtx) + boost::optional<boost::intrusive_ptr<DocumentSourceUnwind>> unwindSrc) : DocumentSourceNeedsMongod(expCtx), _from(std::move(from)), _as(std::move(as)), @@ -469,7 +470,8 @@ DocumentSourceGraphLookUp::DocumentSourceGraphLookUp( _depthField(depthField), _maxDepth(maxDepth), _visited(ValueComparator::kInstance.makeUnorderedValueMap<BSONObj>()), - _cache(expCtx->getValueComparator()) {} + _cache(expCtx->getValueComparator()), + _unwind(unwindSrc) {} intrusive_ptr<DocumentSourceGraphLookUp> DocumentSourceGraphLookUp::create( const intrusive_ptr<ExpressionContext>& expCtx, @@ -480,9 +482,11 @@ intrusive_ptr<DocumentSourceGraphLookUp> DocumentSourceGraphLookUp::create( intrusive_ptr<Expression> startWith, boost::optional<BSONObj> additionalFilter, boost::optional<FieldPath> depthField, - boost::optional<long long> maxDepth) { + boost::optional<long long> maxDepth, + boost::optional<boost::intrusive_ptr<DocumentSourceUnwind>> unwindSrc) { intrusive_ptr<DocumentSourceGraphLookUp> source( - new DocumentSourceGraphLookUp(std::move(fromNs), + new DocumentSourceGraphLookUp(expCtx, + std::move(fromNs), std::move(asField), std::move(connectFromField), std::move(connectToField), @@ -490,7 +494,7 @@ intrusive_ptr<DocumentSourceGraphLookUp> DocumentSourceGraphLookUp::create( additionalFilter, depthField, maxDepth, - expCtx)); + unwindSrc)); source->_variables.reset(new Variables()); source->injectExpressionContext(expCtx); @@ -595,7 +599,8 @@ intrusive_ptr<DocumentSource> DocumentSourceGraphLookUp::createFromBson( !isMissingRequiredField); intrusive_ptr<DocumentSourceGraphLookUp> newSource( - new DocumentSourceGraphLookUp(std::move(from), + new DocumentSourceGraphLookUp(expCtx, + std::move(from), std::move(as), std::move(connectFromField), std::move(connectToField), @@ -603,7 +608,7 @@ intrusive_ptr<DocumentSource> DocumentSourceGraphLookUp::createFromBson( additionalFilter, depthField, maxDepth, - expCtx)); + boost::none)); newSource->_variables.reset(new Variables(idGenerator.getIdCount())); |