X-Git-Url: http://git.onelab.eu/?p=nodemanager.git;a=blobdiff_plain;f=net.py;h=7756d6bf3aeac18b090240e357aad5cdc9f2cb84;hp=de3360b9a8e9355f2683c77d1a13824c333cedca;hb=HEAD;hpb=08d6f2b70b86a10b222a5afe80945598296196ad diff --git a/net.py b/net.py index de3360b..7756d6b 100644 --- a/net.py +++ b/net.py @@ -1,30 +1,48 @@ -# $Id$ -# $URL$ - -"""network configuration""" +""" +network configuration +""" # system provided modules -import os, string, time, socket +import os # PlanetLab system modules import sioc, plnet # local modules -import bwlimit, logger, iptables, tools +import plnode.bwlimit as bwlimit +import logger +import iptables +import tools # we can't do anything without a network -priority=1 +priority = 1 dev_default = tools.get_default_if() + def start(): logger.log("net: plugin starting up...") def GetSlivers(data, config, plc): + # added by caglar + # band-aid for short period as old API returns networks instead of interfaces + global KEY_NAME + KEY_NAME = "interfaces" + ################# + logger.verbose("net: GetSlivers called.") if not 'interfaces' in data: - logger.log_missing_data('net.GetSlivers','interfaces') - return + # added by caglar + # band-aid for short period as old API returns networks instead of interfaces + # logger.log_missing_data('net.GetSlivers', 'interfaces') + # return + if not 'networks' in data: + logger.log_missing_data('net.GetSlivers', 'interfaces') + return + else: + KEY_NAME = "networks" + ################## + plnet.InitInterfaces(logger, plc, data) if 'OVERRIDES' in dir(config): if config.OVERRIDES.get('net_max_rate') == '-1': @@ -45,16 +63,16 @@ def InitNodeLimit(data): # query running network interfaces devs = sioc.gifconf() - ips = dict(zip(devs.values(), devs.keys())) + ips = dict(list(zip(list(devs.values()), list(devs.keys())))) macs = {} for dev in devs: macs[sioc.gifhwaddr(dev).lower()] = dev - for interface in data['interfaces']: + for interface in data[KEY_NAME]: # Get interface name preferably from MAC address, falling # back on IP address. hwaddr=interface['mac'] - if hwaddr <> None: hwaddr=hwaddr.lower() + if hwaddr != None: hwaddr=hwaddr.lower() if hwaddr in macs: dev = macs[interface['mac']] elif interface['ip'] in ips: @@ -112,17 +130,17 @@ def InitNAT(plc, data): # query running network interfaces devs = sioc.gifconf() - ips = dict(zip(devs.values(), devs.keys())) + ips = dict(list(zip(list(devs.values()), list(devs.keys())))) macs = {} for dev in devs: macs[sioc.gifhwaddr(dev).lower()] = dev ipt = iptables.IPTables() - for interface in data['interfaces']: + for interface in data[KEY_NAME]: # Get interface name preferably from MAC address, falling # back on IP address. hwaddr=interface['mac'] - if hwaddr <> None: hwaddr=hwaddr.lower() + if hwaddr != None: hwaddr=hwaddr.lower() if hwaddr in macs: dev = macs[interface['mac']] elif interface['ip'] in ips: