Lines Matching defs:q
68 static int tirdwropen(queue_t *q, dev_t *dev,
71 static int tirdwrclose(queue_t *q, int flag, cred_t *cr);
73 static int check_strhead(queue_t *q);
79 static void tirdwrrput(queue_t *q, mblk_t *mp);
80 static void tirdwrwput(queue_t *q, mblk_t *mp);
150 static void send_fatal(queue_t *q, mblk_t *mp);
151 static void strip_strhead(queue_t *q);
161 queue_t *q,
170 if (q->q_ptr) {
181 trwptr->trw_rdq = q;
182 q->q_ptr = (caddr_t)trwptr;
183 WR(q)->q_ptr = (caddr_t)trwptr;
184 qprocson(q);
186 freezestr(q);
188 (void) strqset(WR(q), QMAXPSZ, 0, (uintptr_t)WR(q)->q_next->q_maxpsz);
189 (void) strqset(q, QMAXPSZ, 0, (uintptr_t)q->q_next->q_maxpsz);
191 if (!check_strhead(q)) {
192 unfreezestr(q);
193 qprocsoff(q);
197 strip_strhead(q);
198 unfreezestr(q);
210 tirdwrclose(queue_t *q, int flag, cred_t *cr)
216 qprocsoff(q);
217 trwptr = (struct trw_trw *)q->q_ptr;
230 putnext(WR(q), mp);
245 tirdwrrput(queue_t *q, mblk_t *mp)
251 trwptr = (struct trw_trw *)q->q_ptr;
263 putnext(q, mp);
267 putnext(q, mp);
283 send_fatal(q, mp);
293 putnext(q, tmp);
300 putnext(q, mp);
308 putnext(q, tmp);
312 putnext(q, mp);
316 send_fatal(q, mp);
329 tirdwrwput(queue_t *q, mblk_t *mp)
333 trwptr = (struct trw_trw *)q->q_ptr;
344 putnext(q, mp);
348 putnext(q, mp);
353 send_fatal(q, mp);
360 send_fatal(queue_t *q, mblk_t *mp)
364 trwptr = (struct trw_trw *)q->q_ptr;
372 if (q->q_flag&QREADR)
373 putnext(q, mp);
375 qreply(q, mp);
379 check_strhead(queue_t *q)
384 for (mp = q->q_next->q_first; mp != NULL; mp = mp->b_next) {
419 strip_strhead(queue_t *q)
426 q = q->q_next;
428 for (mp = q->q_first; mp != NULL; ) {
439 rmvq(q, mp);
445 rmvq(q, mp);
448 (void) insq(q, emp, tmp);