[Sheepdog] [PATCH 2/2] tests: add qemu-io testcases.
chenbaozi at gmail.com
chenbaozi at gmail.com
Fri Nov 11 16:17:23 CET 2011
From: CHEN Baozi <chenbaozi.pt at taobao.com>
Signed-off-by: CHEN Baozi <chenbaozi.pt at taobao.com>
---
tests/qemu_io_testcases.py | 159 ++++++++++++++++++++++++++++++++++++++++++++
tests/test_qemu_io.py | 84 +++++++++++++++++++++++
2 files changed, 243 insertions(+), 0 deletions(-)
create mode 100644 tests/qemu_io_testcases.py
create mode 100644 tests/test_qemu_io.py
diff --git a/tests/qemu_io_testcases.py b/tests/qemu_io_testcases.py
new file mode 100644
index 0000000..6998bbe
--- /dev/null
+++ b/tests/qemu_io_testcases.py
@@ -0,0 +1,159 @@
+cases_desc = {
+"001": "Test simple read/write using plain bdrv_read/bdrv_write.",
+"002": "Test simple read/write using plain bdrv_pread/bdrv_pwrite.",
+"003": "Test simple read/write using bdrv_aio_readv/bdrv_aio_writev.",
+"004": "Make sure we can't read and write outside of the image size.",
+"008": "Test simple asynchronous read/write operations.",
+"011": "Test for AIO allocation on the same cluster.",
+"016": "Test I/O after EOF for growable images.",
+"025": "Resizing images.",
+}
+
+io_cases = {
+"001":[
+("read 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write -P 0xa 0 128M", """wrote 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -P 0xa 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+"002":[
+("read -p 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write -pP 0xa 0 128M", """wrote 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -pP 0xa 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write -pP 0xab 66 42", """wrote 42/42 bytes at offset 66
+42.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -pP 0xab 66 42", """read 42/42 bytes at offset 66
+42.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+"003":[
+("readv 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("writev -P 0xa 0 128M", """wrote 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("readv -P 0xa 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("writev -P 0xb 67M 8k 8k 8k 8k 8k 8k 8k",
+"""wrote 57344/57344 bytes at offset 70254592
+56 KiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("readv -P 0xb 67M 8k 8k 8k 8k 8k 8k 8k",
+"""read 57344/57344 bytes at offset 70254592
+56 KiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+"004":[
+("write 127M 1M", """wrote 1048576/1048576 bytes at offset 133169152
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write 127M 4M", """write failed: Input/output error"""),
+("write 128M 4096", """write failed: Input/output error"""),
+("write 140M 4096", """write failed: Input/output error"""),
+("write -p 140M 4096", """write failed: Input/output error"""),
+("writev 140M 4096","""writev failed: Input/output error"""),
+("read 127M 1M", """read 1048576/1048576 bytes at offset 133169152
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read 127M 4M", """read failed: Input/output error"""),
+("read 128M 4096", """read failed: Input/output error"""),
+("read 140M 4096", """read failed: Input/output error"""),
+("read -p 140M 4096", """read failed: Input/output error"""),
+("readv 140M 4096", """readv failed: Input/output error"""),
+],
+"008":[
+("aio_read 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("aio_write -P 0xa 0 128M", """wrote 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("aio_read -P 0xa 0 128M", """read 134217728/134217728 bytes at offset 0
+128 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+"025":[
+("length", """128 MiB"""),
+("truncate 384M", """"""),
+("length", """384 MiB"""),
+],
+}
+
+io_cases_g = {
+"016":[
+("read -P 0 128M 512", """read 512/512 bytes at offset 134217728
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -P 0 256M 512", """read 512/512 bytes at offset 268435456
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write -P 66 128M 512", """wrote 512/512 bytes at offset 134217728
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -P 66 128M 512", """read 512/512 bytes at offset 134217728
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("write -P 66 256M 512", """wrote 512/512 bytes at offset 268435456
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("read -P 66 256M 512", """read 512/512 bytes at offset 268435456
+512.000000 bytes, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+}
+
+aio_cases = {
+"011":[
+("""aio_write 1M 1M
+aio_write 1536K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 2M 1M
+aio_write 2560K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 3M 1M
+aio_write 3584K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 4M 1M
+aio_write 4608K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 5M 1M
+aio_write 5632K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 6M 1M
+aio_write 6656K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 7M 1M
+aio_write 7680K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 8M 1M
+aio_write 8704K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 9M 1M
+aio_write 9728K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+("""aio_write 10M 1M
+aio_write 10752K 1M""", """wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)
+wrote 1048576/1048576 bytes at offset XXX
+1 MiB, X ops; XX:XX:XX.X (XXX YYY/sec and XXX ops/sec)"""),
+],
+}
+
+size_cases = {
+"001":128*1024*1024,
+"002":128*1024*1024,
+"003":128*1024*1024,
+"004":128*1024*1024,
+"008":128*1024*1024,
+"011":6*1024*1024*1024,
+"016":128*1024*1024,
+"025":128*1024*1024,
+}
diff --git a/tests/test_qemu_io.py b/tests/test_qemu_io.py
new file mode 100644
index 0000000..e460f4d
--- /dev/null
+++ b/tests/test_qemu_io.py
@@ -0,0 +1,84 @@
+from sheepdog_test import *
+from testcases import *
+import time
+
+def test_io():
+
+ cmd = ["qemu-io"]
+ sdog = Sheepdog()
+
+ for n in sdog.nodes:
+ n.start()
+ n.wait()
+
+ p = sdog.format()
+ p.wait()
+
+ for i in io_cases:
+ vdi = sdog.create_vdi(str(i), size_cases[i])
+ vdi.wait()
+ time.sleep(1)
+ vm = n.create_vm(vdi)
+ for j in io_cases[i]:
+ (out, err) = vm.test_io(cmd, j[0] + "\n")
+ assert out == j[1]
+ time.sleep(1)
+ print "Pass"
+ vdi.destroy()
+ vdi.wait()
+
+ p = sdog.format()
+ p.wait()
+ for n in sdog.nodes:
+ n.stop()
+
+def test_aio():
+
+ cmd = ["qemu-io"]
+ sdog = Sheepdog()
+
+ for n in sdog.nodes:
+ n.start()
+ n.wait()
+
+ p = sdog.format()
+ p.wait()
+
+ for i in aio_cases:
+ vdi = sdog.create_vdi(str(i), size_cases[i])
+ vdi.wait()
+ time.sleep(1)
+ vm = n.create_vm(vdi)
+ for j in aio_cases[i]:
+ (out, err) = vm.test_io(cmd, j[0] + "\n", async=True)
+ assert out == j[1]
+ time.sleep(1)
+ print "Pass"
+ vdi.destroy()
+ vdi.wait()
+
+def test_growable_rw():
+
+ cmd = ["qemu-io", "-g"]
+ sdog = Sheepdog()
+
+ for n in sdog.nodes:
+ n.start()
+ n.wait()
+
+ p = sdog.format()
+ p.wait()
+
+ for i in io_cases_g:
+ vdi = sdog.create_vdi(str(i), size_cases[i])
+ vdi.wait()
+ time.sleep(1)
+ vm = n.create_vm(vdi)
+ for j in io_cases_g[i]:
+ (out, err) = vm.test_io(cmd, j[0] + "\n")
+ assert out == j[1]
+ time.sleep(1)
+ print "Pass"
+ vdi.destroy()
+ vdi.wait()
+
--
1.7.6.4
More information about the sheepdog
mailing list