Home
last modified time | relevance | path

Searched refs:co (Results 1 – 25 of 278) sorted by relevance

12345678910>>...12

/openbmc/qemu/util/
H A Dcoroutine-ucontext.c88 void on_new_fiber(CoroutineUContext *co) in on_new_fiber() argument
91 co->tsan_co_fiber = __tsan_create_fiber(0); /* flags: sync on switch */ in on_new_fiber()
92 co->tsan_caller_fiber = __tsan_get_current_fiber(); in on_new_fiber()
133 CoroutineUContext *co, in start_switch_fiber_tsan() argument
138 co->tsan_caller_fiber : in start_switch_fiber_tsan()
139 co->tsan_co_fiber; in start_switch_fiber_tsan()
152 Coroutine *co; in coroutine_trampoline() local
160 co = &self->base; in coroutine_trampoline()
169 siglongjmp(*(sigjmp_buf *)co->entry_arg, 1); in coroutine_trampoline()
175 co->entry(co->entry_arg); in coroutine_trampoline()
[all …]
H A Dcoroutine-wasm.c50 Coroutine *co = co_; in coroutine_trampoline() local
53 co->entry(co->entry_arg); in coroutine_trampoline()
54 qemu_coroutine_switch(co, co->caller, COROUTINE_TERMINATE); in coroutine_trampoline()
60 CoroutineEmscripten *co; in qemu_coroutine_new() local
62 co = g_malloc0(sizeof(*co)); in qemu_coroutine_new()
64 co->stack_size = COROUTINE_STACK_SIZE; in qemu_coroutine_new()
65 co->stack = qemu_alloc_stack(&co->stack_size); in qemu_coroutine_new()
67 co->asyncify_stack_size = COROUTINE_STACK_SIZE; in qemu_coroutine_new()
68 co->asyncify_stack = g_malloc0(co->asyncify_stack_size); in qemu_coroutine_new()
69 emscripten_fiber_init(&co->fiber, coroutine_trampoline, &co->base, in qemu_coroutine_new()
[all …]
H A Dqemu-coroutine.c81 Coroutine *co; in coroutine_pool_batch_delete() local
84 QSLIST_FOREACH_SAFE(co, &batch->list, pool_next, tmp) { in coroutine_pool_batch_delete()
86 qemu_coroutine_delete(co); in coroutine_pool_batch_delete()
118 Coroutine *co; in coroutine_pool_get_local() local
124 co = QSLIST_FIRST(&batch->list); in coroutine_pool_get_local()
132 return co; in coroutine_pool_get_local()
179 Coroutine *co; in coroutine_pool_get() local
181 co = coroutine_pool_get_local(); in coroutine_pool_get()
182 if (!co) { in coroutine_pool_get()
184 co = coroutine_pool_get_local(); in coroutine_pool_get()
[all …]
H A Dcoroutine-sigaltstack.c96 static void coroutine_bootstrap(CoroutineSigAltStack *self, Coroutine *co) in coroutine_bootstrap() argument
100 siglongjmp(*(sigjmp_buf *)co->entry_arg, 1); in coroutine_bootstrap()
104 co->entry(co->entry_arg); in coroutine_bootstrap()
105 qemu_coroutine_switch(co, co->caller, COROUTINE_TERMINATE); in coroutine_bootstrap()
117 Coroutine *co; in coroutine_trampoline() local
124 co = &self->base; in coroutine_trampoline()
145 coroutine_bootstrap(self, co); in coroutine_trampoline()
150 CoroutineSigAltStack *co; in qemu_coroutine_new() local
170 co = g_malloc0(sizeof(*co)); in qemu_coroutine_new()
171 co->stack_size = COROUTINE_STACK_SIZE; in qemu_coroutine_new()
[all …]
H A Dcoroutine-windows.c64 Coroutine *co = co_; in coroutine_trampoline() local
67 co->entry(co->entry_arg); in coroutine_trampoline()
68 qemu_coroutine_switch(co, co->caller, COROUTINE_TERMINATE); in coroutine_trampoline()
75 CoroutineWin32 *co; in qemu_coroutine_new() local
77 co = g_malloc0(sizeof(*co)); in qemu_coroutine_new()
78 co->fiber = CreateFiber(stack_size, coroutine_trampoline, &co->base); in qemu_coroutine_new()
79 return &co->base; in qemu_coroutine_new()
84 CoroutineWin32 *co = DO_UPCAST(CoroutineWin32, base, co_); in qemu_coroutine_delete() local
86 DeleteFiber(co->fiber); in qemu_coroutine_delete()
87 g_free(co); in qemu_coroutine_delete()
H A Dqemu-coroutine-sleep.c23 Coroutine *co; in qemu_co_sleep_wake() local
25 co = w->to_wake; in qemu_co_sleep_wake()
27 if (co) { in qemu_co_sleep_wake()
29 const char *scheduled = qatomic_cmpxchg(&co->scheduled, in qemu_co_sleep_wake()
33 aio_co_wake(co); in qemu_co_sleep_wake()
45 Coroutine *co = qemu_coroutine_self(); in qemu_co_sleep() local
47 const char *scheduled = qatomic_cmpxchg(&co->scheduled, NULL, in qemu_co_sleep()
56 w->to_wake = co; in qemu_co_sleep()
H A Dqemu-coroutine-lock.c138 Coroutine *co; member
144 w->co = qemu_coroutine_self(); in push_waiter()
184 static void coroutine_fn qemu_co_mutex_wake(CoMutex *mutex, Coroutine *co) in qemu_co_mutex_wake() argument
190 mutex->ctx = co->ctx; in qemu_co_mutex_wake()
191 aio_co_wake(co); in qemu_co_mutex_wake()
221 Coroutine *co = to_wake->co; in qemu_co_mutex_lock_slowpath() local
222 if (co == self) { in qemu_co_mutex_lock_slowpath()
229 qemu_co_mutex_wake(mutex, co); in qemu_co_mutex_lock_slowpath()
299 qemu_co_mutex_wake(mutex, to_wake->co); in qemu_co_mutex_unlock()
334 Coroutine *co; member
[all …]
H A Dasync.c535 Coroutine *co = QSLIST_FIRST(&reversed); in aio_context_notifier_poll()
537 QSLIST_INSERT_HEAD(&straight, co, co_scheduled_next); in aio_context_notifier_poll()
541 Coroutine *co = QSLIST_FIRST(&straight); in aio_context_notifier_poll()
543 trace_aio_co_schedule_bh_cb(ctx, co); in aio_context_notifier_poll()
546 qatomic_set(&co->scheduled, NULL); in aio_context_notifier_poll()
547 qemu_aio_coroutine_enter(ctx, co);
626 void aio_co_schedule(AioContext *ctx, Coroutine *co) in aio_context_new()
628 trace_aio_co_schedule(ctx, co); in aio_context_new()
629 const char *scheduled = qatomic_cmpxchg(&co->scheduled, NULL, in aio_context_new()
646 co, co_scheduled_nex in aio_co_schedule()
562 Coroutine *co = QSLIST_FIRST(&reversed); co_schedule_bh_cb() local
568 Coroutine *co = QSLIST_FIRST(&straight); co_schedule_bh_cb() local
632 aio_co_schedule(AioContext * ctx,Coroutine * co) aio_co_schedule() argument
659 Coroutine *co; global() member
688 aio_co_wake(Coroutine * co) aio_co_wake() argument
701 aio_co_enter(AioContext * ctx,Coroutine * co) aio_co_enter() argument
[all...]
H A Dqemu-co-timeout.c61 Coroutine *co; in qemu_co_timeout() local
75 co = qemu_coroutine_create(qemu_co_timeout_entry, s); in qemu_co_timeout()
77 aio_co_enter(qemu_get_current_aio_context(), co); in qemu_co_timeout()
H A Dqemu-coroutine-io.c70 Coroutine *co; member
78 qemu_coroutine_enter(data->co); in fd_coroutine_enter()
87 data.co = qemu_coroutine_self(); in yield_until_fd_readable()
/openbmc/qemu/tests/qemu-iotests/
H A D186.out57 Testing: -blockdev driver=null-co,read-zeroes=on,node-name=null -device ide-hd,drive=null
60 null: json:{"read-zeroes": true, "driver": "null-co"} (null-co)
65 Testing: -blockdev driver=null-co,read-zeroes=on,node-name=null -device ide-hd,drive=null,id=qdev_id
68 null: json:{"read-zeroes": true, "driver": "null-co"} (null-co)
73 Testing: -blockdev driver=null-co,read-zeroes=on,node-name=null -device scsi-hd,drive=null
76 null: json:{"read-zeroes": true, "driver": "null-co"} (null-co)
81 Testing: -blockdev driver=null-co,read-zeroes=on,node-name=null -device scsi-hd,drive=null,id=qdev_…
84 null: json:{"read-zeroes": true, "driver": "null-co"} (null-co)
89 Testing: -blockdev driver=null-co,read-zeroes=on,node-name=null -device virtio-blk-pci,drive=null
92 null: json:{"read-zeroes": true, "driver": "null-co"} (null-co)
[all …]
H A D18642 _require_drivers null-co
92 check_info_block -blockdev driver=null-co,read-zeroes=on,node-name=null -device $dev,drive=null
93 …check_info_block -blockdev driver=null-co,read-zeroes=on,node-name=null -device $dev,drive=null,id…
103 …check_info_block -drive if=none,driver=null-co,read-zeroes=on,node-name=null -device $dev,drive=nu…
111 …check_info_block -drive if=none,driver=null-co,read-zeroes=on,node-name=null -device $dev,drive=no…
112 …check_info_block -drive if=none,driver=null-co,read-zeroes=on,node-name=null -device $dev,drive=no…
131 check_info_block -drive if=floppy,driver=null-co,read-zeroes=on
133 check_info_block -drive if=ide,driver=null-co,read-zeroes=on
135 check_info_block -drive if=ide,driver=null-co,read-zeroes=on,media=cdrom
137 check_info_block -drive if=virtio,driver=null-co,read-zeroes=on
[all …]
H A D22763 run_qemu -drive driver=null-co,read-zeroes=on,if=virtio <<EOF
73 run_qemu -drive driver=null-co,if=none <<EOF
83 run_qemu -blockdev driver=null-co,node-name=null <<EOF
93 run_qemu -blockdev driver=null-co,read-zeroes=on,node-name=null -device virtio-blk,drive=null,id=vi…
H A D224.out4 {"execute": "blockdev-add", "arguments": {"backing": {"backing": {"backing": {"driver": "null-co"},…
6 …co\"}, \"driver\": \"IMGFMT\", \"file\": {\"driver\": \"file\", \"filename\": \"TEST_DIR/PID-base.…
13 {"execute": "blockdev-add", "arguments": {"backing": {"backing": {"backing": {"driver": "null-co"},…
15 …co\"}, \"driver\": \"IMGFMT\", \"file\": {\"driver\": \"file\", \"filename\": \"TEST_DIR/PID-base.…
H A D184.out33 "filename": "null-co://",
34 "format": "null-co",
38 "filename": "json:{\"throttle-group\": \"group0\", \"driver\": \"throttle\", \"file\": {\"driver\": \"null-co\"}}",
58 "file": "json:{\"throttle-group\": \"group0\", \"driver\": \"throttle\", \"file\": {\"driver\": \"null-co\"}}"
66 "filename": "null-co://",
67 "format": "null-co",
74 "drv": "null-co",
86 "file": "null-co://"
H A D283.out1 {"execute": "blockdev-add", "arguments": {"driver": "null-co", "node-name": "target", "size": 10485…
3 {"execute": "blockdev-add", "arguments": {"driver": "blkdebug", "image": {"driver": "null-co", "nod…
12 {"execute": "blockdev-add", "arguments": {"driver": "null-co", "node-name": "source"}}
14 {"execute": "blockdev-add", "arguments": {"driver": "null-co", "node-name": "target"}}
/openbmc/qemu/hw/9pfs/
H A Dcoth.c29 Coroutine *co = opaque; in coroutine_enter_cb() local
30 qemu_coroutine_enter(co); in coroutine_enter_cb()
36 Coroutine *co = arg; in coroutine_enter_func() local
37 qemu_coroutine_enter(co); in coroutine_enter_func()
43 Coroutine *co = opaque; in co_run_in_worker_bh() local
44 thread_pool_submit_aio(coroutine_enter_func, co, coroutine_enter_cb, co); in co_run_in_worker_bh()
/openbmc/qemu/tests/tcg/aarch64/gdbstub/
H A Dtest-mte.py55 co = gdb.execute(f"memory-tag check {ta}", False, True)
56 tags_match = re.findall(PATTERN_0, co, re.MULTILINE)
76 co = gdb.execute(f"memory-tag print-allocation-tag {ta}", False, True)
77 first_tag = re.match(PATTERN_1, co)[1]
79 co = gdb.execute(f"memory-tag print-allocation-tag {ta}+16", False, True)
80 second_tag = re.match(PATTERN_1, co)[1]
93 co = gdb.execute(f"memory-tag print-allocation-tag {ta}+4096-32", False, True)
94 tag = re.match(PATTERN_1, co)[1]
96 co = gdb.execute(f"memory-tag print-allocation-tag {ta}+4096-16", False, True)
97 last_tag = re.match(PATTERN_1, co)[
[all...]
/openbmc/qemu/include/qemu/
H A Dcoroutine-core.h88 void qemu_coroutine_enter_if_inactive(Coroutine *co);
93 void qemu_aio_coroutine_enter(AioContext *ctx, Coroutine *co);
106 AioContext *qemu_coroutine_get_aio_context(Coroutine *co);
134 bool qemu_coroutine_entered(Coroutine *co);
/openbmc/qemu/block/
H A Dtrace-events70 qcow2_add_task(void *co, void *bs, void *pool, const char *action, int cluster_type, uint64_t host_offset, uint64_t offset, uint64_t bytes, void *qiov, size_t qiov_offset) "co %p bs %p pool %p: %s: cluster_type %d file_cluster_offset %" PRIu64 " offset %" PRIu64 " bytes %" PRIu64 " qiov %p qiov_offset %zu"
71 qcow2_writev_start_req(void *co, int64_t offset, int64_t bytes) "co %p offset 0x%" PRIx64 " bytes %" PRId64
72 qcow2_writev_done_req(void *co, int ret) "co %p ret %d"
73 qcow2_writev_start_part(void *co) "co %p"
74 qcow2_writev_done_part(void *co, int cur_bytes) "co
[all...]
H A Dblkreplay.c20 Coroutine *co; member
57 aio_co_wake(req->co); in blkreplay_bh_cb()
63 Coroutine *co) in block_request_create() argument
66 AioContext *ctx = qemu_coroutine_get_aio_context(co); in block_request_create()
68 .co = co, in block_request_create()
H A Dblock-gen.h35 Coroutine *co; /* Keep pointer here for debugging */ member
42 aio_co_enter(s->ctx, s->co); in bdrv_poll_co()
H A Dquorum.c119 Coroutine *co; member
174 .co = qemu_coroutine_self(), in quorum_aio_get()
279 QuorumCo *co = opaque; in quorum_rewrite_entry() local
280 QuorumAIOCB *acb = co->acb; in quorum_rewrite_entry()
287 bdrv_co_pwritev(s->children[co->idx], acb->offset, acb->bytes, in quorum_rewrite_entry()
293 qemu_coroutine_enter_if_inactive(acb->co); in quorum_rewrite_entry()
325 Coroutine *co; in quorum_rewrite_bad_versions() local
331 co = qemu_coroutine_create(quorum_rewrite_entry, &data); in quorum_rewrite_bad_versions()
332 qemu_coroutine_enter(co); in quorum_rewrite_bad_versions()
584 QuorumCo *co = opaque; in read_quorum_children_entry() local
[all …]
/openbmc/qemu/scripts/qemugdb/
H A Dcoroutine.py134 def co_cast(co): argument
135 return co.cast(gdb.lookup_type('CoroutineUContext').pointer())
137 def coroutine_to_jmpbuf(co): argument
138 coroutine_pointer = co_cast(co)
177 co = co_cast(co_ptr)
178 co_ptr = co["base"]["caller"]
/openbmc/qemu/tests/perf/block/qcow2/
H A Dconvert-blockstatus49 /usr/bin/time -f %e $QEMU_IMG convert -n "$src" null-co://
64 /usr/bin/time -f %e $QEMU_IMG convert -n "$src" null-co://
71 /usr/bin/time -f %e $QEMU_IMG convert -n "$src" null-co://

12345678910>>...12