diff options
-rw-r--r-- | lcm/lcm/nf/biz/grant_vnf.py | 52 | ||||
-rw-r--r-- | lcm/lcm/nf/biz/terminate_vnf.py | 37 | ||||
-rw-r--r-- | lcm/lcm/nf/tests/test_terminate_vnf.py | 11 |
3 files changed, 65 insertions, 35 deletions
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']
|