Merge pull request #908 from hieblmi/non-blocking-depo-recovery

staticaddr: non-concurrent deposit recovery
This commit is contained in:
Slyghtning 2025-03-26 16:43:39 +01:00 committed by GitHub
commit 3845bded2a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -196,13 +196,10 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
}
// Send the OnRecover event to the state machine.
go func() {
err = fsm.SendEvent(ctx, OnRecover, nil)
if err != nil {
log.Errorf("Error sending OnStart event: %v",
err)
}
}()
err = fsm.SendEvent(ctx, OnRecover, nil)
if err != nil {
log.Errorf("Error sending OnStart event: %v", err)
}
m.mu.Lock()
m.activeDeposits[d.OutPoint] = fsm