summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp')
-rw-r--r--src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp b/src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp
index ae6b61fb314..61eb1a620c4 100644
--- a/src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp
+++ b/src/mongo/db/s/resharding/resharding_coordinator_commit_monitor.cpp
@@ -88,13 +88,13 @@ boost::optional<Milliseconds> extractOperationRemainingTime(const BSONObj& obj)
} // namespace
CoordinatorCommitMonitor::CoordinatorCommitMonitor(
- std::shared_ptr<ReshardingMetricsNew> metricsNew,
+ std::shared_ptr<ReshardingMetrics> metrics,
NamespaceString ns,
std::vector<ShardId> recipientShards,
CoordinatorCommitMonitor::TaskExecutorPtr executor,
CancellationToken cancelToken,
Milliseconds maxDelayBetweenQueries)
- : _metricsNew{std::move(metricsNew)},
+ : _metrics{std::move(metrics)},
_ns(std::move(ns)),
_recipientShards(std::move(recipientShards)),
_executor(std::move(executor)),
@@ -209,8 +209,8 @@ ExecutorFuture<void> CoordinatorCommitMonitor::_makeFuture() const {
return RemainingOperationTimes{Milliseconds(0), Milliseconds::max()};
})
.then([this, anchor = shared_from_this()](RemainingOperationTimes remainingTimes) {
- _metricsNew->setCoordinatorHighEstimateRemainingTimeMillis(remainingTimes.max);
- _metricsNew->setCoordinatorLowEstimateRemainingTimeMillis(remainingTimes.min);
+ _metrics->setCoordinatorHighEstimateRemainingTimeMillis(remainingTimes.max);
+ _metrics->setCoordinatorLowEstimateRemainingTimeMillis(remainingTimes.min);
// Check if all recipient shards are within the commit threshold.
if (remainingTimes.max <= _threshold)