Cross Reference: /src/sys/altq/altq

Lines Matching defs:rqp
742 	red_queue_t *rqp;
745 	while ((rqp = red_list) != NULL) {
747 		err = red_detach(rqp);
759 	red_queue_t *rqp;
780 		if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
784 		error = altq_enable(rqp->rq_ifq);
789 		if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
793 		error = altq_disable(rqp->rq_ifq);
804 		rqp = malloc(sizeof(red_queue_t), M_DEVBUF, M_WAITOK|M_ZERO);
805 		if (rqp == NULL) {
810 		rqp->rq_q = malloc(sizeof(class_queue_t), M_DEVBUF,
812 		if (rqp->rq_q == NULL) {
813 			free(rqp, M_DEVBUF);
818 		rqp->rq_red = red_alloc(0, 0, 0, 0, 0, 0);
819 		if (rqp->rq_red == NULL) {
820 			free(rqp->rq_q, M_DEVBUF);
821 			free(rqp, M_DEVBUF);
826 		rqp->rq_ifq = &ifp->if_snd;
827 		qtail(rqp->rq_q) = NULL;
828 		qlen(rqp->rq_q) = 0;
829 		qlimit(rqp->rq_q) = RED_LIMIT;
830 		qtype(rqp->rq_q) = Q_RED;
835 		error = altq_attach(rqp->rq_ifq, ALTQT_RED, rqp,
839 			red_destroy(rqp->rq_red);
840 			free(rqp->rq_q, M_DEVBUF);
841 			free(rqp, M_DEVBUF);
846 		rqp->rq_next = red_list;
847 		red_list = rqp;
852 		if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
856 		error = red_detach(rqp);
865 			if ((rqp = altq_lookup(q_stats->iface.red_ifname,
871 			q_stats->q_len 	   = qlen(rqp->rq_q);
872 			q_stats->q_limit   = qlimit(rqp->rq_q);
874 			rp = rqp->rq_red;
915 			if ((rqp = altq_lookup(fc->iface.red_ifname,
932 			red_purgeq(rqp);
936 			qlimit(rqp->rq_q) = limit;
939 			red_destroy(rqp->rq_red);
940 			rqp->rq_red = new;
946 			fc->red_inv_pmax = rqp->rq_red->red_inv_pmax;
947 			fc->red_thmin = rqp->rq_red->red_thmin;
948 			fc->red_thmax = rqp->rq_red->red_thmax;
973 red_detach(red_queue_t *rqp)
978 	if (ALTQ_IS_ENABLED(rqp->rq_ifq))
979 		altq_disable(rqp->rq_ifq);
981 	if ((error = altq_detach(rqp->rq_ifq)))
984 	if (red_list == rqp)
985 		red_list = rqp->rq_next;
988 			if (tmp->rq_next == rqp) {
989 				tmp->rq_next = rqp->rq_next;
996 	red_destroy(rqp->rq_red);
997 	free(rqp->rq_q, M_DEVBUF);
998 	free(rqp, M_DEVBUF);
1012 	red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1018 	if (red_addq(rqp->rq_red, rqp->rq_q, m, &pktattr) < 0)
1035 	red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1039 		return qhead(rqp->rq_q);
1042 	m =  red_getq(rqp->rq_red, rqp->rq_q);
1051 	red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1055 		red_purgeq(rqp);
1062 red_purgeq(red_queue_t *rqp)
1064 	_flushq(rqp->rq_q);
1065 	if (ALTQ_IS_ENABLED(rqp->rq_ifq))
1066 		rqp->rq_ifq->ifq_len = 0;
OpenGrok
