attempt to keep TCP listener alive if there's a temporary error (e.g. too many open files), just pause and retry later

This commit is contained in:
Arceliar 2020-10-18 11:01:18 -05:00
parent 9eb4981ac1
commit 1d1c6efa1f
2 changed files with 10 additions and 2 deletions

View File

@ -191,7 +191,9 @@ func (m *Multicast) getAllowedInterfaces() map[string]net.Interface {
// Ask the system for network interfaces // Ask the system for network interfaces
allifaces, err := net.Interfaces() allifaces, err := net.Interfaces()
if err != nil { if err != nil {
panic(err) // Don't panic, since this may be from e.g. too many open files (from too much connection spam)
// TODO? log something
return nil
} }
// Work out which interfaces to announce on // Work out which interfaces to announce on
for _, iface := range allifaces { for _, iface := range allifaces {

View File

@ -226,7 +226,13 @@ func (t *tcp) listener(l *TcpListener, listenaddr string) {
sock, err := l.Listener.Accept() sock, err := l.Listener.Accept()
if err != nil { if err != nil {
t.links.core.log.Errorln("Failed to accept connection:", err) t.links.core.log.Errorln("Failed to accept connection:", err)
return select {
case <-l.stop:
return
default:
}
time.Sleep(time.Second) // So we don't busy loop
continue
} }
t.waitgroup.Add(1) t.waitgroup.Add(1)
options := tcpOptions{ options := tcpOptions{