yggdrasil-network/yggdrasil-go
1
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go.git synced 2025-04-30 15:15:07 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Lookup by domain

Browse source
This commit is contained in:
Neil Alexander 2020-05-09 21:57:08 +01:00
parent 7453c1cc06
commit 8c741e0e5a
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
3 changed files with 17 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/mdns/mdns.go
View file

@ -1,6 +1,7 @@
package mdns
import (
"bytes"
"encoding/hex"
"errors"
"fmt"
@ -36,6 +37,7 @@ type MDNS struct {
type mDNSServer struct {
mdns *MDNS
ourIP net.IP
intf net.Interface
server *mdns.Server
listener *yggdrasil.TcpListener
@ -282,6 +284,7 @@ func (m *MDNS) _startInterface(intf net.Interface, addr string) error {
m._servers[intf.Name][addr] = &mDNSServer{
mdns: m,
intf: intf,
ourIP: tcpaddr.IP,
stop: make(chan struct{}),
server: server,
listener: listener,
@ -323,7 +326,8 @@ func (s *mDNSServer) listen() {
incoming := make(chan *mdns.ServiceEntry)
go func() {
if err := mdns.Listen(incoming, s.stop, &s.intf); err != nil {
defer close(s.stop)
if err := mdns.Lookup(MDNSService, MDNSDomain, incoming); err != nil {
s.mdns.log.Errorln("Failed to initialize resolver:", err.Error())
}
}()
@ -334,10 +338,17 @@ func (s *mDNSServer) listen() {
s.mdns.log.Debugln("Stopped listening for mDNS on", s.intf.Name)
break
case entry := <-incoming:
if entry.AddrV6.IP.IsLinkLocalUnicast() && entry.AddrV6.Zone == "" {
if bytes.Equal(entry.Addr, s.ourIP) {
s.mdns.log.Warnln("That's us")
continue
}
addr := fmt.Sprintf("tcp://%s:%d", entry.AddrV6.IP, entry.Port)
if entry.AddrV6.IP.IsLinkLocalUnicast() && entry.AddrV6.Zone == "" {
s.mdns.log.Warnln("Not link-local")
continue
}
addr := fmt.Sprintf("tcp://[%s]:%d", entry.AddrV6.IP, entry.Port)
s.mdns.log.Println("Calling", addr, "via", entry.AddrV6.Zone)
if err := s.mdns.core.CallPeer(addr, entry.AddrV6.Zone); err != nil {
s.mdns.log.Warn("Failed to add peer from mDNS: ", err)
}