Merge pull request #5016 from alecbrick/fix/dag-goroutine-leak

Fix goroutine leak in dag put
ipfs · May 24, 2018 · 06f11bd · 06f11bd
2 parents d99d3d9 + 4a59b55
commit 06f11bd
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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 {