mirror of
https://github.com/ipfs/kubo.git
synced 2025-09-10 03:42:21 +08:00
a couple small fixes
This commit is contained in:
@ -269,7 +269,6 @@ func (dht *IpfsDHT) findProvidersAsyncRoutine(ctx context.Context, key u.Key, co
|
||||
// Add unique providers from request, up to 'count'
|
||||
for _, prov := range provs {
|
||||
if ps.TryAdd(prov.ID) {
|
||||
dht.peerstore.AddAddresses(prov.ID, prov.Addrs)
|
||||
select {
|
||||
case peerOut <- prov:
|
||||
case <-ctx.Done():
|
||||
|
Reference in New Issue
Block a user