added cancel func calls previously ignored

49b95f54 · Juan Batiz-Benet · cf59044e · 49b95f54
Commit 49b95f54 authored Mar 07, 2015 by Juan Batiz-Benet
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

dht.go dht.go +2 -1

No files found.
--- a/dht.go
+++ b/dht.go
@@ -357,11 +357,12 @@ func (dht *IpfsDHT) PingRoutine(t time.Duration) {
 			rand.Read(id)
 			peers := dht.routingTable.NearestPeers(kb.ConvertKey(u.Key(id)), 5)
 			for _, p := range peers {
-				ctx, _ := context.WithTimeout(dht.Context(), time.Second*5)
+				ctx, cancel := context.WithTimeout(dht.Context(), time.Second*5)
 				_, err := dht.Ping(ctx, p)
 				if err != nil {
 					log.Debugf("Ping error: %s", err)
 				}
+				cancel()
 			}
 		case <-dht.Closing():
 			return