diff options
| author |   fujinhua <fu.jinhua@zte.com.cn> | 2018-11-23 14:34:39 +0800 |
|---|---|---|
| committer | fujinhua <fu.jinhua@zte.com.cn> | 2018-11-23 15:05:44 +0800 |
| commit | ab5909cac2ecda59ca6177850505ab1464334705 (patch) | |
| tree | 1e21dd3358713303a80f132ff184556f3eef5c8c | |
| parent | 9e49959502c940149b73352f120f76273b1683cc (diff) | |
Update ns terminate to parallel
Change-Id: I7c7b8e8e7e8e88c3c3a53afe170a595793b41a9e
Issue-ID: VFC-1163
Signed-off-by: fujinhua <fu.jinhua@zte.com.cn>
| -rw-r--r-- | lcm/ns/biz/ns_terminate.py | 25 | ||||
| -rw-r--r-- | lcm/workflows/build_in.py | 2 |
2 files changed, 20 insertions, 7 deletions
diff --git a/lcm/ns/biz/ns_terminate.py b/lcm/ns/biz/ns_terminate.py index 95f5e6a1..e2419821 100644 --- a/lcm/ns/biz/ns_terminate.py +++ b/lcm/ns/biz/ns_terminate.py @@ -109,19 +109,32 @@ class TerminateNsService(threading.Thread): if not array_vnfinst: logger.info("[cancel_vnf_list] no vnfinst attatch to ns_inst_id: %s" % self.ns_inst_id) return - step_progress = 20 / len(array_vnfinst) + step_progress = 10 / len(array_vnfinst) cur_progress = 50 + vnf_jobs = [] for vnfinst in array_vnfinst: cur_progress += step_progress delete_result = "failed" + vnf_job_id = '' try: - if self.delete_vnf(vnfinst.nfinstid): - delete_result = "success" + vnf_job_id = self.delete_vnf(vnfinst.nfinstid) + if vnf_job_id: + delete_result = "deleting" except Exception as e: logger.error("[cancel_vnf_list] error[%s]!" % e.message) logger.error(traceback.format_exc()) job_msg = "Delete vnfinst:[%s] %s." % (vnfinst.nfinstid, delete_result) JobUtil.add_job_status(self.job_id, cur_progress, job_msg) + vnf_jobs.append((vnfinst.nfinstid, vnf_job_id)) + + for vnfinstid, vnfjobid in vnf_jobs: + cur_progress += step_progress + if not vnfjobid: + continue + is_job_ok = self.wait_delete_vnf_job_finish(vnfjobid) + msg = "%s to delete VNF(%s)" % ("Succeed" if is_job_ok else "Failed", vnfinstid) + logger.debug(msg) + JobUtil.add_job_status(self.job_id, cur_progress, msg) def delete_vnf(self, nf_instid): term_param = { @@ -132,10 +145,10 @@ class TerminateNsService(threading.Thread): ret = call_from_ns_cancel_resource('vnf', nf_instid, term_param) if ret[0] != 0: logger.error("Terminate VNF(%s) failed: %s", nf_instid, ret[1]) - return False + return '' job_info = json.JSONDecoder().decode(ret[1]) vnf_job_id = ignore_case_get(job_info, "jobId") - return self.wait_delete_vnf_job_finish(vnf_job_id) + return vnf_job_id def wait_delete_vnf_job_finish(self, vnf_job_id): count = 0 @@ -153,7 +166,7 @@ class TerminateNsService(threading.Thread): continue job_result = json.JSONDecoder().decode(ret[1]) if "responseDescriptor" not in job_result: - logger.error("Job(%s) does not exist.", vnf_job_id) + logger.debug("No new progress after response_id(%s) in job(%s)", response_id, vnf_job_id) continue progress = job_result["responseDescriptor"]["progress"] new_response_id = job_result["responseDescriptor"]["responseId"] diff --git a/lcm/workflows/build_in.py b/lcm/workflows/build_in.py index fa267855..e47a6db9 100644 --- a/lcm/workflows/build_in.py +++ b/lcm/workflows/build_in.py @@ -214,7 +214,7 @@ class JobWaitThread(Thread): continue job_result = json.JSONDecoder().decode(ret[1]) if "responseDescriptor" not in job_result: - logger.error("Job(%s) does not exist.", self.job_id) + logger.debug("No new progress after response_id(%s) in job(%s)", response_id, self.job_id) continue progress = job_result["responseDescriptor"]["progress"] new_response_id = job_result["responseDescriptor"]["responseId"] |