from sfa.util.callids import Callids
from sfa.util.sfalogging import logger
from sfa.util.faults import SfaInvalidArgument, InvalidRSpecVersion
+from sfa.server.api_versions import ApiVersions
class AggregateManager:
return version_string
def GetVersion(self, api, options):
- xrn=Xrn(api.hrn, type='authority')
+ xrn=Xrn(api.hrn, type='authority+am')
version = version_core()
cred_types = [{'geni_type': 'geni_sfa', 'geni_version': str(i)} for i in range(4)[-2:]]
+ geni_api_versions = ApiVersions().get_versions()
+ geni_api_versions['3'] = 'http://%s:%s' % (api.config.sfa_aggregate_host, api.config.sfa_aggregate_port)
version_generic = {
'testbed': self.driver.testbed_name(),
'interface':'aggregate',
'hrn':xrn.get_hrn(),
'urn':xrn.get_urn(),
'geni_api': 3,
- 'geni_api_versions': {'3': 'http://%s:%s' % (socket.gethostname(), api.config.sfa_aggregate_port)},
+ 'geni_api_versions': geni_api_versions,
'geni_single_allocation': 0, # Accept operations that act on as subset of slivers in a given state.
'geni_allocate': 'geni_many',# Multiple slivers can exist and be incrementally added, including those which connect or overlap in some way.
'geni_credential_types': cred_types,
return self.driver.status (urns, options=options)
- def Allocate(self, api, xrn, creds, rspec_string, options):
+ def Allocate(self, api, xrn, creds, rspec_string, expiration, options):
"""
Allocate resources as described in a request RSpec argument
to a slice with the named URN.
"""
call_id = options.get('call_id')
if Callids().already_handled(call_id): return ""
- return self.driver.allocate(xrn, rspec_string, options)
+ return self.driver.allocate(xrn, rspec_string, expiration, options)
def Provision(self, api, xrns, creds, options):
"""