1 | 308a309,325 |
---|
2 | > def renew_slice(self, api, xrn, cred, expiration_time): |
---|
3 | > slice_id = xrn |
---|
4 | > (ret, output) = self.call_am_apiclient("RenewSliceNetworkClient", [slice_id, expiration_time], 3) |
---|
5 | > if output.find("Unkown Rspec:") > 0: |
---|
6 | > raise NonExistingRecord(slice_id) |
---|
7 | > elif output.find("Status => FAILED") > 0: |
---|
8 | > errmsg = re.search("Message => ([^\n]+)", output) |
---|
9 | > if errmsg == None: |
---|
10 | > raise SfaAPIError('Unknown AM internal failure') |
---|
11 | > if errmsg.group(1) != None: |
---|
12 | > raise SfaAPIError(errmsg.group(1)) |
---|
13 | > elif output.find("Exception") > 0: |
---|
14 | > raise SfaAPIError(extract_exception(output)) |
---|
15 | > elif output.find("Error") > 0: |
---|
16 | > raise SfaAPIError('Unknown SFA failure') |
---|
17 | > return 1 |
---|
18 | > |
---|
19 | 379c396,398 |
---|
20 | < raise SfaNotImplemented('aggregate_manager') |
---|
21 | --- |
---|
22 | > call_id = options.get('call_id') |
---|
23 | > if Callids().already_handled(call_id): return "" |
---|
24 | > return self.renew_slice(api, xrn, creds, expiration_time) |
---|