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

Fix goroutine leak in pin verify
ipfs · May 12, 2018 · fc4ace2 · fc4ace2
2 parents 7853e53 + f3f186b
commit fc4ace2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/commands/pin.go b/core/commands/pin.go
@@ -647,7 +647,11 @@ func pinVerify(ctx context.Context, n *core.IpfsNode, opts pinVerifyOpts) <-chan
 		for _, cid := range recPins {
 			pinStatus := checkPin(cid)
 			if !pinStatus.Ok || opts.includeOk {
-				out <- &PinVerifyRes{cid.String(), pinStatus}
+				select {
+				case out <- &PinVerifyRes{cid.String(), pinStatus}:
+				case <-ctx.Done():
+					return
+				}
 			}
 		}
 	}()