io/oplmsu/oplmsu.c

459 oplmsu_open(queue_t *urq, dev_t *dev, int oflag, int sflag, cred_t *cred_p)
524 	if ((urq != NULL) && (urq->q_ptr != NULL)) {
552 	ctrl->queue = urq;
571 	RD(urq)->q_ptr = ctrl;
572 	WR(urq)->q_ptr = ctrl;
577 	OPLMSU_TRACE(urq, (mblk_t *)node_flag, MSU_TRC_OPN);
579 	qprocson(urq);	/* Enable put and service routine */
585 oplmsu_close(queue_t *urq, int flag, cred_t *cred_p)
597 	if ((ctrl = urq->q_ptr) == NULL) {
624 		if (((RD(urq) == lpath->hndl_uqueue) ||
625 		    (WR(urq) == lpath->hndl_uqueue)) &&
643 	flushq(RD(urq), FLUSHALL);
644 	flushq(WR(urq), FLUSHALL);
646 	qprocsoff(urq);		/* Disable queuing of queue */
674 	RD(urq)->q_ptr = NULL;
675 	WR(urq)->q_ptr = NULL;
689 	OPLMSU_TRACE(urq, (mblk_t *)node_flag, MSU_TRC_CLS);
1016 oplmsu_ursrv(queue_t *urq)
1025 	while (mp = getq(urq)) {
1032 			OPLMSU_TRACE(RD(urq), mp, MSU_TRC_UO);
1033 			putnext(RD(urq), mp);
1046 				ctrl = (ctrl_t *)urq->q_ptr;
1059 		dst_queue = RD(urq);
1066 			(void) putbq(urq, mp);
1072 	ctrl = urq->q_ptr;