52 lines
1.0 KiB
Go
52 lines
1.0 KiB
Go
//go:build !windows
|
|
// +build !windows
|
|
|
|
package main
|
|
|
|
import (
|
|
"net"
|
|
"time"
|
|
|
|
"github.com/jedisct1/dlog"
|
|
)
|
|
|
|
func NetProbe(proxy *Proxy, address string, timeout int) error {
|
|
if len(address) <= 0 || timeout == 0 {
|
|
return nil
|
|
}
|
|
if captivePortalHandler, err := ColdStart(proxy); err == nil {
|
|
if captivePortalHandler != nil {
|
|
defer captivePortalHandler.Stop()
|
|
}
|
|
} else {
|
|
dlog.Critical(err)
|
|
}
|
|
remoteUDPAddr, err := net.ResolveUDPAddr("udp", address)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
retried := false
|
|
if timeout < 0 {
|
|
timeout = MaxTimeout
|
|
} else {
|
|
timeout = Min(MaxTimeout, timeout)
|
|
}
|
|
for tries := timeout; tries > 0; tries-- {
|
|
pc, err := net.DialUDP("udp", nil, remoteUDPAddr)
|
|
if err != nil {
|
|
if !retried {
|
|
retried = true
|
|
dlog.Notice("Network not available yet -- waiting...")
|
|
}
|
|
dlog.Debug(err)
|
|
time.Sleep(1 * time.Second)
|
|
continue
|
|
}
|
|
pc.Close()
|
|
dlog.Notice("Network connectivity detected")
|
|
return nil
|
|
}
|
|
dlog.Error("Timeout while waiting for network connectivity")
|
|
return nil
|
|
}
|