diff options
| author | Rishab Joshi <rishab.joshi@mongodb.com> | 2021-06-17 21:05:30 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-06-23 23:12:44 +0000 |
| commit | 1c65954179826c76a0922e35bd4429600a1448f6 (patch) | |
| tree | ec2c8bdb7fca607a20b883dda7db558e381b6eae /src/mongo/s/query/async_results_merger.cpp | |
| parent | 8bd1e746079a416eac1611fae01b8b3efa4b92e0 (diff) | |
| download | mongo-1c65954179826c76a0922e35bd4429600a1448f6.tar.gz | |
SERVER-56871: Allow $match and $project to get pushed down to the shards for the change streams.
Diffstat (limited to 'src/mongo/s/query/async_results_merger.cpp')
| -rw-r--r-- | src/mongo/s/query/async_results_merger.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/s/query/async_results_merger.cpp b/src/mongo/s/query/async_results_merger.cpp index d6eca0d9b1b..236729e2359 100644 --- a/src/mongo/s/query/async_results_merger.cpp +++ b/src/mongo/s/query/async_results_merger.cpp @@ -489,6 +489,11 @@ Status AsyncResultsMerger::_askForNextBatch(WithLock, size_t remoteIndex) { Status AsyncResultsMerger::scheduleGetMores() { stdx::lock_guard<Latch> lk(_mutex); + + if (feature_flags::gFeatureFlagChangeStreamsOptimization.isEnabledAndIgnoreFCV()) { + _assertNotInvalidated(lk); + } + return _scheduleGetMores(lk); } |