1 from sfa.util.version import version_core
2 from sfa.util.xrn import Xrn
3 from sfa.util.callids import Callids
5 class AggregateManager:
7 def __init__ (self, config): pass
9 # essentially a union of the core version, the generic version (this code) and
10 # whatever the driver needs to expose
11 def GetVersion(self, api, options):
13 version = version_core()
15 'interface':'aggregate',
18 'geni_api_versions': {'2': 'http://%s:%s' % (api.config.SFA_AGGREGATE_HOST, api.config.SFA_AGGREGATE_PORT)},
22 version.update(version_generic)
23 testbed_version = self.driver.aggregate_version()
24 version.update(testbed_version)
27 def ListSlices(self, api, creds, options):
28 call_id = options.get('call_id')
29 if Callids().already_handled(call_id): return []
30 return self.driver.list_slices (creds, options)
32 def ListResources(self, api, creds, options):
33 call_id = options.get('call_id')
34 if Callids().already_handled(call_id): return ""
36 # get slice's hrn from options
37 slice_xrn = options.get('geni_slice_urn', None)
38 # pass None if no slice is specified
40 slice_hrn, slice_urn = None, None
43 slice_urn=xrn.get_urn()
44 slice_hrn=xrn.get_hrn()
45 return self.driver.list_resources (slice_urn, slice_hrn, creds, options)
47 def SliverStatus (self, api, xrn, creds, options):
48 call_id = options.get('call_id')
49 if Callids().already_handled(call_id): return {}
51 xrn = Xrn(xrn,'slice')
52 slice_urn=xrn.get_urn()
53 slice_hrn=xrn.get_hrn()
54 return self.driver.sliver_status (slice_urn, slice_hrn)
56 def CreateSliver(self, api, xrn, creds, rspec_string, users, options):
58 Create the sliver[s] (slice) at this aggregate.
59 Verify HRN and initialize the slice record in PLC if necessary.
61 call_id = options.get('call_id')
62 if Callids().already_handled(call_id): return ""
64 xrn = Xrn(xrn, 'slice')
65 slice_urn=xrn.get_urn()
66 slice_hrn=xrn.get_hrn()
68 return self.driver.create_sliver (slice_urn, slice_hrn, creds, rspec_string, users, options)
70 def DeleteSliver(self, api, xrn, creds, options):
71 call_id = options.get('call_id')
72 if Callids().already_handled(call_id): return True
74 xrn = Xrn(xrn, 'slice')
75 slice_urn=xrn.get_urn()
76 slice_hrn=xrn.get_hrn()
77 return self.driver.delete_sliver (slice_urn, slice_hrn, creds, options)
79 def RenewSliver(self, api, xrn, creds, expiration_time, options):
80 call_id = options.get('call_id')
81 if Callids().already_handled(call_id): return True
83 xrn = Xrn(xrn, 'slice')
84 slice_urn=xrn.get_urn()
85 slice_hrn=xrn.get_hrn()
86 return self.driver.renew_sliver (slice_urn, slice_hrn, creds, expiration_time, options)
88 ### these methods could use an options extension for at least call_id
89 def start_slice(self, api, xrn, creds):
91 slice_urn=xrn.get_urn()
92 slice_hrn=xrn.get_hrn()
93 return self.driver.start_slice (slice_urn, slice_hrn, creds)
95 def stop_slice(self, api, xrn, creds):
97 slice_urn=xrn.get_urn()
98 slice_hrn=xrn.get_hrn()
99 return self.driver.stop_slice (slice_urn, slice_hrn, creds)
101 def reset_slice(self, api, xrn):
103 slice_urn=xrn.get_urn()
104 slice_hrn=xrn.get_hrn()
105 return self.driver.reset_slice (slice_urn, slice_hrn)
107 def GetTicket(self, api, xrn, creds, rspec, users, options):
110 slice_urn=xrn.get_urn()
111 slice_hrn=xrn.get_hrn()
113 # xxx sounds like GetTicket is dead, but if that gets resurrected we might wish
114 # to pass 'users' over to the driver as well
115 return self.driver.get_ticket (slice_urn, slice_hrn, creds, rspec, options)