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 f8d27ec01b79d7f25d2405fe2fb12085fce17ef2..d61871da6475dcdde342789069492e9e8dcfedf2 100644 (file)
--- 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 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
                                                        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)
                                                }
                                        }
                                                        stderr <- fmt.Sprintf("crunchstat: blkio.io_service_bytes %s write %v", device, disk[device].next_write-disk[device].last_write)
                                                }
                                        }