Home
last modified time | relevance | path

Searched refs:wait_queue (Results 1 – 7 of 7) sorted by relevance

/xnu-12377.1.9/tests/unit/mocks/fibers/
H A Dcondition.c45 if (num_fibers < 0 || num_fibers > cond->wait_queue.count) { in fibers_condition_wakeup_some()
46 num_fibers = cond->wait_queue.count; in fibers_condition_wakeup_some()
51 fiber_t target = fibers_queue_pop(&cond->wait_queue, random_below(cond->wait_queue.count)); in fibers_condition_wakeup_some()
77 fibers_queue_push(&cond->wait_queue, fibers_current); in fibers_condition_wait()
85 …FIBERS_ASSERT(cond->wait_queue.count == 0, "fibers_mutex_destroy: tried to destroy condition with … in fibers_condition_destroy()
91 FIBERS_LOG(FIBERS_LOG_DEBUG, "identify from wait queue of %d fibers", cond->wait_queue.count); in fibers_condition_identify()
93 if (cond->wait_queue.count == 0) { in fibers_condition_identify()
96 size_t index = random_below(cond->wait_queue.count); in fibers_condition_identify()
97 fiber_t iter = cond->wait_queue.top; in fibers_condition_identify()
118 if (!fibers_queue_remove(&cond->wait_queue, target)) { in fibers_condition_wakeup_identified()
H A Dmutex.c44 mtx->wait_queue = (struct fibers_queue){0, 0}; in fibers_mutex_init()
66 fibers_queue_push(&mtx->wait_queue, fibers_current); in fibers_mutex_lock_helper()
103 if (mtx->wait_queue.count) { in fibers_mutex_unlock_helper()
104 fiber_t new_holder = fibers_queue_pop(&mtx->wait_queue, random_below(mtx->wait_queue.count)); in fibers_mutex_unlock_helper()
165 …FIBERS_ASSERT(mtx->wait_queue.count == 0, "fibers_mutex_destroy: tried to destroy mutex with non e… in fibers_mutex_destroy()
H A Dmutex.h37 struct fibers_queue wait_queue; member
H A Dcondition.h38 struct fibers_queue wait_queue; member
/xnu-12377.1.9/osfmk/kern/
H A Dkern_types.h46 struct wait_queue { unsigned int opaque[2]; uintptr_t opaquep[2]; }; argument
48 struct wait_queue { unsigned char opaque[32]; }; struct
56 typedef struct wait_queue *wait_queue_t;
58 #define SIZEOF_WAITQUEUE sizeof(struct wait_queue)
/xnu-12377.1.9/tools/lldbmacros/core/
H A Doperating_system.py767 wait_queue = self._strip_ptr(th.GetChildMemberWithName('wait_queue').GetValueAsUnsigned())
771 'queue' : hex(wait_queue).rstrip('L'),
/xnu-12377.1.9/tools/lldbmacros/
H A DREADME.md69 …thread thread_id processor pri io_policy state wait_queue …
258 …thread thread_id processor pri io_policy state wait_queue …