replica selector refactor

config/config.go

@@ -82,23 +82,26 @@ type Config struct {
 	RegionsRefreshInterval uint64
 	// EnablePreload indicates whether to preload region info when initializing the client.
 	EnablePreload bool
+	// EnableReplicaSelectorV2 indicates whether to enable ReplicaSelectorV2.
+	EnableReplicaSelectorV2 bool
 }
 
 // DefaultConfig returns the default configuration.
 func DefaultConfig() Config {
 	return Config{
-		CommitterConcurrency:  128,
-		MaxTxnTTL:             60 * 60 * 1000, // 1hour
-		TiKVClient:            DefaultTiKVClient(),
-		PDClient:              DefaultPDClient(),
-		TxnLocalLatches:       DefaultTxnLocalLatches(),
-		StoresRefreshInterval: DefStoresRefreshInterval,
-		OpenTracingEnable:     false,
-		Path:                  "",
-		EnableForwarding:      false,
-		TxnScope:              "",
-		EnableAsyncCommit:     false,
-		Enable1PC:             false,
+		CommitterConcurrency:    128,
+		MaxTxnTTL:               60 * 60 * 1000, // 1hour
+		TiKVClient:              DefaultTiKVClient(),
+		PDClient:                DefaultPDClient(),
+		TxnLocalLatches:         DefaultTxnLocalLatches(),
+		StoresRefreshInterval:   DefStoresRefreshInterval,
+		OpenTracingEnable:       false,
+		Path:                    "",
+		EnableForwarding:        false,
+		TxnScope:                "",
+		EnableAsyncCommit:       false,
+		Enable1PC:               false,
+		EnableReplicaSelectorV2: true,
 	}
 }
 

internal/locate/region_cache.go

@@ -1310,6 +1310,7 @@ func (c *RegionCache) scheduleReloadRegion(region *Region) {
 		// async reload scheduled by other thread.
 		return
 	}
+	logutil.Logger(context.Background()).Info("schedule to reload region", zap.Uint64("regionID", region.GetID()), zap.Stack("stack"))
 	regionID := region.GetID()
 	if regionID > 0 {
 		c.regionsNeedReload.Lock()