Fix goroutine leak in dag put

License: MIT Signed-off-by: Alec Brickner <alecjbrick@gmail.com>

Fix goroutine leak in dag put
License: MIT Signed-off-by: Alec Brickner <alecjbrick@gmail.com>
4a59b557 · Alec Brickner · fc4ace28 · 4a59b557
Commit 4a59b557 authored May 12, 2018 by Alec Brickner
Show whitespace changes
Inline Side-by-side

Showing with 6 additions and 1 deletion

core/commands/dag/dag.go core/commands/dag/dag.go +6 -1

No files found.
--- a/core/commands/dag/dag.go
+++ b/core/commands/dag/dag.go
@@ -128,7 +128,12 @@ into an object of the specified format.
 				cid := nds[0].Cid()
 				cids.Add(cid)
-				outChan <- &OutputObject{Cid: cid}
+				select {
+				case outChan <- &OutputObject{Cid: cid}:
+				case <-req.Context().Done():
+					return nil
+				}
 			}
 			if err := b.Commit(); err != nil {