--- /dev/null
+# Copyright 2019 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
+import traceback
+from threading import Thread
+
+from lcm.nf.biz.common import port_save
+from lcm.nf.biz.grant_vnf import grant_resource
+from lcm.nf.const import RESOURCE_MAP, GRANT_TYPE, OPERATION_STATE_TYPE
+from lcm.nf.const import VNF_STATUS
+from lcm.pub.database.models import VmInstModel, NfInstModel, PortInstModel
+from lcm.pub.utils.notificationsutil import NotificationsUtil, prepare_notification
+from lcm.pub.utils.values import ignore_case_get
+from lcm.pub.utils.timeutil import now_time
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.exceptions import NFLCMException
+from lcm.pub.vimapi import adaptor
+
+logger = logging.getLogger(__name__)
+
+
+class ChangeExtConn(Thread):
+ def __init__(self, data, nf_inst_id, job_id):
+ super(ChangeExtConn, self).__init__()
+ self.data = data
+ self.nf_inst_id = nf_inst_id
+ self.job_id = job_id
+ self.vnf_insts = NfInstModel.objects.filter(nfinstid=self.nf_inst_id)
+ self.extVirtualLinks = ignore_case_get(self.data, "extVirtualLinks")
+ self.vimConnectionInfo = ignore_case_get(self.data, "vimConnectionInfo")
+ self.additionalParams = ignore_case_get(self.data, "additionalParams")
+
+ def run(self):
+ try:
+ JobUtil.add_job_status(self.job_id,
+ 10,
+ "Start to apply grant.")
+ self.apply_grant()
+ JobUtil.add_job_status(self.job_id,
+ 50,
+ "Start to change ext conn.")
+ self.do_operation()
+ self.vnf_insts.update(
+ status='INSTANTIATED',
+ lastuptime=now_time()
+ )
+ JobUtil.add_job_status(self.job_id,
+ 100,
+ "Change ext conn success.")
+ except NFLCMException as e:
+ logger.error(e.message)
+ self.change_ext_conn_failed_handle(e.message)
+ except Exception as e:
+ logger.error(e.message)
+ logger.error(traceback.format_exc())
+ self.change_ext_conn_failed_handle(e.message)
+
+ def apply_grant(self):
+ vdus = VmInstModel.objects.filter(instid=self.nf_inst_id)
+ apply_result = grant_resource(data=self.data,
+ nf_inst_id=self.nf_inst_id,
+ job_id=self.job_id,
+ grant_type=GRANT_TYPE.CHANGE_CONNECTIVITY,
+ vdus=vdus)
+ logger.debug("Grant resource end, response: %s" % apply_result)
+
+ def do_operation(self):
+ logger.info('Operation resource begin')
+ logger.debug("self.vimConnectionInfo: %s" % self.vimConnectionInfo)
+ vnfd_info = json.loads(self.vnf_insts[0].vnfd_model)
+ vm_id = ignore_case_get(self.additionalParams, "vmid")
+ if not vm_id:
+ vms = VmInstModel.objects.filter(instid=self.nf_inst_id)
+ vm_id = vms[0].resourceid
+ vim_id = ignore_case_get(self.vimConnectionInfo[0], "vimid")
+ accessInfo = ignore_case_get(self.vimConnectionInfo[0], "accessInfo")
+ tenant = ignore_case_get(accessInfo, "tenant")
+
+ self.vim_cache, self.res_cache = {}, {}
+ for extVirtualLink in self.extVirtualLinks:
+ network_id = ignore_case_get(extVirtualLink, "resourceId")
+ ext_cps = ignore_case_get(extVirtualLink, "extCps")
+ for ext_cp in ext_cps:
+ cpd_id = ignore_case_get(ext_cp, "cpdId")
+ cp_config = ignore_case_get(ext_cp, "cpConfig")
+ # cp_instance_id = ignore_case_get(cp_config[0], "cpInstanceId")
+ cp_protocol_data = ignore_case_get(cp_config[0], "cpProtocolData")
+ # mac_address = ignore_case_get(ignore_case_get(cp_protocol_data[0], "ipOverEthernet"), "macAddress")
+ ip_addresses = ignore_case_get(ignore_case_get(cp_protocol_data[0], "ipOverEthernet"), "ipAddresses")
+ # fixed_addresse = ignore_case_get(ip_addresses[0], "fixedAddresses")[0]
+ # addressRange = ignore_case_get(ip_addresses[0], "addressRange")
+ # minAddress = ignore_case_get(addressRange, "minAddress")
+ # maxAddress = ignore_case_get(addressRange, "maxAddress")
+ subnet_id = ignore_case_get(ip_addresses[0], "subnetId")
+
+ vdu_id = ""
+ cps = ignore_case_get(vnfd_info, "cps")
+ for cp in cps:
+ cpd_id_in_model = ignore_case_get(cp, "cpd_id")
+ if cpd_id == cpd_id_in_model:
+ vdu_id = ignore_case_get(cp, "vdu_id")
+ break
+
+ port = {
+ "cp_id": cpd_id,
+ "cpd_id": cpd_id,
+ "vm_id": vm_id,
+ "description": "",
+ "properties": {
+ # "name": "",
+ # "mac_address": mac_address,
+ # "ip_address:": fixed_addresse,
+ # "ip_range_start": minAddress,
+ # "ip_range_end": maxAddress,
+ "location_info": {
+ "vimid": vim_id,
+ "tenant": tenant
+ }
+ },
+ "vl_id": network_id,
+ "vdu_id": vdu_id,
+ "networkId": network_id,
+ "subnetId": subnet_id
+ }
+ for resource_type in ['vdus', 'vls', 'cps', 'volume_storages']:
+ for resource in ignore_case_get(vnfd_info, resource_type):
+ if "location_info" not in resource["properties"]:
+ resource["properties"]["location_info"] = {}
+ resource["properties"]["location_info"]["vimid"] = vim_id
+ resource["properties"]["location_info"]["tenant"] = tenant
+
+ # if cp_instance_id:
+ # ret = adaptor.get_port_of_vm(self.vim_cache, self.res_cache, vnfd_info, port,
+ # self.do_notify_op, "port")
+ # port_info = ignore_case_get(ret, "interfaceAttachment")
+ # net_id = ignore_case_get(port_info, "net_id")
+ # if network_id == net_id:
+ # adaptor.update_port(self.vim_cache, self.res_cache, vnfd_info, port,
+ # self.do_notify_op, "port")
+ # else:
+ # adaptor.delete_port_of_vm(self.vim_cache, self.res_cache, vnfd_info, port,
+ # self.do_notify_op, "port")
+ # adaptor.create_port_of_vm(self.vim_cache, self.res_cache, vnfd_info, port,
+ # self.do_notify_op, "port")
+ # else:
+ adaptor.create_port(self.vim_cache, self.res_cache, vnfd_info, port, self.do_create_port_notify, "port")
+ port["port_id"] = self.port_id
+ logger.debug('create_port_of_vm request data = %s' % port)
+ adaptor.create_port_of_vm(self.vim_cache, self.res_cache, vnfd_info, port,
+ self.do_notify_op, "port")
+ PortInstModel.objects.filter(resourceid=self.port_id).update(vmid=vm_id)
+ logger.info('Operate resource complete')
+
+ def send_notification(self):
+ data = prepare_notification(nfinstid=self.nf_inst_id,
+ jobid=self.job_id,
+ operation=self.op_type,
+ operation_state=OPERATION_STATE_TYPE.COMPLETED)
+ self.set_ext_connectivity(data['changedExtConnectivity'])
+
+ logger.debug('Notify request data = %s' % data)
+ NotificationsUtil().send_notification(data)
+
+ def rollback_operation(self):
+ pass
+
+ def query_inst_resource(self, inst_resource):
+ logger.debug('Query resource begin')
+ for resource_type in RESOURCE_MAP.keys():
+ resource_table = globals().get(resource_type + 'InstModel')
+ resource_insts = resource_table.objects.filter(instid=self.nf_inst_id)
+ for resource_inst in resource_insts:
+ if not resource_inst.resourceid:
+ continue
+ inst_resource[RESOURCE_MAP.get(resource_type)].append(self.get_resource(resource_inst))
+ logger.debug('Query resource end, resource=%s' % inst_resource)
+
+ def get_resource(self, resource):
+ return {
+ "vim_id": resource.vimid,
+ "tenant_id": resource.tenant,
+ "res_id": resource.resourceid
+ }
+
+ def do_create_port_notify(self, res_type, ret):
+ self.port_id = ignore_case_get(ret, "id")
+ port_save("", self.nf_inst_id, ret)
+
+ def do_notify_op(self, operation_type, status, resid):
+ if operation_type == "delete":
+ PortInstModel.objects.filter()
+ # TODO delete port from table
+ elif operation_type == "create":
+ pass
+ # TODO save port in table
+ else:
+ pass
+ # TODO update port in table
+ logger.info('VNF resource %s updated to: %s' % (resid, status))
+
+ def set_ext_connectivity(self, ext_connectivity):
+ for extVirtualLink in self.extVirtualLinks:
+ vim_connection_id = ignore_case_get(extVirtualLink, "vimConnectionId")
+ network_id = ignore_case_get(extVirtualLink, "resourceId")
+ ext_cps = ignore_case_get(extVirtualLink, "extCps")
+ ext_link_ports = []
+ for ext_cp in ext_cps:
+ cpd_id = ignore_case_get(ext_cp, "cpdId")
+ cp_config = ignore_case_get(ext_cp, "cpConfig")
+ cp_instance_id = ignore_case_get(cp_config[0], "cpInstanceId")
+ ext_link_ports.append({
+ 'id': cp_instance_id,
+ 'resourceHandle': {
+ 'vimConnectionId': vim_connection_id,
+ 'resourceId': self.res_cache.get("port").get(cp_instance_id),
+ 'resourceProviderId': cpd_id,
+ 'vimLevelResourceType': 'port'
+ },
+ 'cpInstanceId': cp_instance_id
+ })
+ network_resource = {
+ 'vimConnectionId': vim_connection_id,
+ 'resourceId': network_id,
+ 'resourceProviderId': "",
+ 'vimLevelResourceType': 'network'
+ }
+ ext_connectivity.append({
+ 'id': network_id,
+ 'resourceHandle': network_resource,
+ 'extLinkPorts': ext_link_ports
+ })
+
+ def change_ext_conn_failed_handle(self, error_msg):
+ logger.error('Chnage ext conn failed, detail message: %s', error_msg)
+ self.vnf_insts.update(status=VNF_STATUS.FAILED,
+ lastuptime=now_time())
+ JobUtil.add_job_status(self.job_id, 255, error_msg)
Code Review / vfc / gvnfm / vnflcm.git / commitdiff