LoadAverage

Complexity

Total Complexity

6

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	poll()	0	6	1
A	__init__()	0	17	2
A	check()	0	16	3

# -*- coding: utf-8 -*-
"""Load average reader for /proc on Linux."""
import plumd
from plumd.util import get_file

__author__ = 'Kenny Freeman'
__email__ = 'kenny.freeman@gmail.com'
__license__ = "ISCL"
__docformat__ = 'reStructuredText'


class LoadAverage(plumd.Reader):
    """Plugin to measure various kernel metrics from /proc."""

    proc_colums = 5

    defaults = {
        'poll.interval': 10,
        'proc_path': '/proc'
    }

    def __init__(self, log, config):
        """Plugin to measure various kernel metrics from /proc.

        :param log: A logger
        :type log: logging.RootLogger
        :param config: a plumd.config.Conf configuration helper instance.
        :type config: plumd.config.Conf
        """
        super(LoadAverage, self).__init__(log, config)
        config.defaults(LoadAverage.defaults)
        self.proc_file = "{0}/loadavg".format(config.get('proc_path'))
        ncols = len(get_file(self.proc_file).strip().split())
        self.enabled = ncols == LoadAverage.proc_colums
        if not self.enabled:
            msg = "LoadAverage: invalid: {0} has {1} cols, expected {2}"
            self.log.error(msg.format(self.proc_file, ncols,
                                      LoadAverage.proc_colums))

    def poll(self):
        """Poll for kernel metrics under /proc.

        :rtype: ResultSet
        """
        return plumd.ResultSet(self.check())

    def check(self):
        """Return 1, 5 and 15 minute load averages from proc file loadavg.

        :rtype: plumd.Result
        """
        result = plumd.Result("loadavg")
        if not self.enabled:
            return result
        dat = []
        # read and process /proc/stat
        dat = get_file(self.proc_file).split()
        if len(dat) >= 3:
            result.add(plumd.Float("1", dat[0]))
            result.add(plumd.Float("5", dat[1]))
            result.add(plumd.Float("15", dat[2]))
        return [result]