SERVER-33918: Support $changeStream against all collections in a database for a replica set only

1 files changed, 10 insertions, 0 deletions

diff --git a/src/mongo/db/pipeline/document_source_current_op.h b/src/mongo/db/pipeline/document_source_current_op.h
index d655c0ed2bf..c1f3e4654c1 100644
--- a/src/mongo/db/pipeline/document_source_current_op.h
+++ b/src/mongo/db/pipeline/document_source_current_op.h
@@ -39,6 +39,8 @@ public:
     using LocalOpsMode = MongoProcessInterface::CurrentOpLocalOpsMode;
     using UserMode = MongoProcessInterface::CurrentOpUserMode;
 
+    static constexpr StringData kStageName = "$currentOp"_sd;
+
     class LiteParsed final : public LiteParsedDocumentSource {
     public:
         static std::unique_ptr<LiteParsed> parse(const AggregationRequest& request,
@@ -77,6 +79,14 @@ public:
             return true;
         }
 
+        void assertSupportsReadConcern(const repl::ReadConcernArgs& readConcern) const {
+            uassert(ErrorCodes::InvalidOptions,
+                    str::stream() << "Aggregation stage " << kStageName
+                                  << " requires read concern local but found "
+                                  << readConcern.toString(),
+                    readConcern.getLevel() == repl::ReadConcernLevel::kLocalReadConcern);
+        }
+
     private:
         const UserMode _allUsers;
         const LocalOpsMode _localOps;