Skip to content

Commit b1a476f

Browse files
committed
Review fixes
1 parent 00a2b66 commit b1a476f

File tree

1 file changed

+2
-13
lines changed

1 file changed

+2
-13
lines changed

fracmanager/fracmanager.go

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -287,8 +287,6 @@ func (fm *FracManager) Start() {
287287
}
288288

289289
func (fm *FracManager) Load(ctx context.Context) error {
290-
var err error
291-
292290
l := NewLoader(fm.config, fm.fracProvider, fm.fracCache)
293291

294292
actives, sealed, err := l.load()
@@ -322,9 +320,6 @@ func (fm *FracManager) Load(ctx context.Context) error {
322320
}
323321

324322
func (fm *FracManager) replayAll(ctx context.Context, actives []*frac.Active) error {
325-
wg := sync.WaitGroup{}
326-
defer wg.Wait()
327-
328323
for i, a := range actives {
329324
if err := a.Replay(ctx); err != nil {
330325
return err
@@ -338,15 +333,9 @@ func (fm *FracManager) replayAll(ctx context.Context, actives []*frac.Active) er
338333

339334
if i == len(actives)-1 { // last and not empty
340335
fm.active = r
341-
} else {
342-
wg.Wait() // wait previous sealing complete
343-
344-
wg.Add(1)
345-
go func() {
346-
fm.seal(r)
347-
wg.Done()
348-
}()
336+
continue
349337
}
338+
fm.seal(r)
350339
}
351340

352341
return nil

0 commit comments

Comments
 (0)