提交 4b82c899 作者: Jeromy Johnson 提交者: GitHub

Merge pull request #3353 from ipfs/fix/diag-hang

respect contexts when returning diagnostics responses
......@@ -191,7 +191,11 @@ func (d *Diagnostics) getDiagnosticFromPeers(ctx context.Context, peers map[peer
return
}
for d := range out {
respdata <- d
select {
case respdata <- d:
case <-ctx.Done():
return
}
}
}(p)
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论