address the comment

Signed-off-by: yisaer <disxiaofei@163.com>
tikv · May 14, 2021 · ed8cab7 · ed8cab7
1 parent fe009de
commit ed8cab7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/statistics/hot_peer_cache.go b/server/statistics/hot_peer_cache.go
@@ -170,8 +170,8 @@ func (f *hotPeerCache) CollectExpiredItems(region *core.RegionInfo) []*HotPeerSt
 // CheckPeerFlow checks the flow information of a peer.
 // Notice: CheckPeerFlow couldn't be used concurrently.
 func (f *hotPeerCache) CheckPeerFlow(peer *core.PeerInfo, region *core.RegionInfo) *HotPeerStat {
-	f.Lock()
-	defer f.Unlock()
+	f.RLock()
+	defer f.RUnlock()
 	storeID := peer.GetStoreID()
 	deltaLoads := f.getFlowDeltaLoads(peer)
 	interval := peer.GetInterval()