X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=tools.py;h=267ec3149066ab06d47b9ba14d2a89a0c2f4af16;hb=74a8cfb9d2eac39ae02e5323e1fb5b1d33297981;hp=941838bd41529c5a69cded3d3edd309beb2ab670;hpb=0ade807b91a8c84098406935d41d749f33efbe9d;p=nodemanager.git diff --git a/tools.py b/tools.py index 941838b..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 @@ -18,18 +21,21 @@ 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) - if dev_hwaddr == hwaddr: return dev - return None + import sioc + devs = sioc.gifconf() + for dev in devs: + dev_hwaddr = sioc.gifhwaddr(dev) + if dev_hwaddr == hwaddr: return dev + return None def as_daemon_thread(run): """Call function with no arguments in its own thread.""" @@ -75,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) @@ -122,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 @@ -144,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 @@ -152,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)