Skip to content

Commit

Permalink
Add logs
Browse files Browse the repository at this point in the history
Signed-off-by: MyonKeminta <MyonKeminta@users.noreply.github.com>
  • Loading branch information
MyonKeminta committed Feb 18, 2024
1 parent cce241a commit f769b67
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
1 change: 1 addition & 0 deletions internal/client/client_batch.go
Original file line number Diff line number Diff line change
Expand Up @@ -643,6 +643,7 @@ func (c *batchCommandsClient) batchRecvLoop(cfg config.TiKVClient, tikvTransport
continue
}

logutil.BgLogger().Info("received batch response", zap.Stringer("feedback", resp.GetHealthFeedback()))
if resp.GetHealthFeedback() != nil {
c.onHealthFeedback(resp.GetHealthFeedback())
}
Expand Down
4 changes: 2 additions & 2 deletions internal/locate/region_cache.go
Original file line number Diff line number Diff line change
Expand Up @@ -2597,9 +2597,9 @@ func (s *StoreHealthStatus) updateTiKVServerSideSlowScore(score int64, currTime
s.tikvSideSlowScore.hasTiKVFeedback.Store(true)

lastScore := s.tikvSideSlowScore.score.Load()
logutil.BgLogger().Info("updateTiKVServerSideSlowScore called", zap.Int64("score", score), zap.Int64("lastScore", lastScore))

// Skip updating to avoid the overhead when it doesn't look slow.
if lastScore < 10 && score < 10 {
if lastScore == score {
return
}

Expand Down

0 comments on commit f769b67

Please sign in to comment.