Proc

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	7
Bugs	2	Features	2

2 Methods

Rating	Name	Duplication	Size	Complexity
A	poll()	0	18	4
A	__init__()	0	20	3

# -*- coding: utf-8 -*-
"""Reader for many useful metrics in /proc on Linux."""

from collections import deque, Iterable

import plumd

from plumd.readers.linux.conntrack import Conntrack
from plumd.readers.linux.diskstats import DiskStats
from plumd.readers.linux.loadavg import LoadAverage
from plumd.readers.linux.mem import Mem
from plumd.readers.linux.netdev import NetDev
from plumd.readers.linux.netsnmp import NetSnmp
from plumd.readers.linux.netstat import Netstat
from plumd.readers.linux.sockstat import SockStat
from plumd.readers.linux.pstat import Stat
from plumd.readers.linux.swap import Swap
from plumd.readers.linux.uptime import Uptime
from plumd.readers.linux.vmstat import VmStat

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

classes = [Conntrack, DiskStats, LoadAverage, Mem, NetDev, NetSnmp, Netstat,
           SockStat, Stat, Swap, Uptime, VmStat]


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

    defaults = {
        'poll.interval': 10,
        'disabled_readers': []
    }

    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(Proc, self).__init__(log, config)
        config.defaults(Proc.defaults)
        self.readers = deque()
        disabled = config.get('disabled_readers')
        for cls in classes:
            if cls.__name__ in disabled:
                msg = "Proc: skipping disabled reader: {0}"
                self.log.warn(msg.format(cls.__name__))
                continue
            self.log.debug(
                "Proc: initializing reader: {0}".format(cls.__name__))
            self.readers.append(cls(log, config))

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

        :rtype: ResultSet
        """
        ret = plumd.ResultSet([])
        for rdr in self.readers:
            try:
                vals = rdr.check()
                if isinstance(vals, Iterable):
                    ret.add_list(vals)
                else:
                    msg = "Proc: invalid return from {0}"
                    self.log.warn(msg.format(rdr))
            except Exception as exc:

Catching very general exceptions such as Exception is usually not recommended.

                msg = "Proc: exception polling: {0}: {1}"
                self.log.error(msg.format(rdr, exc))
        return ret