Searched refs:dataq (Results 1 – 2 of 2) sorted by relevance
57 dataq_enqueue(dataq_t *dataq, void *in) in dataq_enqueue() argument65 (void) pthread_mutex_lock(&dataq->lock); in dataq_enqueue()66 assert(dataq_check(dataq)); in dataq_enqueue()67 ll_enqueue(&dataq->data, &ptr->list); in dataq_enqueue()68 dataq->num_data++; in dataq_enqueue()69 if (dataq->num_waiters) { in dataq_enqueue()71 sleeper = (dataq_waiter_t *)ll_peek(&dataq->waiters); in dataq_enqueue()75 assert(dataq_check(dataq)); in dataq_enqueue()76 (void) pthread_mutex_unlock(&dataq->lock); in dataq_enqueue()81 dataq_dequeue(dataq_t *dataq, void **outptr, int try) in dataq_dequeue() argument[all …]
43 typedef struct dataq { struct52 int dataq_enqueue(dataq_t *dataq, void *in); argument53 int dataq_dequeue(dataq_t *dataq, void **outptr, int);54 int dataq_destroy(dataq_t *dataq);