X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=slivermanager.py;h=4a3c3ebb9503ea08e1bb001f6c19700c31ffb26d;hb=570d234b7d7b40416b296de71225f28c826ee991;hp=eb0a096de1f84f43116d6492706a81fa6ee5b3af;hpb=ac6786141feadccdc48b819ab21a825a54881ded;p=nodemanager.git diff --git a/slivermanager.py b/slivermanager.py index eb0a096..4a3c3eb 100644 --- a/slivermanager.py +++ b/slivermanager.py @@ -35,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 = { @@ -136,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 @@ -186,7 +191,7 @@ def GetSlivers(data, config = None, plc=None, fullupdate=True): # if tag 'initscript_code' is set, that's what we use 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: @@ -213,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()