| /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()
114 static Coroutine *coroutine_pool_get_local(void) in coroutine_pool_get_local()
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()
189 static void coroutine_pool_put(Coroutine *co) in coroutine_pool_put()
217 Coroutine *qemu_coroutine_create(CoroutineEntry *entry, void *opaque) in qemu_coroutine_create()
219 Coroutine *co = NULL; in qemu_coroutine_create()
[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;
184 static void coroutine_fn qemu_co_mutex_wake(CoMutex *mutex, Coroutine *co) in qemu_co_mutex_wake()
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()
[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 | async.c | 553 QSLIST_HEAD(, Coroutine) straight, reversed; in co_schedule_bh_cb()
559 Coroutine *co = QSLIST_FIRST(&reversed); in co_schedule_bh_cb()
565 Coroutine *co = QSLIST_FIRST(&straight); in co_schedule_bh_cb()
630 void aio_co_schedule(AioContext *ctx, Coroutine *co) in aio_co_schedule()
657 Coroutine *co;
686 void aio_co_wake(Coroutine *co) in aio_co_wake()
699 void aio_co_enter(AioContext *ctx, Coroutine *co) in aio_co_enter()
707 Coroutine *self = qemu_coroutine_self(); in aio_co_enter()
|
| 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 | 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()
42 Coroutine **p_co = opaque; in verify_self()
48 Coroutine *coroutine; in test_self()
60 Coroutine *caller = (Coroutine *)opaque; in verify_entered_step_2()
73 Coroutine *self = qemu_coroutine_self(); in verify_entered_step_1()
74 Coroutine *coroutine; in verify_entered_step_1()
87 Coroutine *coroutine; in test_entered()
111 Coroutine *child; in nest()
122 Coroutine *root; in test_nesting()
154 Coroutine *coroutine; in test_yield()
[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()
|
| H A D | test-bdrv-drain.c | 54 Coroutine *co = qemu_coroutine_create(sleep_in_drain_begin, bs); in bdrv_test_drain_begin()
143 Coroutine *co; in call_in_coroutine()
530 Coroutine *co; in test_iothread_common()
1039 Coroutine *co; in do_test_delete_by_drain()
1724 Coroutine *io_co;
1725 Coroutine *drain_co;
1848 Coroutine *co = qemu_coroutine_create(bdrv_replace_test_read_entry, in bdrv_replace_test_drain_end()
1915 Coroutine *io_co; in do_test_replace_child_mid_drain()
|
| /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 | 202 QSLIST_HEAD(, Coroutine) scheduled_coroutines;
625 void aio_co_schedule(AioContext *ctx, Coroutine *co);
651 void aio_co_wake(Coroutine *co);
660 void aio_co_enter(AioContext *ctx, Coroutine *co);
|
| /openbmc/qemu/block/ |
| H A D | blkreplay.c | 20 Coroutine *co;
63 Coroutine *co) in block_request_create()
|
| H A D | block-gen.h | 35 Coroutine *co; /* Keep pointer here for debugging */
|
| H A D | aio_task.c | 30 Coroutine *main_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/migration/ |
| H A D | migration.h | 184 Coroutine *loadvm_co;
187 Coroutine *colo_incoming_co;
|
| /openbmc/qemu/nbd/ |
| H A D | client-connection.c | 67 Coroutine *wait_co;
413 Coroutine *wait_co = NULL; in nbd_co_establish_connection_cancel()
|