summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPierlauro Sciarelli <pierlauro.sciarelli@mongodb.com>2022-12-05 11:33:13 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-12-21 14:06:28 +0000
commit9ba29038b9316acb6f0a5a414285ca39fddb3fa5 (patch)
treee8780aa23ef944ddd27d0937a6ff827559a5a17d
parentf5588ecf825dcb0b05cea9c744a374b129e4b452 (diff)
downloadmongo-9ba29038b9316acb6f0a5a414285ca39fddb3fa5.tar.gz
SERVER-71787 Balancer needs to attach forceJumbo to `moveRange` command
-rw-r--r--src/mongo/db/s/balancer/balancer.cpp10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/mongo/db/s/balancer/balancer.cpp b/src/mongo/db/s/balancer/balancer.cpp
index f4752f3d12d..a9b4aa0cb6f 100644
--- a/src/mongo/db/s/balancer/balancer.cpp
+++ b/src/mongo/db/s/balancer/balancer.cpp
@@ -1054,6 +1054,16 @@ int Balancer::_moveChunks(OperationContext* opCtx,
shardSvrRequest.setMaxChunkSizeBytes(maxChunkSizeBytes);
shardSvrRequest.setFromShard(migrateInfo.from);
shardSvrRequest.setEpoch(migrateInfo.version.epoch());
+ const auto forceJumbo = [&]() {
+ if (migrateInfo.forceJumbo == MoveChunkRequest::ForceJumbo::kForceManual) {
+ return ForceJumbo::kForceManual;
+ }
+ if (migrateInfo.forceJumbo == MoveChunkRequest::ForceJumbo::kForceBalancer) {
+ return ForceJumbo::kForceBalancer;
+ }
+ return ForceJumbo::kDoNotForce;
+ }();
+ shardSvrRequest.setForceJumbo(forceJumbo);
const auto [secondaryThrottle, wc] =
getSecondaryThrottleAndWriteConcern(balancerConfig->getSecondaryThrottle());
shardSvrRequest.setSecondaryThrottle(secondaryThrottle);