mirror of
https://github.com/xemu-project/xemu.git
synced 2024-12-04 09:53:32 +00:00
a7abb53765
This change adds the simplest possible migration test. Beyond the test purpose itself it's also useful to exercise the multi virtual machines capabilities from base avocado qemu test class. Signed-off-by: Cleber Rosa <crosa@redhat.com> Signed-off-by: Caio Carrara <ccarrara@redhat.com> Reviewed-by: Cleber Rosa <crosa@redhat.com> Reviewed-by: Wainer dos Santos Moschetta <wainersm@redhat.com> Message-Id: <20190212193855.13223-3-ccarrara@redhat.com> Signed-off-by: Cleber Rosa <crosa@redhat.com>
54 lines
1.5 KiB
Python
54 lines
1.5 KiB
Python
# Migration test
|
|
#
|
|
# Copyright (c) 2019 Red Hat, Inc.
|
|
#
|
|
# Authors:
|
|
# Cleber Rosa <crosa@redhat.com>
|
|
# Caio Carrara <ccarrara@redhat.com>
|
|
#
|
|
# This work is licensed under the terms of the GNU GPL, version 2 or
|
|
# later. See the COPYING file in the top-level directory.
|
|
|
|
|
|
from avocado_qemu import Test
|
|
|
|
from avocado.utils import network
|
|
from avocado.utils import wait
|
|
|
|
|
|
class Migration(Test):
|
|
"""
|
|
:avocado: enable
|
|
"""
|
|
|
|
timeout = 10
|
|
|
|
@staticmethod
|
|
def migration_finished(vm):
|
|
return vm.command('query-migrate')['status'] in ('completed', 'failed')
|
|
|
|
def _get_free_port(self):
|
|
port = network.find_free_port()
|
|
if port is None:
|
|
self.cancel('Failed to find a free port')
|
|
return port
|
|
|
|
|
|
def test_migration_with_tcp_localhost(self):
|
|
source_vm = self.get_vm()
|
|
dest_uri = 'tcp:localhost:%u' % self._get_free_port()
|
|
dest_vm = self.get_vm('-incoming', dest_uri)
|
|
dest_vm.launch()
|
|
source_vm.launch()
|
|
source_vm.qmp('migrate', uri=dest_uri)
|
|
wait.wait_for(
|
|
self.migration_finished,
|
|
timeout=self.timeout,
|
|
step=0.1,
|
|
args=(source_vm,)
|
|
)
|
|
self.assertEqual(dest_vm.command('query-migrate')['status'], 'completed')
|
|
self.assertEqual(source_vm.command('query-migrate')['status'], 'completed')
|
|
self.assertEqual(dest_vm.command('query-status')['status'], 'running')
|
|
self.assertEqual(source_vm.command('query-status')['status'], 'postmigrate')
|