coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-03-10 18:57:57 +08:00
Code Issues Actions 14 Packages Projects Releases Wiki Activity

use ALL THE ADDRESSES!

Browse Source
This commit is contained in:
Jeromy 2015-04-29 01:02:45 -07:00
parent 04f773166f
commit 5ecc4e890b
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
p2p/discovery/mdns.go
View File

@ -42,21 +42,22 @@ type mdnsService struct {
interval time.Duration
}
func getDialableListenAddr(ph host.Host) (*net.TCPAddr, error) {
func getDialableListenAddrs(ph host.Host) ([]*net.TCPAddr, error) {
var out []*net.TCPAddr
for _, addr := range ph.Addrs() {
if manet.IsIPLoopback(addr) {
continue
}
na, err := manet.ToNetAddr(addr)
if err != nil {
continue
}
tcp, ok := na.(*net.TCPAddr)
if ok {
return tcp, nil
out = append(out, tcp)
}
}
return nil, errors.New("failed to find good external addr from peerhost")
if len(out) == 0 {
return nil, errors.New("failed to find good external addr from peerhost")
}
return out, nil
}
func NewMdnsService(peerhost host.Host, interval time.Duration) (Service, error) {
@ -67,12 +68,14 @@ func NewMdnsService(peerhost host.Host, interval time.Duration) (Service, error)
var ipaddrs []net.IP
port := 4001
addr, err := getDialableListenAddr(peerhost)
addrs, err := getDialableListenAddrs(peerhost)
if err != nil {
log.Warning(err)
} else {
ipaddrs = []net.IP{addr.IP}
port = addr.Port
port = addrs[0].Port
for _, a := range addrs {
ipaddrs = append(ipaddrs, a.IP)
}
}
myid := peerhost.ID().Pretty()