Skip to content

Commit

Permalink
playground - increased max nr of repair jobs per host to 3
Browse files Browse the repository at this point in the history
  • Loading branch information
karol-kokoszka committed Mar 15, 2024
1 parent ef46c8b commit cd86625
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pkg/service/repair/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ func (c *rowLevelRepairController) TryBlock(replicaSet []string) Intensity {
func (c *rowLevelRepairController) shouldBlock(replicaSet []string) bool {
// DENY if any node is already participating in repair job
for _, r := range replicaSet {
if c.nodeJobs[r] > 0 {
if c.nodeJobs[r] > 2 {
return false
}
}
Expand Down
4 changes: 2 additions & 2 deletions pkg/service/repair/plan.go
Original file line number Diff line number Diff line change
Expand Up @@ -320,7 +320,7 @@ func MaxRingParallel(ring scyllaclient.Ring, dcs []string) int {
repaired += cnt
}
}
return repaired / ring.RF
return (repaired / ring.RF) * 3
case scyllaclient.NetworkTopologyStrategy:
minDC := math.MaxInt / 2
for dc, rf := range ring.DCrf {
Expand All @@ -331,7 +331,7 @@ func MaxRingParallel(ring scyllaclient.Ring, dcs []string) int {
if minDC == math.MaxInt/2 {
minDC = 1
}
return minDC
return minDC * 3
default:
return 1
}
Expand Down

0 comments on commit cd86625

Please sign in to comment.