Lines Matching defs:rqp

139 	blue_queue_t *rqp;
142 	while ((rqp = blue_list) != NULL) {
144 		err = blue_detach(rqp);
156 	blue_queue_t *rqp;
177 		if ((rqp = altq_lookup(ifacep->blue_ifname, ALTQT_BLUE)) == NULL) {
181 		error = altq_enable(rqp->rq_ifq);
186 		if ((rqp = altq_lookup(ifacep->blue_ifname, ALTQT_BLUE)) == NULL) {
190 		error = altq_disable(rqp->rq_ifq);
201 		rqp = malloc(sizeof(blue_queue_t), M_DEVBUF, M_WAITOK|M_ZERO);
202 		if (rqp == NULL) {
207 		rqp->rq_q = malloc(sizeof(class_queue_t), M_DEVBUF,
209 		if (rqp->rq_q == NULL) {
210 			free(rqp, M_DEVBUF);
215 		rqp->rq_blue = malloc(sizeof(blue_t), M_DEVBUF,
217 		if (rqp->rq_blue == NULL) {
218 			free(rqp->rq_q, M_DEVBUF);
219 			free(rqp, M_DEVBUF);
224 		rqp->rq_ifq = &ifp->if_snd;
225 		qtail(rqp->rq_q) = NULL;
226 		qlen(rqp->rq_q) = 0;
227 		qlimit(rqp->rq_q) = BLUE_LIMIT;
230 		blue_init(rqp->rq_blue, 0, 800, 1000, 50000);
235 		error = altq_attach(rqp->rq_ifq, ALTQT_BLUE, rqp,
239 			free(rqp->rq_blue, M_DEVBUF);
240 			free(rqp->rq_q, M_DEVBUF);
241 			free(rqp, M_DEVBUF);
246 		rqp->rq_next = blue_list;
247 		blue_list = rqp;
252 		if ((rqp = altq_lookup(ifacep->blue_ifname, ALTQT_BLUE)) == NULL) {
256 		error = blue_detach(rqp);
265 			if ((rqp = altq_lookup(q_stats->iface.blue_ifname,
271 			q_stats->q_len 	   = qlen(rqp->rq_q);
272 			q_stats->q_limit   = qlimit(rqp->rq_q);
274 			rp = rqp->rq_blue;
293 			if ((rqp = altq_lookup(fc->iface.blue_ifname,
299 			qlimit(rqp->rq_q) = limit;
302 				rqp->rq_blue->blue_pkttime = fc->blue_pkttime;
304 				rqp->rq_blue->blue_max_pmark = fc->blue_max_pmark;
306 				rqp->rq_blue->blue_hold_time = fc->blue_hold_time;
307 			rqp->rq_blue->blue_flags = fc->blue_flags;
309 			blue_init(rqp->rq_blue, rqp->rq_blue->blue_flags,
310 				  rqp->rq_blue->blue_pkttime,
311 				  rqp->rq_blue->blue_max_pmark,
312 				  rqp->rq_blue->blue_hold_time);
324 blue_detach(blue_queue_t *rqp)
329 	if (ALTQ_IS_ENABLED(rqp->rq_ifq))
330 		altq_disable(rqp->rq_ifq);
332 	if ((error = altq_detach(rqp->rq_ifq)))
335 	if (blue_list == rqp)
336 		blue_list = rqp->rq_next;
339 			if (tmp->rq_next == rqp) {
340 				tmp->rq_next = rqp->rq_next;
347 	free(rqp->rq_q, M_DEVBUF);
348 	free(rqp->rq_blue, M_DEVBUF);
349 	free(rqp, M_DEVBUF);
392 	blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc;
399 	if (blue_addq(rqp->rq_blue, rqp->rq_q, m, &pktattr) == 0)
613 	blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc;
617 		return (qhead(rqp->rq_q));
619 	m = blue_getq(rqp->rq_blue, rqp->rq_q);
649 	blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc;
653 		_flushq(rqp->rq_q);