diff --git a/util/execdetails.go b/util/execdetails.go index 30f108a4..a9db7a7c 100644 --- a/util/execdetails.go +++ b/util/execdetails.go @@ -653,6 +653,13 @@ func (td *TimeDetail) String() string { buf.WriteString("total_wait_time: ") buf.WriteString(FormatDuration(td.WaitTime)) } + if td.KvReadWallTime > 0 { + if buf.Len() > 0 { + buf.WriteString(", ") + } + buf.WriteString("total_kv_read_wall_time: ") + buf.WriteString(FormatDuration(td.KvReadWallTime)) + } if td.TotalRPCWallTime > 0 { if buf.Len() > 0 { buf.WriteString(", ") @@ -663,6 +670,17 @@ func (td *TimeDetail) String() string { return buf.String() } +// Merge merges the time detail into itself. +func (td *TimeDetail) Merge(detail *TimeDetail) { + if detail != nil { + td.ProcessTime += detail.ProcessTime + td.SuspendTime += detail.SuspendTime + td.WaitTime += detail.WaitTime + td.KvReadWallTime += detail.KvReadWallTime + td.TotalRPCWallTime += detail.TotalRPCWallTime + } +} + // MergeFromTimeDetail merges time detail from pb into itself. func (td *TimeDetail) MergeFromTimeDetail(timeDetailV2 *kvrpcpb.TimeDetailV2, timeDetail *kvrpcpb.TimeDetail) { if timeDetailV2 != nil {