[mirror_qemu.git] / tests / qemu-iotests / 218

#!/usr/bin/env python
#
# This test covers what happens when a mirror block job is cancelled
# in various phases of its existence.
#
# Note that this test only checks the emitted events (i.e.
# BLOCK_JOB_COMPLETED vs. BLOCK_JOB_CANCELLED), it does not compare
# whether the target is in sync with the source when the
# BLOCK_JOB_COMPLETED event occurs.  This is covered by other tests
# (such as 041).
#
# Copyright (C) 2018 Red Hat, Inc.
#
# This program 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 of the License, or
# (at your option) any later version.
#
# This program 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 program.  If not, see <http://www.gnu.org/licenses/>.
#
# Creator/Owner: Max Reitz <mreitz@redhat.com>

import iotests
from iotests import log

iotests.verify_platform(['linux'])


# Launches the VM, adds two null-co nodes (source and target), and
# starts a blockdev-mirror job on them.
#
# Either both or none of speed and buf_size must be given.

def start_mirror(vm, speed=None, buf_size=None):
    vm.launch()

    ret = vm.qmp('blockdev-add',
                     node_name='source',
                     driver='null-co',
                     size=1048576)
    assert ret['return'] == {}

    ret = vm.qmp('blockdev-add',
                     node_name='target',
                     driver='null-co',
                     size=1048576)
    assert ret['return'] == {}

    if speed is not None:
        ret = vm.qmp('blockdev-mirror',
                         job_id='mirror',
                         device='source',
                         target='target',
                         sync='full',
                         speed=speed,
                         buf_size=buf_size)
    else:
        ret = vm.qmp('blockdev-mirror',
                         job_id='mirror',
                         device='source',
                         target='target',
                         sync='full')

    assert ret['return'] == {}


log('')
log('=== Cancel mirror job before convergence ===')
log('')

log('--- force=false ---')
log('')

with iotests.VM() as vm:
    # Low speed so it does not converge
    start_mirror(vm, 65536, 65536)

    log('Cancelling job')
    log(vm.qmp('block-job-cancel', device='mirror', force=False))

    log(vm.event_wait('BLOCK_JOB_CANCELLED'),
        filters=[iotests.filter_qmp_event])

log('')
log('--- force=true ---')
log('')

with iotests.VM() as vm:
    # Low speed so it does not converge
    start_mirror(vm, 65536, 65536)

    log('Cancelling job')
    log(vm.qmp('block-job-cancel', device='mirror', force=True))

    log(vm.event_wait('BLOCK_JOB_CANCELLED'),
        filters=[iotests.filter_qmp_event])


log('')
log('=== Cancel mirror job after convergence ===')
log('')

log('--- force=false ---')
log('')

with iotests.VM() as vm:
    start_mirror(vm)

    log(vm.event_wait('BLOCK_JOB_READY'),
        filters=[iotests.filter_qmp_event])

    log('Cancelling job')
    log(vm.qmp('block-job-cancel', device='mirror', force=False))

    log(vm.event_wait('BLOCK_JOB_COMPLETED'),
        filters=[iotests.filter_qmp_event])

log('')
log('--- force=true ---')
log('')

with iotests.VM() as vm:
    start_mirror(vm)

    log(vm.event_wait('BLOCK_JOB_READY'),
        filters=[iotests.filter_qmp_event])

    log('Cancelling job')
    log(vm.qmp('block-job-cancel', device='mirror', force=True))

    log(vm.event_wait('BLOCK_JOB_CANCELLED'),
        filters=[iotests.filter_qmp_event])
Commit	Line	Data
dc885fff HR	1	#!/usr/bin/env python
	2	#
	3	# This test covers what happens when a mirror block job is cancelled
	4	# in various phases of its existence.
	5	#
	6	# Note that this test only checks the emitted events (i.e.
	7	# BLOCK_JOB_COMPLETED vs. BLOCK_JOB_CANCELLED), it does not compare
	8	# whether the target is in sync with the source when the
	9	# BLOCK_JOB_COMPLETED event occurs. This is covered by other tests
	10	# (such as 041).
	11	#
	12	# Copyright (C) 2018 Red Hat, Inc.
	13	#
	14	# This program is free software; you can redistribute it and/or modify
	15	# it under the terms of the GNU General Public License as published by
	16	# the Free Software Foundation; either version 2 of the License, or
	17	# (at your option) any later version.
	18	#
	19	# This program is distributed in the hope that it will be useful,
	20	# but WITHOUT ANY WARRANTY; without even the implied warranty of
	21	# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	22	# GNU General Public License for more details.
	23	#
	24	# You should have received a copy of the GNU General Public License
	25	# along with this program. If not, see <http://www.gnu.org/licenses/>.
	26	#
	27	# Creator/Owner: Max Reitz <mreitz@redhat.com>
	28
	29	import iotests
	30	from iotests import log
	31
	32	iotests.verify_platform(['linux'])
	33
	34
	35	# Launches the VM, adds two null-co nodes (source and target), and
	36	# starts a blockdev-mirror job on them.
	37	#
	38	# Either both or none of speed and buf_size must be given.
	39
	40	def start_mirror(vm, speed=None, buf_size=None):
	41	vm.launch()
	42
	43	ret = vm.qmp('blockdev-add',
	44	node_name='source',
	45	driver='null-co',
	46	size=1048576)
	47	assert ret['return'] == {}
	48
	49	ret = vm.qmp('blockdev-add',
	50	node_name='target',
	51	driver='null-co',
	52	size=1048576)
	53	assert ret['return'] == {}
	54
	55	if speed is not None:
	56	ret = vm.qmp('blockdev-mirror',
	57	job_id='mirror',
	58	device='source',
	59	target='target',
	60	sync='full',
	61	speed=speed,
	62	buf_size=buf_size)
	63	else:
	64	ret = vm.qmp('blockdev-mirror',
65	job_id='mirror',
66	device='source',
67	target='target',
68	sync='full')
69
70	assert ret['return'] == {}
71
72
73	log('')
74	log('=== Cancel mirror job before convergence ===')
75	log('')
76
77	log('--- force=false ---')
78	log('')
79
80	with iotests.VM() as vm:
81	# Low speed so it does not converge
82	start_mirror(vm, 65536, 65536)
83
84	log('Cancelling job')
85	log(vm.qmp('block-job-cancel', device='mirror', force=False))
86
87	log(vm.event_wait('BLOCK_JOB_CANCELLED'),
88	filters=[iotests.filter_qmp_event])
89
90	log('')
91	log('--- force=true ---')
92	log('')
93
94	with iotests.VM() as vm:
95	# Low speed so it does not converge
96	start_mirror(vm, 65536, 65536)
97
98	log('Cancelling job')
99	log(vm.qmp('block-job-cancel', device='mirror', force=True))
100
101	log(vm.event_wait('BLOCK_JOB_CANCELLED'),
102	filters=[iotests.filter_qmp_event])
103
104
105	log('')
106	log('=== Cancel mirror job after convergence ===')
107	log('')
108
109	log('--- force=false ---')
110	log('')
111
112	with iotests.VM() as vm:
113	start_mirror(vm)
114
115	log(vm.event_wait('BLOCK_JOB_READY'),
116	filters=[iotests.filter_qmp_event])
117
118	log('Cancelling job')
119	log(vm.qmp('block-job-cancel', device='mirror', force=False))
120
121	log(vm.event_wait('BLOCK_JOB_COMPLETED'),
122	filters=[iotests.filter_qmp_event])
123
124	log('')
125	log('--- force=true ---')
126	log('')
127
128	with iotests.VM() as vm:
129	start_mirror(vm)
130
131	log(vm.event_wait('BLOCK_JOB_READY'),
132	filters=[iotests.filter_qmp_event])
133
134	log('Cancelling job')
135	log(vm.qmp('block-job-cancel', device='mirror', force=True))
136
137	log(vm.event_wait('BLOCK_JOB_CANCELLED'),
138	filters=[iotests.filter_qmp_event])