From: Fu Jinhua Date: Wed, 15 Aug 2018 08:46:41 +0000 (+0000) Subject: Merge "Deal with gvnfm adapter stuffs." X-Git-Tag: 1.2.0~31 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=35c91f806a0b8cbf637243dd600dbb7e69f40deb;hp=25bc088ee9ccd268396f7b1b87aa56fe90344d0b;p=vfc%2Fgvnfm%2Fvnflcm.git Merge "Deal with gvnfm adapter stuffs." --- diff --git a/lcm/lcm/nf/biz/grant_vnf.py b/lcm/lcm/nf/biz/grant_vnf.py new file mode 100644 index 00000000..cbfa88b0 --- /dev/null +++ b/lcm/lcm/nf/biz/grant_vnf.py @@ -0,0 +1,52 @@ +# Copyright 2018 ZTE Corporation. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +import json +import logging + +from lcm.pub.database.models import NfInstModel, VmInstModel +from lcm.pub.msapi.gvnfmdriver import apply_grant_to_nfvo + +logger = logging.getLogger(__name__) + + +def grant_resource(nf_inst_id, job_id): + logger.info("Grant resource begin") + content_args = { + 'vnfInstanceId': nf_inst_id, + 'vnfDescriptorId': '', + 'lifecycleOperation': 'Terminate', + 'vnfLcmOpOccId': job_id, + 'addResource': [], + 'removeResource': [], + 'placementConstraint': [], + 'additionalParam': {} + } + + vdus = VmInstModel.objects.filter(instid=nf_inst_id, is_predefined=1) + res_index = 1 + for vdu in vdus: + res_def = { + 'type': 'VDU', + 'resDefId': str(res_index), + 'resDesId': vdu.resouceid} + content_args['removeResource'].append(res_def) + res_index += 1 + + vnfInsts = NfInstModel.objects.filter(nfinstid=nf_inst_id) + content_args['additionalParam']['vnfmid'] = vnfInsts[0].vnfminstid + content_args['additionalParam']['vimid'] = vdus[0].vimid + logger.info('Grant request data=%s' % content_args) + apply_result = apply_grant_to_nfvo(json.dumps(content_args)) + logger.info("Grant resource end, response: %s" % apply_result) diff --git a/lcm/lcm/nf/biz/terminate_vnf.py b/lcm/lcm/nf/biz/terminate_vnf.py index 98edf1ed..c0caf51d 100644 --- a/lcm/lcm/nf/biz/terminate_vnf.py +++ b/lcm/lcm/nf/biz/terminate_vnf.py @@ -21,11 +21,12 @@ from lcm.nf.const import VNF_STATUS, RESOURCE_MAP from lcm.pub.database.models import NfInstModel, VmInstModel, NetworkInstModel, StorageInstModel, \ PortInstModel, VNFCInstModel, FlavourInstModel, SubNetworkInstModel from lcm.pub.exceptions import NFLCMException -from lcm.pub.msapi.gvnfmdriver import apply_grant_to_nfvo, notify_lcm_to_nfvo +from lcm.pub.msapi.gvnfmdriver import notify_lcm_to_nfvo from lcm.pub.utils.jobutil import JobUtil from lcm.pub.utils.timeutil import now_time from lcm.pub.utils.values import ignore_case_get from lcm.pub.vimapi import adaptor +from lcm.nf.biz.grant_vnf import grant_resource logger = logging.getLogger(__name__) @@ -43,7 +44,8 @@ class TerminateVnf(Thread): def run(self): try: if self.term_pre(): - self.grant_resource() + grant_resource(nf_inst_id=self.nf_inst_id, job_id=self.job_id) + JobUtil.add_job_status(self.job_id, 20, 'Nf terminating grant_resource finish') self.query_inst_resource() self.query_notify_data() self.delete_resource() @@ -68,37 +70,6 @@ class TerminateVnf(Thread): logger.info("Nf terminating pre-check finish") return True - def grant_resource(self): - logger.info("Grant resource begin") - content_args = { - 'vnfInstanceId': self.nf_inst_id, - 'vnfDescriptorId': '', - 'lifecycleOperation': 'Terminate', - 'jobId': self.job_id, - 'addResource': [], - 'removeResource': [], - 'placementConstraint': [], - 'additionalParam': {} - } - - vdus = VmInstModel.objects.filter(instid=self.nf_inst_id, is_predefined=1) - res_index = 1 - for vdu in vdus: - res_def = { - 'type': 'VDU', - 'resDefId': str(res_index), - 'resDesId': vdu.resouceid} - content_args['removeResource'].append(res_def) - res_index += 1 - - vnfInsts = NfInstModel.objects.filter(nfinstid=self.nf_inst_id) - content_args['additionalParam']['vnfmid'] = vnfInsts[0].vnfminstid - content_args['additionalParam']['vimid'] = vdus[0].vimid - logger.info('Grant request data=%s' % content_args) - self.apply_result = apply_grant_to_nfvo(json.dumps(content_args)) - logger.info("Grant resource end, response: %s" % self.apply_result) - JobUtil.add_job_status(self.job_id, 20, 'Nf terminating grant_resource finish') - def query_inst_resource(self): logger.info('Query resource begin') for resource_type in RESOURCE_MAP.keys(): diff --git a/lcm/lcm/nf/tests/test_terminate_vnf.py b/lcm/lcm/nf/tests/test_terminate_vnf.py index 2179df97..23b246d7 100644 --- a/lcm/lcm/nf/tests/test_terminate_vnf.py +++ b/lcm/lcm/nf/tests/test_terminate_vnf.py @@ -133,8 +133,15 @@ class TestNFTerminate(TestCase): create_time=now_time()) t1_apply_grant_result = [0, json.JSONEncoder().encode( { - "vimid": 'vimid_1', - "tenant": 'tenantname_1' + "id": "1", + "vnfInstanceId": "1", + "vnfLcmOpOccId": "2", + "vimConnections": [ + { + "id": "1", + "vimId": "1" + } + ] }), '200'] t2_lcm_notify_result = [0, json.JSONEncoder().encode(''), '200'] t3_delete_flavor = [0, json.JSONEncoder().encode({"vim_id": "vimid_1"}), '200']