X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=slivermanager.py;h=4a3c3ebb9503ea08e1bb001f6c19700c31ffb26d;hb=cedf34d7518216fb2ce4bd8f99fed469dc2646c8;hp=624853e72bc8ad59ce4e9123f38c8f2d2b184717;hpb=b73120ba3084fb66167ac70ec3632b74353c08ca;p=nodemanager.git diff --git a/slivermanager.py b/slivermanager.py index 624853e..4a3c3eb 100644 --- a/slivermanager.py +++ b/slivermanager.py @@ -7,7 +7,8 @@ also to make inter-sliver resource loans. The sliver manager is also responsible for handling delegation accounts. """ -import string,re +import string +import re import time import logger @@ -34,10 +35,12 @@ except: exit(1) # just being safe -try : from plnode.bwlimit import bwmin, bwmax -except: bwmin, bwmax = 8, 1000*1000*1000 +try: + from plnode.bwlimit import bwmin, bwmax +except: + bwmin, bwmax = 8, 1000*1000*1000 -priority=10 +priority = 10 DEFAULT_ALLOCATION = { @@ -135,9 +138,12 @@ def GetSlivers(data, config = None, plc=None, fullupdate=True): node_id = None try: f = open('/etc/planetlab/node_id') - try: node_id = int(f.read()) - finally: f.close() - except: logger.log_exc("slivermanager: GetSlivers failed to read /etc/planetlab/node_id") + try: + node_id = int(f.read()) + finally: + f.close() + except: + logger.log_exc("slivermanager: GetSlivers failed to read /etc/planetlab/node_id") if data.has_key('node_id') and data['node_id'] != node_id: return @@ -149,7 +155,7 @@ def GetSlivers(data, config = None, plc=None, fullupdate=True): # Take initscripts (global) returned by API, build a hash scriptname->code iscripts_hash = {} if 'initscripts' not in data: - logger.log_missing_data("slivermanager.GetSlivers",'initscripts') + logger.log_missing_data("slivermanager.GetSlivers", 'initscripts') return for initscript_rec in data['initscripts']: logger.verbose("slivermanager: initscript: %s" % initscript_rec['name']) @@ -183,9 +189,9 @@ def GetSlivers(data, config = None, plc=None, fullupdate=True): ### set initscripts; set empty rec['initscript'] if not # if tag 'initscript_code' is set, that's what we use - iscode = attributes.get('initscript_code','') + iscode = attributes.get('initscript_code', '') if iscode: - rec['initscript']=iscode + rec['initscript'] = iscode else: isname = attributes.get('initscript') if isname is not None and isname in iscripts_hash: @@ -212,10 +218,11 @@ def GetSlivers(data, config = None, plc=None, fullupdate=True): rspec[key] = attributes[key] # also export tags in rspec so they make it to the sliver_vs.start call - rspec['tags']=attributes + rspec['tags'] = attributes database.db.deliver_record(rec) - if fullupdate: database.db.set_min_timestamp(data['timestamp']) + if fullupdate: + database.db.set_min_timestamp(data['timestamp']) # slivers are created here. database.db.sync()