dht: helpful debugging for no closer peers
Juan Batiz-Benet committed
Dec 23, 2014 at 03:14 UTC
a7eb52a7faaad57063d47de770c1643543ee80b2
2 files changed
+6
-2
routing/dht/query.go
+5
-2
@@ -258,12 +258,15 @@ func (r *dhtQueryRunner) queryPeer(p peer.ID) {
258
r.Unlock()
259
r.cancel() // signal to everyone that we're done.
260
261
- } else if res.closerPeers != nil {
262
- log.Debugf("PEERS CLOSER -- worker for: %v", p)
261
+ } else if len(res.closerPeers) > 0 {
262
+ log.Debugf("PEERS CLOSER -- worker for: %v (%d closer peers)", p, len(res.closerPeers))
263
for _, next := range res.closerPeers {
264
// add their addresses to the dialer's peerstore
265
r.query.dialer.Peerstore().AddAddresses(next.ID, next.Addrs)
266
r.addPeerToQuery(next.ID, p)
267
+ log.Debugf("PEERS CLOSER -- worker for: %v added %v (%v)", p, next.ID, next.Addrs)
268
}
269
+ } else {
270
+ log.Debugf("QUERY worker for: %v - not found, and no closer peers.", p)
271
}
272
}
routing/dht/routing.go
+1
@@ -139,6 +139,7 @@ func (dht *IpfsDHT) FindProvidersAsync(ctx context.Context, key u.Key, count int
139
140
func (dht *IpfsDHT) findProvidersAsyncRoutine(ctx context.Context, key u.Key, count int, peerOut chan peer.PeerInfo) {
141
defer close(peerOut)
142
+ log.Debugf("%s FindProviders %s", dht.self, key)
143
144
ps := pset.NewLimited(count)
145
provs := dht.providers.GetProviders(ctx, key)