contractcourt: fix concurrent access to launched

Author: yyforyongyu

contractcourt/anchor_resolver.go

@@ -176,13 +176,13 @@ var _ ContractResolver = (*anchorResolver)(nil)
 
 // Launch offers the anchor output to the sweeper.
 func (c *anchorResolver) Launch() error {
-	if c.launched {
+	if c.launched.Load() {
 		c.log.Tracef("already launched")
 		return nil
 	}
 
 	c.log.Debugf("launching resolver...")
-	c.launched = true
+	c.launched.Store(true)
 
 	// If we're already resolved, then we can exit early.
 	if c.IsResolved() {

contractcourt/breach_resolver.go

@@ -126,13 +126,13 @@ var _ ContractResolver = (*breachResolver)(nil)
 
 // TODO(yy): implement it once the outputs are offered to the sweeper.
 func (b *breachResolver) Launch() error {
-	if b.launched {
+	if b.launched.Load() {
 		b.log.Tracef("already launched")
 		return nil
 	}
 
 	b.log.Debugf("launching resolver...")
-	b.launched = true
+	b.launched.Store(true)
 
 	return nil
 }

contractcourt/commit_sweep_resolver.go

@@ -361,13 +361,13 @@ var _ reportingContractResolver = (*commitSweepResolver)(nil)
 
 // Launch constructs a commit input and offers it to the sweeper.
 func (c *commitSweepResolver) Launch() error {
-	if c.launched {
+	if c.launched.Load() {
 		c.log.Tracef("already launched")
 		return nil
 	}
 
 	c.log.Debugf("launching resolver...")
-	c.launched = true
+	c.launched.Store(true)
 
 	// If we're already resolved, then we can exit early.
 	if c.IsResolved() {

contractcourt/contract_resolver.go

@@ -131,7 +131,7 @@ type contractResolverKit struct {
 
 	// launched specifies whether the resolver has been launched. Calling
 	// `Launch` will be a no-op if this is true.
-	launched bool
+	launched atomic.Bool
 
 	// resolved reflects if the contract has been fully resolved or not.
 	resolved atomic.Bool

contractcourt/htlc_incoming_contest_resolver.go

@@ -83,7 +83,7 @@ func (h *htlcIncomingContestResolver) processFinalHtlcFail() error {
 func (h *htlcIncomingContestResolver) Launch() error {
 	// NOTE: we don't mark this resolver as launched as the inner resolver
 	// will set it when it's launched.
-	if h.launched {
+	if h.launched.Load() {
 		h.log.Tracef("already launched")
 		return nil
 	}

contractcourt/htlc_outgoing_contest_resolver.go

@@ -40,7 +40,7 @@ func newOutgoingContestResolver(res lnwallet.OutgoingHtlcResolution,
 func (h *htlcOutgoingContestResolver) Launch() error {
 	// NOTE: we don't mark this resolver as launched as the inner resolver
 	// will set it when it's launched.
-	if h.launched {
+	if h.launched.Load() {
 		h.log.Tracef("already launched")
 		return nil
 	}

contractcourt/htlc_success_resolver.go

@@ -725,13 +725,13 @@ func (h *htlcSuccessResolver) resolveSuccessTxOutput(op wire.OutPoint) error {
 // Launch creates an input based on the details of the incoming htlc resolution
 // and offers it to the sweeper.
 func (h *htlcSuccessResolver) Launch() error {
-	if h.launched {
+	if h.launched.Load() {
 		h.log.Tracef("already launched")
 		return nil
 	}
 
 	h.log.Debugf("launching resolver...")
-	h.launched = true
+	h.launched.Store(true)
 
 	// If the HTLC has custom records, then for now we'll pause resolution.
 	//

contractcourt/htlc_timeout_resolver.go

@@ -1228,13 +1228,13 @@ func (h *htlcTimeoutResolver) resolveTimeoutTxOutput(op wire.OutPoint) error {
 // Launch creates an input based on the details of the outgoing htlc resolution
 // and offers it to the sweeper.
 func (h *htlcTimeoutResolver) Launch() error {
-	if h.launched {
+	if h.launched.Load() {
 		h.log.Tracef("already launched")
 		return nil
 	}
 
 	h.log.Debugf("launching resolver...")
-	h.launched = true
+	h.launched.Store(true)
 
 	// If the HTLC has custom records, then for now we'll pause resolution.
 	//