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

Merge pull request #5018 from forstmeier/fix/refs-goroutine-leak

Browse Source 
Fix goroutine leaks in refs.go
This commit is contained in:
Whyrusleeping
2018-05-24 13:13:44 +02:00
committed by GitHub
parent 06f11bd81a 20b06c297c
commit 8c7c2ceb43
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
core/commands/refs.go
View File

@ -129,7 +129,10 @@ NOTE: List all references recursively by using the flag '-r'.
for _, o := range objs { for _, o := range objs {
if _, err := rw.WriteRefs(o); err != nil { if _, err := rw.WriteRefs(o); err != nil {
out <- &RefWrapper{Err: err.Error()} select {
case out <- &RefWrapper{Err: err.Error()}:
case <-ctx.Done():
}
return return
} }
} }
@ -169,7 +172,11 @@ Displays the hashes of all local objects.
defer close(out) defer close(out)
for k := range allKeys { for k := range allKeys {
out <- &RefWrapper{Ref: k.String()} select {
case out <- &RefWrapper{Ref: k.String()}:
case <-req.Context().Done():
return
}
} }
}() }()
}, },