| /qemu/scripts/ |
| H A D | minikconf.py | 38 def __init__(self, msg): argument
39 self.msg = msg
41 def __str__(self): argument
42 return self.msg
51 def __and__(self, rhs): argument
52 return KconfigData.AND(self, rhs)
53 def __or__(self, rhs): argument
54 return KconfigData.OR(self, rhs)
55 def __invert__(self): argument
56 return KconfigData.NOT(self)
[all …]
|
| H A D | analyze-migration.py | 36 def __init__(self, filename): argument
37 self.filename = filename
38 self.file = open(self.filename, "rb")
40 def read64(self): argument
41 return int.from_bytes(self.file.read(8), byteorder='big', signed=False)
43 def read32(self): argument
44 return int.from_bytes(self.file.read(4), byteorder='big', signed=False)
46 def read16(self): argument
47 return int.from_bytes(self.file.read(2), byteorder='big', signed=False)
49 def read8(self): argument
[all …]
|
| /qemu/docs/sphinx/ |
| H A D | dbusparser.py | 24 def __init__(self, key, value): argument
25 self.key = key
26 self.value = value
27 self.annotations = []
28 self.since = ""
32 def __init__(self, name, signature): argument
33 self.name = name
34 self.signature = signature
35 self.annotations = []
36 self.doc_string = ""
[all …]
|
| /qemu/tests/qemu-iotests/ |
| H A D | 118 | 48 def process_events(self): argument
49 for event in self.vm.get_qmp_events(wait=False):
52 event['data']['id'] == self.device_name)):
54 self.has_closed = True
56 self.has_opened = True
58 def wait_for_open(self): argument
59 if not self.has_real_tray:
63 while not self.has_opened:
64 self.process_events()
66 def wait_for_close(self): argument
[all …]
|
| H A D | 040 | 39 def wait_for_complete(self, need_ready=False): argument
43 for event in self.vm.get_qmp_events(wait=True):
45 self.assert_qmp_absent(event, 'data/error')
46 self.assert_qmp(event, 'data/type', 'commit')
47 self.assert_qmp(event, 'data/device', 'drive0')
48 self.assert_qmp(event, 'data/offset', event['data']['len'])
50 self.assertTrue(ready, "Expecting BLOCK_JOB_COMPLETED event")
54 self.assert_qmp(event, 'data/type', 'commit')
55 self.assert_qmp(event, 'data/device', 'drive0')
56 self.vm.qmp('block-job-complete', device='drive0')
[all …]
|
| H A D | 055 | 49 def setUp(self): argument
52 self.vm = iotests.VM()
53 self.vm.add_drive('blkdebug::' + test_img, 'node-name=source')
54 self.vm.add_drive(blockdev_target_img, 'node-name=target',
57 self.vm.add_drive(None, 'media=cdrom', 'ide')
58 self.vm.launch()
60 def tearDown(self): argument
61 self.vm.shutdown()
68 def do_test_cancel(self, cmd, target): argument
69 self.assert_no_active_block_jobs()
[all …]
|
| H A D | 041 | 47 def setUp(self): argument
48 iotests.create_image(backing_img, self.image_len)
51 self.vm = iotests.VM().add_drive(test_img, "node-name=top,backing.node-name=base")
53 self.vm.add_drive(None, 'media=cdrom', 'ide')
54 self.vm.launch()
56 def tearDown(self): argument
57 self.vm.shutdown()
65 def test_complete(self): argument
66 self.assert_no_active_block_jobs()
68 self.vm.cmd(self.qmp_cmd, device='drive0', sync='full',
[all …]
|
| H A D | 030 | 35 def setUp(self): argument
45 self.vm = iotests.VM().add_drive("blkdebug::" + test_img,
48 self.vm.launch()
50 def tearDown(self): argument
51 self.vm.shutdown()
56 def test_stream(self): argument
57 self.assert_no_active_block_jobs()
59 self.vm.cmd('block-stream', device='drive0')
61 self.wait_until_completed()
63 self.assert_no_active_block_jobs()
[all …]
|
| H A D | 300 | 41 def setUp(self) -> None: argument
42 self.vm_a = iotests.VM(path_suffix='-a')
43 self.vm_a.add_blockdev(f'node-name={self.src_node_name},'
45 self.vm_a.launch()
47 self.vm_b = iotests.VM(path_suffix='-b')
48 self.vm_b.add_blockdev(f'node-name={self.dst_node_name},'
50 self.vm_b.add_incoming(f'unix:{mig_sock}')
51 self.vm_b.launch()
53 self.vm_a.cmd('block-dirty-bitmap-add',
54 node=self.src_node_name,
[all …]
|
| H A D | 139 | 32 def setUp(self): argument
34 self.vm = iotests.VM()
35 self.vm.add_device("{},id=virtio-scsi".format('virtio-scsi'))
36 self.vm.launch()
38 def tearDown(self): argument
39 self.vm.shutdown()
45 def checkBlockDriverState(self, node, must_exist = True): argument
46 result = self.vm.qmp('query-named-block-nodes')
48 self.assertLessEqual(len(nodes), 1)
49 self.assertEqual(must_exist, len(nodes) == 1)
[all …]
|
| H A D | 136 | 49 def blockstats(self, device): argument
50 result = self.vm.qmp("query-blockstats")
56 def create_blkdebug_file(self): argument
71 def required_drivers(self): argument
72 return [self.test_driver]
75 def setUp(self): argument
79 (self.account_invalid and "on" or "off"))
81 (self.account_failed and "on" or "off"))
83 self.create_blkdebug_file()
84 self.vm = iotests.VM().add_drive('blkdebug:%s:%s://' %
[all …]
|
| H A D | qcow2_format.py | 26 def default(self, obj): argument
30 return json.JSONEncoder.default(self, obj)
35 def __init__(self, value): argument
36 self.value = value
38 def __str__(self): argument
39 return str(self.value)
44 def __str__(self): argument
47 if self.value & (1 << bit):
59 def __str__(self): argument
62 flag = self.value & (1 << bit)
[all …]
|
| H A D | fat16.py | 29 def __init__(self, data: bytes): argument
31 self.partition_table = []
34 self.partition_table.append(
51 def __str__(self): argument
55 for i, partition in enumerate(self.partition_table)
62 def __init__(self, data: bytes): argument
64 self.bytes_per_sector = int.from_bytes(data[11:13], "little")
65 self.sectors_per_cluster = data[13]
66 self.reserved_sectors = int.from_bytes(data[14:16], "little")
67 self.fat_count = data[16]
[all …]
|
| H A D | 124 | 53 def __init__(self, name, drive): argument
54 self.name = name
55 self.drive = drive
56 self.num = 0
57 self.backups = list()
59 def base_target(self): argument
60 return (self.drive['backup'], None)
62 def new_target(self, num=None): argument
64 num = self.num
65 self.num = num + 1
[all …]
|
| /qemu/tests/functional/ |
| H A D | test_ppc_74xx.py | 17 def test_ppc_7400(self): argument
18 self.require_accelerator("tcg")
19 self.set_machine('g3beige')
20 self.vm.set_console()
21 self.vm.add_args('-cpu', '7400')
22 self.vm.launch()
23 wait_for_console_pattern(self, '>> OpenBIOS')
24 wait_for_console_pattern(self, '>> CPU type PowerPC,G4')
26 def test_ppc_7410(self): argument
27 self.require_accelerator("tcg")
[all …]
|
| H A D | test_s390x_topology.py | 57 def wait_until_booted(self): argument
58 wait_for_console_pattern(self, 'no job control',
62 def check_topology(self, c, s, b, d, e, t): argument
63 res = self.vm.qmp('query-cpus-fast')
73 self.assertEqual(drawer, d)
74 self.assertEqual(book, b)
75 self.assertEqual(socket, s)
76 self.assertEqual(entitlement, e)
77 self.assertEqual(dedicated, t)
79 def kernel_init(self): argument
[all …]
|
| H A D | test_aarch64_smmu.py | 35 def set_up_boot(self, path): argument
36 self.vm.add_args('-device', 'virtio-blk-pci,bus=pcie.0,' +
38 'werror=stop,rerror=stop' + self.IOMMU_ADDON)
39 self.vm.add_args('-drive',
42 self.vm.add_args('-netdev',
44 self.GUEST_PORT)
45 self.vm.add_args('-device', 'virtio-net,netdev=n1' + self.IOMMU_ADDON)
47 def common_vm_setup(self, kernel, initrd, disk): argument
48 self.require_accelerator("kvm")
49 self.require_netdev('user')
[all …]
|
| /qemu/scripts/qapi/ |
| H A D | schema.py | 51 self, argument
54 self.ifcond = ifcond
56 def _cgen(self) -> str: argument
57 return cgen_ifcond(self.ifcond)
59 def gen_if(self) -> str: argument
60 return gen_if(self._cgen())
62 def gen_endif(self) -> str: argument
63 return gen_endif(self._cgen())
65 def docgen(self) -> str: argument
66 return docgen_ifcond(self.ifcond)
[all …]
|
| H A D | parser.py | 49 def __init__(self, argument
54 self.info = info
55 self.doc: Optional['QAPIDoc'] = doc
60 def __init__(self, parser: 'QAPISchemaParser', msg: str): argument
92 def __init__(self, argument
96 self._fname = fname
97 self._included = previously_included or set()
98 self._included.add(os.path.abspath(self._fname))
99 self.src = ''
102 self.info = QAPISourceInfo(self._fname, incl_info)
[all …]
|
| H A D | gen.py | 51 def __init__(self, fname: str): argument
52 self.fname = fname
53 self._preamble = ''
54 self._body = ''
56 def preamble_add(self, text: str) -> None: argument
57 self._preamble += text
59 def add(self, text: str) -> None: argument
60 self._body += text
62 def get_content(self) -> str: argument
63 return self._top() + self._preamble + self._body + self._bottom()
[all …]
|
| /qemu/tests/functional/acpi-bits/bits-tests/ |
| H A D | smbios.py2 | 69 def __init__(self):
70 super(SMBIOS, self).__init__()
71 u = unpack.Unpackable(self._header_memory)
72 self.add_field('header', Header(u))
73 …self._structure_memory = bits.memory(self.header.structure_table_address, self.header.structure_ta…
74 u = unpack.Unpackable(self._structure_memory)
75 …self.add_field('structures', unpack.unpack_all(u, _smbios_structures, self), unpack.format_each("\…
77 def structure_type(self, num):
80 … types_present = [self.structures[x].smbios_structure_type for x in range(len(self.structures))]
84 matrix[types_present[index]] = self.structures[index]
[all …]
|
| /qemu/tests/vm/ |
| H A D | netbsd | 85 def build_image(self, img): argument
86 cimg = self._download_with_cache(self.link, sha512sum=self.csum)
90 self.print_step("Preparing iso and disk image")
92 self.exec_qemu_img("create", "-f", "qcow2", img_tmp, self.size)
94 self.print_step("Booting installer")
95 self.boot(img_tmp, extra_args = [
99 self.console_init()
100 self.console_wait_send("3. Drop to boot prompt", "3")
101 self.console_wait_send("> ", "consdev com0\n")
102 self.console_wait_send("> ", "boot\n")
[all …]
|
| H A D | openbsd | 78 def build_image(self, img): argument
79 self.print_step("Downloading install iso")
80 cimg = self._download_with_cache(self.link, sha256sum=self.csum)
84 self.print_step("Preparing iso and disk image")
86 self.exec_qemu_img("create", "-f", "qcow2", img_tmp, self.size)
88 self.print_step("Booting installer")
89 self.boot(img_tmp, extra_args = [
94 self.console_init()
95 self.console_wait_send("boot>", "set tty com0\n")
96 self.console_wait_send("boot>", "\n")
[all …]
|
| /qemu/python/tests/ |
| H A D | protocol.py | 35 def __init__(self, name=None): argument
36 self.fake_session = False
37 self.trigger_input: asyncio.Event
40 async def _establish_session(self): argument
41 self.trigger_input = asyncio.Event()
44 async def _do_start_server(self, address, ssl=None): argument
45 if self.fake_session:
46 self._accepted = asyncio.Event()
47 self._set_state(Runstate.CONNECTING)
52 async def _do_accept(self): argument
[all …]
|
| /qemu/python/qemu/machine/ |
| H A D | machine.py | 76 def __init__(self, exitcode: Optional[int], argument
79 self.exitcode = exitcode
80 self.command = command
81 self.output = output
83 def __str__(self) -> str: argument
85 if self.__cause__ is not None:
86 name = type(self.__cause__).__name__
87 reason = str(self.__cause__)
94 if self.exitcode is not None:
95 ret += f"\tExit code: {self.exitcode}\n"
[all …]
|