sensors/io_sensors.py

from discover import provides
from utils import SensorInfo, is_dev_accepted

#  1 - major number
#  2 - minor mumber
#  3 - device name
#  4 - reads completed successfully
#  5 - reads merged
#  6 - sectors read
#  7 - time spent reading (ms)
#  8 - writes completed
#  9 - writes merged
# 10 - sectors written
# 11 - time spent writing (ms)
# 12 - I/Os currently in progress
# 13 - time spent doing I/Os (ms)
# 14 - weighted time spent doing I/Os (ms)

io_values_pos = [
    (3, 'reads_completed', True),
    (5, 'sectors_read', True),
    (6, 'rtime', True),
    (7, 'writes_completed', True),
    (9, 'sectors_written', True),
    (10, 'wtime', True),
    (11, 'io_queue', False),
    (13, 'io_time', True)
]


@provides("block-io")
def io_stat(disallowed_prefixes=('ram', 'loop'), allowed_prefixes=None):
    results = {}
    for line in open('/proc/diskstats'):
        vals = line.split()
        dev_name = vals[2]

        dev_ok = is_dev_accepted(dev_name,
                                 disallowed_prefixes,
                                 allowed_prefixes)

        if dev_ok:
            for pos, name, accum_val in io_values_pos:
                sensor_name = "{0}.{1}".format(dev_name, name)
                results[sensor_name] = SensorInfo(int(vals[pos]), accum_val)
    return results


def get_latency(stat1, stat2):
    disks = set(i.split('.', 1)[0] for i in stat1)
    results = {}

    for disk in disks:
        rdc = disk + '.reads_completed'
        wrc = disk + '.writes_completed'
        rdt = disk + '.rtime'
        wrt = disk + '.wtime'
        lat = 0.0

        io_ops1 = stat1[rdc].value + stat1[wrc].value
        io_ops2 = stat2[rdc].value + stat2[wrc].value

        diops = io_ops2 - io_ops1

        if diops != 0:
            io1 = stat1[rdt].value + stat1[wrt].value
            io2 = stat2[rdt].value + stat2[wrt].value
            lat = abs(float(io1 - io2)) / diops

        results[disk + '.latence'] = SensorInfo(lat, False)

    return results