msgio pooling first hack

63e2295d · Jeromy · 65feb72f · 63e2295d
Commit 63e2295d authored Oct 27, 2014 by Jeromy
Hide whitespace changes
Inline Side-by-side

Showing with 18 additions and 0 deletions

merkledag.go merkledag.go +18 -0

No files found.
--- a/merkledag.go
+++ b/merkledag.go
@@ -241,3 +241,21 @@ func (n *dagService) Remove(nd *Node) error {
 	}
 	return n.Blocks.DeleteBlock(k)
 }
+
+func FetchGraph(ctx context.Context, root *Node, serv *DAGService) {
+	for _, l := range root.Links {
+		go func(lnk *Link) {
+			select {
+			case <-ctx.Done():
+				return
+			}
+
+			nd, err := lnk.GetNode(serv)
+			if err != nil {
+				log.Error(err)
+				return
+			}
+			FetchGraph(ctx, nd, serv)
+		}(l)
+	}
+}