diff options
Diffstat (limited to 'src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp')
| -rw-r--r-- | src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp b/src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp index 2cadf4e26b0..59d6bae1fc7 100644 --- a/src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp +++ b/src/mongo/db/s/balancer/balancer_defragmentation_policy_impl.cpp @@ -336,8 +336,8 @@ public: rangesToMerge += pendingActions.rangesToMerge.size(); rangesWithoutDataSize += pendingActions.rangesWithoutDataSize.size(); } - auto remainingChunksToProcess = - static_cast<long long>(_outstandingActions + rangesToMerge + rangesWithoutDataSize); + auto remainingChunksToProcess = static_cast<long long>(_outstandingActions) + + static_cast<long long>(rangesToMerge) + static_cast<long long>(rangesWithoutDataSize); return BSON(kRemainingChunksToProcess << remainingChunksToProcess); } @@ -1129,7 +1129,8 @@ public: for (const auto& [_, unmergedRanges] : _unmergedRangesByShard) { rangesToMerge += unmergedRanges.size(); } - auto remainingRangesToProcess = static_cast<long long>(_outstandingActions + rangesToMerge); + auto remainingRangesToProcess = + static_cast<long long>(_outstandingActions) + static_cast<long long>(rangesToMerge); return BSON(kRemainingChunksToProcess << remainingRangesToProcess); } @@ -1343,8 +1344,8 @@ public: rangesToFindSplitPoints += pendingActions.rangesToFindSplitPoints.size(); rangesToSplit += pendingActions.rangesToSplit.size(); } - auto remainingChunksToProcess = - static_cast<long long>(_outstandingActions + rangesToFindSplitPoints + rangesToSplit); + auto remainingChunksToProcess = static_cast<long long>(_outstandingActions) + + static_cast<long long>(rangesToFindSplitPoints) + static_cast<long long>(rangesToSplit); return BSON(kRemainingChunksToProcess << remainingChunksToProcess); } |