fix goroutine leaks in filestore.go

License: MIT Signed-off-by: Kejie Zhang <601172892@qq.com>
ipfs · Sep 5, 2018 · 0cfd643 · 0cfd643
1 parent 78a32f2
commit 0cfd643
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/commands/filestore.go b/core/commands/filestore.go
@@ -269,10 +269,14 @@ func perKeyActionToChan(ctx context.Context, args []string, action func(*cid.Cid
 		for _, arg := range args {
 			c, err := cid.Decode(arg)
 			if err != nil {
-				out <- &filestore.ListRes{
+				select {
+				case out <- &filestore.ListRes{
 					Status:   filestore.StatusOtherError,
 					ErrorMsg: fmt.Sprintf("%s: %v", arg, err),
+				}:
+				case <- ctx.Done():
 				}
+
 				continue
 			}
 			r := action(c)