mirrors/yggdrasil-go
2
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go synced 2024-11-10 15:30:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

Clean up old listeners first

Browse Source
This commit is contained in:
Neil Alexander 2019-03-06 12:09:57 +00:00
parent f4e17b9a9f
commit c0d5a8c0bd
No known key found for this signature in database
GPG Key ID: A02A2019A2BB0944
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/yggdrasil/multicast.go
View File

@ -115,6 +115,15 @@ func (m *multicast) announce() {
} }
for { for {
interfaces := m.interfaces() interfaces := m.interfaces()
// There might be interfaces that we configured listeners for but are no
// longer up - if that's the case then we should stop the listeners
for name, listener := range m.listeners {
if _, ok := interfaces[name]; !ok {
listener.stop <- true
delete(m.listeners, name)
m.core.log.Debugln("No longer multicasting on", name)
}
}
// Now that we have a list of valid interfaces from the operating system, // Now that we have a list of valid interfaces from the operating system,
// we can start checking if we can send multicasts on them // we can start checking if we can send multicasts on them
for _, iface := range interfaces { for _, iface := range interfaces {
@ -164,15 +173,6 @@ func (m *multicast) announce() {
} }
time.Sleep(time.Second) time.Sleep(time.Second)
} }
// There might be interfaces that we configured listeners for but are no
// longer up - if that's the case then we should stop the listeners
for name, listener := range m.listeners {
if _, ok := interfaces[name]; !ok {
listener.stop <- true
delete(m.listeners, name)
m.core.log.Debugln("No longer multicasting on", name)
}
}
time.Sleep(time.Second * 5) time.Sleep(time.Second * 5)
} }
} }