Home
last modified time | relevance | path

Searched refs:fiber_t (Results 1 – 11 of 11) sorted by relevance

/xnu-12377.61.12/tests/unit/mocks/fibers/
H A Dfibers.h44 typedef struct fiber_context *fiber_t; typedef
110 extern fiber_t fibers_current;
156 fiber_t joining; /* waiting for this fiber if FIBER_JOIN */
157 fiber_t joiner; /* signal this fiber on termination */
158 fiber_t next; /* next fiber on the same queue (run or wait queue) */
159 fiber_t next_existing; /* next fiber in the list of existing fibers */
191 fiber_t top;
196 fibers_queue_push(struct fibers_queue *queue, fiber_t fiber) in fibers_queue_push()
204 static inline fiber_t
209 fiber_t *iter = &queue->top; in fibers_queue_pop()
[all …]
H A Dfibers.c65 fiber_t fibers_current = &fibers_main; /* currently running */
104 fiber_t fiber;
114 fiber_t fiber = args->fiber; in fibers_create_trampoline()
147 fiber_t
165 fiber_t fiber = calloc(1, sizeof(struct fiber_context)); in fibers_create()
226 fibers_dispose(fiber_t fiber) in fibers_dispose()
262 fibers_join(fiber_t target) in fibers_join()
290 fibers_switch_helper(fiber_t target, int state) in fibers_switch_helper()
299 fiber_t save = fibers_current; in fibers_switch_helper()
325 fibers_switch_to(fiber_t target, int state) in fibers_switch_to()
[all …]
H A Dcondition.c39 …wakeup_some(fibers_condition_t *cond, int num_fibers, void (*callback)(void *, fiber_t), void *arg) in fibers_condition_wakeup_some() argument
51 fiber_t target = fibers_queue_pop(&cond->wait_queue, random_below(cond->wait_queue.count)); in fibers_condition_wakeup_some()
88 fiber_t
97 fiber_t iter = cond->wait_queue.top; in fibers_condition_identify()
110 fibers_condition_wakeup_identified(fibers_condition_t *cond, fiber_t target) in fibers_condition_wakeup_identified()
H A Dcondition.h42 …wakeup_some(fibers_condition_t *cond, int num_fibers, void (*callback)(void*, fiber_t), void *arg);
45 extern fiber_t fibers_condition_identify(fibers_condition_t *cond);
46 extern bool fibers_condition_wakeup_identified(fibers_condition_t *cond, fiber_t target);
H A Drwlock.c185 …fiber_t new_writer = fibers_queue_pop(&rwlock->writer_wait_queue, random_below(rwlock->writer_wait… in fibers_rwlock_rdunlock_helper()
214 …fiber_t new_writer = fibers_queue_pop(&rwlock->writer_wait_queue, random_below(rwlock->writer_wait… in fibers_rwlock_wrunlock_helper()
225 …fiber_t new_reader = fibers_queue_pop(&rwlock->reader_wait_queue, random_below(rwlock->reader_wait… in fibers_rwlock_wrunlock_helper()
406 …fiber_t new_reader = fibers_queue_pop(&rwlock->reader_wait_queue, random_below(rwlock->reader_wait… in fibers_rwlock_downgrade()
429 fiber_t current = fibers_current; in fibers_rwlock_assert()
H A Dmutex.h36 fiber_t holder;
H A Drwlock.h44 fiber_t writer_active;
H A Dchecker.c58 …ruct watchpoint_entry* entry, uintptr_t address, enum access_type type, size_t size, fiber_t fiber) in watchpoint_entry_init()
169 watchpoint_map_find_remove(struct watchpoint_map* map, uintptr_t address, fiber_t fiber, struct wat… in watchpoint_map_find_remove()
H A Dmutex.c104 fiber_t new_holder = fibers_queue_pop(&mtx->wait_queue, random_below(mtx->wait_queue.count)); in fibers_mutex_unlock_helper()
/xnu-12377.61.12/tests/unit/
H A Dfibers_test.c88 …fiber_t first = fibers_create(FIBERS_DEFAULT_STACK_SIZE, coop_fibers_func, (void*)&cooperative_cou…
89 …fiber_t second = fibers_create(FIBERS_DEFAULT_STACK_SIZE, coop_fibers_func, (void*)&cooperative_co…
90 …fiber_t third = fibers_create(FIBERS_DEFAULT_STACK_SIZE, coop_fibers_func, (void*)&cooperative_cou…
135 fiber_t fiber = fibers_create(FIBERS_DEFAULT_STACK_SIZE, tiny_race_func, NULL);
174 fiber_t mythreads[NUM_THREADS] = {};
/xnu-12377.61.12/tests/unit/mocks/
H A Dmock_thread.c151 fiber_t fiber;
1470 waitq_wakeup_fiber_callback(void *arg, fiber_t target) in waitq_wakeup_fiber_callback()