[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-block] [PATCH v12 15/19] qemu-iotests: Test block-stream and b
From: |
Kevin Wolf |
Subject: |
Re: [Qemu-block] [PATCH v12 15/19] qemu-iotests: Test block-stream and block-commit in parallel |
Date: |
Thu, 27 Oct 2016 17:54:52 +0200 |
User-agent: |
Mutt/1.5.21 (2010-09-15) |
Am 26.10.2016 um 12:29 hat Alberto Garcia geschrieben:
> As with test_stream_parallel(), we allow mixing block-stream and
> block-commit operations in the same backing chain as long as there's
> no overlap among the involved nodes.
>
> Signed-off-by: Alberto Garcia <address@hidden>
> ---
> tests/qemu-iotests/030 | 30 ++++++++++++++++++++++++++++++
> tests/qemu-iotests/030.out | 4 ++--
> 2 files changed, 32 insertions(+), 2 deletions(-)
>
> diff --git a/tests/qemu-iotests/030 b/tests/qemu-iotests/030
> index e3bded8..d88823a 100755
> --- a/tests/qemu-iotests/030
> +++ b/tests/qemu-iotests/030
> @@ -315,6 +315,36 @@ class TestParallelOps(iotests.QMPTestCase):
> self.assert_qmp(result, 'return', {})
>
> self.wait_until_completed(drive='commit-drive0')
> +
> + # Test a block-stream and a block-commit job in parallel
> + def test_stream_commit(self):
> + self.assertLessEqual(8, self.num_imgs)
> + self.assert_no_active_block_jobs()
> +
> + # Stream from node0 into node2
> + result = self.vm.qmp('block-stream', device='node2', job_id='node2')
> + self.assert_qmp(result, 'return', {})
> +
> + # Commit from the active layer into node3
> + result = self.vm.qmp('block-commit', device='drive0',
> top=self.imgs[5], base=self.imgs[3])
> + self.assert_qmp(result, 'return', {})
I'm not sure what you wanted to test here (active commit/mirror or
normal commit), but the comment and what you really do don't match. This
doesn't use the active layer...
> + # Wait for all jobs to be finished.
> + pending_jobs = ['node2', 'drive0']
> + while len(pending_jobs) > 0:
> + for event in self.vm.get_qmp_events(wait=True):
> + if event['event'] == 'BLOCK_JOB_COMPLETED':
> + node_name = self.dictpath(event, 'data/device')
> + self.assertTrue(node_name in pending_jobs)
> + self.assert_qmp_absent(event, 'data/error')
> + pending_jobs.remove(node_name)
> + if event['event'] == 'BLOCK_JOB_READY':
> + self.assert_qmp(event, 'data/device', 'drive0')
> + self.assert_qmp(event, 'data/type', 'commit')
> + self.assert_qmp_absent(event, 'data/error')
> + self.assertTrue('drive0' in pending_jobs)
> + self.vm.qmp('block-job-complete', device='drive0')
...so the BLOCK_JOB_READY handling is dead code because we're not using
a mirror job internally.
> self.assert_no_active_block_jobs()
>
> class TestSmallerBackingFile(iotests.QMPTestCase):
Kevin
- [Qemu-block] [PATCH v12 06/19] block: Check blockers in all nodes involved in a block-commit job, (continued)
- [Qemu-block] [PATCH v12 06/19] block: Check blockers in all nodes involved in a block-commit job, Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 04/19] block: Use block_job_add_bdrv() in mirror_start_job(), Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 07/19] block: Block all nodes involved in the block-commit operation, Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 02/19] block: Pause all jobs during bdrv_reopen_multiple(), Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 19/19] qemu-iotests: Test the 'base-node' parameter of 'block-stream', Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 15/19] qemu-iotests: Test block-stream and block-commit in parallel, Alberto Garcia, 2016/10/26
- Re: [Qemu-block] [PATCH v12 15/19] qemu-iotests: Test block-stream and block-commit in parallel,
Kevin Wolf <=
- [Qemu-block] [PATCH v12 12/19] qemu-iotests: Test streaming to an intermediate layer, Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 16/19] qemu-iotests: Add iotests.supports_quorum(), Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 17/19] qemu-iotests: Test streaming to a Quorum child, Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 03/19] block: Add block_job_add_bdrv(), Alberto Garcia, 2016/10/26
- [Qemu-block] [PATCH v12 11/19] docs: Document how to stream to an intermediate layer, Alberto Garcia, 2016/10/26