Skip to content

Commit b1afc98

Browse files
committed
staticaddr: avoid startup SendEvent data races
1 parent 6af4268 commit b1afc98

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

staticaddr/deposit/manager.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,7 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
208208
go func(fsm *FSM) {
209209
err := fsm.SendEvent(ctx, OnRecover, nil)
210210
if err != nil {
211-
log.Errorf("Error sending OnStart event: %v",
211+
log.Errorf("Error sending OnRecover event: %v",
212212
err)
213213
}
214214
}(fsm)
@@ -393,7 +393,7 @@ func (m *Manager) startDepositFsm(ctx context.Context, deposit *Deposit) error {
393393

394394
// Send the start event to the state machine.
395395
go func() {
396-
err = fsm.SendEvent(ctx, OnStart, nil)
396+
err := fsm.SendEvent(ctx, OnStart, nil)
397397
if err != nil {
398398
log.Errorf("Error sending OnStart event: %v", err)
399399
}

staticaddr/loopin/manager.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -809,7 +809,7 @@ func (m *Manager) startLoopInFsm(ctx context.Context,
809809

810810
// Send the start event to the state machine.
811811
go func() {
812-
err = loopInFsm.SendEvent(ctx, OnInitHtlc, nil)
812+
err := loopInFsm.SendEvent(ctx, OnInitHtlc, nil)
813813
if err != nil {
814814
log.Errorf("Error sending OnNewRequest event: %v", err)
815815
}

0 commit comments

Comments
 (0)