# HG changeset patch # User Deepti B. Kalakeri&lt;deeptik(a)linux.vnet.ibm.com&gt; # Date 1239181516 25200 # Node ID fbd3990003091191b34ce74569d07d999b22eb41 # Parent 9fc3064048044e18e14f96d12cadf7a0f8245c07 [TEST] #2 Adding new tc to cover restart and resume migration scenarios . Updates: -------- Patch 2: -------- Included break stmt when cleanup of guest fails. Tested with KVM and Xen with current sources and rpm. Signed-off-by: Deepti B. Kalakeri <deeptik(a)linux.vnet.ibm.com&gt; diff -r 9fc306404804 -r fbd399000309 suites/libvirt-cim/cimtest/VirtualSystemMigrationService/08_remote_restart_resume_migration.py --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/suites/libvirt-cim/cimtest/VirtualSystemMigrationService/08_remote_restart_resume_migration.py Wed Apr 08 02:05:16 2009 -0700 @@ -0,0 +1,189 @@ +#!/usr/bin/python +# +# Copyright 2009 IBM Corp. +# +# Authors: +# Deepti B. Kalakeri <deeptik(a)linux.vnet.ibm.com&gt; +# +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU General Public +# License as published by the Free Software Foundation; either +# version 2.1 of the License, or (at your option) any later version. +# +# This library is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# General Public License for more details. +# +# You should have received a copy of the GNU General Public +# License along with this library; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA +# +# +# This testcase is used to verify the resume and restart remote migration. +# +# Date : 05-04-2009 +# + +import sys +import os +from socket import gethostname +from XenKvmLib import vxml +from XenKvmLib.xm_virt_util import domain_list, net_list +from CimTest.Globals import logger +from XenKvmLib.const import do_main, default_network_name +from CimTest.ReturnCodes import PASS, FAIL, SKIP +from XenKvmLib.classes import get_typed_class +from XenKvmLib.vsmigrations import check_mig_support, local_remote_migrate +from XenKvmLib.common_util import poll_for_state_change, create_netpool_conf,\ + destroy_netpool + +sup_types = ['KVM', 'Xen'] + +REQUESTED_STATE = 2 + +def setup_guest(test_dom, ip, virt): + virt_xml = vxml.get_class(virt) + cxml = virt_xml(test_dom) + ret = cxml.cim_define(ip) + if not ret: + logger.error("Error define domain %s", test_dom) + return FAIL, cxml + + status = cxml.cim_start(ip) + if status != PASS: + cxml.undefine(test_dom) + logger.error("Error to start domain %s", test_dom) + return FAIL, cxml + + status, dom_cs = poll_for_state_change(ip, virt, test_dom, + REQUESTED_STATE) + if status != PASS: + cxml.cim_destroy(test_dom) + cxml.undefine(test_dom) + logger.error("'%s' didn't change state as expected" % test_dom) + return FAIL, cxml + + return PASS, cxml + +def cleanup_guest(virt, cxml, test_dom, t_sysname, s_sysname): + status = PASS + # Clean the domain on target machine. + # This is req when migration is successful, also when migration is not + # completely successful VM might be created on the target machine + # and hence need to clean. + target_list = domain_list(t_sysname, virt) + if target_list != None and test_dom in target_list: + ret_value = cxml.destroy(t_sysname) + if not ret_value: + logger.info("Failed to destroy the migrated domain '%s' on '%s'", + test_dom, t_sysname) + status = FAIL + + ret_value = cxml.undefine(t_sysname) + if not ret_value: + logger.info("Failed to undefine the migrated domain '%s' on '%s'", + test_dom, t_sysname) + status = FAIL + + # Remote Migration not Successful, clean the domain on src machine + src_list = domain_list(s_sysname, virt) + if src_list != None and test_dom in src_list: + ret_value = cxml.cim_destroy(s_sysname) + if not ret_value: + logger.info("Failed to destroy the domain '%s' on the source '%s'", + test_dom, s_sysname) + status = FAIL + + ret_value = cxml.undefine(s_sysname) + if not ret_value: + logger.info("Failed to undefine the domain '%s' on source '%s'", + test_dom, s_sysname) + status = FAIL + + return status + +def str_status(status): + if status == PASS: + return 'PASSED' + else: + return 'FAILED' + +@do_main(sup_types) +def main(): + options = main.options + virt = options.virt + status, s_sysname, t_sysname = check_mig_support(virt, options) + if status != PASS: + return status + + status = FAIL + test_dom = 'VM_frm_' + gethostname() + net_pool_name = default_network_name + mig_types = [ 'restart', 'resume' ] + status_resume = status_restart = None + cxml = None + + try: + + for mig_type in mig_types: + logger.info("Executing '%s' migration for '%s' from '%s' to '%s'", + mig_type, test_dom, s_sysname, t_sysname) + status, cxml = setup_guest(test_dom, s_sysname, virt) + if status != PASS: + logger.error("Error setting up the guest") + return status + + # create the networkpool used in the domain to be migrated + # on the target machine. + t_net_list = net_list(t_sysname, virt) + if t_net_list != None and net_pool_name not in t_net_list: + status, netpool = create_netpool_conf(t_sysname, virt, + net_name=net_pool_name) + if status != PASS: + raise Exception("Unable to create network pool '%s' on '%s'" + % (net_pool_name, t_sysname)) + + # Migrate the test_dom to t_sysname. + # Enable remote migration by setting remote_migrate=1 + status = local_remote_migrate(s_sysname, t_sysname, virt, + remote_migrate=1, guest_name=test_dom, + mtype=mig_type) + + logger.info("'%s' Migration for '%s %s' \n", + mig_type, test_dom, str_status(status)) + if mig_type == 'restart' : + status_restart = status + else: + status_resume = status + + ret = cleanup_guest(virt, cxml, test_dom, t_sysname, s_sysname) + if ret != PASS: + logger.error("Cleanup failed after '%s' migration", mig_type) + break + + except Exception, details: + logger.error("Exception details is :%s", details) + cleanup_guest(virt, cxml, test_dom, t_sysname, s_sysname) + status = FAIL + + # clean the networkpool created on the remote machine + target_net_list = net_list(t_sysname, virt) + if target_net_list != None and net_pool_name in target_net_list: + ret_value = destroy_netpool(t_sysname, virt, net_pool_name) + if ret_value != PASS: + logger.info("Unable to destroy networkpool '%s' on '%s'", + net_pool_name, t_sysname) + + if status_restart != PASS or status_resume != PASS: + status = FAIL + else: + status = PASS + + logger.info("Test case %s", str_status(status)) + return status + +if __name__ == "__main__": + sys.exit(main()) +