Block patches:

- New @force parameter for blockdev-change-medium

- Improvements to the iotests to help with debugging

- Fix iotest 108 on systems without user_allow_other in fuse.conf

Denis V. Lunev (1):

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

CC: Hanna Reitz <hreitz@redhat.com>

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>

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

From: John Snow <jsnow@redhat.com>

I know we just added it, sorry. This is done in favor of qemu_io() which

*also* returns the console output and status, but with more robust error

handling on 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-11-jsnow@redhat.com>

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

---

tests/qemu-iotests/iotests.py | 3 ---

1 file changed, 3 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_io(*args: str, check: bool = True, combine_stdio: bool = True

return qemu_tool(*qemu_io_wrap_args(args),

check=check, combine_stdio=combine_stdio)

-def qemu_io_pipe_and_status(*args):

- return qemu_tool_pipe_and_status('qemu-io', qemu_io_wrap_args(args))

-

def qemu_io_log(*args: str) -> 'subprocess.CompletedProcess[str]':

result = qemu_io(*args, check=False)

log(result.stdout, filters=[filter_testfiles, filter_qemu_io])

--

2.35.1

From: John Snow <jsnow@redhat.com>

Like qemu-img, qemu-io returning 0 should be the norm and not the

exception. Remove all calls to qemu_io_silent that just assert the

return code is zero (That's every last call, as it turns out), and

replace them with a normal qemu_io() call.

qemu_io_silent_check() appeared to have been unused already.

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-12-jsnow@redhat.com>

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

---

tests/qemu-iotests/216 | 12 +++++-----

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

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

tests/qemu-iotests/258 | 11 +++++-----

tests/qemu-iotests/298 | 17 ++++++--------

tests/qemu-iotests/310 | 22 +++++++++----------

tests/qemu-iotests/iotests.py | 16 --------------

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

.../tests/mirror-ready-cancel-error | 2 +-

.../qemu-iotests/tests/stream-error-on-reset | 4 ++--

10 files changed, 38 insertions(+), 59 deletions(-)

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

index XXXXXXX..XXXXXXX 100755

--- a/tests/qemu-iotests/216

+++ b/tests/qemu-iotests/216

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

# Creator/Owner: Hanna Reitz <hreitz@redhat.com>

import iotests

-from iotests import log, qemu_img, qemu_io_silent

+from iotests import log, qemu_img, qemu_io

# Need backing file support

iotests.script_initialize(supported_fmts=['qcow2', 'qcow', 'qed', 'vmdk'],

@@ -XXX,XX +XXX,XX @@ with iotests.FilePath('base.img') as base_img_path, \

log('')

qemu_img('create', '-f', iotests.imgfmt, base_img_path, '64M')