| OLD | NEW | 
|---|
| 1 AUTHOR = "Yolkfull Chow <yzhou@redhat.com>" | 1 AUTHOR = "Yolkfull Chow <yzhou@redhat.com>" | 
| 2 TIME = "SHORT" | 2 TIME = "SHORT" | 
| 3 NAME = "Migration across multiple hosts" | 3 NAME = "Migration across multiple hosts" | 
| 4 TEST_CATEGORY = "Functional" | 4 TEST_CATEGORY = "Functional" | 
| 5 TEST_CLASS = "Virtualization" | 5 TEST_CLASS = "Virtualization" | 
| 6 TEST_TYPE = "Server" | 6 TEST_TYPE = "Server" | 
| 7 DOC = """ | 7 DOC = """ | 
| 8 Migrate KVM guest between two hosts. It parses the base config file, restricts | 8 Migrate KVM guest between two hosts. It parses the base config file, restricts | 
| 9 it with appropriate parameters, generates the test dicts, modify the test_dicts | 9 it with appropriate parameters, generates the test dicts, modify the test_dicts | 
| 10 so there's a distinction between the migration roles ('dest' or 'source'). | 10 so there's a distinction between the migration roles ('dest' or 'source'). | 
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
| 43     dest = hosts.create_host(pair[1]) | 43     dest = hosts.create_host(pair[1]) | 
| 44     source_at = autotest.Autotest(source) | 44     source_at = autotest.Autotest(source) | 
| 45     dest_at = autotest.Autotest(dest) | 45     dest_at = autotest.Autotest(dest) | 
| 46 | 46 | 
| 47     cfg_file = os.path.join(KVM_DIR, "tests_base.cfg") | 47     cfg_file = os.path.join(KVM_DIR, "tests_base.cfg") | 
| 48 | 48 | 
| 49     if not os.path.exists(cfg_file): | 49     if not os.path.exists(cfg_file): | 
| 50         raise error.JobError("Config file %s was not found", cfg_file) | 50         raise error.JobError("Config file %s was not found", cfg_file) | 
| 51 | 51 | 
| 52     # Get test set (dictionary list) from the configuration file | 52     # Get test set (dictionary list) from the configuration file | 
| 53     cfg = kvm_config.config() | 53     parser = kvm_config.Parser() | 
| 54     test_variants = """ | 54     test_variants = """ | 
| 55 image_name(_.*)? ?<= /tmp/kvm_autotest_root/images/ | 55 image_name(_.*)? ?<= /tmp/kvm_autotest_root/images/ | 
| 56 cdrom(_.*)? ?<= /tmp/kvm_autotest_root/ | 56 cdrom(_.*)? ?<= /tmp/kvm_autotest_root/ | 
| 57 floppy ?<= /tmp/kvm_autotest_root/ | 57 floppy ?<= /tmp/kvm_autotest_root/ | 
| 58 Linux: | 58 Linux: | 
| 59     unattended_install: | 59     unattended_install: | 
| 60         kernel ?<= /tmp/kvm_autotest_root/ | 60         kernel ?<= /tmp/kvm_autotest_root/ | 
| 61         initrd ?<= /tmp/kvm_autotest_root/ | 61         initrd ?<= /tmp/kvm_autotest_root/ | 
| 62 qemu_binary = /usr/libexec/qemu-kvm | 62 qemu_binary = /usr/libexec/qemu-kvm | 
| 63 qemu_img_binary = /usr/bin/qemu-img | 63 qemu_img_binary = /usr/bin/qemu-img | 
| 64 only qcow2 | 64 only qcow2 | 
| 65 only virtio_net | 65 only virtio_net | 
| 66 only virtio_blk | 66 only virtio_blk | 
| 67 only smp2 | 67 only smp2 | 
| 68 only no_pci_assignable | 68 only no_pci_assignable | 
| 69 only smallpages | 69 only smallpages | 
| 70 only Fedora.13.64 | 70 only Fedora.14.64 | 
| 71 only migrate_multi_host | 71 only migrate_multi_host | 
| 72 nic_mode = tap | 72 nic_mode = tap | 
| 73 nic_mac_nic1 = %s | 73 nic_mac_nic1 = %s | 
| 74 """ % (generate_mac_address()) | 74 """ % (generate_mac_address()) | 
| 75     cfg.fork_and_parse(cfg_file, test_variants) | 75     parser.parse_file(cfg_file) | 
| 76     test_dicts = cfg.get_list() | 76     parser.parse_string(test_variants) | 
|  | 77     test_dicts = parser.get_dicts() | 
| 77 | 78 | 
| 78     source_control_file = dest_control_file = """ | 79     source_control_file = dest_control_file = """ | 
| 79 kvm_test_dir = os.path.join(os.environ['AUTODIR'],'tests/kvm') | 80 kvm_test_dir = os.path.join(os.environ['AUTODIR'],'tests/kvm') | 
| 80 sys.path.append(kvm_test_dir)\n | 81 sys.path.append(kvm_test_dir)\n | 
| 81 """ | 82 """ | 
| 82     for params in test_dicts: | 83     for params in test_dicts: | 
| 83         params['srchost'] = source.ip | 84         params['srchost'] = source.ip | 
| 84         params['dsthost'] = dest.ip | 85         params['dsthost'] = dest.ip | 
| 85         params['rootdir'] = rootdir | 86         params['rootdir'] = rootdir | 
| 86 | 87 | 
| (...skipping 26 matching lines...) Expand all  Loading... | 
| 113 | 114 | 
| 114 # Grab the pairs (and failures) | 115 # Grab the pairs (and failures) | 
| 115 (pairs, failures) = utils.form_ntuples_from_machines(machines, 2) | 116 (pairs, failures) = utils.form_ntuples_from_machines(machines, 2) | 
| 116 | 117 | 
| 117 # Log the failures | 118 # Log the failures | 
| 118 for failure in failures: | 119 for failure in failures: | 
| 119     job.record("FAIL", failure[0], "kvm", failure[1]) | 120     job.record("FAIL", failure[0], "kvm", failure[1]) | 
| 120 | 121 | 
| 121 # Now run through each pair and run | 122 # Now run through each pair and run | 
| 122 job.parallel_simple(run, pairs, log=False) | 123 job.parallel_simple(run, pairs, log=False) | 
| OLD | NEW | 
|---|