Fix the panic

Signed-off-by: JmPotato <ghzpotato@gmail.com>
tikv · Mar 13, 2023 · 55e0b31 · 55e0b31
1 parent eece096
commit 55e0b31
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/tikv/kv.go b/tikv/kv.go
@@ -605,7 +605,7 @@ func (s *KVStore) updateSafeTS(ctx context.Context) {
 
 // CreateRURuntimeStats creates a RURuntimeStats for the startTS and returns it.
 func (s *KVStore) CreateRURuntimeStats(startTS uint64) *util.RURuntimeStats {
-	rrs, _ := s.ruRuntimeStatsMap.LoadOrStore(startTS, &util.RURuntimeStats{})
+	rrs, _ := s.ruRuntimeStatsMap.LoadOrStore(startTS, util.NewRURuntimeStats())
 	return rrs.(*util.RURuntimeStats)
 }
 

diff --git a/util/execdetails.go b/util/execdetails.go
@@ -673,6 +673,14 @@ type RURuntimeStats struct {
 	writeRU *uatomic.Float64
 }
 
+// NewRURuntimeStats creates a new RURuntimeStats.
+func NewRURuntimeStats() *RURuntimeStats {
+	return &RURuntimeStats{
+		readRU:  uatomic.NewFloat64(0),
+		writeRU: uatomic.NewFloat64(0),
+	}
+}
+
 // Clone implements the RuntimeStats interface.
 func (rs *RURuntimeStats) Clone() *RURuntimeStats {
 	return &RURuntimeStats{