X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmanagers%2Faggregate_manager_eucalyptus.py;h=2356f333d7fc6f368b2cdcdf04734e990d690e60;hb=a0ef6e7c91c3c8fa376943d28fec8c5c204a78cd;hp=588f090fad82622c65e6fba8e9f7229c38bfd939;hpb=e6ac86e7b51322c1f6ec3bc1f952252d28ebfe41;p=sfa.git diff --git a/sfa/managers/aggregate_manager_eucalyptus.py b/sfa/managers/aggregate_manager_eucalyptus.py index 588f090f..2356f333 100644 --- a/sfa/managers/aggregate_manager_eucalyptus.py +++ b/sfa/managers/aggregate_manager_eucalyptus.py @@ -17,22 +17,19 @@ from sqlobject import * from sfa.util.faults import InvalidRSpec from sfa.util.xrn import urn_to_hrn, Xrn -from sfa.util.plxrn import hrn_to_pl_slicename, slicename_to_hrn from sfa.util.callids import Callids #comes with its own logging #from sfa.util.sfalogging import logger from sfa.util.version import version_core + from sfa.trust.credential import Credential -from sfa.plc.plaggregate import PlAggregate -# No Slice symbol in there -#from sfa.plc.plslices import Slice, Slices -from sfa.plc.plslices import PlSlices + from sfa.rspecs.version_manager import VersionManager from sfa.rspecs.rspec import RSpec -# not sure what this used to be nor where it is now defined -#from sfa.rspecs.sfa_rspec import sfa_rspec_version -# most likely this should now be -#from sfa.rspecs.version_manager import VersionManager + +from sfa.planetlab.plaggregate import PlAggregate +from sfa.planetlab.plslices import PlSlices +from sfa.planetlab.plxrn import slicename_to_hrn ## # Meta data of an instance. @@ -82,7 +79,7 @@ class EucaInstance(SQLObject): self.instance_id = instance.id # If there is an error, destroy itself. - except EC2ResponseError, ec2RespErr: + except EC2ResponseError as ec2RespErr: errTree = ET.fromstring(ec2RespErr.body) msg = errTree.find('.//Message') logger.error(msg.text) @@ -286,7 +283,7 @@ class AggregateManagerEucalyptus: _inited=False # the init_server mechanism has vanished - def __init__ (self): + def __init__ (self, config): if AggregateManagerEucalyptus._inited: return AggregateManagerEucalyptus.init_server() @@ -527,7 +524,7 @@ class AggregateManagerEucalyptus: instList.append(instInfoDict) AggregateManagerEucalyptus.cloud['instances'] = instancesDict - except EC2ResponseError, ec2RespErr: + except EC2ResponseError as ec2RespErr: errTree = ET.fromstring(ec2RespErr.body) errMsgE = errTree.find('.//Message') logger.error(errMsgE.text) @@ -647,7 +644,7 @@ class AggregateManagerEucalyptus: ramdisk_id = instRamDisk, key_pair = instKey, inst_type = instType, - meta = Meta(start_time=datetime.datetime.now())) + meta = Meta(start_time=datetime.datetime.utcnow())) eucaInst.reserveInstance(conn, pubKeys) # xxx - should return altered rspec @@ -664,7 +661,7 @@ class AggregateManagerEucalyptus: try: os.makedirs(outdir) - except OSError, e: + except OSError as e: if e.errno != errno.EEXIST: raise @@ -682,7 +679,7 @@ class AggregateManagerEucalyptus: f.write("%s %s %s\n" % (instId, ipaddr, hrn)) f.close() - def GetVersion(api): + def GetVersion(api, options): version_manager = VersionManager() ad_rspec_versions = [] @@ -695,7 +692,7 @@ class AggregateManagerEucalyptus: xrn=Xrn(api.hrn) version_more = {'interface':'aggregate', 'sfa': 1, - 'geni_api': api.config.SFA_AGGREGATE_API_VERSION, + 'geni_api': '2', 'testbed':'myplc', 'hrn':xrn.get_hrn(), 'geni_request_rspec_versions': request_rspec_versions,