112 int dm2s_open(queue_t *rq, dev_t *dev, int flag, int sflag, cred_t *cr);
113 int dm2s_close(queue_t *rq, int flag, cred_t *cred);
115 int dm2s_rsrv(queue_t *rq);
388 dm2s_open(queue_t *rq, dev_t *dev, int flag, int sflag, cred_t *cr)  in dm2s_open()  argument
401 	if (rq->q_ptr != NULL) {  in dm2s_open()
426 	rq->q_ptr = WR(rq)->q_ptr = (void *)dm2sp;  in dm2s_open()
427 	dm2sp->ms_rq = rq;  in dm2s_open()
428 	dm2sp->ms_wq = WR(rq);  in dm2s_open()
432 		qprocson(rq);		/* now schedule our queue */  in dm2s_open()
443 dm2s_close(queue_t *rq, int flag, cred_t *cred)  in dm2s_close()  argument
445 	dm2s_t *dm2sp = (dm2s_t *)rq->q_ptr;  in dm2s_close()
463 	(void) putnextctl(rq, M_HANGUP);  in dm2s_close()
464 	qprocsoff(rq);  in dm2s_close()
466 		qunbufcall(rq, dm2sp->ms_rbufcid);  in dm2s_close()
487 	rq->q_ptr = WR(rq)->q_ptr = NULL;  in dm2s_close()
488 	(void) qassociate(rq, -1);  in dm2s_close()
500 dm2s_rsrv(queue_t *rq)  in dm2s_rsrv()  argument
503 	dm2s_t *dm2sp = (dm2s_t *)rq->q_ptr;  in dm2s_rsrv()
514 	while ((mp = getq(rq)) != NULL) {  in dm2s_rsrv()
515 		if (canputnext(rq)) {  in dm2s_rsrv()
516 			putnext(rq, mp);  in dm2s_rsrv()
518 			(void) putbq(rq, mp);  in dm2s_rsrv()
801 	queue_t	*rq;  in dm2s_event_handler()  local
866 			rq = dm2sp->ms_rq;  in dm2s_event_handler()
867 			if (rq != NULL) {  in dm2s_event_handler()
873 				(void) putctl(rq, M_HANGUP);  in dm2s_event_handler()
965 	queue_t	*rq = dm2sp->ms_rq;  in dm2s_receive()  local
973 	if (rq == NULL) {  in dm2s_receive()
993 			dm2sp->ms_rbufcid = qbufcall(rq, len, BPRI_MED,  in dm2s_receive()
1004 				dm2sp->ms_rq_timeoutid = qtimeout(rq,  in dm2s_receive()
1030 		(void) putq(rq, mp);  in dm2s_receive()
1040 		flushq(WR(rq), FLUSHDATA);  in dm2s_receive()
1041 		(void) putnextctl(rq, M_HANGUP);  in dm2s_receive()