Skip to content

Commit 25751e6

Browse files
Revert "use sync.WaitGroup in CheckAndRecover()"
This reverts commit 91d3264. Signed-off-by: Tim Vaillancourt <tim@timvaillancourt.com>
1 parent be8a291 commit 25751e6

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

go/vt/vtorc/logic/topology_recovery.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1141,13 +1141,11 @@ func CheckAndRecover() {
11411141
rand.Shuffle(len(shardKeys), func(i, j int) {
11421142
shardKeys[i], shardKeys[j] = shardKeys[j], shardKeys[i]
11431143
})
1144-
var wg sync.WaitGroup
11451144
for _, key := range shardKeys {
1146-
wg.Go(func() {
1145+
go func() {
11471146
recoverShardAnalyses(analysisByShard[key], executeCheckAndRecoverFunction)
1148-
})
1147+
}()
11491148
}
1150-
wg.Wait()
11511149
}
11521150

11531151
func postPrsCompletion(topologyRecovery *TopologyRecovery, analysisEntry *inst.DetectionAnalysis, promotedReplica *inst.Instance) {

0 commit comments

Comments
 (0)