Fix vm status logger output

[vfc/gvnfm/vnflcm.git] / lcm / lcm / pub / vimapi / adaptor.py

diff --git a/lcm/lcm/pub/vimapi/adaptor.py b/lcm/lcm/pub/vimapi/adaptor.py
index a7a0fd3..bc71aac 100644 (file)
--- a/lcm/lcm/pub/vimapi/adaptor.py
+++ b/lcm/lcm/pub/vimapi/adaptor.py
@@ -16,9 +16,9 @@ import logging
 import time
 import json
 import os
+import base64
 
 from lcm.pub.utils.values import ignore_case_get, set_opt_val
-from lcm.pub.msapi.aai import get_flavor_info
 from . import api
 from .exceptions import VimException
 from lcm.pub.exceptions import NFLCMException
@@ -87,6 +87,7 @@ def action_vm(action_type, server, vimId, tenantId):
         else:
             param["reboot"]["type"] = "HARD"
     res_id = server["id"]
+    logger.debug("%s,%s,%s,%s", vimId, tenantId, res_id, param)
     api.action_vm(vimId, tenantId, res_id, param)
 
 
@@ -115,15 +116,20 @@ def heal_vim_res(vdus, vnfd_info, do_notify, data, vim_cache, res_cache):
         vimid = data["vimid"]
         tenant = data["tenant"]
         actionType = data["action"]
+        resid = ''
         if actionType == HEAL_ACTION_TYPE.START:
+            resid = vdus[0]["vdu_id"]
             create_vm(vim_cache, res_cache, vnfd_info, vdus[0], do_notify, RES_VM)
         elif actionType == HEAL_ACTION_TYPE.RESTART:
+            resid = vdus[0].resourceid
+            logger.debug("Start restart vm(%s)", resid)
             vm_info = api.get_vm(vimid, tenant, vdus[0].resourceid)
+            logger.debug("vminfo=%s", vm_info)
             action_vm(ACTION_TYPE.REBOOT, vm_info, vimid, tenant)
     except VimException as e:
-        logger.error("Failed to Heal %s(%s)", RES_VM, vdus[0]["vdu_id"])
+        logger.error("Failed to Heal %s(%s)", RES_VM, resid)
         logger.error("%s:%s", e.http_code, e.message)
-        raise NFLCMException("Failed to Heal %s(%s)", RES_VM, vdus[0]["vdu_id"])
+        raise NFLCMException("Failed to Heal %s(%s)" % (RES_VM, resid))
 
 
 def create_vim_res(data, do_notify, vim_cache={}, res_cache={}):
@@ -280,29 +286,6 @@ def create_port(vim_cache, res_cache, data, port, do_notify, res_type):
     set_res_cache(res_cache, res_type, port["cp_id"], ret["id"])
 
 
-def parse_unit(val, base_unit):
-    recognized_units = ["B", "kB", "KiB", "MB", "MiB", "GB", "GiB", "TB", "TiB"]
-    units_rate = [1, 1000, 1024, 1000000, 1048576, 1000000000, 1073741824, 1000000000000, 1099511627776]
-    unit_rate_map = {unit.upper(): rate for unit, rate in zip(recognized_units, units_rate)}
-    num_unit = val.strip().split(" ")
-    if len(num_unit) != 2:
-        return val.strip
-    num, unit = num_unit[0], num_unit[1]
-    return int(num) * unit_rate_map[unit.upper()] / unit_rate_map[base_unit.upper()]
-
-
-def search_flavor_aai(vim_id, flavor_name):
-    aai_flavors = get_flavor_info(vim_id)
-    if not aai_flavors:
-        return None
-    aai_flavor = aai_flavors["flavor"]
-    for one_aai_flavor in aai_flavor:
-        if one_aai_flavor["flavor-name"].find(flavor_name) == -1:
-            return one_aai_flavor
-
-    return None
-
-
 def create_flavor(vim_cache, res_cache, data, flavor, do_notify, res_type):
     location_info = flavor["properties"]["location_info"]
     vim_id, tenant_name = location_info["vimid"], location_info["tenant"]
@@ -317,19 +300,19 @@ def create_flavor(vim_cache, res_cache, data, flavor, do_notify, res_type):
         "isPublic": True
     }
 
-    # Using flavor name returned by OOF to search falvor
-    vdu_id = ignore_case_get(flavor, "vdu_id")
-    aai_flavor = None
+    # Get flavor id from OOF
+    vdu_id = ignore_case_get(flavor, "vdu_id", "")
+    flavor_id = ""
     for one_vdu in location_info["vduInfo"]:
         if one_vdu["vduName"] == vdu_id:
-            aai_flavor = search_flavor_aai(vim_id, one_vdu["flavorName"])
+            flavor_id = ignore_case_get(one_vdu, "flavorId", "")
             break
 
-    # Add aai flavor
-    if aai_flavor:
-        ret = aai_flavor
-        do_notify(res_type, ret)
-        set_res_cache(res_cache, res_type, flavor["vdu_id"], ret["flavor-id"])
+    # Add check if OOF return flavor id has value
+    # If value is not None, we use it.
+    # If value is None, we will create flavor again.
+    if flavor_id:
+        set_res_cache(res_cache, res_type, flavor["vdu_id"], flavor_id)
     else:
         for virtual_storage in virtual_storages:
             vs_id = virtual_storage["virtual_storage_id"]
@@ -400,8 +383,9 @@ def create_vm(vim_cache, res_cache, data, vm, do_notify, res_type):
             "volumeId": get_res_id(res_cache, RES_VOLUME, vol_id)
         })
 
+    user_data = base64.encodestring(ignore_case_get(vm["properties"], "user_data"))
     set_opt_val(param, "availabilityZone", ignore_case_get(location_info, "availability_zone"))
-    set_opt_val(param, "userdata", ignore_case_get(vm["properties"], "user_data"))
+    set_opt_val(param, "userdata", user_data)
     set_opt_val(param, "metadata", ignore_case_get(vm["properties"], "meta_data"))
     set_opt_val(param, "securityGroups", "")   # TODO List of names of security group
     set_opt_val(param, "serverGroup", "")      # TODO the ServerGroup for anti-affinity and affinity
@@ -417,7 +401,7 @@ def create_vm(vim_cache, res_cache, data, vm, do_notify, res_type):
     while retry_count < max_retry_count:
         vm_info = api.get_vm(vim_id, tenant_id, vm_id)
         if vm_info["status"].upper() == "ACTIVE":
-            logger.debug("Vm(%s) is active", vim_id)
+            logger.debug("Vm(%s) is active", vm_id)
             return
         if vm_info["status"].upper() == "ERROR":
             opt_vm_status = vm_info["status"]