3826: Remove duplicate log message, add missing crunchstat: log prefix.
authorTom Clegg <tom@curoverse.com>
Tue, 14 Oct 2014 12:54:13 +0000 (08:54 -0400)
committerTom Clegg <tom@curoverse.com>
Tue, 14 Oct 2014 13:17:26 +0000 (09:17 -0400)
services/crunchstat/crunchstat.go

index 26b8bb3ce125f63599299c12d751642c9d160186..d02af56013b5e1951c0e5307fbb0afa60dbc77a8 100644 (file)
@@ -49,7 +49,7 @@ func OpenAndReadAll(filename string, log_chan chan<- string) ([]byte, error) {
        in, err := os.Open(filename)
        if err != nil {
                if log_chan != nil {
-                       log_chan <- fmt.Sprintf("open %s: %s", filename, err)
+                       log_chan <- fmt.Sprintf("crunchstat: open %s: %s", filename, err)
                }
                return nil, err
        }
@@ -57,7 +57,7 @@ func OpenAndReadAll(filename string, log_chan chan<- string) ([]byte, error) {
        {
                content, err := ioutil.ReadAll(in)
                if err != nil && log_chan != nil {
-                       log_chan <- fmt.Sprintf("read %s: %s", filename, err)
+                       log_chan <- fmt.Sprintf("crunchstat: read %s: %s", filename, err)
                }
                return content, err
        }
@@ -99,7 +99,6 @@ func GetContainerNetStats(stderr chan<- string, cgroup Cgroup) (io.Reader, error
                statsFilename := fmt.Sprintf("/proc/%s/net/dev", taskPid)
                stats, err := OpenAndReadAll(statsFilename, stderr)
                if err != nil {
-                       stderr <- fmt.Sprintf("crunchstat: open %s: %s", statsFilename, err)
                        continue
                }
                return strings.NewReader(string(stats)), nil