unistack-org/metrics
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

process_metrics_linux.go: consistently mention the metrics package in error logs

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2022-07-21 19:33:33 +03:00
parent 195ac63dbf
commit c75f3497fe
No known key found for this signature in database
GPG Key ID: A72BEC6CD3D0DED1
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
process_metrics_linux.go
View File

@ -45,13 +45,13 @@ func writeProcessMetrics(w io.Writer) {
statFilepath := "/proc/self/stat" statFilepath := "/proc/self/stat"
data, err := ioutil.ReadFile(statFilepath) data, err := ioutil.ReadFile(statFilepath)
if err != nil { if err != nil {
log.Printf("ERROR: cannot open %s: %s", statFilepath, err) log.Printf("ERROR: metrics: cannot open %s: %s", statFilepath, err)
return return
} }
// Search for the end of command. // Search for the end of command.
n := bytes.LastIndex(data, []byte(") ")) n := bytes.LastIndex(data, []byte(") "))
if n < 0 { if n < 0 {
log.Printf("ERROR: cannot find command in parentheses in %q read from %s", data, statFilepath) log.Printf("ERROR: metrics: cannot find command in parentheses in %q read from %s", data, statFilepath)
return return
} }
data = data[n+2:] data = data[n+2:]
@ -62,7 +62,7 @@ func writeProcessMetrics(w io.Writer) {
&p.State, &p.Ppid, &p.Pgrp, &p.Session, &p.TtyNr, &p.Tpgid, &p.Flags, &p.Minflt, &p.Cminflt, &p.Majflt, &p.Cmajflt, &p.State, &p.Ppid, &p.Pgrp, &p.Session, &p.TtyNr, &p.Tpgid, &p.Flags, &p.Minflt, &p.Cminflt, &p.Majflt, &p.Cmajflt,
&p.Utime, &p.Stime, &p.Cutime, &p.Cstime, &p.Priority, &p.Nice, &p.NumThreads, &p.ItrealValue, &p.Starttime, &p.Vsize, &p.Rss) &p.Utime, &p.Stime, &p.Cutime, &p.Cstime, &p.Priority, &p.Nice, &p.NumThreads, &p.ItrealValue, &p.Starttime, &p.Vsize, &p.Rss)
if err != nil { if err != nil {
log.Printf("ERROR: cannot parse %q read from %s: %s", data, statFilepath, err) log.Printf("ERROR: metrics: cannot parse %q read from %s: %s", data, statFilepath, err)
return return
} }
@ -89,17 +89,17 @@ func writeIOMetrics(w io.Writer) {
ioFilepath := "/proc/self/io" ioFilepath := "/proc/self/io"
data, err := ioutil.ReadFile(ioFilepath) data, err := ioutil.ReadFile(ioFilepath)
if err != nil { if err != nil {
log.Printf("ERROR: cannot open %q: %s", ioFilepath, err) log.Printf("ERROR: metrics: cannot open %q: %s", ioFilepath, err)
} }
getInt := func(s string) int64 { getInt := func(s string) int64 {
n := strings.IndexByte(s, ' ') n := strings.IndexByte(s, ' ')
if n < 0 { if n < 0 {
log.Printf("ERROR: cannot find whitespace in %q at %q", s, ioFilepath) log.Printf("ERROR: metrics: cannot find whitespace in %q at %q", s, ioFilepath)
return 0 return 0
} }
v, err := strconv.ParseInt(s[n+1:], 10, 64) v, err := strconv.ParseInt(s[n+1:], 10, 64)
if err != nil { if err != nil {
log.Printf("ERROR: cannot parse %q at %q: %s", s, ioFilepath, err) log.Printf("ERROR: metrics: cannot parse %q at %q: %s", s, ioFilepath, err)
return 0 return 0
} }
return v return v
@ -137,12 +137,12 @@ var startTimeSeconds = time.Now().Unix()
func writeFDMetrics(w io.Writer) { func writeFDMetrics(w io.Writer) {
totalOpenFDs, err := getOpenFDsCount("/proc/self/fd") totalOpenFDs, err := getOpenFDsCount("/proc/self/fd")
if err != nil { if err != nil {
log.Printf("ERROR: cannot determine open file descriptors count: %s", err) log.Printf("ERROR: metrics: cannot determine open file descriptors count: %s", err)
return return
} }
maxOpenFDs, err := getMaxFilesLimit("/proc/self/limits") maxOpenFDs, err := getMaxFilesLimit("/proc/self/limits")
if err != nil { if err != nil {
log.Printf("ERROR: cannot determine the limit on open file descritors: %s", err) log.Printf("ERROR: metrics: cannot determine the limit on open file descritors: %s", err)
return return
} }
fmt.Fprintf(w, "process_max_fds %d\n", maxOpenFDs) fmt.Fprintf(w, "process_max_fds %d\n", maxOpenFDs)
@ -211,7 +211,7 @@ type memStats struct {
func writeProcessMemMetrics(w io.Writer) { func writeProcessMemMetrics(w io.Writer) {
ms, err := getMemStats("/proc/self/status") ms, err := getMemStats("/proc/self/status")
if err != nil { if err != nil {
log.Printf("ERROR: cannot determine memory status: %s", err) log.Printf("ERROR: metrics: cannot determine memory status: %s", err)
return return
} }
fmt.Fprintf(w, "process_virtual_memory_peak_bytes %d\n", ms.vmPeak) fmt.Fprintf(w, "process_virtual_memory_peak_bytes %d\n", ms.vmPeak)