summaryrefslogtreecommitdiff
path: root/internal/failover/ping.go
diff options
context:
space:
mode:
authorSimon Rozman <simon@rozman.si>2023-03-23 10:23:18 +0100
committerJeroen Wijenbergh <46386452+jwijenbergh@users.noreply.github.com>2023-09-25 09:43:37 +0200
commit498b747669e97e8af414a369433c04371396f08c (patch)
tree5829ff36ae8c46214fd651b77a98647250940575 /internal/failover/ping.go
parenteb57e36d3c017bef80277e97db1009c38893ce2d (diff)
Fix connection monitoring on Windows
Linux requires su for `ip4:icmp` pings. Windows does not support `udp4` pings. Signed-off-by: Simon Rozman <simon@rozman.si>
Diffstat (limited to 'internal/failover/ping.go')
-rw-r--r--internal/failover/ping.go13
1 files changed, 3 insertions, 10 deletions
diff --git a/internal/failover/ping.go b/internal/failover/ping.go
index 15d4adb..fb1df4e 100644
--- a/internal/failover/ping.go
+++ b/internal/failover/ping.go
@@ -18,14 +18,7 @@ var mtuOverhead = 28
type Pinger struct {
listener net.PacketConn
buffer []byte
-}
-
-func NewPinger(size int) (*Pinger, error) {
- l, err := icmp.ListenPacket("udp4", "0.0.0.0")
- if err != nil {
- return nil, errors.WrapPrefix(err, "failed creating ping", 0)
- }
- return &Pinger{listener: l, buffer: make([]byte, size-mtuOverhead)}, nil
+ gateway net.Addr
}
func (p Pinger) Read(deadline time.Time) error {
@@ -52,7 +45,7 @@ func (p Pinger) Read(deadline time.Time) error {
}
}
-func (p Pinger) Send(gateway string, seq int) error {
+func (p Pinger) Send(seq int) error {
errorMessage := fmt.Sprintf("failed sending ping, seq %d", seq)
// Make a new ICMP message
m := icmp.Message{
@@ -68,7 +61,7 @@ func (p Pinger) Send(gateway string, seq int) error {
return errors.WrapPrefix(err, errorMessage, 0)
}
// And send it to the gateway IP!
- _, err = p.listener.WriteTo(b, &net.UDPAddr{IP: net.ParseIP(gateway)})
+ _, err = p.listener.WriteTo(b, p.gateway)
if err != nil {
return errors.WrapPrefix(err, errorMessage, 0)
}