From 7e4050302078b25da44622df280c7ad02f917101 Mon Sep 17 00:00:00 2001
From: Jeromy <jeromyj@gmail.com>
Date: Sat, 21 Feb 2015 19:26:58 -0800
Subject: [PATCH] dont potentially kill our memory
---
routing/dht/routing.go | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/routing/dht/routing.go b/routing/dht/routing.go
index 49449eda7..99df4423c 100644
--- a/routing/dht/routing.go
+++ b/routing/dht/routing.go
@@ -1,7 +1,6 @@
package dht
import (
- "math"
"sync"
"time"
@@ -89,7 +88,7 @@ func (dht *IpfsDHT) GetValue(ctx context.Context, key u.Key) ([]byte, error) {
// get closest peers in the routing table
rtp := dht.routingTable.ListPeers()
- log.Debugf("peers in rt: %s", len(rtp), rtp)
+ log.Errorf("peers in rt: %s", len(rtp), rtp)
if len(rtp) == 0 {
log.Warning("No peers from routing table!")
return nil, errors.Wrap(kb.ErrLookupFailure)
@@ -169,7 +168,7 @@ func (dht *IpfsDHT) Provide(ctx context.Context, key u.Key) error {
// FindProviders searches until the context expires.
func (dht *IpfsDHT) FindProviders(ctx context.Context, key u.Key) ([]peer.PeerInfo, error) {
var providers []peer.PeerInfo
- for p := range dht.FindProvidersAsync(ctx, key, math.MaxInt32) {
+ for p := range dht.FindProvidersAsync(ctx, key, KValue) {
providers = append(providers, p)
}
return providers, nil
--
GitLab