cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fix(client): insure cancelled context avoids lock

Browse Source
This commit is contained in:
hannahhoward 2020-08-26 10:59:07 -07:00
parent 10c1399474
commit 1cd49cec39
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/impl/client/client.go
View File

@ -508,10 +508,12 @@ func (a *API) clientRetrieve(ctx context.Context, order api.RetrievalOrder, ref
var dealID retrievalmarket.DealID var dealID retrievalmarket.DealID
subscribeEvents := make(chan retrievalSubscribeEvent, 1) subscribeEvents := make(chan retrievalSubscribeEvent, 1)
subscribeCtx, cancel := context.WithCancel(ctx)
defer cancel()
unsubscribe := a.Retrieval.SubscribeToEvents(func(event rm.ClientEvent, state rm.ClientDealState) { unsubscribe := a.Retrieval.SubscribeToEvents(func(event rm.ClientEvent, state rm.ClientDealState) {
if state.PayloadCID.Equals(order.Root) && state.ID == dealID { if state.PayloadCID.Equals(order.Root) && state.ID == dealID {
select { select {
case <-ctx.Done(): case <-subscribeCtx.Done():
case subscribeEvents <- retrievalSubscribeEvent{event, state}: case subscribeEvents <- retrievalSubscribeEvent{event, state}:
} }
} }