]>
git.proxmox.com Git - mirror_qemu.git/blob - tests/qemu-iotests/258
4 # Very specific tests for adjacent commit/stream block jobs
6 # Copyright (C) 2019 Red Hat, Inc.
8 # This program is free software; you can redistribute it and/or modify
9 # it under the terms of the GNU General Public License as published by
10 # the Free Software Foundation; either version 2 of the License, or
11 # (at your option) any later version.
13 # This program is distributed in the hope that it will be useful,
14 # but WITHOUT ANY WARRANTY; without even the implied warranty of
15 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 # GNU General Public License for more details.
18 # You should have received a copy of the GNU General Public License
19 # along with this program. If not, see <http://www.gnu.org/licenses/>.
21 # Creator/Owner: Max Reitz <mreitz@redhat.com>
24 from iotests
import log
, qemu_img
, qemu_io_silent
, \
25 filter_qmp_testfiles
, filter_qmp_imgfmt
27 # Returns a node for blockdev-add
28 def node(node_name
, path
, backing
=None, fmt
=None, throttle
=None):
33 'node-name': node_name
,
41 if backing
is not None:
42 res
['backing'] = backing
47 'throttle-group': throttle
,
53 # Finds a node in the debug block graph
54 def find_graph_node(graph
, node_id
):
55 return next(node
for node
in graph
['nodes'] if node
['id'] == node_id
)
58 def test_concurrent_finish(write_to_stream_node
):
60 log('=== Commit and stream finish concurrently (letting %s write) ===' % \
61 ('stream' if write_to_stream_node
else 'commit'))
64 # All chosen in such a way that when the commit job wants to
65 # finish, it polls and thus makes stream finish concurrently --
66 # and the other way around, depending on whether the commit job
67 # is finalized before stream completes or not.
69 with iotests
.FilePath('node4.img') as node4_path
, \
70 iotests
.FilePath('node3.img') as node3_path
, \
71 iotests
.FilePath('node2.img') as node2_path
, \
72 iotests
.FilePath('node1.img') as node1_path
, \
73 iotests
.FilePath('node0.img') as node0_path
, \
76 # It is important to use raw for the base layer (so that
77 # permissions are just handed through to the protocol layer)
78 assert qemu_img('create', '-f', 'raw', node0_path
, '64M') == 0
83 for path
in [node1_path
, node2_path
, node3_path
, node4_path
]:
84 assert qemu_img('create', '-f', iotests
.imgfmt
, path
, '64M') == 0
86 if write_to_stream_node
:
87 # This is what (most of the time) makes commit finish
88 # earlier and then pull in stream
89 assert qemu_io_silent(node2_path
,
90 '-c', 'write %iK 64K' % (65536 - 192),
91 '-c', 'write %iK 64K' % (65536 - 64)) == 0
95 # And this makes stream finish earlier
96 assert qemu_io_silent(node1_path
,
97 '-c', 'write %iK 64K' % (65536 - 64)) == 0
103 vm
.qmp_log('object-add',
104 qom_type
='throttle-group',
108 'x-iops-write-max': 1
111 vm
.qmp_log('blockdev-add',
112 filters
=[filter_qmp_testfiles
, filter_qmp_imgfmt
],
113 **node('node4', node4_path
, throttle
=stream_throttle
,
114 backing
=node('node3', node3_path
,
115 backing
=node('node2', node2_path
,
116 backing
=node('node1', node1_path
,
117 backing
=node('node0', node0_path
, throttle
=commit_throttle
,
120 vm
.qmp_log('block-commit',
123 filter_node_name
='commit-filter',
128 vm
.qmp_log('block-stream',
131 base_node
='commit-filter')
133 if write_to_stream_node
:
134 vm
.run_job('commit', auto_finalize
=False, auto_dismiss
=True)
135 vm
.run_job('stream', auto_finalize
=True, auto_dismiss
=True)
137 # No, the jobs do not really finish concurrently here,
138 # the stream job does complete strictly before commit.
139 # But still, this is close enough for what we want to
141 vm
.run_job('stream', auto_finalize
=True, auto_dismiss
=True)
142 vm
.run_job('commit', auto_finalize
=False, auto_dismiss
=True)
144 # Assert that the backing node of node3 is node 0 now
145 graph
= vm
.qmp('x-debug-query-block-graph')['return']
146 for edge
in graph
['edges']:
147 if edge
['name'] == 'backing' and \
148 find_graph_node(graph
, edge
['parent'])['name'] == 'node3':
149 assert find_graph_node(graph
, edge
['child'])['name'] == 'node0'
154 log('Running tests:')
155 test_concurrent_finish(True)
156 test_concurrent_finish(False)
158 if __name__
== '__main__':
159 # Need backing file and change-backing-file support
160 iotests
.script_main(main
,
161 supported_fmts
=['qcow2', 'qed'],
162 supported_platforms
=['linux'])