Cross Reference: /osnet-11/usr/src/lib/libc/port/threads/synch.c

Lines Matching refs:qrp
505 	queue_root_t *qrp;
515 	for (cnt = 0, qrp = qp->qh_hlist; qrp != NULL; qrp = qrp->qr_next) {
517 		ASSERT((qrp->qr_head != NULL && qrp->qr_tail != NULL) ||
518 		    (qrp->qr_head == NULL && qrp->qr_tail == NULL));
526 	for (cnt = 0, qrp = qp->qh_hlist; qrp != NULL; qrp = qrp->qr_next) {
527 		for (prev = NULL, ulwp = qrp->qr_head; ulwp != NULL;
536 			ASSERT(qrp->qr_wchan == wchan);
540 		ASSERT(qrp->qr_tail == prev);
559 	queue_root_t *qrp;
573 	for (qrp = qp->qh_hlist; qrp != NULL; qrp = qrp->qr_next)
574 		if (qrp->qr_wchan == wchan)
576 	if (qrp == NULL && qp->qh_def_root.qr_head == NULL) {
578 		qrp = &qp->qh_def_root;
579 		qrp->qr_wchan = wchan;
580 		ASSERT(qrp->qr_next == NULL);
581 		ASSERT(qrp->qr_tail == NULL &&
582 		    qrp->qr_rtcount == 0 && qrp->qr_qlen == 0);
585 	qp->qh_root = qrp;	/* valid until queue_unlock() is called */
611 	queue_root_t *qrp;
619 	if ((qrp = qp->qh_root) == NULL) {
621 		qrp = &ulwp->ul_queue_root;
622 		qrp->qr_next = qp->qh_hlist;
623 		qrp->qr_prev = NULL;
624 		qrp->qr_head = NULL;
625 		qrp->qr_tail = NULL;
626 		qrp->qr_wchan = qp->qh_wchan;
627 		qrp->qr_rtcount = 0;
628 		qrp->qr_qlen = 0;
629 		qrp->qr_qmax = 0;
630 		qp->qh_hlist->qr_prev = qrp;
631 		qp->qh_hlist = qrp;
632 		qp->qh_root = qrp;
659 	if (qrp->qr_head == NULL) {
663 		ASSERT(qrp->qr_tail == NULL);
664 		ulwpp = &qrp->qr_head;
672 		if (pri <= CMP_PRIO(qrp->qr_tail))
673 			ulwpp = &qrp->qr_tail->ul_link;
675 			for (ulwpp = &qrp->qr_head; (next = *ulwpp) != NULL;
686 		for (ulwpp = &qrp->qr_head; (next = *ulwpp) != NULL;
692 		qrp->qr_tail = ulwp;
702 		qrp->qr_rtcount++;
704 	MAXINCR(qrp->qr_qmax, qrp->qr_qlen);
780 	queue_root_t *qrp;
787 	if ((qrp = qp->qh_root) == NULL || (ulwp = qrp->qr_head) == NULL) {
791 	rt = (qrp->qr_rtcount != 0);
796 		return (&qrp->qr_head);
801 		return (queue_slot_rt(&qrp->qr_head, prevp));
807 	    (ulwpp = queue_slot_runnable(&qrp->qr_head, prevp, 0)) != NULL) {
816 	return (&qrp->qr_head);
825 	queue_root_t *qrp = qp->qh_root;
834 	DECR(qrp->qr_qlen);
837 		qrp->qr_rtcount--;
842 	if (qrp->qr_tail == ulwp)
843 		qrp->qr_tail = prev;
844 	if (qrp == &ulwp->ul_queue_root) {
849 		queue_root_t *qr_next = qrp->qr_next;
850 		queue_root_t *qr_prev = qrp->qr_prev;
852 		if (qrp->qr_tail) {
854 			ASSERT(qrp->qr_qlen != 0);
855 			nqrp = &qrp->qr_tail->ul_queue_root;
856 			*nqrp = *qrp;
866 			ASSERT(qrp->qr_qlen == 0);
914 	queue_root_t *qrp;
923 	if ((qrp = qp->qh_root) != NULL) {
924 		for (prev = NULL, ulwpp = &qrp->qr_head;
941 	return ((qrp = qp->qh_root) != NULL && qrp->qr_head != NULL);
1671 	queue_root_t *qrp;
1696 		if ((qrp = qp->qh_root) == NULL ||
1697 		    (ulwp = qrp->qr_head) == NULL)
1700 		queue_unlink(qp, &qrp->qr_head, NULL);
3820 	queue_root_t *qrp;
3861 		if ((qrp = qp->qh_root) == NULL ||
3862 		    (ulwp = qrp->qr_head) == NULL)
3865 		queue_unlink(qp, &qrp->qr_head, NULL);