Skip to content

Commit 0004200

Browse files
authored
Merge 4bb0f99 into 315fac0
2 parents 315fac0 + 4bb0f99 commit 0004200

File tree

1 file changed

+8
-9
lines changed

1 file changed

+8
-9
lines changed

ydb/core/blobstorage/pdisk/blobstorage_pdisk_blockdevice_async.cpp

+8-9
Original file line numberDiff line numberDiff line change
@@ -401,16 +401,15 @@ class TRealBlockDevice : public IBlockDevice {
401401
}
402402
EndOffset = op->GetOffset() + opSize;
403403

404-
ui64 duration = HPNow() - completionAction->SubmitTime;
405-
ui64 durationMs = HPMilliSecondsFloat(duration);
404+
double duration = HPMilliSecondsFloat(HPNow() - completionAction->SubmitTime);
406405
if (op->GetType() == IAsyncIoOperation::EType::PRead) {
407406
NSan::Unpoison(op->GetData(), opSize);
408407
REQUEST_VALGRIND_MAKE_MEM_DEFINED(op->GetData(), opSize);
409-
Device.Mon.DeviceReadDuration.Increment(durationMs);
410-
LWPROBE(PDiskDeviceReadDuration, Device.GetPDiskId(), HPMilliSecondsFloat(duration), opSize);
408+
Device.Mon.DeviceReadDuration.Increment(duration);
409+
LWPROBE(PDiskDeviceReadDuration, Device.GetPDiskId(), duration, opSize);
411410
} else {
412-
Device.Mon.DeviceWriteDuration.Increment(durationMs);
413-
LWPROBE(PDiskDeviceWriteDuration, Device.GetPDiskId(), HPMilliSecondsFloat(duration), opSize);
411+
Device.Mon.DeviceWriteDuration.Increment(duration);
412+
LWPROBE(PDiskDeviceWriteDuration, Device.GetPDiskId(), duration, opSize);
414413
}
415414
if (completionAction->FlushAction) {
416415
ui64 idx = completionAction->FlushAction->OperationIdx;
@@ -668,8 +667,8 @@ class TRealBlockDevice : public IBlockDevice {
668667
Device.IsTrimEnabled = Device.IoContext->DoTrim(op);
669668
NHPTimer::STime endTime = HPNow();
670669
Device.IdleCounter.Decrement();
671-
const ui64 durationUs = HPMicroSeconds(endTime - beginTime);
672-
Device.Mon.DeviceTrimDuration.Increment(durationUs);
670+
const double duration = HPMilliSecondsFloat(endTime - beginTime);
671+
Device.Mon.DeviceTrimDuration.Increment(duration);
673672
*Device.Mon.DeviceEstimatedCostNs += completion->CostNs;
674673
if (Device.ActorSystem && Device.IsTrimEnabled) {
675674
LOG_DEBUG_S(*Device.ActorSystem, NKikimrServices::BS_DEVICE,
@@ -680,7 +679,7 @@ class TRealBlockDevice : public IBlockDevice {
680679
<< "\" offset# " << op->GetOffset()
681680
<< " size# " << op->GetSize());
682681
LWPROBE(PDiskDeviceTrimDuration, Device.GetPDiskId(),
683-
HPMilliSecondsFloat(endTime - beginTime), op->GetOffset());
682+
duration, op->GetOffset());
684683
}
685684
}
686685
completion->SetResult(EIoResult::Ok);

0 commit comments

Comments
 (0)