External/cloud-hypervisor
1
0
Fork 0
mirror of https://github.com/cloud-hypervisor/cloud-hypervisor.git synced 2025-02-21 19:02:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

tests: Cover 'virtio-watchdog' for live migration and live upgrade

Browse Source 
Signed-off-by: Bo Chen <chen.bo@intel.com>
This commit is contained in:
Bo Chen 2022-04-25 21:35:37 -07:00 committed by Bo Chen
parent 16740b4fcd
commit 3d1b2eb4e5
1 changed files with 54 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
tests/integration.rs
View File

@ -7337,7 +7337,7 @@ mod live_migration {
// 4. The destination VM is functional (including various virtio-devices are working properly) after
// live migration;
// Note: This test does not use vsock as we can't create two identical vsock on the same host.
fn _test_live_migration(upgrade_test: bool, numa: bool, local: bool) {
fn _test_live_migration(upgrade_test: bool, numa: bool, local: bool, watchdog: bool) {
let focal = UbuntuDiskConfig::new(FOCAL_IMAGE_NAME.to_string());
let guest = Guest::new(Box::new(focal));
let kernel_path = direct_kernel_boot_path();
@ -7392,7 +7392,8 @@ mod live_migration {
cloud_hypervisor_release_path()
};
let src_api_socket = temp_api_path(&guest.tmp_dir);
let mut src_child = GuestCommand::new_with_binary_path(&guest, &src_vm_path)
let mut src_vm_cmd = GuestCommand::new_with_binary_path(&guest, &src_vm_path);
src_vm_cmd
.args(&["--cpus", "boot=6,max=12"])
.args(memory_param)
.args(&["--kernel", kernel_path.to_str().unwrap()])
@ -7403,10 +7404,11 @@ mod live_migration {
.args(&[
"--pmem",
format!("file={}", pmem_temp_file.as_path().to_str().unwrap(),).as_str(),
])
.capture_output()
.spawn()
.unwrap();
]);
if watchdog {
src_vm_cmd.args(&["--watchdog"]);
}
let mut src_child = src_vm_cmd.capture_output().spawn().unwrap();
// Start the destination VM
let mut dest_api_socket = temp_api_path(&guest.tmp_dir);
@ -7476,6 +7478,12 @@ mod live_migration {
thread::sleep(std::time::Duration::new(10, 0));
}
if watchdog {
let mut current_reboot_count = 1;
enable_guest_watchdog(&guest, &mut current_reboot_count);
check_guest_watchdog_no_reboot(&guest, &current_reboot_count);
}
// Start the live-migration
let migration_socket = String::from(
guest
@ -7655,6 +7663,16 @@ mod live_migration {
);
}
}
if watchdog {
let mut current_reboot_count = 2;
check_guest_watchdog_no_reboot(&guest, &current_reboot_count);
check_guest_watchdog_one_reboot(
&guest,
&dest_api_socket,
&mut current_reboot_count,
);
}
});
// Clean-up the destination VM and make sure it terminated correctly
@ -7671,50 +7689,72 @@ mod live_migration {
#[test]
fn test_live_migration_basic() {
_test_live_migration(false, false, false)
_test_live_migration(false, false, false, false)
}
#[test]
fn test_live_migration_local() {
_test_live_migration(false, false, true)
_test_live_migration(false, false, true, false)
}
#[test]
#[cfg(not(feature = "mshv"))]
fn test_live_migration_numa() {
_test_live_migration(false, true, false)
_test_live_migration(false, true, false, false)
}
#[test]
#[cfg(not(feature = "mshv"))]
fn test_live_migration_numa_local() {
_test_live_migration(false, true, true)
_test_live_migration(false, true, true, false)
}
#[test]
fn test_live_migration_watchdog() {
_test_live_migration(false, false, false, true)
}
#[test]
fn test_live_migration_watchdog_local() {
_test_live_migration(false, false, true, true)
}
#[test]
#[ignore]
fn test_live_upgrade_basic() {
_test_live_migration(true, false, false)
_test_live_migration(true, false, false, false)
}
#[test]
#[ignore]
fn test_live_upgrade_local() {
_test_live_migration(true, false, true)
_test_live_migration(true, false, true, false)
}
#[test]
#[ignore]
#[cfg(not(feature = "mshv"))]
fn test_live_upgrade_numa() {
_test_live_migration(true, true, false)
_test_live_migration(true, true, false, false)
}
#[test]
#[ignore]
#[cfg(not(feature = "mshv"))]
fn test_live_upgrade_numa_local() {
_test_live_migration(true, true, true)
_test_live_migration(true, true, true, false)
}
#[test]
#[ignore]
fn test_live_upgrade_watchdog() {
_test_live_migration(true, false, false, true)
}
#[test]
#[ignore]
fn test_live_upgrade_watchdog_local() {
_test_live_migration(true, false, true, true)
}
fn _test_live_migration_ovs_dpdk(upgrade_test: bool, local: bool) {