diff options
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.cpp | 5 |
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(), |