Lines Matching refs:rqp
740 red_queue_t *rqp;
743 while ((rqp = red_list) != NULL) {
745 err = red_detach(rqp);
765 red_queue_t *rqp;
790 if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
794 error = altq_enable(rqp->rq_ifq);
799 if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
803 error = altq_disable(rqp->rq_ifq);
814 rqp = malloc(sizeof(red_queue_t), M_DEVBUF, M_WAITOK);
815 if (rqp == NULL) {
819 bzero(rqp, sizeof(red_queue_t));
821 rqp->rq_q = malloc(sizeof(class_queue_t),
823 if (rqp->rq_q == NULL) {
824 free(rqp, M_DEVBUF);
828 bzero(rqp->rq_q, sizeof(class_queue_t));
830 rqp->rq_red = red_alloc(0, 0, 0, 0, 0, 0);
831 if (rqp->rq_red == NULL) {
832 free(rqp->rq_q, M_DEVBUF);
833 free(rqp, M_DEVBUF);
838 rqp->rq_ifq = &ifp->if_snd;
839 qtail(rqp->rq_q) = NULL;
840 qlen(rqp->rq_q) = 0;
841 qlimit(rqp->rq_q) = RED_LIMIT;
842 qtype(rqp->rq_q) = Q_RED;
847 error = altq_attach(rqp->rq_ifq, ALTQT_RED, rqp,
851 red_destroy(rqp->rq_red);
852 free(rqp->rq_q, M_DEVBUF);
853 free(rqp, M_DEVBUF);
858 rqp->rq_next = red_list;
859 red_list = rqp;
864 if ((rqp = altq_lookup(ifacep->red_ifname, ALTQT_RED)) == NULL) {
868 error = red_detach(rqp);
877 if ((rqp = altq_lookup(q_stats->iface.red_ifname,
883 q_stats->q_len = qlen(rqp->rq_q);
884 q_stats->q_limit = qlimit(rqp->rq_q);
886 rp = rqp->rq_red;
927 if ((rqp = altq_lookup(fc->iface.red_ifname,
944 red_purgeq(rqp);
948 qlimit(rqp->rq_q) = limit;
951 red_destroy(rqp->rq_red);
952 rqp->rq_red = new;
958 fc->red_inv_pmax = rqp->rq_red->red_inv_pmax;
959 fc->red_thmin = rqp->rq_red->red_thmin;
960 fc->red_thmax = rqp->rq_red->red_thmax;
985 red_detach(rqp)
986 red_queue_t *rqp;
991 if (ALTQ_IS_ENABLED(rqp->rq_ifq))
992 altq_disable(rqp->rq_ifq);
994 if ((error = altq_detach(rqp->rq_ifq)))
997 if (red_list == rqp)
998 red_list = rqp->rq_next;
1001 if (tmp->rq_next == rqp) {
1002 tmp->rq_next = rqp->rq_next;
1009 red_destroy(rqp->rq_red);
1010 free(rqp->rq_q, M_DEVBUF);
1011 free(rqp, M_DEVBUF);
1027 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1031 if (red_addq(rqp->rq_red, rqp->rq_q, m, pktattr) < 0)
1050 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1056 return qhead(rqp->rq_q);
1059 m = red_getq(rqp->rq_red, rqp->rq_q);
1071 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1077 red_purgeq(rqp);
1084 red_purgeq(rqp)
1085 red_queue_t *rqp;
1087 _flushq(rqp->rq_q);
1088 if (ALTQ_IS_ENABLED(rqp->rq_ifq))
1089 rqp->rq_ifq->ifq_len = 0;