Home
last modified time | relevance | path

Searched refs:Coroutine (Results 1 – 25 of 45) sorted by relevance

12

/openbmc/qemu/include/qemu/
H A Dcoroutine_int.h44 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 Dcoroutine-core.h57 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 Dcoroutine.h69 Coroutine *holder;
96 QSIMPLEQ_HEAD(, Coroutine) entries;
227 Coroutine *to_wake;
H A Dvhost-user-server.h54 Coroutine *co_trip; /* coroutine for processing VhostUserMsg */
/openbmc/qemu/util/
H A Dcoroutine-windows.c31 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 Dqemu-coroutine.c53 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 Dcoroutine-wasm.c29 Coroutine base;
44 QEMU_DEFINE_STATIC_CO_TLS(Coroutine *, current);
50 Coroutine *co = co_; in coroutine_trampoline()
58 Coroutine *qemu_coroutine_new(void) in qemu_coroutine_new()
76 void qemu_coroutine_delete(Coroutine *co_) in qemu_coroutine_delete()
85 CoroutineAction qemu_coroutine_switch(Coroutine *from_, Coroutine *to_, in qemu_coroutine_switch()
97 Coroutine *qemu_coroutine_self(void) in qemu_coroutine_self()
99 Coroutine *self = get_current(); in qemu_coroutine_self()
124 Coroutine *self = get_current(); in qemu_in_coroutine()
H A Dcoroutine-sigaltstack.c37 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 Dqemu-coroutine-lock.c44 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 Dcoroutine-ucontext.c46 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 Dqemu-coroutine-sleep.c23 Coroutine *co; in qemu_co_sleep_wake()
45 Coroutine *co = qemu_coroutine_self(); in qemu_co_sleep()
H A Dasync.c529 QSLIST_HEAD(, Coroutine) straight, reversed; in aio_context_notifier_cb()
535 Coroutine *co = QSLIST_FIRST(&reversed); in aio_context_notifier_poll()
541 Coroutine *co = QSLIST_FIRST(&straight); in aio_context_notifier_poll()
626 void aio_co_schedule(AioContext *ctx, Coroutine *co) in aio_context_new()
653 Coroutine *co; in aio_co_schedule()
682 void aio_co_wake(Coroutine *co) in aio_co_reschedule_self()
695 void aio_co_enter(AioContext *ctx, Coroutine *co) in aio_co_wake()
703 Coroutine *self = qemu_coroutine_self(); in aio_co_enter()
H A Dqemu-co-timeout.c61 Coroutine *co; in qemu_co_timeout()
H A Dqemu-coroutine-io.c70 Coroutine *co;
/openbmc/qemu/tests/unit/
H A Dtest-coroutine.c28 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 Dtest-aio-multithread.c109 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()
360 Coroutine *co1 = qemu_coroutine_create(test_multi_fair_mutex_entry, NULL); in test_multi_fair_mutex()
416 Coroutine *co1 = qemu_coroutine_create(test_multi_mutex_entry, NULL); in test_multi_mutex()
H A Dtest-bdrv-drain.c54 Coroutine *co = qemu_coroutine_create(sleep_in_drain_begin, bs); in bdrv_test_drain_begin()
143 Coroutine *co; in call_in_coroutine()
534 Coroutine *co; in test_iothread_common()
1049 Coroutine *co; in do_test_delete_by_drain()
1738 Coroutine *io_co;
1739 Coroutine *drain_co;
1862 Coroutine *co = qemu_coroutine_create(bdrv_replace_test_read_entry, in bdrv_replace_test_drain_end()
1929 Coroutine *io_co; in do_test_replace_child_mid_drain()
H A Dtest-thread-pool.c94 Coroutine *co = qemu_coroutine_create(co_test_cb, &data); in test_submit_co()
/openbmc/qemu/hw/9pfs/
H A Dcoth.c29 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/stubs/
H A Dmonitor-core.c10 Monitor *monitor_set_cur(Coroutine *co, Monitor *mon) in monitor_set_cur()
/openbmc/qemu/block/
H A Dblock-gen.h35 Coroutine *co; /* Keep pointer here for debugging */
H A Daio_task.c30 Coroutine *main_co;
H A Dblkverify.c27 Coroutine *co;
200 Coroutine *co_a, *co_b; in blkverify_co_prwv()
/openbmc/qemu/nbd/
H A Dclient-connection.c69 Coroutine *wait_co;
416 Coroutine *wait_co = NULL; in nbd_co_establish_connection_cancel()
/openbmc/qemu/include/monitor/
H A Dmonitor.h17 Monitor *monitor_set_cur(Coroutine *co, Monitor *mon);

12