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