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

Merge pull request #5427 from kjzz/fix-goroutine

Browse Source 
fix goroutine leaks in filestore.go
This commit is contained in:
Steven Allen
2018-09-07 00:54:51 +00:00
committed by GitHub
parent bdbb63db85 7a9c7b4dd3
commit 573bada803
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/commands/filestore.go
View File

@ -269,10 +269,14 @@ func perKeyActionToChan(ctx context.Context, args []string, action func(*cid.Cid
for _, arg := range args { for _, arg := range args {
c, err := cid.Decode(arg) c, err := cid.Decode(arg)
if err != nil { if err != nil {
out <- &filestore.ListRes{ select {
case out <- &filestore.ListRes{
Status: filestore.StatusOtherError, Status: filestore.StatusOtherError,
ErrorMsg: fmt.Sprintf("%s: %v", arg, err), ErrorMsg: fmt.Sprintf("%s: %v", arg, err),
}:
case <-ctx.Done():
} }
continue continue
} }
r := action(c) r := action(c)