xref: /openbmc/qemu/tests/qemu-iotests/148 (revision b917da4c) 
1#!/usr/bin/env python
2#
3# Test the rate limit of QMP events
4#
5# Copyright (C) 2016 Igalia, S.L.
6# Author: Alberto Garcia <berto@igalia.com>
7#
8# This program is free software; you can redistribute it and/or modify
9# it under the terms of the GNU General Public License as published by
10# the Free Software Foundation; either version 2 of the License, or
11# (at your option) any later version.
12#
13# This program is distributed in the hope that it will be useful,
14# but WITHOUT ANY WARRANTY; without even the implied warranty of
15# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16# GNU General Public License for more details.
17#
18# You should have received a copy of the GNU General Public License
19# along with this program.  If not, see <http://www.gnu.org/licenses/>.
20#
21
22import os
23import iotests
24
25imgs = (os.path.join(iotests.test_dir, 'quorum0.img'),
26        os.path.join(iotests.test_dir, 'quorum1.img'),
27        os.path.join(iotests.test_dir, 'quorum2.img'))
28
29img_conf = (os.path.join(iotests.test_dir, 'quorum0.conf'),
30            os.path.join(iotests.test_dir, 'quorum1.conf'),
31            os.path.join(iotests.test_dir, 'quorum2.conf'))
32
33event_rate = 1000000000
34sector_size = 512
35offset = 10
36
37class TestQuorumEvents(iotests.QMPTestCase):
38
39    def create_blkdebug_file(self, blkdebug_file, bad_sector):
40        file = open(blkdebug_file, 'w')
41        file.write('''
42[inject-error]
43event = "read_aio"
44errno = "5"
45sector = "%d"
46''' % bad_sector)
47        file.close()
48
49    def setUp(self):
50        driveopts = ['driver=quorum', 'vote-threshold=2']
51        for i in range(len(imgs)):
52            iotests.qemu_img('create', '-f', iotests.imgfmt, imgs[i], '1M')
53            self.create_blkdebug_file(img_conf[i], i + offset)
54            driveopts.append('children.%d.driver=%s' % (i, iotests.imgfmt))
55            driveopts.append('children.%d.file.driver=blkdebug' % i)
56            driveopts.append('children.%d.file.config=%s' % (i, img_conf[i]))
57            driveopts.append('children.%d.file.image.filename=%s' % (i, imgs[i]))
58            driveopts.append('children.%d.node-name=img%d' % (i, i))
59        self.vm = iotests.VM()
60        self.vm.add_drive(None, opts = ','.join(driveopts))
61        self.vm.launch()
62
63    def tearDown(self):
64        self.vm.shutdown()
65        for i in range(len(imgs)):
66            os.remove(imgs[i])
67            os.remove(img_conf[i])
68
69    def do_check_event(self, node, sector = 0):
70        if node == None:
71            self.assertEqual(self.vm.get_qmp_event(), None)
72            return
73
74        for event in self.vm.get_qmp_events(wait=True):
75            if event['event'] == 'QUORUM_REPORT_BAD':
76                self.assert_qmp(event, 'data/node-name', node)
77                self.assert_qmp(event, 'data/sector-num', sector)
78
79    def testQuorum(self):
80        if not 'quorum' in iotests.qemu_img_pipe('--help'):
81            return
82
83        # Generate an error and get an event
84        self.vm.hmp_qemu_io("drive0", "aio_read %d %d" %
85                            (offset * sector_size, sector_size))
86        self.vm.qtest("clock_step 10")
87        self.do_check_event('img0', offset)
88
89        # I/O errors in the same child: only one event is emitted
90        delay = 10
91        for i in range(3):
92            self.vm.hmp_qemu_io("drive0", "aio_read %d %d" %
93                                (offset * sector_size, sector_size))
94            self.vm.qtest("clock_step %d" % delay)
95            self.do_check_event(None)
96
97        # Wait enough so the event is finally emitted
98        self.vm.qtest("clock_step %d" % (2 * event_rate))
99        self.do_check_event('img0', offset)
100
101        # I/O errors in the same child: all events are emitted
102        delay = 2 * event_rate
103        for i in range(3):
104            self.vm.hmp_qemu_io("drive0", "aio_read %d %d" %
105                                (offset * sector_size, sector_size))
106            self.vm.qtest("clock_step %d" % delay)
107            self.do_check_event('img0', offset)
108
109        # I/O errors in different children: all events are emitted
110        delay = 10
111        for i in range(len(imgs)):
112            self.vm.hmp_qemu_io("drive0", "aio_read %d %d" %
113                                ((offset + i) * sector_size, sector_size))
114            self.vm.qtest("clock_step %d" % delay)
115            self.do_check_event('img%d' % i, offset + i)
116
117        # I/O errors in different children: all events are emitted
118        delay = 2 * event_rate
119        for i in range(len(imgs)):
120            self.vm.hmp_qemu_io("drive0", "aio_read %d %d" %
121                                ((offset + i) * sector_size, sector_size))
122            self.vm.qtest("clock_step %d" % delay)
123            self.do_check_event('img%d' % i, offset + i)
124
125        # No more pending events
126        self.do_check_event(None)
127
128if __name__ == '__main__':
129    iotests.main(supported_fmts=["raw"])
130