[Libvirt-cim] [PATCH] [TEST] Updating 01_forward.py of ECTP
Deepti B. Kalakeri
deeptik at linux.vnet.ibm.com
Mon Sep 15 12:33:59 UTC 2008
# HG changeset patch
# User Deepti B. Kalakeri <deeptik at linux.vnet.ibm.com>
# Date 1221481998 25200
# Node ID c8703e572857045a8fa75e695cf08575d57f0cd3
# Parent 12931170a223bf6194177be33dfad154d7cb21e9
[TEST] Updating 01_forward.py of ECTP.
Changes:
--------
Updated the tc to align with the modifications for "Central Class to profile" and "Update migration profile version" changes.
Signed-off-by: Deepti B. Kalakeri <deeptik at linux.vnet.ibm.com>
diff -r 12931170a223 -r c8703e572857 suites/libvirt-cim/cimtest/ElementConforms/01_forward.py
--- a/suites/libvirt-cim/cimtest/ElementConforms/01_forward.py Wed Sep 10 18:58:22 2008 -0700
+++ b/suites/libvirt-cim/cimtest/ElementConforms/01_forward.py Mon Sep 15 05:33:18 2008 -0700
@@ -6,6 +6,7 @@
# Guolian Yun <yunguol at cn.ibm.com>
# Kaitlin Rupert <karupert at us.ibm.com>
# Veerendra Chandrappa <vechandr at in.ibm.com>
+# Deepti B. Kalakeri<deeptik at linux.vnet.ibm.com>
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public
@@ -24,13 +25,18 @@
# This tc is used to verify the EnabledState, HealthState, EnabledDefault and
# the Classname are set appropriately for the results returned by the
-# Xen_ElementConformsToProfile association for the Xen_RegisteredProfile class
-# and Xen_ManagedElement Class
+# ElementConformsToProfile association for the RegisteredProfile class
+# and ManagedElement Class
#
# "CIM:DSP1042-SystemVirtualization-1.0.0" ,
# "CIM:DSP1057-VirtualSystem-1.0.0a"
+# "CIM:DSP1059-GenericDeviceResourceVirtualization-1.0.0_d"
+# "CIM:DSP1059-GenericDeviceResourceVirtualization-1.0.0_n"
+# "CIM:DSP1059-GenericDeviceResourceVirtualization-1.0.0_p"
+# "CIM:DSP1045-MemoryResourceVirtualization-1.0.0"
+# "CIM:DSP1081-VirtualSystemMigration-0.8.1"
#
-# Date : 04-12-2007
+# Date : 04-12-2007
import sys
from VirtLib import utils, live
@@ -39,120 +45,198 @@ from XenKvmLib.classes import get_typed_
from XenKvmLib.classes import get_typed_class
from XenKvmLib import vxml
from CimTest import Globals
-from CimTest.Globals import logger, CIM_ERROR_ASSOCIATORS
+from XenKvmLib.common_util import print_field_error
+from CimTest.Globals import logger, CIM_ERROR_ASSOCIATORS, CIM_ERROR_ENUMERATE
from XenKvmLib.const import do_main
from CimTest.ReturnCodes import PASS, FAIL
+from XenKvmLib.enumclass import enumerate
+from XenKvmLib.const import default_network_name, default_pool_name
+
sup_types = ['Xen', 'XenFV', 'KVM', 'LXC']
test_dom = "domU"
-def verify_cs(item, id):
- if item['EnabledState'] != 2 and \
- item['EnabledDefault'] != 2 and \
- item['RequestedState'] != 12 :
- logger.error("Values not set properly for VSP(ComputerSystem)")
+def pool_init(verify_list, pool_cn, pool_name, virt):
+ ccn = get_typed_class(virt, pool_cn)
+ instid = '%s/%s' %(pool_cn, pool_name)
+ verify_list[ccn] = {
+ 'InstanceID' : instid,
+ 'PoolID' : instid
+ }
+ return verify_list
+
+def init_vs_pool_values(server, virt):
+ verify_ectp_list = { }
+ hs_ccn = get_typed_class(virt, 'HostSystem')
+ host = live.hostname(server)
+ cs_fields = {
+ 'EnabledState' : 5,
+ 'RequestedState' : 12,
+ 'EnabledDefault' : 2,
+ 'TransitioningToState' : 12,
+ 'CreationClassName' : hs_ccn,
+ 'Name' : host
+ }
+
+ verify_ectp_list[hs_ccn] = cs_fields
+
+ cs_ccn = get_typed_class(virt, 'ComputerSystem')
+ verify_ectp_list[cs_ccn] = cs_fields.copy()
+ verify_ectp_list[cs_ccn]['EnabledState'] = 2
+ verify_ectp_list[cs_ccn]['RequestedState'] = 0
+ verify_ectp_list[cs_ccn]['HealthState'] = 5
+ verify_ectp_list[cs_ccn]['CreationClassName'] = cs_ccn
+ verify_ectp_list[cs_ccn]['Name'] = test_dom
+ verify_ectp_list[cs_ccn]['ElementName'] = test_dom
+
+ vs_ccn = get_typed_class(virt, 'VirtualSystemMigrationService')
+ verify_ectp_list[vs_ccn] = cs_fields.copy()
+ verify_ectp_list[vs_ccn]['CreationClassName'] = vs_ccn
+ verify_ectp_list[vs_ccn]['SystemCreationClassName'] = hs_ccn
+ verify_ectp_list[vs_ccn]['SystemName'] = host
+ verify_ectp_list[vs_ccn]['Name'] = 'MigrationService'
+
+ verify_ectp_list = pool_init(verify_ectp_list, 'DiskPool',
+ default_pool_name, virt)
+ verify_ectp_list = pool_init(verify_ectp_list, 'NetworkPool',
+ default_network_name, virt)
+ verify_ectp_list = pool_init(verify_ectp_list, 'ProcessorPool', 0, virt)
+ verify_ectp_list = pool_init(verify_ectp_list, 'MemoryPool', 0, virt)
+
+
+ return verify_ectp_list
+
+def verify_fields(assoc_val, pllst_index, vs_pool_values):
+ try:
+ field_names = vs_pool_values[pllst_index].keys()
+ values = vs_pool_values[pllst_index]
+ for field in field_names:
+ if values[field] != assoc_val[field]:
+ print_field_error(field, assoc_val[field], values[field])
+ return FAIL
+ except Exception, details:
+ logger.error("Exception: In fn verify_fields() %s", details)
+ return FAIL
+
+ return PASS
+
+def verify_cs_hs_mig_fields(assoc_info, vs_pool_values):
+ try:
+ pllst_index = assoc_info[0]['CreationClassName']
+ assoc_val = None
+ if 'HostSystem' in pllst_index or \
+ 'VirtualSystemMigrationService' in pllst_index:
+ if len(assoc_info) != 1:
+ logger.error("'%s' returned '%d' records, expected 1",
+ pllst_index, len(assoc_info))
+ return FAIL
+ assoc_val = assoc_info[0]
+ else:
+ # For ComputerSystem info
+ for inst in assoc_info:
+ if inst['Name'] == test_dom:
+ assoc_val = inst
+ break
+ except Exception, details:
+ logger.error("Exception: In fn verify_cs_hs_mig_fields() %s", details)
return FAIL
- else:
- logger.info("1. Property values for %s and domain %s is " %
- (id, item['Name']))
- logger.info("EnabState = %d EnabDefault = %d ReqSt = %d" %
- (item['EnabledState'], item['EnabledDefault'],
- item['RequestedState'] ))
+ if assoc_val == None:
+ return FAIL
- return PASS
+ return verify_fields(assoc_val, pllst_index, vs_pool_values)
-def verify_host(item, id):
- if item['EnabledState'] != 5 and \
- item['EnabledDefault'] != 2 and \
- item['RequestedState'] != 12 :
- logger.error("Values not set properly for the the SVP (HostSystem)")
- return FAIL
+def get_proflist(server, reg_classname, virt):
+ proflist = []
+ status = PASS
+ try:
+ key_list = ["InstanceID"]
+ proflist = enumerate(server, reg_classname, key_list, virt)
+ if len(proflist) < 7:
+ logger.error("'%s' returned '%d' '%s' objects, expected atleast 7",
+ reg_classname, len(proflist), 'Profile')
+ status = FAIL
- else:
- logger.info("2. Values for %s and host %s is" %
- (id, item['Name']))
- logger.info("EnabState = %d EnabDefault = %d ReqSt = %d" %
- (item['EnabledState'], item['EnabledDefault'],
- item['RequestedState'] ))
+ except Exception, detail:
+ logger.error(CIM_ERROR_ENUMERATE, reg_classname)
+ logger.error("Exception: %s", detail)
+ status = FAIL
- return PASS
+ if status != PASS:
+ return status, proflist
+
+ profiles_instid_list = [ profile.InstanceID for profile in proflist ]
+
+ return status, profiles_instid_list
+
+
+def verify_ectp_assoc(server, virt):
+ reg_classname = "RegisteredProfile"
+ an = "ElementConformsToProfile"
+
+ status, inst_lst = get_proflist(server, reg_classname, virt)
+ if status != PASS:
+ return status
+
+ verify_ectp_list = init_vs_pool_values(server, virt)
+ for devid in inst_lst :
+ logger.info("Verifying '%s' with '%s'", an, devid)
+ try:
+ assoc_info = assoc.Associators(server,
+ an,
+ reg_classname,
+ virt,
+ InstanceID = devid)
+ if len(assoc_info) < 1:
+ status = FAIL
+ logger.error(" '%s' returned (%d) '%s' objects", an,
+ len(assoc_info), reg_classname)
+ break
+
+ if 'DSP1059' in devid or 'DSP1045' in devid:
+ instid = assoc_info[0]['InstanceID']
+ index, other = instid.split("/")
+ cn = get_typed_class(virt, index)
+ status = verify_fields(assoc_info[0], cn, verify_ectp_list)
+ else:
+ ccn = assoc_info[0]['CreationClassName']
+ status = verify_cs_hs_mig_fields(assoc_info, verify_ectp_list)
+
+ if status != PASS:
+ break
+
+ except Exception, detail:
+ logger.error(CIM_ERROR_ASSOCIATORS, an)
+ logger.error("Exception: %s" % detail)
+ status = FAIL
+ return status
@do_main(sup_types)
def main():
options = main.options
-
+ server = options.ip
+ virt = options.virt
+
status = PASS
destroy_and_undefine_all(options.ip, options.virt)
virt_xml = vxml.get_class(options.virt)
cxml = virt_xml(test_dom)
- ret = cxml.define(options.ip)
+ ret = cxml.cim_define(server)
+ ret = cxml.start(server)
if not ret:
- logger.error('Unable to define domain %s' % test_dom)
+ logger.error('Unable to start domain %s' % test_dom)
return FAIL
+
prev_namespace = Globals.CIM_NS
Globals.CIM_NS = 'root/interop'
- host = live.hostname(options.ip)
- inst_lst = {
- "InstID1" : "CIM:DSP1042-SystemVirtualization-1.0.0" ,
- "InstID2" : "CIM:DSP1057-VirtualSystem-1.0.0a"
- }
- hs = get_typed_class(options.virt, "HostSystem")
- cs = get_typed_class(options.virt, "ComputerSystem")
+ status = verify_ectp_assoc(server, virt)
- devlist = [
- hs , \
- cs
- ]
-
- for args, devid in inst_lst.items() :
- try:
- assoc_info = assoc.Associators(options.ip,
- "ElementConformsToProfile",
- "RegisteredProfile",
- options.virt,
- InstanceID = devid)
- if len(assoc_info) < 1:
- status = FAIL
- logger.error("ElementConformsToProfile returned %i\
- RegisteredProfile objects" % len(assoc_info))
- break
-
- count = 0
- for info in assoc_info:
- if info['CreationClassName'] == cs :
- if info['Name'] == 'domU' :
- count = count + 1
- verify_cs(info, devid)
-
- elif info['CreationClassName'] == hs and \
- info['Name'] == host:
- count = count + 1
- verify_host(info, devid)
-
- else:
- status = FAIL
- logger.error("CreationClassName Mismatch")
- logger.error("Returned %s instead of %s or %s" % \
- (item['CreationClassName'], devlist[0], devlist[1]))
-
- exp_count = 1
- if count != exp_count:
- status = FAIL
- logger.error("Expected to verify %d instances, not %d." %
- exp_count, count)
-
-
- except Exception, detail:
- logger.error(CIM_ERROR_ASSOCIATORS, 'ElementConformsToProfile')
- logger.error("Exception: %s" % detail)
- status = FAIL
-
- cxml.undefine(options.ip)
Globals.CIM_NS = prev_namespace
+ cxml.destroy(server)
+ cxml.undefine(server)
return status
if __name__ == "__main__":
More information about the Libvirt-cim
mailing list