CalvinBackup/ctrld
1
0
Fork 0
mirror of https://github.com/Control-D-Inc/ctrld.git synced 2026-09-04 13:36:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

internal/clientinfo: add doc comments for mdns operations

Browse Source 
While at it, also remove un-used channel argument of probe function.
This commit is contained in:
Cuong Manh Le
2023-08-09 23:54:23 +07:00
committed by Cuong Manh Le
parent 2cd8b7e021
commit e43b2b5530
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/clientinfo/mdns.go
+5 -2
View File
@@ -73,10 +73,11 @@ func (m *mdns) init(quitCh chan struct{}) error {
return nil return nil
} }
// probeLoop performs mdns probe actively to get hostname updates.
func (m *mdns) probeLoop(conns []*net.UDPConn, remoteAddr net.Addr, quitCh chan struct{}) { func (m *mdns) probeLoop(conns []*net.UDPConn, remoteAddr net.Addr, quitCh chan struct{}) {
bo := backoff.NewBackoff("mdns probe", func(format string, args ...any) {}, time.Second*30) bo := backoff.NewBackoff("mdns probe", func(format string, args ...any) {}, time.Second*30)
for { for {
err := m.probe(conns, remoteAddr, quitCh) err := m.probe(conns, remoteAddr)
if isErrNetUnreachableOrInvalid(err) { if isErrNetUnreachableOrInvalid(err) {
ctrld.ProxyLog.Warn().Msgf("stop probing %q: network unreachable or invalid", remoteAddr) ctrld.ProxyLog.Warn().Msgf("stop probing %q: network unreachable or invalid", remoteAddr)
break break
@@ -96,6 +97,7 @@ func (m *mdns) probeLoop(conns []*net.UDPConn, remoteAddr net.Addr, quitCh chan
} }
} }
// readLoop reads from mdns connection, save/update any hostnames found.
func (m *mdns) readLoop(conn *net.UDPConn) { func (m *mdns) readLoop(conn *net.UDPConn) {
defer conn.Close() defer conn.Close()
buf := make([]byte, dns.MaxMsgSize) buf := make([]byte, dns.MaxMsgSize)
@@ -141,7 +143,8 @@ func (m *mdns) readLoop(conn *net.UDPConn) {
} }
} }
func (m *mdns) probe(conns []*net.UDPConn, remoteAddr net.Addr, quitCh chan struct{}) error { // probe performs mdns queries with known services.
func (m *mdns) probe(conns []*net.UDPConn, remoteAddr net.Addr) error {
msg := new(dns.Msg) msg := new(dns.Msg)
msg.Question = make([]dns.Question, len(services)) msg.Question = make([]dns.Question, len(services))
for i, service := range services { for i, service := range services {