提交 feb6d341 作者: Juan Batiz-Benet

bitswap/net: race fix in peers iteration

上级 64191c1b
...@@ -108,7 +108,7 @@ func (bsnet *impl) FindProvidersAsync(ctx context.Context, k util.Key, max int) ...@@ -108,7 +108,7 @@ func (bsnet *impl) FindProvidersAsync(ctx context.Context, k util.Key, max int)
// the short term. // the short term.
connectedPeers := bsnet.host.Network().Peers() connectedPeers := bsnet.host.Network().Peers()
out := make(chan peer.ID, len(connectedPeers)) // just enough buffer for these connectedPeers out := make(chan peer.ID, len(connectedPeers)) // just enough buffer for these connectedPeers
for _, id := range bsnet.host.Network().Peers() { for _, id := range connectedPeers {
out <- id out <- id
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论