opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-26 23:53:19 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #4885 from ipfs/fix/visit-when-asked

Browse Source 
only visit nodes in EnumerateChildrenAsync when asked
This commit is contained in:
Whyrusleeping
2018-03-29 16:35:34 -07:00
committed by GitHub
parent 5770bf8d6f 08388e739a
commit d82bf5f59b
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
merkledag/merkledag.go
View File

@ -319,17 +319,17 @@ func EnumerateChildrenAsync(ctx context.Context, getLinks GetLinks, c *cid.Cid,
for i := 0; i < FetchGraphConcurrency; i++ { for i := 0; i < FetchGraphConcurrency; i++ {
go func() { go func() {
for ic := range feed { for ic := range feed {
links, err := getLinks(ctx, ic)
if err != nil {
errChan <- err
return
}
setlk.Lock() setlk.Lock()
unseen := visit(ic) shouldVisit := visit(ic)
setlk.Unlock() setlk.Unlock()
if unseen { if shouldVisit {
links, err := getLinks(ctx, ic)
if err != nil {
errChan <- err
return
}
select { select {
case out <- links: case out <- links:
case <-fetchersCtx.Done(): case <-fetchersCtx.Done():