Skip to content

Commit 3845bde

Browse files
authored
Merge pull request #908 from hieblmi/non-blocking-depo-recovery
staticaddr: non-concurrent deposit recovery
2 parents 612c704 + 8401ca5 commit 3845bde

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

staticaddr/deposit/manager.go

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -196,13 +196,10 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
196196
}
197197

198198
// Send the OnRecover event to the state machine.
199-
go func() {
200-
err = fsm.SendEvent(ctx, OnRecover, nil)
201-
if err != nil {
202-
log.Errorf("Error sending OnStart event: %v",
203-
err)
204-
}
205-
}()
199+
err = fsm.SendEvent(ctx, OnRecover, nil)
200+
if err != nil {
201+
log.Errorf("Error sending OnStart event: %v", err)
202+
}
206203

207204
m.mu.Lock()
208205
m.activeDeposits[d.OutPoint] = fsm

0 commit comments

Comments
 (0)