Skip to content

Commit a8f2b05

Browse files
jholdstockjrick
authored andcommitted
vsp: Add missing mutex locks.
1 parent b646752 commit a8f2b05

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

internal/vsp/feepayment.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -849,7 +849,9 @@ func (fp *feePayment) submitPayment() (err error) {
849849
if err != nil {
850850
log.Errorf("error abandoning expired fee tx %v", err)
851851
}
852+
fp.mu.Lock()
852853
fp.feeTx = nil
854+
fp.mu.Unlock()
853855
}
854856
return fmt.Errorf("payfee: %w", err)
855857
}
@@ -922,7 +924,10 @@ func (fp *feePayment) confirmPayment() (err error) {
922924
case "confirmed":
923925
fp.remove("confirmed by VSP")
924926
// nothing scheduled
925-
err = w.UpdateVspTicketFeeToConfirmed(ctx, &fp.ticketHash, &fp.feeHash, fp.client.URL, fp.client.PubKey)
927+
fp.mu.Lock()
928+
feeHash := fp.feeHash
929+
fp.mu.Unlock()
930+
err = w.UpdateVspTicketFeeToConfirmed(ctx, &fp.ticketHash, &feeHash, fp.client.URL, fp.client.PubKey)
926931
if err != nil {
927932
return err
928933
}

internal/vsp/vsp.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,7 @@ func (c *Client) TrackedTickets() []*TicketInfo {
386386
}
387387
c.mu.Unlock()
388388

389-
tickets := make([]*TicketInfo, 0, len(c.jobs))
389+
tickets := make([]*TicketInfo, 0, len(jobs))
390390
for _, job := range jobs {
391391
job.mu.Lock()
392392
tickets = append(tickets, &TicketInfo{

0 commit comments

Comments
 (0)