Searched refs:dataq (Results 1 – 2 of 2) sorted by relevance
59 dataq_enqueue(dataq_t *dataq, void *in) in dataq_enqueue() argument67 (void) pthread_mutex_lock(&dataq->lock); in dataq_enqueue()68 assert(dataq_check(dataq)); in dataq_enqueue()69 ll_enqueue(&dataq->data, &ptr->list); in dataq_enqueue()70 dataq->num_data++; in dataq_enqueue()71 if (dataq->num_waiters) { in dataq_enqueue()73 sleeper = (dataq_waiter_t *)ll_peek(&dataq->waiters); in dataq_enqueue()77 assert(dataq_check(dataq)); in dataq_enqueue()78 (void) pthread_mutex_unlock(&dataq->lock); in dataq_enqueue()83 dataq_dequeue(dataq_t *dataq, void **outptr, int try) in dataq_dequeue() argument[all …]
45 typedef struct dataq { struct54 int dataq_enqueue(dataq_t *dataq, void *in); argument55 int dataq_dequeue(dataq_t *dataq, void **outptr, int);56 int dataq_destroy(dataq_t *dataq);