Searched refs:enqueue_sem (Results 1 – 1 of 1) sorted by relevance
30 semaphore_t *enqueue_sem; member45 ret->enqueue_sem = semaphore_new(capacity); in fixed_queue_new()46 if (!ret->enqueue_sem) in fixed_queue_new()61 semaphore_free(ret->enqueue_sem); in fixed_queue_new()78 semaphore_free(queue->enqueue_sem); in fixed_queue_free()88 semaphore_wait(queue->enqueue_sem); in fixed_queue_enqueue()107 semaphore_post(queue->enqueue_sem); in fixed_queue_dequeue()116 if (!semaphore_try_wait(queue->enqueue_sem)) in fixed_queue_try_enqueue()138 semaphore_post(queue->enqueue_sem); in fixed_queue_try_dequeue()150 return semaphore_get_fd(queue->enqueue_sem); in fixed_queue_get_enqueue_fd()