Lines Matching defs:urq
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;