Lines Matching refs:q
42 av1394_initq(av1394_queue_t *q, ddi_iblock_cookie_t ibc, int max) in av1394_initq() argument
44 bzero(q, sizeof (av1394_queue_t)); in av1394_initq()
46 mutex_init(&q->q_mutex, NULL, MUTEX_DRIVER, ibc); in av1394_initq()
47 cv_init(&q->q_cv, NULL, CV_DRIVER, NULL); in av1394_initq()
49 AV1394_ENTERQ(q); in av1394_initq()
50 av1394_list_init(&q->q_list); in av1394_initq()
51 q->q_max = max; in av1394_initq()
52 AV1394_LEAVEQ(q); in av1394_initq()
56 av1394_destroyq(av1394_queue_t *q) in av1394_destroyq() argument
58 av1394_flushq(q); in av1394_destroyq()
59 mutex_destroy(&q->q_mutex); in av1394_destroyq()
60 cv_destroy(&q->q_cv); in av1394_destroyq()
64 av1394_setmaxq(av1394_queue_t *q, int max) in av1394_setmaxq() argument
66 AV1394_ENTERQ(q); in av1394_setmaxq()
67 q->q_max = max; in av1394_setmaxq()
68 AV1394_LEAVEQ(q); in av1394_setmaxq()
72 av1394_getmaxq(av1394_queue_t *q) in av1394_getmaxq() argument
76 AV1394_ENTERQ(q); in av1394_getmaxq()
77 max = q->q_max; in av1394_getmaxq()
78 AV1394_LEAVEQ(q); in av1394_getmaxq()
83 av1394_flushq(av1394_queue_t *q) in av1394_flushq() argument
87 AV1394_ENTERQ(q); in av1394_flushq()
88 while ((bp = av1394_getq_locked(q)) != NULL) { in av1394_flushq()
91 ASSERT(q->q_size == 0); in av1394_flushq()
92 AV1394_LEAVEQ(q); in av1394_flushq()
96 av1394_putq(av1394_queue_t *q, mblk_t *bp) in av1394_putq() argument
98 return (av1394_put_common(q, bp, av1394_list_put_tail)); in av1394_putq()
102 av1394_putbq(av1394_queue_t *q, mblk_t *bp) in av1394_putbq() argument
104 return (av1394_put_common(q, bp, av1394_list_put_head)); in av1394_putbq()
108 av1394_getq(av1394_queue_t *q) in av1394_getq() argument
112 AV1394_ENTERQ(q); in av1394_getq()
113 bp = av1394_getq_locked(q); in av1394_getq()
114 AV1394_LEAVEQ(q); in av1394_getq()
120 av1394_peekq(av1394_queue_t *q) in av1394_peekq() argument
124 AV1394_ENTERQ(q); in av1394_peekq()
125 mp = av1394_peekq_locked(q); in av1394_peekq()
126 AV1394_LEAVEQ(q); in av1394_peekq()
131 av1394_peekq_locked(av1394_queue_t *q) in av1394_peekq_locked() argument
133 ASSERT(mutex_owned(&q->q_mutex)); in av1394_peekq_locked()
134 return (av1394_list_head(&q->q_list)); in av1394_peekq_locked()
141 av1394_qwait_sig(av1394_queue_t *q) in av1394_qwait_sig() argument
145 AV1394_ENTERQ(q); in av1394_qwait_sig()
146 while (av1394_peekq_locked(q) == NULL) { in av1394_qwait_sig()
147 if ((ret = cv_wait_sig(&q->q_cv, &q->q_mutex)) <= 0) { in av1394_qwait_sig()
151 AV1394_LEAVEQ(q); in av1394_qwait_sig()
157 av1394_put_common(av1394_queue_t *q, mblk_t *bp, putfunc_t put) in av1394_put_common() argument
162 AV1394_ENTERQ(q); in av1394_put_common()
163 if (q->q_size + len > q->q_max) { in av1394_put_common()
166 put(&q->q_list, bp); in av1394_put_common()
167 q->q_size += len; in av1394_put_common()
168 cv_broadcast(&q->q_cv); in av1394_put_common()
171 AV1394_LEAVEQ(q); in av1394_put_common()
177 av1394_getq_locked(av1394_queue_t *q) in av1394_getq_locked() argument
181 if ((bp = av1394_list_get_head(&q->q_list)) != NULL) { in av1394_getq_locked()
182 q->q_size -= MBLKL(bp); in av1394_getq_locked()
183 ASSERT(q->q_size >= 0); in av1394_getq_locked()