Skip to content

Commit

Permalink
This is an automated cherry-pick of tikv#7122
Browse files Browse the repository at this point in the history
close tikv#7121

Signed-off-by: ti-chi-bot <[email protected]>
  • Loading branch information
rleungx authored and ti-chi-bot committed Sep 21, 2023
1 parent 21b47d2 commit cc7a825
Show file tree
Hide file tree
Showing 12 changed files with 2,846 additions and 8 deletions.
466 changes: 466 additions & 0 deletions pkg/mcs/scheduling/server/cluster.go

Large diffs are not rendered by default.

5 changes: 5 additions & 0 deletions pkg/mock/mockcluster/mockcluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -165,8 +165,13 @@ func (mc *Cluster) AllocPeer(storeID uint64) (*metapb.Peer, error) {

func (mc *Cluster) initRuleManager() {
if mc.RuleManager == nil {
<<<<<<< HEAD
mc.RuleManager = placement.NewRuleManager(core.NewStorage(kv.NewMemoryKV()), mc, mc.GetOpts())
mc.RuleManager.Initialize(int(mc.GetReplicationConfig().MaxReplicas), mc.GetReplicationConfig().LocationLabels)
=======
mc.RuleManager = placement.NewRuleManager(mc.GetStorage(), mc, mc.GetSharedConfig())
mc.RuleManager.Initialize(int(mc.GetReplicationConfig().MaxReplicas), mc.GetReplicationConfig().LocationLabels, mc.GetReplicationConfig().IsolationLevel)
>>>>>>> 5b3d0172b (*: fix sync isolation level to default placement rule (#7122))
}
}

Expand Down
Loading

0 comments on commit cc7a825

Please sign in to comment.