opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-28 00:39:31 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #5011 from alecbrick/fix/pin-goroutine-leak

Browse Source 
Fix goroutine leak in pin verify
This commit is contained in:
Whyrusleeping
2018-05-12 11:36:15 +01:00
committed by GitHub
parent 7853e53860 f3f186b493
commit fc4ace2882
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/commands/pin.go
View File

@ -647,7 +647,11 @@ func pinVerify(ctx context.Context, n *core.IpfsNode, opts pinVerifyOpts) <-chan
for _, cid := range recPins { for _, cid := range recPins {
pinStatus := checkPin(cid) pinStatus := checkPin(cid)
if !pinStatus.Ok || opts.includeOk { if !pinStatus.Ok || opts.includeOk {
out <- &PinVerifyRes{cid.String(), pinStatus} select {
case out <- &PinVerifyRes{cid.String(), pinStatus}:
case <-ctx.Done():
return
}
} }
} }
}() }()