X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=tools.py;h=267ec3149066ab06d47b9ba14d2a89a0c2f4af16;hb=74a8cfb9d2eac39ae02e5323e1fb5b1d33297981;hp=f3e67e1595a185c907799d93f1f851526b084282;hpb=4293a16c3c0badbc130c3af6b62c3681a5eeb9d6;p=nodemanager.git diff --git a/tools.py b/tools.py index f3e67e1..267ec31 100644 --- a/tools.py +++ b/tools.py @@ -1,3 +1,6 @@ +# $Id$ +# $URL$ + """A few things that didn't seem to fit anywhere else.""" import cPickle @@ -9,10 +12,6 @@ import threading import fcntl import commands import logger -try: - import sioc -except: - pass PID_FILE = '/var/run/nm.pid' @@ -22,12 +21,16 @@ def get_default_if(): return interface def get_hwaddr_from_plnode(): - for line in open("/usr/boot/plnode.txt", 'r').readlines(): - if line.startswith("NET_DEVICE"): - return line.split("=")[1].strip().strip('"') + try: + for line in open("/usr/boot/plnode.txt", 'r').readlines(): + if line.startswith("NET_DEVICE"): + return line.split("=")[1].strip().strip('"') + except: + pass return None def get_if_from_hwaddr(hwaddr): + import sioc devs = sioc.gifconf() for dev in devs: dev_hwaddr = sioc.gifhwaddr(dev) @@ -78,7 +81,7 @@ def fork_as(su, function, *args): except: os.seteuid(os.getuid()) # undo su so we can write the log file os.setegid(os.getgid()) - logger.log_exc() + logger.log_exc("tools: fork_as") os._exit(0) else: os.waitpid(child_pid, 0) @@ -125,18 +128,6 @@ def node_id(): _node_id="" return _node_id -# get slicefamily from /etc/planetlab/slicefamily and cache it -# http://svn.planet-lab.org/wiki/SliceFamily -_slicefamily=None -def slicefamily(): - global _slicefamily - if _slicefamily is None: - try: - _slicefamily=file("/etc/planetlab/slicefamily").read().strip() - except: - _slicefamily="" - return _slicefamily - _root_context_arch=None def root_context_arch(): global _root_context_arch @@ -147,7 +138,7 @@ def root_context_arch(): class NMLock: def __init__(self, file): - logger.log("Lock %s initialized." % file, 2) + logger.log("tools: Lock %s initialized." % file, 2) self.fd = os.open(file, os.O_RDWR|os.O_CREAT, 0600) flags = fcntl.fcntl(self.fd, fcntl.F_GETFD) flags |= fcntl.FD_CLOEXEC @@ -155,8 +146,8 @@ class NMLock: def __del__(self): os.close(self.fd) def acquire(self): - logger.log("Lock acquired.", 2) + logger.log("tools: Lock acquired.", 2) fcntl.lockf(self.fd, fcntl.LOCK_SH) def release(self): - logger.log("Lock released.", 2) + logger.log("tools: Lock released.", 2) fcntl.lockf(self.fd, fcntl.LOCK_UN)