Merge pull request ipfs/go-unixfs#74 from ipfs/fix/enumerate-children

Stebalien · web-flow · commit 856ed57036b2 · 2019-07-11T16:09:41.000-07:00
fix: enumerate children This commit was moved from ipfs/go-unixfs@06cb1c7
diff --git a/unixfs/ipld-merkledag/hamt/hamt.go b/unixfs/ipld-merkledag/hamt/hamt.go
@@ -339,7 +339,7 @@ func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult {
 		defer cancel()
 		getLinks := makeAsyncTrieGetLinks(ds.dserv, linkResults)
 		cset := cid.NewSet()
-		err := dag.EnumerateChildrenAsync(ctx, getLinks, ds.cid, cset.Visit)
+		err := dag.WalkParallel(ctx, getLinks, ds.cid, cset.Visit)
 		if err != nil {
 			emitResult(ctx, linkResults, format.LinkResult{Link: nil, Err: err})
 		}

Original file line number	Diff line number	Diff line change
`@@ -339,7 +339,7 @@ func (ds *Shard) EnumLinksAsync(ctx context.Context) <-chan format.LinkResult {`
`339`	`339`	`defer cancel()`
`340`	`340`	`getLinks := makeAsyncTrieGetLinks(ds.dserv, linkResults)`
`341`	`341`	`cset := cid.NewSet()`
`342`		`- err := dag.EnumerateChildrenAsync(ctx, getLinks, ds.cid, cset.Visit)`
	`342`	`+ err := dag.WalkParallel(ctx, getLinks, ds.cid, cset.Visit)`
`343`	`343`	`if err != nil {`
`344`	`344`	`emitResult(ctx, linkResults, format.LinkResult{Link: nil, Err: err})`
`345`	`345`	`}`