X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=net.py;h=bfd9113a28d86e7ae8ed82ad82f92dedbe8604bd;hb=a53c6df31a0acdd9a0081d6ded652f6b0d734e54;hp=84cde401f8654649ea0126f4311789b995e0172d;hpb=66c91739d265289b7c466e70b5f3f1c63b1b6e4a;p=nodemanager.git diff --git a/net.py b/net.py index 84cde40..bfd9113 100644 --- a/net.py +++ b/net.py @@ -15,37 +15,36 @@ def GetSlivers(data): # XXX Exempt Internet2 destinations from node bwlimits # bwlimit.exempt_init('Internet2', internet2_ips) - for d in data: - for network in d['networks']: - # Get interface name preferably from MAC address, falling - # back on IP address. - if macs.has_key(network['mac'].lower()): - dev = macs[network['mac'].lower()] - elif ips.has_key(network['ip']): - dev = ips[network['ip']] - else: - logger.log('%s: no such interface with address %s/%s' % (self.name, network['ip'], network['mac'])) - continue - - # Get current node cap - try: - old_bwlimit = bwlimit.get_bwcap(dev) - except: - old_bwlimit = None - - # Get desired node cap - if network['bwlimit'] is None or network['bwlimit'] < 0: - new_bwlimit = bwlimit.bwmax - else: - new_bwlimit = network['bwlimit'] - - if old_bwlimit != new_bwlimit: - # Reinitialize bandwidth limits - bwlimit.init(dev, new_bwlimit) - - # XXX This should trigger an rspec refresh in case - # some previously invalid sliver bwlimit is now valid - # again, or vice-versa. + for network in d['networks']: + # Get interface name preferably from MAC address, falling + # back on IP address. + if macs.has_key(network['mac'].lower()): + dev = macs[network['mac'].lower()] + elif ips.has_key(network['ip']): + dev = ips[network['ip']] + else: + logger.log('%s: no such interface with address %s/%s' % (self.name, network['ip'], network['mac'])) + continue + + # Get current node cap + try: + old_bwlimit = bwlimit.get_bwcap(dev) + except: + old_bwlimit = None + + # Get desired node cap + if network['bwlimit'] is None or network['bwlimit'] < 0: + new_bwlimit = bwlimit.bwmax + else: + new_bwlimit = network['bwlimit'] + + if old_bwlimit != new_bwlimit: + # Reinitialize bandwidth limits + bwlimit.init(dev, new_bwlimit) + + # XXX This should trigger an rspec refresh in case + # some previously invalid sliver bwlimit is now valid + # again, or vice-versa. def start(options, config): pass