diff options
| author | Tess Avitabile <tess.avitabile@mongodb.com> | 2018-01-04 17:32:21 -0500 |
|---|---|---|
| committer | Tess Avitabile <tess.avitabile@mongodb.com> | 2018-01-23 09:57:56 -0500 |
| commit | a98d497c957dc2da7d29c37be9809ace992ef946 (patch) | |
| tree | 17191166815defa371bfead2ddeb022b752f03a6 /src/mongo/db/commands/pipeline_command.cpp | |
| parent | ad0ab27807a29e025b36a82ede139c975ad65cfb (diff) | |
| download | mongo-a98d497c957dc2da7d29c37be9809ace992ef946.tar.gz | |
SERVER-32517 Parse readConcern snapshot and atClusterTime
Diffstat (limited to 'src/mongo/db/commands/pipeline_command.cpp')
| -rw-r--r-- | src/mongo/db/commands/pipeline_command.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/db/commands/pipeline_command.cpp b/src/mongo/db/commands/pipeline_command.cpp index 7f2586f5827..3cc4b4d1e8e 100644 --- a/src/mongo/db/commands/pipeline_command.cpp +++ b/src/mongo/db/commands/pipeline_command.cpp @@ -65,9 +65,11 @@ public: return true; } - bool supportsNonLocalReadConcern(const std::string& dbName, - const BSONObj& cmdObj) const override { - return !AggregationRequest::parseNs(dbName, cmdObj).isCollectionlessAggregateNS(); + bool supportsReadConcern(const std::string& dbName, + const BSONObj& cmdObj, + repl::ReadConcernLevel level) const override { + return level == repl::ReadConcernLevel::kLocalReadConcern || + !AggregationRequest::parseNs(dbName, cmdObj).isCollectionlessAggregateNS(); } ReadWriteType getReadWriteType() const { |