X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sm.py;h=9ba2c383d91203b0bc25ca4b39dafd3540f8c047;hb=2ffdf8bd65525f49ae3e8ef94c12a7203da3e4bd;hp=9f0544c39b8eb9cf88dd89b30bbc6e1c5f9dc2b4;hpb=8a7ca2937db392c6605ffa800077490ab5a64bde;p=nodemanager.git diff --git a/sm.py b/sm.py index 9f0544c..9ba2c38 100644 --- a/sm.py +++ b/sm.py @@ -7,12 +7,13 @@ also to make inter-sliver resource loans. The sliver manager is also responsible for handling delegation accounts. """ -# $Id: sm.py,v 1.28 2007/07/27 18:02:36 dhozac Exp $ +# $Id$ try: from bwlimit import bwmin, bwmax except ImportError: bwmin, bwmax = 8, 1000*1000*1000 import accounts import api +import api_calls import database import delegate import logger @@ -23,7 +24,7 @@ import string,re DEFAULT_ALLOCATION = { 'enabled': 1, # CPU parameters - 'cpu_min': 0, # percent CPU reserved + 'cpu_pct': 0, # percent CPU reserved 'cpu_share': 1, # proportional share # bandwidth parameters 'net_min_rate': bwmin / 1000, # kbps @@ -81,7 +82,7 @@ def GetSlivers(data, fullupdate=True): initscripts = {} for is_rec in data['initscripts']: logger.verbose("initscript: %s" % is_rec['name']) - initscripts[str(is_rec['initscript_id'])] = is_rec['script'] + initscripts[str(is_rec['name'])] = is_rec['script'] for sliver in data['slivers']: logger.verbose("sm:GetSlivers in slivers loop") @@ -90,7 +91,7 @@ def GetSlivers(data, fullupdate=True): # convert attributes field to a proper dict attr_dict = {} - for attr in rec.pop('attributes'): attr_dict[attr['name']] = attr['value'] + for attr in rec.pop('attributes'): attr_dict[attr['tagname']] = attr['value'] # squash keys keys = rec.pop('keys') @@ -103,12 +104,17 @@ def GetSlivers(data, fullupdate=True): # instantiation here, but i suppose its the ssame thing when you think about it. -FA rec['type'] = 'delegate' + # set the vserver reference. If none, set to default. rec.setdefault('vref', attr_dict.get('vref', 'default')) - is_id = attr_dict.get('initscript') - if is_id is not None and is_id in initscripts: - rec['initscript'] = initscripts[is_id] + + # set initscripts. first check if exists, if not, leave empty. + is_name = attr_dict.get('initscript') + if is_name is not None and is_name in initscripts: + rec['initscript'] = initscripts[is_name] else: rec['initscript'] = '' + + # set delegations, if none, set empty rec.setdefault('delegations', attr_dict.get("delegations", [])) # extract the implied rspec @@ -137,5 +143,5 @@ def start(options, config): accounts.register_class(delegate.Delegate) accounts.Startingup = options.startup database.start() - api.deliver_ticket = deliver_ticket + api_calls.deliver_ticket = deliver_ticket api.start()