Searched refs:enqueue_sem (Results 1 – 1 of 1) sorted by relevance
33 semaphore_t* enqueue_sem; member55 ret->enqueue_sem = semaphore_new(capacity); in fixed_queue_new()56 if (!ret->enqueue_sem) goto error; in fixed_queue_new()79 semaphore_free(queue->enqueue_sem); in fixed_queue_free()120 semaphore_wait(queue->enqueue_sem); in fixed_queue_enqueue()142 semaphore_post(queue->enqueue_sem); in fixed_queue_dequeue()151 if (!semaphore_try_wait(queue->enqueue_sem)) return false; in fixed_queue_try_enqueue()174 semaphore_post(queue->enqueue_sem); in fixed_queue_try_dequeue()207 semaphore_post(queue->enqueue_sem); in fixed_queue_try_remove_from_queue()229 return semaphore_get_fd(queue->enqueue_sem); in fixed_queue_get_enqueue_fd()