1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Copyright 2017 Intel 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 threading
import traceback
from lcm.pub.config.config import MR_IP
from lcm.pub.config.config import MR_PORT
from lcm.pub.database.models import NfInstModel, VNFCInstModel, VmInstModel
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.vnfmdriver import send_nf_heal_request
from lcm.pub.utils import restcall
from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE, JOB_MODEL_STATUS
from lcm.pub.utils.values import ignore_case_get
from lcm.ns_vnfs.const import VNF_STATUS
from lcm.ns_vnfs.biz.wait_job import wait_job_finish
JOB_ERROR = 255
logger = logging.getLogger(__name__)
class NFHealService(threading.Thread):
def __init__(self, vnf_instance_id, data):
super(NFHealService, self).__init__()
self.vnf_instance_id = vnf_instance_id
self.data = data
self.job_id = JobUtil.create_job("NF", JOB_TYPE.HEAL_VNF, vnf_instance_id)
self.nf_model = {}
self.nf_additional_params = {}
self.nf_heal_params = {}
self.m_nf_inst_id = ''
self.vnfm_inst_id = ''
def run(self):
try:
self.do_biz()
except NSLCMException as e:
JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
except:
logger.error(traceback.format_exc())
JobUtil.add_job_status(self.job_id, JOB_ERROR, 'nf heal fail')
def do_biz(self):
self.update_job(1, desc='nf heal start')
self.get_and_check_params()
self.update_nf_status(VNF_STATUS.HEALING)
self.send_nf_healing_request()
self.update_nf_status(VNF_STATUS.ACTIVE)
self.update_job(100, desc='nf heal success')
def get_and_check_params(self):
nf_info = NfInstModel.objects.filter(nfinstid=self.vnf_instance_id)
if not nf_info:
logger.error('NF instance[id=%s] does not exist' % self.vnf_instance_id)
raise NSLCMException('NF instance[id=%s] does not exist' % self.vnf_instance_id)
logger.debug('vnfd_model = %s, vnf_instance_id = %s' % (nf_info[0].vnfd_model, self.vnf_instance_id))
self.nf_model = nf_info[0].vnfd_model
self.m_nf_inst_id = nf_info[0].mnfinstid
self.vnfm_inst_id = nf_info[0].vnfm_inst_id
self.nf_additional_params = ignore_case_get(self.data, 'additionalParams')
if not self.nf_additional_params:
logger.error('additionalParams parameter does not exist or value incorrect')
raise NSLCMException('additionalParams parameter does not exist or value incorrect')
actionvminfo = ignore_case_get(self.nf_additional_params, 'actionvminfo')
vmid = ignore_case_get(actionvminfo, 'vmid')
self.nf_heal_params = {
"action": "vmReset",
"affectedvm": {
"vmid": vmid,
"vduid": self.get_vudId(vmid),
"vmname": self.get_vmname(vmid)
}
}
retry_count = 10
while (retry_count > 0):
resp = restcall.call_req('http://%s:%s/events' % (MR_IP, MR_PORT),
'',
'',
restcall.rest_no_auth,
'/test/bins/1?timeout=15000',
'GET')
if resp[2] == '200' and resp[1] != '[]':
for message in eval(resp[1]):
if 'powering-off' in message:
action = "vmReset"
vm_info = json.loads(message)
if vmid == vm_info['instance_id']:
vduid = self.get_vudId(vm_info['instance_id'])
self.nf_heal_params = {
"action": action,
"affectedvm": {
"vmid": vm_info['instance_id'],
"vduid": vduid,
"vmname": vm_info['display_name']
}
}
retry_count = -1
retry_count = retry_count - 1
def send_nf_healing_request(self):
req_param = json.JSONEncoder().encode(self.nf_heal_params)
rsp = send_nf_heal_request(self.vnfm_inst_id, self.m_nf_inst_id, req_param)
vnfm_job_id = ignore_case_get(rsp, 'jobId')
if not vnfm_job_id:
return
ret = wait_job_finish(self.vnfm_inst_id, self.job_id, vnfm_job_id, progress_range=None, timeout=1200,
mode='1')
if ret != JOB_MODEL_STATUS.FINISHED:
logger.error('[NF heal] nf heal failed')
raise NSLCMException("nf heal failed")
# Gets vdu id according to the given vm id.
def get_vudId(self, vmid):
vnfcInstances = VNFCInstModel.objects.filter(vmid=vmid, nfinstid=self.vnf_instance_id)
if not vnfcInstances:
raise NSLCMException('VDU [vmid=%s, vnfInstanceId=%s] does not exist' % (vmid, self.vnf_instance_id))
return vnfcInstances.first().vduid
def get_vmname(self, vmid):
vms = VmInstModel.objects.filter(resouceid=vmid)
if not vms:
return vmid
return vms.first().vmname
def update_job(self, progress, desc=''):
JobUtil.add_job_status(self.job_id, progress, desc)
def update_nf_status(self, status):
NfInstModel.objects.filter(nfinstid=self.vnf_instance_id).update(status=status)
|
