From 64437af24f74ec3f48b1a5694a5805d52dfc4967 Mon Sep 17 00:00:00 2001 From: Peter Amstutz Date: Tue, 24 Jun 2014 17:08:40 -0400 Subject: [PATCH] Don't print blkio stats if no reads or writes have occurred since the last poll. --- .../crunchstat/src/arvados.org/crunchstat/crunchstat.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go b/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go index f8d27ec01b..d61871da64 100644 --- a/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go +++ b/services/crunch/crunchstat/src/arvados.org/crunchstat/crunchstat.go @@ -182,14 +182,14 @@ func PollCgroupStats(cgroup_root string, cgroup_parent string, container_id stri if op == "Read" { disk[device].last_read = disk[device].next_read disk[device].next_read = next - if disk[device].last_read > 0 { + if disk[device].last_read > 0 && (disk[device].next_read != disk[device].last_read) { stderr <- fmt.Sprintf("crunchstat: blkio.io_service_bytes %s read %v", device, disk[device].next_read-disk[device].last_read) } } if op == "Write" { disk[device].last_write = disk[device].next_write disk[device].next_write = next - if disk[device].last_write > 0 { + if disk[device].last_write > 0 && (disk[device].next_write != disk[device].last_write) { stderr <- fmt.Sprintf("crunchstat: blkio.io_service_bytes %s write %v", device, disk[device].next_write-disk[device].last_write) } } -- 2.30.2