"""
Hook called via 'sfi.py create'
"""
-def create_slice(api, xrn, creds, xml, users, call_id):
+def CreateSliver(api, xrn, creds, xml, users, call_id):
if Callids().already_handled(call_id): return False
global cloud
#theRSpec = None
#with open(sys.argv[1]) as xml:
# theRSpec = xml.read()
- #create_slice(None, 'planetcloud.pc.test', theRSpec, 'call-id-cloudtest')
+ #CreateSliver(None, 'planetcloud.pc.test', theRSpec, 'call-id-cloudtest')
#rspec = ListResources('euca', 'planetcloud.pc.test', 'planetcloud.pc.marcoy', 'test_euca')
#print rspec
return (ret_rspec)
-def create_slice(api, xrn, creds, rspec_xml, users, call_id):
+def CreateSliver(api, xrn, creds, rspec_xml, users, call_id):
if Callids().already_handled(call_id): return False
global topology
r = RSpec()
rspec_xml = open(sys.argv[1]).read()
#ListResources(None,'foo')
- create_slice(None, "plc.princeton.sap0", rspec_xml, 'call-id-sap0')
+ CreateSliver(None, "plc.princeton.sap0", rspec_xml, 'call-id-sap0')
if __name__ == "__main__":
main()
if DEBUG: print "Received reset_slices call"
return msg_aggrMgr(SFA_RESET_SLICES)
-def create_slice(cred, xrn, rspec, call_id):
+def CreateSliver(cred, xrn, rspec, call_id):
if Callids().already_handled(call_id): return False
hrn = urn_to_hrn(xrn)[0]
- if DEBUG: print "Received create_slice call"
+ if DEBUG: print "Received CreateSliver call"
slice_id = generate_slide_id(cred, hrn)
msg = struct.pack('> B%ds%ds' % (len(slice_id)+1, len(rspec)), SFA_CREATE_SLICE, slice_id, rspec)
r = RSpec()
r.parseFile(sys.argv[1])
rspec = r.toDict()
- create_slice(None,'plc',rspec,'call-id-plc')
+ CreateSliver(None,'plc',rspec,'call-id-plc')
if __name__ == "__main__":
main()
# XX remove me
return result
-def create_slice(api, slice_xrn, creds, rspec, users, call_id):
+def CreateSliver(api, slice_xrn, creds, rspec, users, call_id):
"""
Create the sliver[s] (slice) at this aggregate.
Verify HRN and initialize the slice record in PLC if necessary.
credential = api.getCredential()
records = registry.Resolve(xrn, credential)
- # similar to create_slice, we must verify that the required records exist
+ # similar to CreateSliver, we must verify that the required records exist
# at this aggregate before we can issue a ticket
site_id, remote_site_id = slices.verify_site(registry, credential, slice_hrn,
peer, sfa_peer, reg_objects)
f = open(sys.argv[1])
xml = f.read()
f.close()
- create_slice(api, "plc.princeton.sapan", xml, 'create_slice_sapan')
+ CreateSliver(api, "plc.princeton.sapan", xml, 'CreateSliver_sapan')
if __name__ == "__main__":
main()
api.plshell.DeleteSliceFromNodes(api.plauth, slicename, slice['node_ids'])
return 1
-def create_slice(api, xrn, creds, xml, users, call_id):
+def CreateSliver(api, xrn, creds, xml, users, call_id):
"""
Verify HRN and initialize the slice record in PLC if necessary.
"""
f = open(sys.argv[1])
xml = f.read()
f.close()
- create_slice(api, "plc.princeton.iias", xml, 'call-id-iias')
+ CreateSliver(api, "plc.princeton.iias", xml, 'call-id-iias')
if __name__ == "__main__":
main()
sm_version['peers'][api.hrn]=local_am_url.replace('localhost',sm_version['hostname'])
return sm_version
-def create_slice(api, xrn, creds, rspec, users, call_id):
+def CreateSliver(api, xrn, creds, rspec, users, call_id):
if Callids().already_handled(call_id): return ""
r = RSpec()
r.parseFile(sys.argv[1])
rspec = r.toDict()
- create_slice(None,'plc.princeton.tmacktestslice',rspec,'create-slice-tmacktestslice')
+ CreateSliver(None,'plc.princeton.tmacktestslice',rspec,'create-slice-tmacktestslice')
if __name__ == "__main__":
main()
chain_name = 'FORWARD-INCOMING'
self.api.logger.debug("CreateSliver: sfatables on chain %s"%chain_name)
rspec = run_sfatables(chain_name, hrn, origin_hrn, rspec)
- # the aggregate's create_slice returns false if call_id was already handled
- if manager.create_slice(self.api, slice_xrn, creds, rspec, users, call_id):
+ # the aggregate's CreateSliver returns false if call_id was already handled
+ if manager.CreateSliver(self.api, slice_xrn, creds, rspec, users, call_id):
return rspec
else:
return ""
return (ret_rspec)
-def create_slice(api, hrn, rspec_xml):
+def CreateSliver(api, hrn, rspec_xml):
global topology
topology = get_interface_map()
r = RSpec()
rspec_xml = open(sys.argv[1]).read()
#ListResources(None,'foo')
- create_slice(None, "plc.princeton.sap0", rspec_xml)
+ CreateSliver(None, "plc.princeton.sap0", rspec_xml)
if __name__ == "__main__":
main()
if DEBUG: print "Received reset_slices call"
return msg_aggrMgr(SFA_RESET_SLICES)
-def create_slice(cred, hrn, rspec):
- if DEBUG: print "Received create_slice call"
+def CreateSliver(cred, hrn, rspec):
+ if DEBUG: print "Received CreateSliver call"
slice_id = generate_slide_id(cred, hrn)
msg = struct.pack('> B%ds%ds' % (len(slice_id)+1, len(rspec)), SFA_CREATE_SLICE, slice_id, rspec)
r = RSpec()
r.parseFile(sys.argv[1])
rspec = r.toDict()
- create_slice(None,'plc',rspec)
+ CreateSliver(None,'plc',rspec)
if __name__ == "__main__":
main()
print "adding %(slicehrn)s back to its original nodes" % locals()
a.list_resources(cred, slicehrn)
-a.create_slice(cred, slicehrn, components)
+a.CreateSliver(cred, slicehrn, components)
a.list_resources(cred, slicehrn)
# get availabel resources
rspec = self.aggregate.get_resources(self.credential)
slice_credential = self.client.get_credential(self.slice['hrn'], 'slice')
- self.aggregate.create_slice(slice_credential, self.slice['hrn'], rspec)
+ self.aggregate.CreateSliver(slice_credential, self.slice['hrn'], rspec)
def testDeleteSlice(self):
slice_credential = self.client.get_credential(self.slice['hrn'], 'slice')
def test_names(testcase):
return [name for name in dir(testcase) if name.startswith('test')]
-def create_slice(client):
+def CreateSliver(client):
# register a slice that will be used for some test
authority = get_authority(client.hrn)
auth_cred = client.get_credential(authority, 'authority')
# create the test slice if necessary
if options.all or options.slicemgr or options.aggregate \
or options.component:
- test_slice = create_slice(client)
+ test_slice = CreateSliver(client)
if options.registry or options.all:
for name in test_names(RegistryTest):