Cross Reference: /src/sys/altq/altq

Lines Matching defs:rqp
476 	rio_queue_t *rqp;
479 	while ((rqp = rio_list) != NULL) {
481 		err = rio_detach(rqp);
493 	rio_queue_t *rqp;
514 		if ((rqp = altq_lookup(ifacep->rio_ifname, ALTQT_RIO)) == NULL) {
518 		error = altq_enable(rqp->rq_ifq);
523 		if ((rqp = altq_lookup(ifacep->rio_ifname, ALTQT_RIO)) == NULL) {
527 		error = altq_disable(rqp->rq_ifq);
538 		rqp = malloc(sizeof(rio_queue_t), M_DEVBUF, M_WAITOK|M_ZERO);
539 		if (rqp == NULL) {
544 		rqp->rq_q = malloc(sizeof(class_queue_t), M_DEVBUF,
546 		if (rqp->rq_q == NULL) {
547 			free(rqp, M_DEVBUF);
552 		rqp->rq_rio = rio_alloc(0, NULL, 0, 0);
553 		if (rqp->rq_rio == NULL) {
554 			free(rqp->rq_q, M_DEVBUF);
555 			free(rqp, M_DEVBUF);
560 		rqp->rq_ifq = &ifp->if_snd;
561 		qtail(rqp->rq_q) = NULL;
562 		qlen(rqp->rq_q) = 0;
563 		qlimit(rqp->rq_q) = RIO_LIMIT;
564 		qtype(rqp->rq_q) = Q_RIO;
569 		error = altq_attach(rqp->rq_ifq, ALTQT_RIO, rqp,
573 			rio_destroy(rqp->rq_rio);
574 			free(rqp->rq_q, M_DEVBUF);
575 			free(rqp, M_DEVBUF);
580 		rqp->rq_next = rio_list;
581 		rio_list = rqp;
586 		if ((rqp = altq_lookup(ifacep->rio_ifname, ALTQT_RIO)) == NULL) {
590 		error = rio_detach(rqp);
600 			if ((rqp = altq_lookup(q_stats->iface.rio_ifname,
606 			rp = rqp->rq_rio;
608 			q_stats->q_limit = qlimit(rqp->rq_q);
636 			if ((rqp = altq_lookup(fc->iface.rio_ifname,
650 			_flushq(rqp->rq_q);
654 			qlimit(rqp->rq_q) = limit;
656 			rio_destroy(rqp->rq_rio);
657 			rqp->rq_rio = new;
665 					rqp->rq_rio->rio_precstate[i].inv_pmax;
667 					rqp->rq_rio->rio_precstate[i].th_min;
669 					rqp->rq_rio->rio_precstate[i].th_max;
694 rio_detach(rio_queue_t *rqp)
699 	if (ALTQ_IS_ENABLED(rqp->rq_ifq))
700 		altq_disable(rqp->rq_ifq);
702 	if ((error = altq_detach(rqp->rq_ifq)))
705 	if (rio_list == rqp)
706 		rio_list = rqp->rq_next;
709 			if (tmp->rq_next == rqp) {
710 				tmp->rq_next = rqp->rq_next;
717 	rio_destroy(rqp->rq_rio);
718 	free(rqp->rq_q, M_DEVBUF);
719 	free(rqp, M_DEVBUF);
729 	rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
733 		_flushq(rqp->rq_q);
751 	rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
758 	if (rio_addq(rqp->rq_rio, rqp->rq_q, m, &pktattr) == 0)
776 	rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
780 		return qhead(rqp->rq_q);
782 	m = rio_getq(rqp->rq_rio, rqp->rq_q);
OpenGrok
