Commit f138a875 authored by Jeromy's avatar Jeromy Committed by Juan Batiz-Benet

small changes to auxiliary dht functions

parent 9dbba5c6
...@@ -23,6 +23,8 @@ import ( ...@@ -23,6 +23,8 @@ import (
var log = u.Logger("dht") var log = u.Logger("dht")
const doPinging = true
// TODO. SEE https://github.com/jbenet/node-ipfs/blob/master/submodules/ipfs-dht/index.js // TODO. SEE https://github.com/jbenet/node-ipfs/blob/master/submodules/ipfs-dht/index.js
// IpfsDHT is an implementation of Kademlia with Coral and S/Kademlia modifications. // IpfsDHT is an implementation of Kademlia with Coral and S/Kademlia modifications.
...@@ -75,7 +77,9 @@ func NewDHT(ctx context.Context, p *peer.Peer, ps peer.Peerstore, net inet.Netwo ...@@ -75,7 +77,9 @@ func NewDHT(ctx context.Context, p *peer.Peer, ps peer.Peerstore, net inet.Netwo
dht.routingTables[2] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Hour) dht.routingTables[2] = kb.NewRoutingTable(20, kb.ConvertPeerID(p.ID), time.Hour)
dht.birth = time.Now() dht.birth = time.Now()
go dht.PingRoutine(time.Second * 10) if doPinging {
go dht.PingRoutine(time.Second * 10)
}
return dht return dht
} }
...@@ -562,5 +566,8 @@ func (dht *IpfsDHT) PingRoutine(t time.Duration) { ...@@ -562,5 +566,8 @@ func (dht *IpfsDHT) PingRoutine(t time.Duration) {
func (dht *IpfsDHT) Bootstrap(ctx context.Context) { func (dht *IpfsDHT) Bootstrap(ctx context.Context) {
id := make([]byte, 16) id := make([]byte, 16)
rand.Read(id) rand.Read(id)
dht.FindPeer(ctx, peer.ID(id)) _, err := dht.FindPeer(ctx, peer.ID(id))
if err != nil {
log.Error("Bootstrap peer error: %s", err)
}
} }
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