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_skip.cpp | |
| parent | d5a46532dd80c4255982308cb933cf78efb21a7f (diff) | |
| download | mongo-ab322d38ef3d5c3836df516f2a40c54c5165cafd.tar.gz | |
SERVER-41294 shard filtering for $sb
Diffstat (limited to 'src/mongo/db/pipeline/document_source_skip.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_skip.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/mongo/db/pipeline/document_source_skip.cpp b/src/mongo/db/pipeline/document_source_skip.cpp index 364f148162e..2eead90aa3f 100644 --- a/src/mongo/db/pipeline/document_source_skip.cpp +++ b/src/mongo/db/pipeline/document_source_skip.cpp @@ -84,6 +84,10 @@ Pipeline::SourceContainer::iterator DocumentSourceSkip::doOptimizeAt( Pipeline::SourceContainer::iterator itr, Pipeline::SourceContainer* container) { invariant(*itr == this); + if (std::next(itr) == container->end()) { + return container->end(); + } + auto nextSkip = dynamic_cast<DocumentSourceSkip*>((*std::next(itr)).get()); if (nextSkip) { // '_nToSkip' can potentially overflow causing it to become negative and skip nothing. |