| /openbmc/qemu/include/qemu/ |
| H A D | coroutine_int.h | 44 struct Coroutine { struct
47 Coroutine *caller; argument
50 QSLIST_ENTRY(Coroutine) pool_next;
62 QSIMPLEQ_ENTRY(Coroutine) co_queue_next; argument
67 QSIMPLEQ_HEAD(, Coroutine) co_queue_wakeup;
69 QSLIST_ENTRY(Coroutine) co_scheduled_next;
72 Coroutine *qemu_coroutine_new(void);
73 void qemu_coroutine_delete(Coroutine *co);
74 CoroutineAction qemu_coroutine_switch(Coroutine *from, Coroutine *to,
|
| H A D | coroutine-core.h | 57 typedef struct Coroutine Coroutine; typedef
77 Coroutine *qemu_coroutine_create(CoroutineEntry *entry, void *opaque);
82 void qemu_coroutine_enter(Coroutine *coroutine);
88 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);
111 Coroutine *qemu_coroutine_self(void);
134 bool qemu_coroutine_entered(Coroutine *co);
|
| H A D | coroutine.h | 68 Coroutine *holder;
95 QSIMPLEQ_HEAD(, Coroutine) entries;
226 Coroutine *to_wake;
|
| H A D | vhost-user-server.h | 54 Coroutine *co_trip; /* coroutine for processing VhostUserMsg */
|
| /openbmc/qemu/util/ |
| H A D | qemu-coroutine.c | 53 QSLIST_HEAD(, Coroutine) list;
81 Coroutine *co; in coroutine_pool_batch_delete()
82 Coroutine *tmp; in coroutine_pool_batch_delete()
118 Coroutine *co; in coroutine_pool_get_local()
177 static Coroutine *coroutine_pool_get(void) in coroutine_pool_get()
179 Coroutine *co; in coroutine_pool_get()
219 Coroutine *co = NULL; in qemu_coroutine_create()
235 static void coroutine_delete(Coroutine *co) in coroutine_delete()
314 void qemu_coroutine_enter(Coroutine *co) in qemu_coroutine_enter()
329 Coroutine *to = self->caller; in qemu_coroutine_yield()
[all …]
|
| H A D | coroutine-windows.c | 31 Coroutine base;
38 QEMU_DEFINE_STATIC_CO_TLS(Coroutine *, current);
49 qemu_coroutine_switch(Coroutine *from_, Coroutine *to_, in qemu_coroutine_switch()
64 Coroutine *co = co_; in coroutine_trampoline()
72 Coroutine *qemu_coroutine_new(void) in qemu_coroutine_new()
82 void qemu_coroutine_delete(Coroutine *co_) in qemu_coroutine_delete()
90 Coroutine *qemu_coroutine_self(void) in qemu_coroutine_self()
92 Coroutine *current = get_current(); in qemu_coroutine_self()
106 Coroutine *current = get_current(); in qemu_in_coroutine()
|
| H A D | coroutine-sigaltstack.c | 37 Coroutine base;
48 Coroutine *current;
96 static void coroutine_bootstrap(CoroutineSigAltStack *self, Coroutine *co) in coroutine_bootstrap()
117 Coroutine *co; in coroutine_trampoline()
148 Coroutine *qemu_coroutine_new(void) in qemu_coroutine_new()
265 void qemu_coroutine_delete(Coroutine *co_) in qemu_coroutine_delete()
273 CoroutineAction qemu_coroutine_switch(Coroutine *from_, Coroutine *to_, in qemu_coroutine_switch()
290 Coroutine *qemu_coroutine_self(void) in qemu_coroutine_self()
|
| H A D | qemu-coroutine-lock.c | 44 Coroutine *self = qemu_coroutine_self(); in qemu_co_queue_wait_impl()
76 Coroutine *next; in qemu_co_enter_next_impl()
138 Coroutine *co;
197 Coroutine *self = qemu_coroutine_self(); in qemu_co_mutex_lock_slowpath()
221 Coroutine *co = to_wake->co; in qemu_co_mutex_lock_slowpath()
239 Coroutine *self = qemu_coroutine_self(); in qemu_co_mutex_lock()
278 Coroutine *self = qemu_coroutine_self(); in qemu_co_mutex_unlock()
334 Coroutine *co;
349 Coroutine *co = NULL; in qemu_co_rwlock_maybe_wake_one()
381 Coroutine *self = qemu_coroutine_self(); in qemu_co_rwlock_rdlock()
[all …]
|
| H A D | coroutine-ucontext.c | 46 Coroutine base;
70 QEMU_DEFINE_STATIC_CO_TLS(Coroutine *, current);
152 Coroutine *co; in coroutine_trampoline()
180 Coroutine *qemu_coroutine_new(void) in qemu_coroutine_new()
281 void qemu_coroutine_delete(Coroutine *co_) in qemu_coroutine_delete()
311 qemu_coroutine_switch(Coroutine *from_, Coroutine *to_, in qemu_coroutine_switch()
337 Coroutine *qemu_coroutine_self(void) in qemu_coroutine_self()
339 Coroutine *self = get_current(); in qemu_coroutine_self()
356 Coroutine *self = get_current(); in qemu_in_coroutine()
|
| H A D | qemu-coroutine-sleep.c | 23 Coroutine *co; in qemu_co_sleep_wake()
45 Coroutine *co = qemu_coroutine_self(); in qemu_co_sleep()
|
| H A D | async.c | 552 QSLIST_HEAD(, Coroutine) straight, reversed; in co_schedule_bh_cb()
558 Coroutine *co = QSLIST_FIRST(&reversed); in co_schedule_bh_cb()
564 Coroutine *co = QSLIST_FIRST(&straight); in co_schedule_bh_cb()
629 void aio_co_schedule(AioContext *ctx, Coroutine *co) in aio_co_schedule()
656 Coroutine *co;
685 void aio_co_wake(Coroutine *co) in aio_co_wake()
698 void aio_co_enter(AioContext *ctx, Coroutine *co) in aio_co_enter()
706 Coroutine *self = qemu_coroutine_self(); in aio_co_enter()
|
| H A D | qemu-co-timeout.c | 61 Coroutine *co; in qemu_co_timeout()
|
| H A D | qemu-coroutine-io.c | 70 Coroutine *co;
|
| /openbmc/qemu/tests/unit/ |
| H A D | test-coroutine.c | 28 Coroutine *coroutine; in test_in_coroutine()
48 Coroutine *coroutine; in test_self()
60 Coroutine *caller = (Coroutine *)opaque; in verify_entered_step_2()
74 Coroutine *coroutine; in verify_entered_step_1()
122 Coroutine *root; in test_nesting()
179 Coroutine *c1; in test_no_dangling_access()
180 Coroutine *c2; in test_no_dangling_access()
181 Coroutine tmp; in test_no_dangling_access()
480 Coroutine *co; in do_order_test()
539 Coroutine *root; in perf_nesting()
[all …]
|
| H A D | test-aio-multithread.c | 109 static Coroutine *to_schedule[NUM_CONTEXTS];
118 Coroutine *co; in schedule_next()
173 Coroutine *co1 = qemu_coroutine_create(test_multi_co_schedule_entry, NULL); in test_multi_co_schedule()
239 Coroutine *co1 = qemu_coroutine_create(test_multi_co_mutex_entry, NULL); in test_multi_co_mutex()
358 Coroutine *co1 = qemu_coroutine_create(test_multi_fair_mutex_entry, NULL); in test_multi_fair_mutex()
414 Coroutine *co1 = qemu_coroutine_create(test_multi_mutex_entry, NULL); in test_multi_mutex()
|
| /openbmc/qemu/hw/9pfs/ |
| H A D | coth.c | 29 Coroutine *co = opaque; in coroutine_enter_cb()
36 Coroutine *co = arg; in coroutine_enter_func()
43 Coroutine *co = opaque; in co_run_in_worker_bh()
|
| /openbmc/qemu/python/qemu/qmp/ |
| H A D | util.py | 18 Coroutine,
87 def create_task(coro: Coroutine[Any, Any, T],
152 def asyncio_run(coro: Coroutine[Any, Any, T], *, debug: bool = False) -> T:
|
| /openbmc/qemu/include/block/ |
| H A D | aio.h | 201 QSLIST_HEAD(, Coroutine) scheduled_coroutines;
624 void aio_co_schedule(AioContext *ctx, Coroutine *co);
650 void aio_co_wake(Coroutine *co);
659 void aio_co_enter(AioContext *ctx, Coroutine *co);
|
| /openbmc/qemu/stubs/ |
| H A D | monitor-core.c | 10 Monitor *monitor_set_cur(Coroutine *co, Monitor *mon) in monitor_set_cur()
|
| /openbmc/qemu/block/ |
| H A D | block-gen.h | 35 Coroutine *co; /* Keep pointer here for debugging */
|
| H A D | blkreplay.c | 20 Coroutine *co;
63 Coroutine *co) in block_request_create()
|
| H A D | aio_task.c | 30 Coroutine *main_co;
|
| /openbmc/qemu/migration/ |
| H A D | migration.h | 170 Coroutine *loadvm_co;
173 Coroutine *colo_incoming_co;
|
| /openbmc/qemu/nbd/ |
| H A D | client-connection.c | 67 Coroutine *wait_co;
413 Coroutine *wait_co; in nbd_co_establish_connection_cancel()
|
| /openbmc/qemu/monitor/ |
| H A D | monitor-internal.h | 166 extern Coroutine *qmp_dispatcher_co;
|