Commit 3745c327 authored by Jeromy's avatar Jeromy

fixing up some bitswap stuff after the PR

parent 1ecb7eda
......@@ -49,7 +49,7 @@ type IpfsDHT struct {
diaglock sync.Mutex
// listener is a server to register to listen for responses to messages
listener *swarm.MesListener
listener *swarm.MessageListener
}
// NewDHT creates a new DHT object with the given peer as the 'local' host
......@@ -66,7 +66,7 @@ func NewDHT(p *peer.Peer, net swarm.Network, dstore ds.Datastore) *IpfsDHT {
dht.routingTables[0] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*30)
dht.routingTables[1] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Millisecond*100)
dht.routingTables[2] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Hour)
dht.listener = swarm.NewMesListener()
dht.listener = swarm.NewMessageListener()
dht.birth = time.Now()
return dht
}
......
......@@ -78,7 +78,7 @@ func TestTableUpdate(t *testing.T) {
for i := 0; i < 10000; i++ {
p := rt.Update(peers[rand.Intn(len(peers))])
if p != nil {
t.Log("evicted peer.")
//t.Log("evicted peer.")
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment