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

retrieval: Fix deadlock in ClientGetRetrievalUpdates

Browse Source
This commit is contained in:
Łukasz Magiera 2021-11-23 18:32:56 +01:00
parent 83f65a673b
commit 78949d6c05
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1157,7 +1157,10 @@ func (a *API) ClientGetRetrievalUpdates(ctx context.Context) (<-chan api.Retriev
unsub := a.Retrieval.SubscribeToEvents(func(evt rm.ClientEvent, deal rm.ClientDealState) { unsub := a.Retrieval.SubscribeToEvents(func(evt rm.ClientEvent, deal rm.ClientDealState) {
update := a.newRetrievalInfo(ctx, deal) update := a.newRetrievalInfo(ctx, deal)
update.Event = &evt update.Event = &evt
updates <- update select {
case updates <- update:
case <-ctx.Done():
}
}) })
go func() { go func() {