opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 02:30:39 +08:00
Code Issues Projects Releases Wiki Activity

dht/query: log when dialing a closerpeer

Browse Source
This commit is contained in:
Juan Batiz-Benet
2014-12-23 22:06:45 -08:00
parent 8adda0fffc
commit 618097d80e
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
routing/dht/query.go
View File

@ -237,8 +237,10 @@ func (r *dhtQueryRunner) queryPeer(cg ctxgroup.ContextGroup, p peer.ID) {
}() }()
// make sure we're connected to the peer. // make sure we're connected to the peer.
err := r.query.dialer.DialPeer(cg.Context(), p) if conns := r.query.dialer.ConnsToPeer(p); len(conns) == 0 {
if err != nil { log.Infof("worker for: %v -- not connected. dial start", p)
if err := r.query.dialer.DialPeer(cg.Context(), p); err != nil {
log.Debugf("ERROR worker for: %v -- err connecting: %v", p, err) log.Debugf("ERROR worker for: %v -- err connecting: %v", p, err)
r.Lock() r.Lock()
r.errs = append(r.errs, err) r.errs = append(r.errs, err)
@ -246,6 +248,9 @@ func (r *dhtQueryRunner) queryPeer(cg ctxgroup.ContextGroup, p peer.ID) {
return return
} }
log.Infof("worker for: %v -- not connected. dial success!", p)
}
// finally, run the query against this peer // finally, run the query against this peer
res, err := r.query.qfunc(cg.Context(), p) res, err := r.query.qfunc(cg.Context(), p)