summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/lite_parsed_pipeline.cpp
diff options
context:
space:
mode:
authorNicholas Zolnierz <nicholas.zolnierz@mongodb.com>2019-10-08 22:18:54 +0000
committerevergreen <evergreen@mongodb.com>2019-10-08 22:18:54 +0000
commit13c2e614e05cb58753ee3a89a0fa9b14d0837a6d (patch)
tree9f9ba57524e99c069a4a5e0db82f6490858e7cac /src/mongo/db/pipeline/lite_parsed_pipeline.cpp
parent40fb24a73ce0c8c1092dda3f2631648990f4587a (diff)
downloadmongo-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.cpp7
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