From: Peter Amstutz <peter.amstutz@curoverse.com>
Date: Tue, 24 Jun 2014 21:08:40 +0000 (-0400)
Subject: Don't print blkio stats if no reads or writes have occurred since the last poll.
X-Git-Tag: 1.1.0~2521^2~17
X-Git-Url: https://git.arvados.org/arvados.git/commitdiff_plain/64437af24f74ec3f48b1a5694a5805d52dfc4967

Don't print blkio stats if no reads or writes have occurred since the last poll.
---

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)
 						}
 					}