opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-09-13 00:38:34 +08:00
Code Issues Projects Releases Wiki Activity

dht: use our most recent Addrs

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-02-02 08:21:45 -08:00
parent a5a60edd09
commit 18ceb73efc
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
routing/dht/dht.go
View File

@ -142,16 +142,20 @@ func (dht *IpfsDHT) putValueToPeer(ctx context.Context, p peer.ID,
func (dht *IpfsDHT) putProvider(ctx context.Context, p peer.ID, key string) error { func (dht *IpfsDHT) putProvider(ctx context.Context, p peer.ID, key string) error {
// add self as the provider // add self as the provider
pi := dht.peerstore.PeerInfo(dht.self) pi := peer.PeerInfo{
ID: dht.self,
Addrs: dht.host.Addrs(),
}
// // only share WAN-friendly addresses ?? // // only share WAN-friendly addresses ??
// pi.Addrs = addrutil.WANShareableAddrs(pi.Addrs) // pi.Addrs = addrutil.WANShareableAddrs(pi.Addrs)
if len(pi.Addrs) < 1 { if len(pi.Addrs) < 1 {
log.Infof("%s putProvider: %s for %s error: no wan-friendly addresses", dht.self, p, u.Key(key), pi.Addrs) // log.Infof("%s putProvider: %s for %s error: no wan-friendly addresses", dht.self, p, u.Key(key), pi.Addrs)
return fmt.Errorf("no known addresses for self. cannot put provider.") return fmt.Errorf("no known addresses for self. cannot put provider.")
} }
pmes := pb.NewMessage(pb.Message_ADD_PROVIDER, string(key), 0) pmes := pb.NewMessage(pb.Message_ADD_PROVIDER, string(key), 0)
pmes.ProviderPeers = pb.PeerInfosToPBPeers(dht.host.Network(), []peer.PeerInfo{pi}) pmes.ProviderPeers = pb.RawPeerInfosToPBPeers([]peer.PeerInfo{pi})
err := dht.sendMessage(ctx, p, pmes) err := dht.sendMessage(ctx, p, pmes)
if err != nil { if err != nil {
return err return err