diff options
| author | Xinhao Zhang <xinhao.zhang@mongodb.com> | 2019-08-16 20:43:48 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2019-08-16 20:43:48 +0000 |
| commit | f83f5784ea56d8158f8da654a964d1cd1d142648 (patch) | |
| tree | d3cac5b51ef6ed7b1f727773a155fc17af3c3694 /src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp | |
| parent | 25418e659b3ed6d09a41c147683fa9493d1ffa29 (diff) | |
| download | mongo-f83f5784ea56d8158f8da654a964d1cd1d142648.tar.gz | |
SERVER-42584 PlanStageStats in aggregation
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp b/src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp index 1fedb3cb940..a4a43c654ee 100644 --- a/src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp +++ b/src/mongo/db/pipeline/document_source_change_stream_close_cursor.cpp @@ -52,9 +52,7 @@ bool isInvalidatingCommand(const boost::intrusive_ptr<ExpressionContext>& pExpCt } // namespace -DocumentSource::GetNextResult DocumentSourceCloseCursor::getNext() { - pExpCtx->checkForInterrupt(); - +DocumentSource::GetNextResult DocumentSourceCloseCursor::doGetNext() { // Close cursor if we have returned an invalidate entry. if (_shouldCloseCursor) { uasserted(ErrorCodes::CloseChangeStream, "Change stream has been invalidated"); |