diff options
author | Nicholas Zolnierz <nicholas.zolnierz@mongodb.com> | 2019-10-08 22:18:54 +0000 |
---|---|---|
committer | evergreen <evergreen@mongodb.com> | 2019-10-08 22:18:54 +0000 |
commit | 13c2e614e05cb58753ee3a89a0fa9b14d0837a6d (patch) | |
tree | 9f9ba57524e99c069a4a5e0db82f6490858e7cac /src/mongo/db/pipeline/lite_parsed_pipeline.cpp | |
parent | 40fb24a73ce0c8c1092dda3f2631648990f4587a (diff) | |
download | mongo-13c2e614e05cb58753ee3a89a0fa9b14d0837a6d.tar.gz |
SERVER-42942 M/R Agg: Implement translation for cluster mapReduce command
Diffstat (limited to 'src/mongo/db/pipeline/lite_parsed_pipeline.cpp')
-rw-r--r-- | src/mongo/db/pipeline/lite_parsed_pipeline.cpp | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/mongo/db/pipeline/lite_parsed_pipeline.cpp b/src/mongo/db/pipeline/lite_parsed_pipeline.cpp index 0b9909c5ba4..6af52389e6a 100644 --- a/src/mongo/db/pipeline/lite_parsed_pipeline.cpp +++ b/src/mongo/db/pipeline/lite_parsed_pipeline.cpp @@ -73,7 +73,7 @@ void LiteParsedPipeline::assertSupportsMultiDocumentTransaction( } } -bool LiteParsedPipeline::verifyIsSupported( +void LiteParsedPipeline::verifyIsSupported( OperationContext* opCtx, const std::function<bool(OperationContext*, const NamespaceString&)> isSharded, const boost::optional<ExplainOptions::Verbosity> explain, @@ -85,14 +85,11 @@ bool LiteParsedPipeline::verifyIsSupported( // Verify litePipe can be run at the given read concern. assertSupportsReadConcern(opCtx, explain, enableMajorityReadConcern); // Verify that no involved namespace is sharded unless allowed by the pipeline. - auto sharded = false; for (const auto& nss : getInvolvedNamespaces()) { - sharded = isSharded(opCtx, nss); uassert(28769, str::stream() << nss.ns() << " cannot be sharded", - allowShardedForeignCollection(nss) || !sharded); + allowShardedForeignCollection(nss) || !isSharded(opCtx, nss)); } - return sharded; } } // namespace mongo |