[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v11 15/19] qemu-iotests: Test block-stream and block
From: |
Alberto Garcia |
Subject: |
[Qemu-devel] [PATCH v11 15/19] qemu-iotests: Test block-stream and block-commit in parallel |
Date: |
Fri, 14 Oct 2016 16:08:27 +0300 |
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', {})
+
+ # 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')
+
self.assert_no_active_block_jobs()
class TestSmallerBackingFile(iotests.QMPTestCase):
diff --git a/tests/qemu-iotests/030.out b/tests/qemu-iotests/030.out
index 4176bb9..3a89159 100644
--- a/tests/qemu-iotests/030.out
+++ b/tests/qemu-iotests/030.out
@@ -1,5 +1,5 @@
-...................
+....................
----------------------------------------------------------------------
-Ran 19 tests
+Ran 20 tests
OK
--
2.9.3
- [Qemu-devel] [PATCH v11 10/19] block: Add QMP support for streaming to an intermediate layer, (continued)
- [Qemu-devel] [PATCH v11 10/19] block: Add QMP support for streaming to an intermediate layer, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 04/19] block: Use block_job_add_bdrv() in mirror_start_job(), Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 17/19] qemu-iotests: Test streaming to a Quorum child, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 13/19] qemu-iotests: Test block-stream operations in parallel, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 19/19] qemu-iotests: Test the 'base-node' parameter of 'block-stream', Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 11/19] docs: Document how to stream to an intermediate layer, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 18/19] block: Add 'base-node' parameter to the 'block-stream' command, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 16/19] qemu-iotests: Add iotests.supports_quorum(), Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 08/19] block: Block all intermediate nodes in commit_active_start(), Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 09/19] block: Support streaming to an intermediate layer, Alberto Garcia, 2016/10/14
- [Qemu-devel] [PATCH v11 15/19] qemu-iotests: Test block-stream and block-commit in parallel,
Alberto Garcia <=
- [Qemu-devel] [PATCH v11 14/19] qemu-iotests: Test overlapping stream and commit operations, Alberto Garcia, 2016/10/14