Crunchstat logs where it reads its stats from. refs #2882

[arvados.git] / services / crunch / crunchstat / src / arvados.org / crunchstat / crunchstat.go

diff --git a/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go b/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go
index 09a99e5df2a5b72eb38671df4e250aa9d109d983..3544e7464600d8bd2fb9d20916b4300d17032782 100644 (file)
--- a/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go
+++ b/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go
@@ -75,6 +75,19 @@ func PollCgroupStats(cgroup_path string, stderr chan string, poll int64) {
        cpuset_cpus := FindStat(cgroup_path, "cpuset", "cpus")
        memory_stat := FindStat(cgroup_path, "memory", "stat")
 
+       if cpuacct_stat != "" {
+               stderr <- fmt.Sprintf("crunchstat: reading stats from ", cpuacct_stat)
+       }
+       if blkio_io_service_bytes != "" {
+               stderr <- fmt.Sprintf("crunchstat: reading stats from ", blkio_io_service_bytes)
+       }
+       if cpuset_cpus != "" {
+               stderr <- fmt.Sprintf("crunchstat: reading stats from ", cpuset_cpus)
+       }
+       if memory_stat != "" {
+               stderr <- fmt.Sprintf("crunchstat: reading stats from ", memory_stat)
+       }
+
        var elapsed int64 = poll
 
        for {