tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cop: add kv read wall time to print result (#1248) 

* add kv read wall time to print result

Signed-off-by: cfzjywxk <cfzjywxk@gmail.com>

* format

Signed-off-by: cfzjywxk <cfzjywxk@gmail.com>

---------

Signed-off-by: cfzjywxk <cfzjywxk@gmail.com>
This commit is contained in:
cfzjywxk 2024-03-27 10:30:46 +08:00 committed by GitHub
parent 05aaba6cc6
commit 603dc7b2e7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
util/execdetails.go
View File

@ -653,6 +653,13 @@ func (td *TimeDetail) String() string {
buf.WriteString("total_wait_time: ") buf.WriteString("total_wait_time: ")
buf.WriteString(FormatDuration(td.WaitTime)) 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 td.TotalRPCWallTime > 0 {
if buf.Len() > 0 { if buf.Len() > 0 {
buf.WriteString(", ") buf.WriteString(", ")
@ -663,6 +670,17 @@ func (td *TimeDetail) String() string {
return buf.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. // MergeFromTimeDetail merges time detail from pb into itself.
func (td *TimeDetail) MergeFromTimeDetail(timeDetailV2 *kvrpcpb.TimeDetailV2, timeDetail *kvrpcpb.TimeDetail) { func (td *TimeDetail) MergeFromTimeDetail(timeDetailV2 *kvrpcpb.TimeDetailV2, timeDetail *kvrpcpb.TimeDetail) {
if timeDetailV2 != nil { if timeDetailV2 != nil {