summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_check_invalidate.h
diff options
context:
space:
mode:
authorXinhao Zhang <xinhao.zhang@mongodb.com>2019-08-16 20:43:48 +0000
committerevergreen <evergreen@mongodb.com>2019-08-16 20:43:48 +0000
commitf83f5784ea56d8158f8da654a964d1cd1d142648 (patch)
treed3cac5b51ef6ed7b1f727773a155fc17af3c3694 /src/mongo/db/pipeline/document_source_check_invalidate.h
parent25418e659b3ed6d09a41c147683fa9493d1ffa29 (diff)
downloadmongo-f83f5784ea56d8158f8da654a964d1cd1d142648.tar.gz
SERVER-42584 PlanStageStats in aggregation
Diffstat (limited to 'src/mongo/db/pipeline/document_source_check_invalidate.h')
-rw-r--r--src/mongo/db/pipeline/document_source_check_invalidate.h9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/document_source_check_invalidate.h b/src/mongo/db/pipeline/document_source_check_invalidate.h
index 349ad68c589..69b4dcb742c 100644
--- a/src/mongo/db/pipeline/document_source_check_invalidate.h
+++ b/src/mongo/db/pipeline/document_source_check_invalidate.h
@@ -40,11 +40,11 @@ namespace mongo {
*/
class DocumentSourceCheckInvalidate final : public DocumentSource {
public:
- GetNextResult getNext() final;
+ static constexpr StringData kStageName = "$_checkInvalidate"_sd;
const char* getSourceName() const final {
// This is used in error reporting.
- return "$_checkInvalidate";
+ return DocumentSourceCheckInvalidate::kStageName.rawData();
}
StageConstraints constraints(Pipeline::SplitState pipeState) const final {
@@ -80,11 +80,14 @@ private:
*/
DocumentSourceCheckInvalidate(const boost::intrusive_ptr<ExpressionContext>& expCtx,
boost::optional<ResumeTokenData> startAfterInvalidate)
- : DocumentSource(expCtx), _startAfterInvalidate(std::move(startAfterInvalidate)) {
+ : DocumentSource(kStageName, expCtx),
+ _startAfterInvalidate(std::move(startAfterInvalidate)) {
invariant(!_startAfterInvalidate ||
_startAfterInvalidate->fromInvalidate == ResumeTokenData::kFromInvalidate);
}
+ GetNextResult doGetNext() final;
+
boost::optional<ResumeTokenData> _startAfterInvalidate;
boost::optional<Document> _queuedInvalidate;
};