add in some extra debug logging, and increase routing table latencies
Jeromy committed
Oct 8, 2014 at 21:55 UTC
1aafd285b545521bdbd0ada6bd8fe48fa598002c
4 files changed
+8
-2
routing/dht/dht.go
+2
-2
@@ -67,8 +67,8 @@ func NewDHT(p *peer.Peer, ps peer.Peerstore, net inet.Network, sender inet.Sende
67
dht.providers = NewProviderManager(p.ID)
68
69
dht.routingTables = make([]*kb.RoutingTable, 3)
70
- dht.routingTables[0] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*30)
71
- dht.routingTables[1] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*100)
70
+ dht.routingTables[0] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*1000)
71
+ dht.routingTables[1] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*1000)
72
dht.routingTables[2] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Hour)
73
dht.birth = time.Now()
74
return dht
routing/dht/handlers.go
+1
@@ -137,6 +137,7 @@ func (dht *IpfsDHT) handleGetProviders(p *peer.Peer, pmes *Message) (*Message, e
137
resp := newMessage(pmes.GetType(), pmes.GetKey(), pmes.GetClusterLevel())
138
139
// check if we have this value, to add ourselves as provider.
140
+ log.Debug("handling GetProviders: '%s'", pmes.GetKey())
141
dsk := u.Key(pmes.GetKey()).DsKey()
142
has, err := dht.datastore.Has(dsk)
143
if err != nil && err != ds.ErrNotFound {
routing/dht/routing.go
+1
@@ -192,6 +192,7 @@ func (dht *IpfsDHT) FindProviders(ctx context.Context, key u.Key) ([]*peer.Peer,
192
log.Debug("Find providers for: '%s'", key)
193
p := dht.routingTables[0].NearestPeer(kb.ConvertKey(key))
194
if p == nil {
195
+ log.Warning("Got no nearest peer for find providers: '%s'", key)
196
return nil, nil
197
}
198
routing/kbucket/table.go
+4
@@ -11,6 +11,8 @@ import (
11
u "github.com/jbenet/go-ipfs/util"
12
)
13
14
+var log = u.Logger("table")
15
+
16
// RoutingTable defines the routing table.
17
type RoutingTable struct {
18
@@ -138,6 +140,8 @@ func (rt *RoutingTable) NearestPeer(id ID) *peer.Peer {
140
if len(peers) > 0 {
141
return peers[0]
142
}
143
+
144
+ log.Error("NearestPeer: Returning nil, table size = %d", rt.Size())
145
return nil
146
}
147