Remove extra logs + set default store liveness to 1s

Author: salarali

internal/client/client_batch.go

@@ -783,8 +783,8 @@ func sendBatchRequest(
 		return tikvrpc.FromBatchCommandsResponse(res)
 	case <-ctx.Done():
 		atomic.StoreInt32(&entry.canceled, 1)
-		logutil.BgLogger().Warn("wait response is cancelled",
-			zap.String("to", addr), zap.String("cause", ctx.Err().Error()))
+		// logutil.BgLogger().Warn("wait response is cancelled",
+		// zap.String("to", addr), zap.String("cause", ctx.Err().Error()))
 		return nil, errors.Trace(ctx.Err())
 	case <-timer.C:
 		atomic.StoreInt32(&entry.canceled, 1)

internal/locate/region_cache.go

@@ -829,7 +829,7 @@ func (c *RegionCache) markRegionNeedBeRefill(s *Store, storeIdx int, rs *regionS
 	// invalidate regions in store.
 	epoch := rs.storeEpochs[storeIdx]
 	if atomic.CompareAndSwapUint32(&s.epoch, epoch, epoch+1) {
-		logutil.BgLogger().Info("mark store's regions need be refill", zap.String("store", s.addr))
+		// logutil.BgLogger().Info("mark store's regions need be refill", zap.String("store", s.addr))
 		incEpochStoreIdx = storeIdx
 		metrics.RegionCacheCounterWithInvalidateStoreRegionsOK.Inc()
 	}
@@ -2111,7 +2111,7 @@ type livenessState uint32
 var (
 	livenessSf singleflight.Group
 	// storeLivenessTimeout is the max duration of resolving liveness of a TiKV instance.
-	storeLivenessTimeout time.Duration
+	storeLivenessTimeout = 1 * time.Second
 )
 
 // SetStoreLivenessTimeout sets storeLivenessTimeout to t.

internal/locate/region_request.go

@@ -341,7 +341,7 @@ func (s *replicaSelector) onSendFailure(bo *retry.Backoffer, err error) {
 	store := replica.store
 	// invalidate regions in store.
 	if atomic.CompareAndSwapUint32(&store.epoch, replica.epoch, replica.epoch+1) {
-		logutil.BgLogger().Info("mark store's regions need be refill", zap.Uint64("id", store.storeID), zap.String("addr", store.addr), zap.Error(err))
+		// logutil.BgLogger().Info("mark store's regions need be refill", zap.Uint64("id", store.storeID), zap.String("addr", store.addr), zap.Error(err))
 		metrics.RegionCacheCounterWithInvalidateStoreRegionsOK.Inc()
 		// schedule a store addr resolve.
 		store.markNeedCheck(s.regionCache.notifyCheckCh)