Remove log message on ping timeout (#3126)
This commit is contained in:
parent
09153c815c
commit
eb0215c382
|
@ -4,11 +4,13 @@ package ping
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
"runtime"
|
"runtime"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/influxdata/telegraf"
|
"github.com/influxdata/telegraf"
|
||||||
|
@ -76,17 +78,36 @@ func (p *Ping) Gather(acc telegraf.Accumulator) error {
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
args := p.args(u)
|
args := p.args(u)
|
||||||
totalTimeout := float64(p.Count)*p.Timeout + float64(p.Count-1)*p.PingInterval
|
totalTimeout := float64(p.Count)*p.Timeout + float64(p.Count-1)*p.PingInterval
|
||||||
|
|
||||||
out, err := p.pingHost(totalTimeout, args...)
|
out, err := p.pingHost(totalTimeout, args...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
// Combine go err + stderr output
|
// Some implementations of ping return a 1 exit code on
|
||||||
acc.AddError(errors.New(
|
// timeout, if this occurs we will not exit and try to parse
|
||||||
strings.TrimSpace(out) + ", " + err.Error()))
|
// the output.
|
||||||
|
status := -1
|
||||||
|
if exitError, ok := err.(*exec.ExitError); ok {
|
||||||
|
if ws, ok := exitError.Sys().(syscall.WaitStatus); ok {
|
||||||
|
status = ws.ExitStatus()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if status != 1 {
|
||||||
|
// Combine go err + stderr output
|
||||||
|
out = strings.TrimSpace(out)
|
||||||
|
if len(out) > 0 {
|
||||||
|
acc.AddError(fmt.Errorf("%s, %s", out, err))
|
||||||
|
} else {
|
||||||
|
acc.AddError(err)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
tags := map[string]string{"url": u}
|
tags := map[string]string{"url": u}
|
||||||
trans, rec, min, avg, max, stddev, err := processPingOutput(out)
|
trans, rec, min, avg, max, stddev, err := processPingOutput(out)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
// fatal error
|
// fatal error
|
||||||
acc.AddError(err)
|
acc.AddError(fmt.Errorf("%s: %s", err, u))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
// Calculate packet loss percentage
|
// Calculate packet loss percentage
|
||||||
|
|
|
@ -211,7 +211,8 @@ Request timeout for icmp_seq 0
|
||||||
`
|
`
|
||||||
|
|
||||||
func mockErrorHostPinger(timeout float64, args ...string) (string, error) {
|
func mockErrorHostPinger(timeout float64, args ...string) (string, error) {
|
||||||
return errorPingOutput, errors.New("No packets received")
|
// This error will not trigger correct error paths
|
||||||
|
return errorPingOutput, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Test that Gather works on a ping with no transmitted packets, even though the
|
// Test that Gather works on a ping with no transmitted packets, even though the
|
||||||
|
|
Loading…
Reference in New Issue