Lines Matching refs:q
23 obj2node(bqueue_t *q, void *data) in obj2node() argument
25 return ((bqueue_node_t *)((char *)data + q->bq_node_offset)); in obj2node()
35 bqueue_init(bqueue_t *q, uint64_t size, size_t node_offset) in bqueue_init() argument
37 list_create(&q->bq_list, node_offset + sizeof (bqueue_node_t), in bqueue_init()
39 cv_init(&q->bq_add_cv, NULL, CV_DEFAULT, NULL); in bqueue_init()
40 cv_init(&q->bq_pop_cv, NULL, CV_DEFAULT, NULL); in bqueue_init()
41 mutex_init(&q->bq_lock, NULL, MUTEX_DEFAULT, NULL); in bqueue_init()
42 q->bq_node_offset = node_offset; in bqueue_init()
43 q->bq_size = 0; in bqueue_init()
44 q->bq_maxsize = size; in bqueue_init()
54 bqueue_destroy(bqueue_t *q) in bqueue_destroy() argument
56 ASSERT0(q->bq_size); in bqueue_destroy()
57 cv_destroy(&q->bq_add_cv); in bqueue_destroy()
58 cv_destroy(&q->bq_pop_cv); in bqueue_destroy()
59 mutex_destroy(&q->bq_lock); in bqueue_destroy()
60 list_destroy(&q->bq_list); in bqueue_destroy()
69 bqueue_enqueue(bqueue_t *q, void *data, uint64_t item_size) in bqueue_enqueue() argument
72 ASSERT3U(item_size, <, q->bq_maxsize); in bqueue_enqueue()
73 mutex_enter(&q->bq_lock); in bqueue_enqueue()
74 obj2node(q, data)->bqn_size = item_size; in bqueue_enqueue()
75 while (q->bq_size + item_size > q->bq_maxsize) { in bqueue_enqueue()
76 cv_wait(&q->bq_add_cv, &q->bq_lock); in bqueue_enqueue()
78 q->bq_size += item_size; in bqueue_enqueue()
79 list_insert_tail(&q->bq_list, data); in bqueue_enqueue()
80 cv_signal(&q->bq_pop_cv); in bqueue_enqueue()
81 mutex_exit(&q->bq_lock); in bqueue_enqueue()
88 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue() argument
92 mutex_enter(&q->bq_lock); in bqueue_dequeue()
93 while (q->bq_size == 0) { in bqueue_dequeue()
94 cv_wait(&q->bq_pop_cv, &q->bq_lock); in bqueue_dequeue()
96 ret = list_remove_head(&q->bq_list); in bqueue_dequeue()
97 item_size = obj2node(q, ret)->bqn_size; in bqueue_dequeue()
98 q->bq_size -= item_size; in bqueue_dequeue()
99 mutex_exit(&q->bq_lock); in bqueue_dequeue()
100 cv_signal(&q->bq_add_cv); in bqueue_dequeue()
108 bqueue_empty(bqueue_t *q) in bqueue_empty() argument
110 return (q->bq_size == 0); in bqueue_empty()