X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fmanagers%2Faggregate_manager.py;h=1d8b420f54d32fd4fa4be24d637ff32181efd96e;hb=6df8766f97d30a7a60d79659043512a300434fe5;hp=b7106e6d9641cd29b9e13003d94ef7b2aa7410a6;hpb=524dea147f722c881aea976ec5d475ef393c6af2;p=sfa.git diff --git a/sfa/managers/aggregate_manager.py b/sfa/managers/aggregate_manager.py index b7106e6d..1d8b420f 100644 --- a/sfa/managers/aggregate_manager.py +++ b/sfa/managers/aggregate_manager.py @@ -9,14 +9,13 @@ class AggregateManager: # essentially a union of the core version, the generic version (this code) and # whatever the driver needs to expose def GetVersion(self, api, options): - xrn=Xrn(api.hrn) version = version_core() version_generic = { 'interface':'aggregate', 'sfa': 2, 'geni_api': 2, - 'geni_api_versions': {'2': '%s:%s' % (api.config.SFA_SM_HOST, api.config.SFA_SM_PORT)}, + 'geni_api_versions': {'2': 'http://%s:%s' % (api.config.SFA_AGGREGATE_HOST, api.config.SFA_AGGREGATE_PORT)}, 'hrn':xrn.get_hrn(), 'urn':xrn.get_urn(), } @@ -43,14 +42,13 @@ class AggregateManager: xrn = Xrn(slice_xrn) slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() - return self.driver.list_resources (slice_urn, slice_hrn, creds, options) def SliverStatus (self, api, xrn, creds, options): call_id = options.get('call_id') if Callids().already_handled(call_id): return {} - xrn = Xrn(xrn) + xrn = Xrn(xrn,'slice') slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() return self.driver.sliver_status (slice_urn, slice_hrn) @@ -63,7 +61,7 @@ class AggregateManager: call_id = options.get('call_id') if Callids().already_handled(call_id): return "" - xrn = Xrn(xrn) + xrn = Xrn(xrn, 'slice') slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() @@ -73,7 +71,7 @@ class AggregateManager: call_id = options.get('call_id') if Callids().already_handled(call_id): return True - xrn = Xrn(xrn) + xrn = Xrn(xrn, 'slice') slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() return self.driver.delete_sliver (slice_urn, slice_hrn, creds, options) @@ -82,7 +80,7 @@ class AggregateManager: call_id = options.get('call_id') if Callids().already_handled(call_id): return True - xrn = Xrn(xrn) + xrn = Xrn(xrn, 'slice') slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() return self.driver.renew_sliver (slice_urn, slice_hrn, creds, expiration_time, options) @@ -112,5 +110,7 @@ class AggregateManager: slice_urn=xrn.get_urn() slice_hrn=xrn.get_hrn() + # xxx sounds like GetTicket is dead, but if that gets resurrected we might wish + # to pass 'users' over to the driver as well return self.driver.get_ticket (slice_urn, slice_hrn, creds, rspec, options)