X-Git-Url: http://git.onelab.eu/?p=nodemanager.git;a=blobdiff_plain;f=cgroups.py;h=a1c38b455dbb5e2ad7e58a7e56586c0ba2b925c9;hp=43a549dec695f48b5bd0f7e29de6a9937bc29273;hb=9c22fed1ec876de377dfabfcbb9648549f26a6bc;hpb=209b8e50cc9068572cdc0328ac4ea2440d2fa75c diff --git a/cgroups.py b/cgroups.py index 43a549d..a1c38b4 100644 --- a/cgroups.py +++ b/cgroups.py @@ -3,52 +3,12 @@ # # Xavi Leon -import os +import os, os.path import pyinotify import logger # Base dir for libvirt BASE_DIR = '/sys/fs/cgroup' -SUB_SYSTEMS = ['blkio', 'freezer', 'devices', 'memory', 'cpu,cpuacct', 'cpuset'] -VIRT_TECHS = ['lxc'] - -# Global cgroup mapping. -CGROUPS = dict() - -class CgroupWatch(pyinotify.ProcessEvent): - - def process_IN_CREATE(self, event): - path = os.path.join(event.path, event.name) - CGROUPS[event.name] = path - logger.verbose("Cgroup Notify: Created cgroup %s on %s" % \ - (event.name, event.path)) - - def process_IN_DELETE(self, event): - try: - del CGROUPS[event.name] - except: - logger.verbose("Cgroup Notify: Cgroup %s does not exist, continuing..."%event.name) - logger.verbose("Cgroup Notify: Deleted cgroup %s on %s" % \ - (event.name, event.path)) - - -#logger.verbose("Cgroups: Recognizing already existing cgroups...") -#for virt in VIRT_TECHS: -# filenames = os.listdir(os.path.join(BASE_DIR, virt)) -# for filename in filenames: -# path = os.path.join(BASE_DIR, virt, filename) -# if os.path.isdir(path): -# CGROUPS[filename] = path - -#logger.verbose("Cgroups: Initializing watchers...") -#wm = pyinotify.WatchManager() -#notifier = pyinotify.ThreadedNotifier(wm, CgroupWatch()) -#for virt in VIRT_TECHS: -# wdd = wm.add_watch(os.path.join(BASE_DIR, virt), -# pyinotify.IN_DELETE | pyinotify.IN_CREATE, -# rec=False) -#notifier.daemon = True -#notifier.start() def get_cgroup_paths(subsystem="cpuset"): subsystem_bases = [