On 09/25/2010 11:36 AM, Jason Wang wrote:
> This test just do the file transfer from host to guest during migartion in order
> to check whether the nic/block state could be saved and loaded correctly.
>
> Signed-off-by: Jason Wang <jasowang@xxxxxxxxxx>
> ---
> .../kvm/tests/migration_with_file_transfer.py | 59 ++++++++++++++++++++
> client/tests/kvm/tests_base.cfg.sample | 7 ++
> 2 files changed, 66 insertions(+), 0 deletions(-)
> create mode 100644 client/tests/kvm/tests/migration_with_file_transfer.py
>
> diff --git a/client/tests/kvm/tests/migration_with_file_transfer.py b/client/tests/kvm/tests/migration_with_file_transfer.py
> new file mode 100644
> index 0000000..8a316bf
> --- /dev/null
> +++ b/client/tests/kvm/tests/migration_with_file_transfer.py
> @@ -0,0 +1,59 @@
> +import logging, time
> +from autotest_lib.client.common_lib import utils, error
> +import kvm_subprocess, kvm_test_utils, kvm_utils
> +
> +
> +def run_migration_with_file_transfer(test, params, env):
> + """
> + KVM migration test:
> + 1) Get a live VM and clone it.
> + 2) Verify that the source VM supports migration. If it does, proceed with
> + the test.
> + 3) Reboot the VM
> + 4) Send a migration command to the source VM and wait until it's finished.
> + 5) Kill off the source VM.
> + 6) Log into the destination VM after the migration is finished.
> +
> + @param test: kvm test object.
> + @param params: Dictionary with test parameters.
> + @param env: Dictionary with the test environment.
> + """
> +
> + def transfer_test(vm, host_path, guest_path, timeout=120):
> + """
> + vm.copy_files_to does not raise exception, so we need a wrapper
> + in order to make it to be used by BackgroundTest.
> + """
> + if not vm.copy_files_to(host_path, guest_path, timeout=timeout):
> + raise error.TestError("Fail to do the file transfer!")
> +
> + vm = kvm_test_utils.get_living_vm(env, params.get("main_vm"))
> + timeout = int(params.get("login_timeout", 360))
> + session = kvm_test_utils.wait_for_login(vm, timeout=timeout)
> +
> + mig_timeout = float(params.get("mig_timeout", "3600"))
> + mig_protocol = params.get("migration_protocol", "tcp")
> +
> + guest_path = params.get("guest_path", "/tmp")
> + file_size = params.get("file_size", "1000")
> + transfer_timeout = int(params.get("transfer_timeout", "240"))
> + bg = None
> +
> + try:
> + utils.run("dd if=/dev/zero of=/tmp/file bs=1M count=%s" % file_size)
Wouldn't it be useful to read from /dev/urandom instead of /dev/zero,
and compare the md5 hash of the file generated on the host with the md5
hash of the file that arrives in the guest?
> +
> + # Transfer file from host to guest
> + bg = kvm_test_utils.BackgroundTest(transfer_test,
> + (vm, "/tmp/file", guest_path,
> + transfer_timeout))
> + bg.start()
> +
> + while bg.is_alive():
> + logging.info("File transfer is not ended, start a round of migration ...")
> + # Migrate the VM
> + dest_vm = kvm_test_utils.migrate(vm, env, mig_timeout, mig_protocol, False)
> + vm = dest_vm
> + finally:
> + if bg: bg.join()
> + session.close()
> + utils.run("rm -rf /tmp/zero")
--
To unsubscribe from this list: send the line "unsubscribe kvm" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
