server = self.get_server(opts.aggregate, opts.port, self.key_file, \
self.cert_file, self.options.debug)
- return server.create_slice(slice_cred, slice_hrn, rspec)
+ result = server.create_slice(slice_cred, slice_hrn, rspec)
+ print result
+ return result
# get a ticket for the specified slice
def get_ticket(self, opts, args):
# Just send entire RSpec to each aggregate
threads.run(server.CreateSliver, xrn, cred, rspec, users)
- threads.get_results()
- return 1
+ results = threads.get_results()
+ merged_rspec = merge_rspecs(results)
+ return merged_rspec
def renew_slice(api, xrn, creds, expiration_time):
# XX
chain_name = 'FORWARD-OUTGOING'
rspec = run_sfatables(chain_name, hrn, origin_hrn, rspec)
allocated = manager.create_slice(self.api, slice_xrn, valid_creds, rspec, users)
- if allocated:
- return rspec
- return ''
+ return rspec