Logo Search packages:      
Sourcecode: landscape-client version File versions


import time
import os

from landscape.lib.disk import get_mount_info
from landscape.lib.monitor import CoverageMonitor
from landscape.accumulate import Accumulator
from landscape.hal import HALManager
from landscape.monitor.monitor import MonitorPlugin

class MountInfo(MonitorPlugin):

    persist_name = "mount-info"

    def __init__(self, interval=300, monitor_interval=60*60,
                 mounts_file="/proc/mounts", create_time=time.time,
                 statvfs=None, hal_manager=None, mtab_file="/etc/mtab"):
        self.run_interval = interval
        self._monitor_interval = monitor_interval
        self._create_time = create_time
        self._mounts_file = mounts_file
        self._mtab_file = mtab_file
        if statvfs is None:
            statvfs = os.statvfs
        self._statvfs = statvfs
        self._create_time = create_time
        self._free_space = []
        self._mount_info = []
        self._mount_activity = []
        self._prev_mount_activity = {}
        self._hal_manager = hal_manager or HALManager()

    def register(self, registry):
        super(MountInfo, self).register(registry)
        self._accumulate = Accumulator(self._persist, self.registry.step_size)
        self._monitor = CoverageMonitor(self.run_interval, 0.8,
                                        "mount info snapshot",
        self.registry.reactor.call_on("stop", self._monitor.log, priority=2000)
        self.registry.reactor.call_on("resynchronize", self._resynchronize)
        self.call_on_accepted("mount-info", self.send_messages, True)

    def _resynchronize(self):

    def create_messages(self):
        return filter(None, [self.create_mount_info_message(),

    def create_mount_activity_message(self):
        if self._mount_activity:
            message = {"type": "mount-activity",
                       "activities": self._mount_activity}
            self._mount_activity = []
            return message
        return None

    def create_mount_info_message(self):
        if self._mount_info:
            message = {"type": "mount-info", "mount-info": self._mount_info}
            self._mount_info = []
            return message
        return None

    def create_free_space_message(self):
        if self._free_space:
            message = {"type": "free-space", "free-space": self._free_space}
            self._free_space = []
            return message
        return None

    def send_messages(self, urgent=False):
        for message in self.create_messages():
            self.registry.broker.send_message(message, urgent=urgent)

    def exchange(self):

    def run(self):
        now = int(self._create_time())
        current_mount_points = set()
        for mount_info in self._get_mount_info():
            mount_point = mount_info["mount-point"]
            free_space = mount_info.pop("free-space")

            key = ("accumulate-free-space", mount_point)
            step_data = self._accumulate(now, free_space, key)
            if step_data:
                timestamp = step_data[0]
                free_space = int(step_data[1])
                self._free_space.append((timestamp, mount_point, free_space))

            prev_mount_info = self._persist.get(("mount-info", mount_point))
            if not prev_mount_info or prev_mount_info != mount_info:
                self._persist.set(("mount-info", mount_point), mount_info)
                self._mount_info.append((now, mount_info))

            if not self._prev_mount_activity.get(mount_point, False):
                self._mount_activity.append((now, mount_point, True))
                self._prev_mount_activity[mount_point] = True


        for mount_point in self._prev_mount_activity:
            if mount_point not in current_mount_points:
                self._mount_activity.append((now, mount_point, False))
                self._prev_mount_activity[mount_point] = False

    def _get_removable_devices(self):
        block_devices = {} # {udi: [device, ...]}
        children = {} # {parent_udi: [child_udi, ...]}
        removable = set()

        # We walk the list of devices building up a dictionary of all removable
        # devices, and a mapping of {UDI => [block devices]}
        # We differentiate between devices that we definitely know are
        # removable and devices that _may_ be removable, depending on their
        # parent device, e.g. /dev/sdb1 isn't flagged as removable, but
        # /dev/sdb may well be removable.

        # Unfortunately, HAL doesn't guarantee the order of the devices
        # returned from get_devices(), so we may not know that a parent device
        # is removable when we find it's first child.
        devices = self._hal_manager.get_devices()
        for device in devices:
            block_device = device.properties.get("block.device")
            if block_device:
                if device.properties.get("storage.removable"):

                except KeyError:
                    block_devices[device.udi] = [block_device]

                parent_udi = device.properties.get("info.parent")
                if parent_udi is not None:
                    except KeyError:
                        children[parent_udi] = [device.udi]

        # Propagate the removable flag from each node all the way to
        # its leaf children.
        updated = True
        while updated:
            updated = False
            for parent_udi in children:
                if parent_udi in removable:
                    for child_udi in children[parent_udi]:
                        if child_udi not in removable:
                            updated = True

        # We've now seen _all_ devices, and have the definitive list of
        # removable UDIs, so we can now find all the removable devices in the
        # system.
        removable_devices = set()
        for udi in removable:

        return removable_devices

    def _get_mount_info(self):
        """Generator yields local mount points worth recording data for."""
        file = open(self._mounts_file, "r")
        removable_devices = self._get_removable_devices()
        bound_mount_points = self._get_bound_mount_points()

        for info in get_mount_info(self._mounts_file, self._statvfs):
            device = info["device"]
            mount_point = info["mount-point"]
            if (device.startswith("/dev/") and
                not mount_point.startswith("/dev/") and
                not device in removable_devices and
                not mount_point in bound_mount_points):
                yield info

    def _get_bound_mount_points(self):
        Returns a set of mount points that have the "bind" option
        by parsing /etc/mtab.
        bound_points = set()
        if not self._mtab_file or not os.path.isfile(self._mtab_file):
            return bound_points

        file = open(self._mtab_file, "r")
        for line in file:
                device, mount_point, filesystem, options = line.split()[:4]
                mount_point = mount_point.decode("string-escape")
            except ValueError:
            if "bind" in options.split(","):
        return bound_points

Generated by  Doxygen 1.6.0   Back to index