util: add lock for MergeBasicStats (#38998)

close pingcap/tidb#38994
2022-11-10 10:17:52 +08:00
parent 7f9219c11b
commit d970c9bf48
1 changed files with 2 additions and 0 deletions
--- a/util/execdetails/execdetails.go
+++ b/util/execdetails/execdetails.go
@ -396,6 +396,8 @@ func (crs *CopRuntimeStats) GetActRows() (totalRows int64) {

 // MergeBasicStats traverses basicCopRuntimeStats in the CopRuntimeStats and collects some useful information.
 func (crs *CopRuntimeStats) MergeBasicStats() (procTimes []time.Duration, totalTime time.Duration, totalTasks, totalLoops, totalThreads int32) {
+	crs.Lock()
+	defer crs.Unlock()
 	procTimes = make([]time.Duration, 0, 32)
 	for _, instanceStats := range crs.stats {
 		for _, stat := range instanceStats {