summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_data_transform_instance_metrics.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/sharding_data_transform_instance_metrics.cpp')
-rw-r--r--src/mongo/db/s/sharding_data_transform_instance_metrics.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/db/s/sharding_data_transform_instance_metrics.cpp b/src/mongo/db/s/sharding_data_transform_instance_metrics.cpp
index e74155e374b..807195c689d 100644
--- a/src/mongo/db/s/sharding_data_transform_instance_metrics.cpp
+++ b/src/mongo/db/s/sharding_data_transform_instance_metrics.cpp
@@ -85,11 +85,11 @@ ShardingDataTransformInstanceMetrics::ShardingDataTransformInstanceMetrics(
_originalCommand{std::move(originalCommand)},
_sourceNs{std::move(sourceNs)},
_role{role},
+ _startTime{startTime},
_clockSource{clockSource},
_observer{std::move(observer)},
_cumulativeMetrics{cumulativeMetrics},
_deregister{_cumulativeMetrics->registerInstanceMetrics(_observer.get())},
- _startTime{startTime},
_copyingStartTime{kNoDate},
_copyingEndTime{kNoDate},
_approxDocumentsToCopy{0},
@@ -118,7 +118,8 @@ ShardingDataTransformInstanceMetrics::~ShardingDataTransformInstanceMetrics() {
Milliseconds ShardingDataTransformInstanceMetrics::getHighEstimateRemainingTimeMillis() const {
switch (_role) {
case Role::kRecipient: {
- auto estimate = estimateRemainingRecipientTime(_applyingStartTime.load() != kNoDate,
+ auto estimate =
+ resharding::estimateRemainingRecipientTime(_applyingStartTime.load() != kNoDate,
_bytesCopied.load(),
_approxBytesToCopy.load(),
getCopyingElapsedTimeSecs(),