added cancel func calls previously ignored

cf7c31b4 · Juan Batiz-Benet · 9a913bbf · cf7c31b4
Commit cf7c31b4 authored 9 years ago by Juan Batiz-Benet
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 1 deletion

dht/dht.go dht/dht.go +2 -1

No files found.
--- a/dht/dht.go
+++ b/dht/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