From 618097d80effbc31c3979d9282bb02752b446abc Mon Sep 17 00:00:00 2001
From: Juan Batiz-Benet <juan@benet.ai>
Date: Tue, 23 Dec 2014 22:06:45 -0800
Subject: [PATCH] dht/query: log when dialing a closerpeer

---
 routing/dht/query.go | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/routing/dht/query.go b/routing/dht/query.go
index aff724bc9..6a7bb687d 100644
--- a/routing/dht/query.go
+++ b/routing/dht/query.go
@@ -237,13 +237,18 @@ func (r *dhtQueryRunner) queryPeer(cg ctxgroup.ContextGroup, p peer.ID) {
 	}()
 
 	// make sure we're connected to the peer.
-	err := r.query.dialer.DialPeer(cg.Context(), p)
-	if err != nil {
-		log.Debugf("ERROR worker for: %v -- err connecting: %v", p, err)
-		r.Lock()
-		r.errs = append(r.errs, err)
-		r.Unlock()
-		return
+	if conns := r.query.dialer.ConnsToPeer(p); len(conns) == 0 {
+		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)
+			r.Lock()
+			r.errs = append(r.errs, err)
+			r.Unlock()
+			return
+		}
+
+		log.Infof("worker for: %v -- not connected. dial success!", p)
 	}
 
 	// finally, run the query against this peer