X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=tools.py;h=f3e67e1595a185c907799d93f1f851526b084282;hb=4293a16c3c0badbc130c3af6b62c3681a5eeb9d6;hp=776a8d48f94aa131fd990754383aea17437d5fc3;hpb=1f41e95b9e61049d5f94edce110d729c399c932b;p=nodemanager.git diff --git a/tools.py b/tools.py index 776a8d4..f3e67e1 100644 --- a/tools.py +++ b/tools.py @@ -7,12 +7,33 @@ import pwd import tempfile import threading import fcntl - +import commands import logger - +try: + import sioc +except: + pass PID_FILE = '/var/run/nm.pid' +def get_default_if(): + interface = get_if_from_hwaddr(get_hwaddr_from_plnode()) + if not interface: interface = "eth0" + 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('"') + return None + +def get_if_from_hwaddr(hwaddr): + 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.""" thr = threading.Thread(target=run) @@ -91,6 +112,38 @@ def write_temp_file(do_write, mode=None, uidgid=None): finally: f.close() return temporary_filename +# utilities functions to get (cached) information from the node + +# get node_id from /etc/planetlab/node_id and cache it +_node_id=None +def node_id(): + global _node_id + if _node_id is None: + try: + _node_id=int(file("/etc/planetlab/node_id").read()) + except: + _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 + if not _root_context_arch: + _root_context_arch=commands.getoutput("uname -i") + return _root_context_arch + class NMLock: def __init__(self, file):