mirror of
https://github.com/ipfs/kubo.git
synced 2025-07-25 03:32:50 +08:00
cleanup from CR
This commit is contained in:
@ -331,14 +331,10 @@ func (ds *dagService) GetDAG(ctx context.Context, root *Node) <-chan *Node {
|
|||||||
nodes[i] = nd
|
nodes[i] = nd
|
||||||
}
|
}
|
||||||
|
|
||||||
if next == is[0] {
|
|
||||||
sig <- nd
|
|
||||||
next++
|
|
||||||
for ; next < len(nodes) && nodes[next] != nil; next++ {
|
for ; next < len(nodes) && nodes[next] != nil; next++ {
|
||||||
sig <- nodes[next]
|
sig <- nodes[next]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
if next < len(nodes) {
|
if next < len(nodes) {
|
||||||
// TODO: bubble errors back up.
|
// TODO: bubble errors back up.
|
||||||
log.Errorf("Did not receive correct number of nodes!")
|
log.Errorf("Did not receive correct number of nodes!")
|
||||||
|
Reference in New Issue
Block a user