Home
last modified time | relevance | path

Searched refs:iothread (Results 1 – 25 of 64) sorted by relevance

123

/openbmc/qemu/tests/unit/
H A Diothread.c33 static void iothread_init_gcontext(IOThread *iothread) in iothread_init_gcontext() argument
37 iothread->worker_context = g_main_context_new(); in iothread_init_gcontext()
38 source = aio_get_g_source(iothread_get_aio_context(iothread)); in iothread_init_gcontext()
39 g_source_attach(source, iothread->worker_context); in iothread_init_gcontext()
41 iothread->main_loop = g_main_loop_new(iothread->worker_context, TRUE); in iothread_init_gcontext()
46 IOThread *iothread = opaque; in iothread_run() local
50 qemu_mutex_lock(&iothread->init_done_lock); in iothread_run()
51 iothread->ctx = aio_context_new(&error_abort); in iothread_run()
52 qemu_set_current_aio_context(iothread->ctx); in iothread_run()
59 iothread_init_gcontext(iothread); in iothread_run()
[all …]
H A Diothread.h22 void iothread_join(IOThread *iothread);
23 AioContext *iothread_get_aio_context(IOThread *iothread);
H A Dtest-block-iothread.c468 IOThread *iothread = iothread_new(); in test_sync_op() local
469 AioContext *ctx = iothread_get_aio_context(iothread); in test_sync_op()
551 IOThread *iothread = iothread_new(); in test_attach_blockjob() local
552 AioContext *ctx = iothread_get_aio_context(iothread); in test_attach_blockjob()
614 IOThread *iothread = iothread_new(); in test_propagate_basic() local
615 AioContext *ctx = iothread_get_aio_context(iothread); in test_propagate_basic()
678 IOThread *iothread = iothread_new(); in test_propagate_diamond() local
679 AioContext *ctx = iothread_get_aio_context(iothread); in test_propagate_diamond()
743 IOThread *iothread = iothread_new(); in test_propagate_mirror() local
744 AioContext *ctx = iothread_get_aio_context(iothread); in test_propagate_mirror()
[all …]
/openbmc/qemu/
H A Diothread.c41 IOThread *iothread = opaque; in iothread_run() local
48 g_main_context_push_thread_default(iothread->worker_context); in iothread_run()
49 qemu_set_current_aio_context(iothread->ctx); in iothread_run()
50 iothread->thread_id = qemu_get_thread_id(); in iothread_run()
51 qemu_sem_post(&iothread->init_done_sem); in iothread_run()
53 while (iothread->running) { in iothread_run()
63 aio_poll(iothread->ctx, true); in iothread_run()
69 if (iothread->running && qatomic_read(&iothread->run_gcontext)) { in iothread_run()
70 g_main_loop_run(iothread->main_loop); in iothread_run()
74 g_main_context_pop_thread_default(iothread->worker_context); in iothread_run()
[all …]
/openbmc/qemu/include/system/
H A Diothread.h47 char *iothread_get_id(IOThread *iothread);
49 AioContext *iothread_get_aio_context(IOThread *iothread);
50 GMainContext *iothread_get_g_main_context(IOThread *iothread);
58 void iothread_stop(IOThread *iothread);
59 void iothread_destroy(IOThread *iothread);
/openbmc/qemu/hw/virtio/
H A Diothread-vq-mapping.c22 const char *name = node->value->iothread; in iothread_vq_mapping_validate()
94 IOThread *iothread = iothread_by_id(node->value->iothread); in iothread_vq_mapping_apply() local
95 AioContext *ctx = iothread_get_aio_context(iothread); in iothread_vq_mapping_apply()
98 object_ref(OBJECT(iothread)); in iothread_vq_mapping_apply()
127 IOThread *iothread = iothread_by_id(node->value->iothread); in iothread_vq_mapping_cleanup() local
128 object_unref(OBJECT(iothread)); in iothread_vq_mapping_cleanup()
/openbmc/qemu/tests/qemu-iotests/
H A D240.out4 {"execute": "object-add", "arguments": {"id": "iothread0", "qom-type": "iothread"}}
6 {"execute": "device_add", "arguments": {"driver": "virtio-scsi", "id": "scsi0", "iothread": "iothre…
18 .==Attach two SCSI disks using the same block device and the same iothread==
21 {"execute": "object-add", "arguments": {"id": "iothread0", "qom-type": "iothread"}}
23 {"execute": "device_add", "arguments": {"driver": "virtio-scsi", "id": "scsi0", "iothread": "iothre…
38 {"execute": "object-add", "arguments": {"id": "iothread0", "qom-type": "iothread"}}
40 {"execute": "object-add", "arguments": {"id": "iothread1", "qom-type": "iothread"}}
42 {"execute": "device_add", "arguments": {"driver": "virtio-scsi", "id": "scsi0", "iothread": "iothre…
44 {"execute": "device_add", "arguments": {"driver": "virtio-scsi", "id": "scsi1", "iothread": "iothre…
63 {"execute": "object-add", "arguments": {"id": "iothread0", "qom-type": "iothread"}}
[all …]
H A D24045 …self.vm.qmp_log('device_add', id='scsi0', driver='virtio-scsi', iothread='iothread0', filters=[iot…
58 …self.vm.qmp_log('device_add', id='scsi0', driver='virtio-scsi', iothread='iothread0', filters=[iot…
76 …self.vm.qmp_log('device_add', id='scsi0', driver='virtio-scsi', iothread='iothread0', filters=[iot…
77 …self.vm.qmp_log('device_add', id='scsi1', driver='virtio-scsi', iothread='iothread1', filters=[iot…
100 …self.vm.qmp_log('device_add', id='scsi0', driver='virtio-scsi', iothread='iothread0', filters=[iot…
H A D20348 node_name='drive0-node', iothread='iothread0',
51 node_name='drive1-node', iothread='iothread0',
H A D223113 _launch_qemu -object iothread,id=io0 2> >(_filter_nbd)
129 for attempt in normal iothread; do
134 if [ $attempt = iothread ]; then
H A D20268 iothread='iothread0'))
71 iothread='iothread0'))
H A D051191 echo === Attach to node in non-default iothread ===
196 …iothread="-drive file=$TEST_IMG,if=none,node-name=disk -object iothread,id=thread0 -device virtio-…
199 run_qemu $iothread -device ide-hd,drive=disk,share-rw=on
200 run_qemu $iothread -device virtio-blk-pci,drive=disk,share-rw=on
201 … run_qemu $iothread -device lsi53c895a,id=lsi0 -device scsi-hd,bus=lsi0.0,drive=disk,share-rw=on
202 …run_qemu $iothread -device virtio-scsi,id=virtio-scsi1 -device scsi-hd,bus=virtio-scsi1.0,drive=di…
207 run_qemu $iothread -device virtio-blk-pci,drive=disk,iothread=thread0,share-rw=on
208 …run_qemu $iothread -device virtio-scsi,id=virtio-scsi1,iothread=thread0 -device scsi-hd,bus=virtio…
H A D12764 -object iothread,id=iothr \
66 -device virtio-scsi,id=scsi-bus,iothread=iothr \
H A D28150 node_name='drive0', iothread='iothread0',
86 node_name='drive0', iothread='iothread0',
96 node_name='drive0', iothread='iothread0',
151 node_name='drive0', iothread='iothread0',
301 node_name='nbd', iothread='iothr')
H A D068.out14 … reloading a VM state to/from a qcow2 image (-object iothread,id=iothread0 -set device.hba0.iothre…
H A D307.out39 === Move export to an iothread ===
56 === Add export with conflicting iothread ===
59 {"execute": "block-export-add", "arguments": {"fixed-iothread": true, "id": "export1", "iothread": …
60 {"error": {"class": "GenericError", "desc": "Cannot change iothread of active block backend"}}
61 {"execute": "block-export-add", "arguments": {"fixed-iothread": false, "id": "export1", "iothread":…
/openbmc/qemu/hw/remote/
H A Dmpqemu-link.c37 bool iothread = qemu_in_iothread(); in mpqemu_msg_send() local
58 assert(qemu_in_coroutine() || !iothread); in mpqemu_msg_send()
66 if (drop_bql && !iothread && !qemu_in_coroutine()) { in mpqemu_msg_send()
77 if (drop_bql && !iothread && !qemu_in_coroutine()) { in mpqemu_msg_send()
100 bool iothread = qemu_in_iothread(); in mpqemu_read() local
107 assert(qemu_in_coroutine() || !iothread); in mpqemu_read()
109 if (drop_bql && !iothread && !qemu_in_coroutine()) { in mpqemu_read()
115 if (drop_bql && !iothread && !qemu_in_coroutine()) { in mpqemu_read()
/openbmc/qemu/hw/block/
H A Dxen-block.c426 blockdev->props.iothread); in xen_block_realize()
678 DEFINE_PROP_LINK("iothread", XenBlockDevice, props.iothread,
991 static void xen_block_iothread_destroy(XenBlockIOThread *iothread, in xen_block_iothread_destroy() argument
994 qmp_object_del(iothread->id, errp); in xen_block_iothread_destroy()
996 g_free(iothread->id); in xen_block_iothread_destroy()
997 g_free(iothread); in xen_block_iothread_destroy()
1004 XenBlockIOThread *iothread = g_new(XenBlockIOThread, 1); in xen_block_iothread_create() local
1007 iothread->id = g_strdup(id); in xen_block_iothread_create()
1018 g_free(iothread->id); in xen_block_iothread_create()
1019 g_free(iothread); in xen_block_iothread_create()
[all …]
/openbmc/qemu/hw/scsi/
H A Dvirtio-scsi-dataplane.c32 if (vs->conf.iothread && vs->conf.iothread_vq_mapping_list) { in virtio_scsi_dataplane_setup()
39 if (vs->conf.iothread || vs->conf.iothread_vq_mapping_list) { in virtio_scsi_dataplane_setup()
75 } else if (vs->conf.iothread) { in virtio_scsi_dataplane_setup()
76 AioContext *ctx = iothread_get_aio_context(vs->conf.iothread); in virtio_scsi_dataplane_setup()
82 object_ref(OBJECT(vs->conf.iothread)); in virtio_scsi_dataplane_setup()
100 if (vs->conf.iothread) { in virtio_scsi_dataplane_cleanup()
101 object_unref(OBJECT(vs->conf.iothread)); in virtio_scsi_dataplane_cleanup()
/openbmc/qemu/block/export/
H A Dexport.c119 if (export->iothread) { in blk_exp_add()
120 IOThread *iothread; in blk_exp_add() local
124 iothread = iothread_by_id(export->iothread); in blk_exp_add()
125 if (!iothread) { in blk_exp_add()
126 error_setg(errp, "iothread \"%s\" not found", export->iothread); in blk_exp_add()
130 new_ctx = iothread_get_aio_context(iothread); in blk_exp_add()
/openbmc/qemu/scripts/qemugdb/
H A Dtcg.py28 iothread = gdb.parse_and_eval("iothread_locked")
42 iothread, replay, blocked))
/openbmc/qemu/tests/qemu-iotests/tests/
H A Diothreads-resize60 -object iothread,id=t0 \
61 -device virtio-scsi-pci,iothread=t0 \
H A Dqcow2-internal-snapshots54 -object iothread,id=iothread0 \
55 -device virtio-scsi,iothread=iothread0 \
/openbmc/qemu/include/hw/xen/
H A Dxen-block.h38 IOThread *iothread; member
57 XenBlockIOThread *iothread; member
/openbmc/qemu/hw/block/dataplane/
H A Dxen-block.c66 IOThread *iothread; member
612 IOThread *iothread) in xen_block_dataplane_create() argument
623 if (iothread) { in xen_block_dataplane_create()
624 dataplane->iothread = iothread; in xen_block_dataplane_create()
625 object_ref(OBJECT(dataplane->iothread)); in xen_block_dataplane_create()
626 dataplane->ctx = iothread_get_aio_context(dataplane->iothread); in xen_block_dataplane_create()
654 if (dataplane->iothread) { in xen_block_dataplane_destroy()
655 object_unref(OBJECT(dataplane->iothread)); in xen_block_dataplane_destroy()

123