Skip to content

Commit bccfc7b

Browse files
authored
Bsqueue RequestTrackingStats lwprobe (#8494)
1 parent 6ca39ec commit bccfc7b

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

ydb/core/blobstorage/backpressure/queue_backpressure_client.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -778,6 +778,8 @@ class TVDiskBackpressureClientActor : public TActorBootstrapped<TVDiskBackpressu
778778
ctx.Schedule(TDuration::Seconds(1), new TEvents::TEvWakeup);
779779
UpdateRequestTrackingStatsScheduled = true;
780780
}
781+
782+
LWPROBE(BackPressureRequestTrackingStats, RecentGroup->GetGroupID(), EPDiskType_Name(RecentGroup->GetDeviceType()), VDiskId.ToStringWOGeneration(), WorstDuration.MicroSeconds() / 1000.0);
781783
}
782784

783785
////////////////////////////////////////////////////////////////////////

ydb/core/blobstorage/lwtrace_probes/blobstorage_probes.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -282,6 +282,7 @@ struct TEventTypeField {
282282
PROBE(VDiskReply, GROUPS("DSProxy"), TYPES(), NAMES()) \
283283
PROBE(DSProxyPutRequest, GROUPS("DSProxy", "LWTrackStart"), TYPES(ui32, TString, TString, TString, ui64, ui64), NAMES("groupId", "deviceType", "handleClass", "tactic", "count", "totalSize")) \
284284
PROBE(DSProxyVPutSent, GROUPS("DSProxy"), TYPES(NKikimr::TEventTypeField, TString, ui32, ui32, ui64, bool), NAMES("type", "vDiskId", "vdiskOrderNum", "count", "totalSize", "accelerate")) \
285+
PROBE(BackPressureRequestTrackingStats, GROUPS("BSQUEUE"), TYPES(ui32, TString, TString, double), NAMES("groupId", "deviceType", "vDiskId", "worstDurationMs")) \
285286
/**/
286287
LWTRACE_DECLARE_PROVIDER(BLOBSTORAGE_PROVIDER)
287288

0 commit comments

Comments
 (0)