Home
last modified time | relevance | path

Searched refs:dataq (Results 1 – 2 of 2) sorted by relevance

/titanic_44/usr/src/cmd/syslogd/
H A Dqueue.c59 dataq_enqueue(dataq_t *dataq, void *in) in dataq_enqueue() argument
67 (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 …]
H A Ddataq.h45 typedef struct dataq { struct
54 int dataq_enqueue(dataq_t *dataq, void *in); argument
55 int dataq_dequeue(dataq_t *dataq, void **outptr, int);
56 int dataq_destroy(dataq_t *dataq);