diff options
| author | Ian Boros <puppyofkosh@gmail.com> | 2019-05-29 19:31:05 -0400 |
|---|---|---|
| committer | Ian Boros <puppyofkosh@gmail.com> | 2019-06-07 13:15:21 -0400 |
| commit | ab322d38ef3d5c3836df516f2a40c54c5165cafd (patch) | |
| tree | 1a1d77ad40275d3160b1701a2984745965f9da45 /src/mongo/db/pipeline/document_source_cursor.cpp | |
| parent | d5a46532dd80c4255982308cb933cf78efb21a7f (diff) | |
| download | mongo-ab322d38ef3d5c3836df516f2a40c54c5165cafd.tar.gz | |
SERVER-41294 shard filtering for $sb
Diffstat (limited to 'src/mongo/db/pipeline/document_source_cursor.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_cursor.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_cursor.cpp b/src/mongo/db/pipeline/document_source_cursor.cpp index 0015d915acc..1d971d188a8 100644 --- a/src/mongo/db/pipeline/document_source_cursor.cpp +++ b/src/mongo/db/pipeline/document_source_cursor.cpp @@ -175,6 +175,10 @@ Pipeline::SourceContainer::iterator DocumentSourceCursor::doOptimizeAt( Pipeline::SourceContainer::iterator itr, Pipeline::SourceContainer* container) { invariant(*itr == this); + if (std::next(itr) == container->end()) { + return container->end(); + } + auto nextLimit = dynamic_cast<DocumentSourceLimit*>((*std::next(itr)).get()); if (nextLimit) { |