// +build !windows package ping import ( "errors" "fmt" "net" "os/exec" "runtime" "strconv" "strings" "sync" "syscall" "time" "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/internal" "github.com/influxdata/telegraf/plugins/inputs" ) // HostPinger is a function that runs the "ping" function using a list of // passed arguments. This can be easily switched with a mocked ping function // for unit test purposes (see ping_test.go) type HostPinger func(timeout float64, args ...string) (string, error) type Ping struct { // Interval at which to ping (ping -i ) PingInterval float64 `toml:"ping_interval"` // Number of pings to send (ping -c ) Count int // Ping timeout, in seconds. 0 means no timeout (ping -W ) Timeout float64 // Ping deadline, in seconds. 0 means no deadline. (ping -w ) Deadline int // Interface or source address to send ping from (ping -I/-S ) Interface string // URLs to ping Urls []string // host ping function pingHost HostPinger } func (_ *Ping) Description() string { return "Ping given url(s) and return statistics" } const sampleConfig = ` ## NOTE: this plugin forks the ping command. You may need to set capabilities ## via setcap cap_net_raw+p /bin/ping # ## List of urls to ping urls = ["www.google.com"] # required ## number of pings to send per collection (ping -c ) # count = 1 ## interval, in s, at which to ping. 0 == default (ping -i ) # ping_interval = 1.0 ## per-ping timeout, in s. 0 == no timeout (ping -W ) # timeout = 1.0 ## total-ping deadline, in s. 0 == no deadline (ping -w ) # deadline = 10 ## interface or source address to send ping from (ping -I ) ## on Darwin and Freebsd only source address possible: (ping -S ) # interface = "" ` func (_ *Ping) SampleConfig() string { return sampleConfig } func (p *Ping) Gather(acc telegraf.Accumulator) error { var wg sync.WaitGroup // Spin off a go routine for each url to ping for _, url := range p.Urls { wg.Add(1) go func(u string) { defer wg.Done() tags := map[string]string{"url": u} fields := map[string]interface{}{"result_code": 0} _, err := net.LookupHost(u) if err != nil { acc.AddError(err) fields["result_code"] = 1 acc.AddFields("ping", fields, tags) return } args := p.args(u, runtime.GOOS) totalTimeout := float64(p.Count)*p.Timeout + float64(p.Count-1)*p.PingInterval out, err := p.pingHost(totalTimeout, args...) if err != nil { // Some implementations of ping return a 1 exit code on // timeout, if this occurs we will not exit and try to parse // 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("host %s: %s, %s", u, out, err)) } else { acc.AddError(fmt.Errorf("host %s: %s", u, err)) } fields["result_code"] = 2 acc.AddFields("ping", fields, tags) return } } trans, rec, min, avg, max, stddev, err := processPingOutput(out) if err != nil { // fatal error acc.AddError(fmt.Errorf("%s: %s", err, u)) fields["result_code"] = 2 acc.AddFields("ping", fields, tags) return } // Calculate packet loss percentage loss := float64(trans-rec) / float64(trans) * 100.0 fields["packets_transmitted"] = trans fields["packets_received"] = rec fields["percent_packet_loss"] = loss if min >= 0 { fields["minimum_response_ms"] = min } if avg >= 0 { fields["average_response_ms"] = avg } if max >= 0 { fields["maximum_response_ms"] = max } if stddev >= 0 { fields["standard_deviation_ms"] = stddev } acc.AddFields("ping", fields, tags) }(url) } wg.Wait() return nil } func hostPinger(timeout float64, args ...string) (string, error) { bin, err := exec.LookPath("ping") if err != nil { return "", err } c := exec.Command(bin, args...) out, err := internal.CombinedOutputTimeout(c, time.Second*time.Duration(timeout+5)) return string(out), err } // args returns the arguments for the 'ping' executable func (p *Ping) args(url string, system string) []string { // Build the ping command args based on toml config args := []string{"-c", strconv.Itoa(p.Count), "-n", "-s", "16"} if p.PingInterval > 0 { args = append(args, "-i", strconv.FormatFloat(p.PingInterval, 'f', -1, 64)) } if p.Timeout > 0 { switch system { case "darwin", "freebsd", "netbsd", "openbsd": args = append(args, "-W", strconv.FormatFloat(p.Timeout*1000, 'f', -1, 64)) case "linux": args = append(args, "-W", strconv.FormatFloat(p.Timeout, 'f', -1, 64)) default: // Not sure the best option here, just assume GNU ping? args = append(args, "-W", strconv.FormatFloat(p.Timeout, 'f', -1, 64)) } } if p.Deadline > 0 { switch system { case "darwin", "freebsd", "netbsd", "openbsd": args = append(args, "-t", strconv.Itoa(p.Deadline)) case "linux": args = append(args, "-w", strconv.Itoa(p.Deadline)) default: // Not sure the best option here, just assume GNU ping? args = append(args, "-w", strconv.Itoa(p.Deadline)) } } if p.Interface != "" { switch system { case "darwin", "freebsd", "netbsd", "openbsd": args = append(args, "-S", p.Interface) case "linux": args = append(args, "-I", p.Interface) default: // Not sure the best option here, just assume GNU ping? args = append(args, "-I", p.Interface) } } args = append(args, url) return args } // processPingOutput takes in a string output from the ping command, like: // // PING www.google.com (173.194.115.84): 56 data bytes // 64 bytes from 173.194.115.84: icmp_seq=0 ttl=54 time=52.172 ms // 64 bytes from 173.194.115.84: icmp_seq=1 ttl=54 time=34.843 ms // // --- www.google.com ping statistics --- // 2 packets transmitted, 2 packets received, 0.0% packet loss // round-trip min/avg/max/stddev = 34.843/43.508/52.172/8.664 ms // // It returns (, , ) func processPingOutput(out string) (int, int, float64, float64, float64, float64, error) { var trans, recv int var min, avg, max, stddev float64 = -1.0, -1.0, -1.0, -1.0 // Set this error to nil if we find a 'transmitted' line err := errors.New("Fatal error processing ping output") lines := strings.Split(out, "\n") for _, line := range lines { if strings.Contains(line, "transmitted") && strings.Contains(line, "received") { stats := strings.Split(line, ", ") // Transmitted packets trans, err = strconv.Atoi(strings.Split(stats[0], " ")[0]) if err != nil { return trans, recv, min, avg, max, stddev, err } // Received packets recv, err = strconv.Atoi(strings.Split(stats[1], " ")[0]) if err != nil { return trans, recv, min, avg, max, stddev, err } } else if strings.Contains(line, "min/avg/max") { stats := strings.Split(line, " ")[3] data := strings.Split(stats, "/") min, err = strconv.ParseFloat(data[0], 64) if err != nil { return trans, recv, min, avg, max, stddev, err } avg, err = strconv.ParseFloat(data[1], 64) if err != nil { return trans, recv, min, avg, max, stddev, err } max, err = strconv.ParseFloat(data[2], 64) if err != nil { return trans, recv, min, avg, max, stddev, err } if len(data) == 4 { stddev, err = strconv.ParseFloat(data[3], 64) if err != nil { return trans, recv, min, avg, max, stddev, err } } } } return trans, recv, min, avg, max, stddev, err } func init() { inputs.Add("ping", func() telegraf.Input { return &Ping{ pingHost: hostPinger, PingInterval: 1.0, Count: 1, Timeout: 1.0, Deadline: 10, } }) }