use cache

Signed-off-by: bufferflies <1045931706@qq.com>
tikv · Apr 12, 2023 · 65c5f24 · 65c5f24
1 parent 6a7d122
commit 65c5f24
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/pkg/statistics/store_hot_peers_infos.go b/pkg/statistics/store_hot_peers_infos.go
@@ -183,19 +183,21 @@ func summaryStoresLoadByEngine(
 			ty = "query-rate-" + rwTy.String() + "-" + kind.String()
 			hotPeerSummary.WithLabelValues(ty, fmt.Sprintf("%v", id)).Set(peerLoadSum[QueryDim])
 		}
+		loads := collector.GetLoads(storeLoads, peerLoadSum, rwTy, kind)
 
-		historyLoads := storesHistoryLoads.Get(id, rwTy, kind)
-		for i, loads := range historyLoads {
-			if allStoreHistoryLoadSum[i] == nil || len(allStoreHistoryLoadSum[i]) < len(loads) {
-				allStoreHistoryLoadSum[i] = make([]float64, len(loads))
-			}
-			for j, load := range loads {
-				allStoreHistoryLoadSum[i][j] += load
+		if storesHistoryLoads != nil {
+			historyLoads := storesHistoryLoads.Get(id, rwTy, kind)
+			for i, loads := range historyLoads {
+				if allStoreHistoryLoadSum[i] == nil || len(allStoreHistoryLoadSum[i]) < len(loads) {
+					allStoreHistoryLoadSum[i] = make([]float64, len(loads))
+				}
+				for j, load := range loads {
+					allStoreHistoryLoadSum[i][j] += load
+				}
 			}
+			storesHistoryLoads.Add(id, rwTy, kind, loads)
 		}
 
-		loads := collector.GetLoads(storeLoads, peerLoadSum, rwTy, kind)
-		storesHistoryLoads.Add(id, rwTy, kind, loads)
 		for i := range allStoreLoadSum {
 			allStoreLoadSum[i] += loads[i]
 		}