Denis V. Lunev (1):

block: add 'force' parameter to 'blockdev-change-medium' command

From: John Snow <jsnow@redhat.com>

This makes these callsites a little simpler, but the real motivation is

a forthcoming commit will change the return type of qemu_io(), so removing

users of the return value now is helpful.

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-2-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/242 | 6 +++---

tests/qemu-iotests/255 | 4 +---

tests/qemu-iotests/303 | 4 ++--

3 files changed, 6 insertions(+), 8 deletions(-)

diff --git a/tests/qemu-iotests/242 b/tests/qemu-iotests/242

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/242

+++ b/tests/qemu-iotests/242

@@ -XXX,XX +XXX,XX @@

import iotests

import json

import struct

-from iotests import qemu_img_create, qemu_io, qemu_img_info, \

- file_path, img_info_log, log, filter_qemu_io

+from iotests import qemu_img_create, qemu_io_log, qemu_img_info, \

+ file_path, img_info_log, log

iotests.script_initialize(supported_fmts=['qcow2'],

supported_protocols=['file'],

@@ -XXX,XX +XXX,XX @@ def add_bitmap(bitmap_number, persistent, disabled):

def write_to_disk(offset, size):

write = 'write {} {}'.format(offset, size)

- log(qemu_io('-c', write, disk), filters=[filter_qemu_io])

+ qemu_io_log('-c', write, disk)

def toggle_flag(offset):

diff --git a/tests/qemu-iotests/255 b/tests/qemu-iotests/255

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/255

+++ b/tests/qemu-iotests/255

@@ -XXX,XX +XXX,XX @@ with iotests.FilePath('src.qcow2') as src_path, \

iotests.qemu_img_create('-f', iotests.imgfmt, src_path, size_str)

iotests.qemu_img_create('-f', iotests.imgfmt, dst_path, size_str)

- iotests.log(iotests.qemu_io('-f', iotests.imgfmt, '-c', 'write 0 1M',

- src_path),

- filters=[iotests.filter_test_dir, iotests.filter_qemu_io])

+ iotests.qemu_io_log('-f', iotests.imgfmt, '-c', 'write 0 1M', src_path),

vm.add_object('throttle-group,x-bps-read=4096,id=throttle0')

diff --git a/tests/qemu-iotests/303 b/tests/qemu-iotests/303

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/303

+++ b/tests/qemu-iotests/303

@@ -XXX,XX +XXX,XX @@

import iotests

import subprocess

-from iotests import qemu_img_create, qemu_io, file_path, log, filter_qemu_io, \

+from iotests import qemu_img_create, qemu_io_log, file_path, log, \

verify_qcow2_zstd_compression

iotests.script_initialize(supported_fmts=['qcow2'],

@@ -XXX,XX +XXX,XX @@ def create_bitmap(bitmap_number, disabled):

def write_to_disk(offset, size):

write = f'write {offset} {size}'

- log(qemu_io('-c', write, disk), filters=[filter_qemu_io])

+ qemu_io_log('-c', write, disk)

def add_bitmap(num, begin, end, disabled):

--

2.35.1

From: John Snow <jsnow@redhat.com>

The 'read' commands to qemu-io were malformed, and this invocation only

worked by coincidence because the error messages were identical. Oops.

There's no point in checking the patterning of the reference image, so

just check the empty image by itself instead.

(Note: as of this commit, nothing actually enforces that this command

completes successfully, but a forthcoming commit in this series will

enforce that qemu_io() must have a zero status code.)

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-3-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/163 | 5 +----

1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/tests/qemu-iotests/163 b/tests/qemu-iotests/163

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/163

+++ b/tests/qemu-iotests/163

@@ -XXX,XX +XXX,XX @@ class ShrinkBaseClass(iotests.QMPTestCase):

qemu_img('resize', '-f', iotests.imgfmt, '--shrink', test_img,

self.shrink_size)

- self.assertEqual(

- qemu_io('-c', 'read -P 0x00 %s'%self.shrink_size, test_img),

- qemu_io('-c', 'read -P 0x00 %s'%self.shrink_size, check_img),

- "Verifying image content")

+ qemu_io('-c', f"read -P 0x00 0 {self.shrink_size}", test_img)

self.image_verify()

--

2.35.1

From: John Snow <jsnow@redhat.com>

A forthcoming commit updates qemu_io() to raise an exception on non-zero

return by default, and changes its return type.

In preparation, simplify some calls to qemu_io() that assert that

specific error message strings do not appear in qemu-io's

output. Asserting that all of these calls return a status code of zero

will be a more robust way to guard against failure.

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-4-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/040 | 33 ++++++++++++++++-----------------

tests/qemu-iotests/056 | 2 +-

2 files changed, 17 insertions(+), 18 deletions(-)

diff --git a/tests/qemu-iotests/040 b/tests/qemu-iotests/040

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/040

+++ b/tests/qemu-iotests/040

@@ -XXX,XX +XXX,XX @@ class TestSingleDrive(ImageCommitTestCase):

def test_commit(self):

self.run_commit_test(mid_img, backing_img)

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

def test_commit_node(self):

self.run_commit_test("mid", "base", node_names=True)

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

@iotests.skip_if_unsupported(['throttle'])

def test_commit_with_filter_and_quit(self):

@@ -XXX,XX +XXX,XX @@ class TestSingleDrive(ImageCommitTestCase):

def test_top_is_active(self):

self.run_commit_test(test_img, backing_img, need_ready=True)

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

def test_top_is_default_active(self):

self.run_default_commit_test()

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

def test_top_and_base_reversed(self):

self.assert_no_active_block_jobs()

@@ -XXX,XX +XXX,XX @@ class TestRelativePaths(ImageCommitTestCase):

def test_commit(self):

self.run_commit_test(self.mid_img, self.backing_img)

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', self.backing_img_abs).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', self.backing_img_abs).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', self.backing_img_abs)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', self.backing_img_abs)

def test_device_not_found(self):

result = self.vm.qmp('block-commit', device='nonexistent', top='%s' % self.mid_img)

@@ -XXX,XX +XXX,XX @@ class TestRelativePaths(ImageCommitTestCase):

def test_top_is_active(self):

self.run_commit_test(self.test_img, self.backing_img)

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', self.backing_img_abs).find("verification failed"))

- self.assertEqual(-1, qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', self.backing_img_abs).find("verification failed"))

+ qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', self.backing_img_abs)

+ qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', self.backing_img_abs)

def test_top_and_base_reversed(self):

self.assert_no_active_block_jobs()

@@ -XXX,XX +XXX,XX @@ class TestCommitWithFilters(iotests.QMPTestCase):

def do_test_io(self, read_or_write):

for index, pattern_file in enumerate(self.pattern_files):

- result = qemu_io('-f', iotests.imgfmt,

- '-c',

- f'{read_or_write} -P {index + 1} {index}M 1M',

- pattern_file)

- self.assertFalse('Pattern verification failed' in result)

+ qemu_io('-f', iotests.imgfmt,

+ '-c',

+ f'{read_or_write} -P {index + 1} {index}M 1M',

+ pattern_file)

@iotests.skip_if_unsupported(['throttle'])

def setUp(self):

diff --git a/tests/qemu-iotests/056 b/tests/qemu-iotests/056

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/056

+++ b/tests/qemu-iotests/056

@@ -XXX,XX +XXX,XX @@ class TestSyncModesNoneAndTop(iotests.QMPTestCase):

self.vm.shutdown()

time.sleep(1)

- self.assertEqual(-1, qemu_io('-c', 'read -P0x41 0 512', target_img).find("verification failed"))

+ qemu_io('-c', 'read -P0x41 0 512', target_img)

class TestBeforeWriteNotifier(iotests.QMPTestCase):

def setUp(self):

--

2.35.1

From: John Snow <jsnow@redhat.com>

qemu-io fails on read/write beyond end-of-file on raw images, so skip

these invocations when running the zero-length image tests.

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-5-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/040 | 14 ++++++++++++--

1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/tests/qemu-iotests/040 b/tests/qemu-iotests/040

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/040

+++ b/tests/qemu-iotests/040

@@ -XXX,XX +XXX,XX @@ class TestSingleDrive(ImageCommitTestCase):

qemu_img('create', '-f', iotests.imgfmt,

'-o', 'backing_file=%s' % mid_img,

'-F', iotests.imgfmt, test_img)

- qemu_io('-f', 'raw', '-c', 'write -P 0xab 0 524288', backing_img)

- qemu_io('-f', iotests.imgfmt, '-c', 'write -P 0xef 524288 524288', mid_img)

+ if self.image_len:

+ qemu_io('-f', 'raw', '-c', 'write -P 0xab 0 524288', backing_img)

+ qemu_io('-f', iotests.imgfmt, '-c', 'write -P 0xef 524288 524288',

+ mid_img)

self.vm = iotests.VM().add_drive(test_img, "node-name=top,backing.node-name=mid,backing.backing.node-name=base", interface="none")

self.vm.add_device('virtio-scsi')

self.vm.add_device("scsi-hd,id=scsi0,drive=drive0")

@@ -XXX,XX +XXX,XX @@ class TestSingleDrive(ImageCommitTestCase):

def test_commit(self):

self.run_commit_test(mid_img, backing_img)

+ if not self.image_len:

+ return

qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

def test_commit_node(self):

self.run_commit_test("mid", "base", node_names=True)

+ if not self.image_len:

+ return

qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

@@ -XXX,XX +XXX,XX @@ class TestSingleDrive(ImageCommitTestCase):

def test_top_is_active(self):

self.run_commit_test(test_img, backing_img, need_ready=True)

+ if not self.image_len:

+ return

qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

def test_top_is_default_active(self):

self.run_default_commit_test()

+ if not self.image_len:

+ return

qemu_io('-f', 'raw', '-c', 'read -P 0xab 0 524288', backing_img)

qemu_io('-f', 'raw', '-c', 'read -P 0xef 524288 524288', backing_img)

--

2.35.1

From: John Snow <jsnow@redhat.com>

Without this change, asserting that qemu_io always returns 0 causes this

test to fail in a way we happened not to be catching previously:

qemu.utils.VerboseProcessError: Command

'('/home/jsnow/src/qemu/bin/git/tests/qemu-iotests/../../qemu-io',

'--cache', 'writeback', '--aio', 'threads', '-f', 'qcow2', '-c',

'read -P 4 3M 1M',

'/home/jsnow/src/qemu/bin/git/tests/qemu-iotests/scratch/3.img')'

returned non-zero exit status 1.

┏━ output ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━

┃ qemu-io: can't open device

┃ /home/jsnow/src/qemu/bin/git/tests/qemu-iotests/scratch/3.img:

┃ Could not open backing file: Could not open backing file: Throttle

┃ group 'tg' does not exist

┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━

The commit jobs changes the backing file string stored in the image file

header belonging to the node above the commit’s top node to point to the

commit target (the base node). QEMU tries to be as accurate as

possible, and so in these test cases will include the filter that is

part of the block graph in that backing file string (by virtue of making

it a json:{} description of the post-commit subgraph). This makes

little sense outside of QEMU, though: Specifically, the throttle node in

that subgraph will dearly miss its supposedly associated throttle group

object.

When starting the commit job, we can specify a custom backing file

string to write into said image file, so let’s use that feature to write

the plain filename of the backing chain’s next actual image file there.

Explicitly provide the backing file so that opening the file outside of

QEMU (Where we will not have throttle groups) will succeed.

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Message-Id: <20220418211504.943969-6-jsnow@redhat.com>

---

tests/qemu-iotests/040 | 6 ++++--

1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/tests/qemu-iotests/040 b/tests/qemu-iotests/040

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/040

+++ b/tests/qemu-iotests/040

@@ -XXX,XX +XXX,XX @@ class TestCommitWithFilters(iotests.QMPTestCase):

job_id='commit',

device='top-filter',

top_node='cow-2',

- base_node='cow-1')

+ base_node='cow-1',

+ backing_file=self.img1)

self.assert_qmp(result, 'return', {})

self.wait_until_completed(drive='commit')

@@ -XXX,XX +XXX,XX @@ class TestCommitWithFilters(iotests.QMPTestCase):

job_id='commit',

device='top-filter',

top_node='cow-1',

- base_node='cow-0')

+ base_node='cow-0',

+ backing_file=self.img0)

self.assert_qmp(result, 'return', {})

self.wait_until_completed(drive='commit')

--

2.35.1

From: John Snow <jsnow@redhat.com>

reimplement qemu_img() in terms of qemu_tool() in preparation for doing

the same with qemu_io().

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-7-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/iotests.py | 32 +++++++++++++++++++++-----------

1 file changed, 21 insertions(+), 11 deletions(-)

diff --git a/tests/qemu-iotests/iotests.py b/tests/qemu-iotests/iotests.py

index XXXXXXX..XXXXXXX 100644

--- a/tests/qemu-iotests/iotests.py

+++ b/tests/qemu-iotests/iotests.py

@@ -XXX,XX +XXX,XX @@ def qemu_img_create_prepare_args(args: List[str]) -> List[str]:

return result

-def qemu_img(*args: str, check: bool = True, combine_stdio: bool = True

- ) -> 'subprocess.CompletedProcess[str]':

- """

- Run qemu_img and return the status code and console output.

- This function always prepends QEMU_IMG_OPTIONS and may further alter

- the args for 'create' commands.

+def qemu_tool(*args: str, check: bool = True, combine_stdio: bool = True

+ ) -> 'subprocess.CompletedProcess[str]':

+ """

+ Run a qemu tool and return its status code and console output.

- :param args: command-line arguments to qemu-img.

+ :param args: full command line to run.

:param check: Enforce a return code of zero.

:param combine_stdio: set to False to keep stdout/stderr separated.

@@ -XXX,XX +XXX,XX @@ def qemu_img(*args: str, check: bool = True, combine_stdio: bool = True

properties. If streams are not combined, it will also have a

stderr property.

"""

- full_args = qemu_img_args + qemu_img_create_prepare_args(list(args))

-

subp = subprocess.run(

- full_args,

+ args,

stdout=subprocess.PIPE,

stderr=subprocess.STDOUT if combine_stdio else subprocess.PIPE,

universal_newlines=True,

@@ -XXX,XX +XXX,XX @@ def qemu_img(*args: str, check: bool = True, combine_stdio: bool = True

if check and subp.returncode or (subp.returncode < 0):

raise VerboseProcessError(

- subp.returncode, full_args,

+ subp.returncode, args,

output=subp.stdout,

stderr=subp.stderr,

)

@@ -XXX,XX +XXX,XX @@ def qemu_img(*args: str, check: bool = True, combine_stdio: bool = True

return subp

+def qemu_img(*args: str, check: bool = True, combine_stdio: bool = True

+ ) -> 'subprocess.CompletedProcess[str]':

+ """

+ Run QEMU_IMG_PROG and return its status code and console output.

+

+ This function always prepends QEMU_IMG_OPTIONS and may further alter

+ the args for 'create' commands.

+

+ See `qemu_tool()` for greater detail.

+ """

+ full_args = qemu_img_args + qemu_img_create_prepare_args(list(args))

+ return qemu_tool(*full_args, check=check, combine_stdio=combine_stdio)

+

+

def ordered_qmp(qmsg, conv_keys=True):

# Dictionaries are not ordered prior to 3.6, therefore:

if isinstance(qmsg, list):

--

2.35.1

From: John Snow <jsnow@redhat.com>

Modify this test to use assertRaises for its negative testing of

qemu_io. If the exception raised does not match the one we tell it to

expect, we get *that* exception unhandled. If we get no exception, we

get a unittest assertion failure and the provided emsg printed to

screen.

If we get the CalledProcessError exception but the output is not what we

expect, we re-raise the original CalledProcessError.

Tidy.

(Note: Yes, you can reference "with" objects after that block ends; it

just means that ctx.__exit__(...) will have been called on it. It does

not *actually* go out of scope. unittests expects you to want to inspect

the Exception object, so they leave it defined post-exit.)

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Tested-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-9-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

.../qemu-iotests/tests/migration-permissions | 28 +++++++++----------

1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/tests/qemu-iotests/tests/migration-permissions b/tests/qemu-iotests/tests/migration-permissions

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/tests/migration-permissions

+++ b/tests/qemu-iotests/tests/migration-permissions

@@ -XXX,XX +XXX,XX @@

#

import os

+from subprocess import CalledProcessError

+

import iotests

from iotests import imgfmt, qemu_img_create, qemu_io

@@ -XXX,XX +XXX,XX @@ class TestMigrationPermissions(iotests.QMPTestCase):

def test_post_migration_permissions(self):

# Try to access the image R/W, which should fail because virtio-blk

# has not been configured with share-rw=on

- log = qemu_io('-f', imgfmt, '-c', 'quit', test_img, check=False).stdout

- if not log.strip():

- print('ERROR (pre-migration): qemu-io should not be able to '

- 'access this image, but it reported no error')

- else:

- # This is the expected output

- assert 'Is another process using the image' in log

+ emsg = ('ERROR (pre-migration): qemu-io should not be able to '

+ 'access this image, but it reported no error')

+ with self.assertRaises(CalledProcessError, msg=emsg) as ctx:

+ qemu_io('-f', imgfmt, '-c', 'quit', test_img)

+ if 'Is another process using the image' not in ctx.exception.stdout:

+ raise ctx.exception

# Now migrate the VM

self.vm_s.qmp('migrate', uri=f'unix:{mig_sock}')

@@ -XXX,XX +XXX,XX @@ class TestMigrationPermissions(iotests.QMPTestCase):

# Try the same qemu-io access again, verifying that the WRITE

# permission remains unshared

- log = qemu_io('-f', imgfmt, '-c', 'quit', test_img, check=False).stdout

- if not log.strip():

- print('ERROR (post-migration): qemu-io should not be able to '

- 'access this image, but it reported no error')

- else:

- # This is the expected output

- assert 'Is another process using the image' in log

+ emsg = ('ERROR (post-migration): qemu-io should not be able to '

+ 'access this image, but it reported no error')

+ with self.assertRaises(CalledProcessError, msg=emsg) as ctx:

+ qemu_io('-f', imgfmt, '-c', 'quit', test_img)

+ if 'Is another process using the image' not in ctx.exception.stdout:

+ raise ctx.exception

if __name__ == '__main__':

--

2.35.1

From: John Snow <jsnow@redhat.com>

This test expects failure ... but only sometimes. When? Why?

It's for reads of a region not defined by a bitmap. Adjust the test to

be more explicit about what it expects to fail and why.

Signed-off-by: John Snow <jsnow@redhat.com>

Reviewed-by: Eric Blake <eblake@redhat.com>

Reviewed-by: Hanna Reitz <hreitz@redhat.com>

Message-Id: <20220418211504.943969-10-jsnow@redhat.com>

Signed-off-by: Hanna Reitz <hreitz@redhat.com>

---

tests/qemu-iotests/tests/image-fleecing | 28 +++++++++++++++++--------

1 file changed, 19 insertions(+), 9 deletions(-)

diff --git a/tests/qemu-iotests/tests/image-fleecing b/tests/qemu-iotests/tests/image-fleecing

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/tests/image-fleecing

+++ b/tests/qemu-iotests/tests/image-fleecing

@@ -XXX,XX +XXX,XX @@

#

# Creator/Owner: John Snow <jsnow@redhat.com>

+from subprocess import CalledProcessError

+

import iotests

-from iotests import log, qemu_img, qemu_io, qemu_io_silent, \

- qemu_io_pipe_and_status

+from iotests import log, qemu_img, qemu_io, qemu_io_silent

iotests.script_initialize(

supported_fmts=['qcow2'],

@@ -XXX,XX +XXX,XX @@ def do_test(vm, use_cbw, use_snapshot_access_filter, base_img_path,

for p in patterns + zeroes:

cmd = 'read -P%s %s %s' % p

log(cmd)

- out, ret = qemu_io_pipe_and_status('-r', '-f', 'raw', '-c', cmd,

- nbd_uri)

- if ret != 0:

- print(out)

+

+ try:

+ qemu_io('-r', '-f', 'raw', '-c', cmd, nbd_uri)

+ except CalledProcessError as exc:

+ if bitmap and p in zeroes:

+ log(exc.stdout)

+ else:

+ raise

log('')

log('--- Testing COW ---')

@@ -XXX,XX +XXX,XX @@ def do_test(vm, use_cbw, use_snapshot_access_filter, base_img_path,

args += [target_img_path]

else:

args += ['-f', 'raw', nbd_uri]

- out, ret = qemu_io_pipe_and_status(*args)

- if ret != 0:

- print(out)

+

+ try:

+ qemu_io(*args)

+ except CalledProcessError as exc:

+ if bitmap and p in zeroes:

+ log(exc.stdout)

+ else:

+ raise

log('')

log('--- Cleanup ---')

--

2.35.1