From f80aee4daee43c30e922983fd03bc303a7d2c4c0 Mon Sep 17 00:00:00 2001 From: Slyghtning Date: Sat, 28 Feb 2026 11:43:35 +0100 Subject: [PATCH] staticaddr: avoid startup SendEvent data races --- staticaddr/deposit/manager.go | 4 ++-- staticaddr/loopin/manager.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/staticaddr/deposit/manager.go b/staticaddr/deposit/manager.go index 72375edb..c2d02083 100644 --- a/staticaddr/deposit/manager.go +++ b/staticaddr/deposit/manager.go @@ -208,7 +208,7 @@ func (m *Manager) recoverDeposits(ctx context.Context) error { go func(fsm *FSM) { err := fsm.SendEvent(ctx, OnRecover, nil) if err != nil { - log.Errorf("Error sending OnStart event: %v", + log.Errorf("Error sending OnRecover event: %v", err) } }(fsm) @@ -393,7 +393,7 @@ func (m *Manager) startDepositFsm(ctx context.Context, deposit *Deposit) error { // Send the start event to the state machine. go func() { - err = fsm.SendEvent(ctx, OnStart, nil) + err := fsm.SendEvent(ctx, OnStart, nil) if err != nil { log.Errorf("Error sending OnStart event: %v", err) } diff --git a/staticaddr/loopin/manager.go b/staticaddr/loopin/manager.go index e5191441..410eaba2 100644 --- a/staticaddr/loopin/manager.go +++ b/staticaddr/loopin/manager.go @@ -809,9 +809,9 @@ func (m *Manager) startLoopInFsm(ctx context.Context, // Send the start event to the state machine. go func() { - err = loopInFsm.SendEvent(ctx, OnInitHtlc, nil) + err := loopInFsm.SendEvent(ctx, OnInitHtlc, nil) if err != nil { - log.Errorf("Error sending OnNewRequest event: %v", err) + log.Errorf("Error sending OnInitHtlc event: %v", err) } }()