Home
last modified time | relevance | path

Searched refs:ifq (Results 1 – 25 of 33) sorted by relevance

12

/netbsd/src/sys/altq/
Dif_altq.h139 #define ALTQ_IS_READY(ifq) ((ifq)->altq_flags & ALTQF_READY) argument
140 #define ALTQ_IS_ENABLED(ifq) ((ifq)->altq_flags & ALTQF_ENABLED) argument
141 #define ALTQ_NEEDS_CLASSIFY(ifq) ((ifq)->altq_flags & ALTQF_CLASSIFY) argument
142 #define ALTQ_IS_CNDTNING(ifq) ((ifq)->altq_flags & ALTQF_CNDTNING) argument
144 #define ALTQ_SET_CNDTNING(ifq) ((ifq)->altq_flags |= ALTQF_CNDTNING) argument
145 #define ALTQ_CLEAR_CNDTNING(ifq) ((ifq)->altq_flags &= ~ALTQF_CNDTNING) argument
146 #define ALTQ_IS_ATTACHED(ifq) ((ifq)->altq_disc != NULL) argument
148 #define ALTQ_ENQUEUE(ifq, m, err) \ argument
149 (err) = (*(ifq)->altq_enqueue)((ifq),(m))
150 #define ALTQ_DEQUEUE(ifq, m) \ argument
[all …]
Daltq_subr.c127 altq_attach(struct ifaltq *ifq, int type, void *discipline, in altq_attach() argument
133 if (!ALTQ_IS_READY(ifq)) in altq_attach()
142 if (ALTQ_IS_ENABLED(ifq)) in altq_attach()
144 if (ALTQ_IS_ATTACHED(ifq)) in altq_attach()
148 ifq->altq_type = type; in altq_attach()
149 ifq->altq_disc = discipline; in altq_attach()
150 ifq->altq_enqueue = enqueue; in altq_attach()
151 ifq->altq_dequeue = dequeue; in altq_attach()
152 ifq->altq_request = request; in altq_attach()
153 ifq->altq_clfier = clfier; in altq_attach()
[all …]
Daltq_wfq.c101 error = altq_enable(wfqp->ifq); in wfq_setenable()
104 error = altq_disable(wfqp->ifq); in wfq_setenable()
145 new_wfqp->ifq = &ifp->if_snd; in wfq_ifattach()
189 wfq_flush(wfqp->ifq); in wfq_ifdetach()
192 (void)altq_disable(wfqp->ifq); in wfq_ifdetach()
193 (void)altq_detach(wfqp->ifq); in wfq_ifdetach()
215 wfq_request(struct ifaltq *ifq, int req, void *arg) in wfq_request() argument
217 wfq_state_t *wfqp = (wfq_state_t *)ifq->altq_disc; in wfq_request()
221 wfq_flush(wfqp->ifq); in wfq_request()
229 wfq_flush(struct ifaltq *ifq) in wfq_flush() argument
[all …]
Daltq_fifoq.c263 fifoq_enqueue(struct ifaltq *ifq, struct mbuf *m) in fifoq_enqueue() argument
265 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc; in fifoq_enqueue()
284 ifq->ifq_len++; in fifoq_enqueue()
304 fifoq_dequeue(struct ifaltq *ifq, int op) in fifoq_dequeue() argument
306 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc; in fifoq_dequeue()
319 ifq->ifq_len--; in fifoq_dequeue()
329 fifoq_request(struct ifaltq *ifq, int req, void *arg) in fifoq_request() argument
331 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc; in fifoq_request()
Daltq_blue.c389 blue_enqueue(struct ifaltq *ifq, struct mbuf *m) in blue_enqueue() argument
392 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; in blue_enqueue()
400 ifq->ifq_len++; in blue_enqueue()
611 blue_dequeue(struct ifaltq * ifq, int op) in blue_dequeue() argument
613 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; in blue_dequeue()
621 ifq->ifq_len--; in blue_dequeue()
647 blue_request(struct ifaltq *ifq, int req, void *arg) in blue_request() argument
649 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; in blue_request()
654 if (ALTQ_IS_ENABLED(ifq)) in blue_request()
655 ifq->ifq_len = 0; in blue_request()
Daltq_priq.c256 priq_request(struct ifaltq *ifq, int req, void *arg) in priq_request() argument
258 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_request()
428 priq_enqueue(struct ifaltq *ifq, struct mbuf *m) in priq_enqueue() argument
431 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_enqueue()
440 ifq->altq_ifp->if_xname); in priq_enqueue()
448 else if (ifq->altq_flags & ALTQF_CLASSIFY) in priq_enqueue()
474 IFQ_INC_LEN(ifq); in priq_enqueue()
490 priq_dequeue(struct ifaltq *ifq, int op) in priq_dequeue() argument
492 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_dequeue()
497 if (IFQ_IS_EMPTY(ifq)) in priq_dequeue()
[all …]
Daltq_rio.c727 rio_request(struct ifaltq *ifq, int req, void *arg) in rio_request() argument
729 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; in rio_request()
734 if (ALTQ_IS_ENABLED(ifq)) in rio_request()
735 ifq->ifq_len = 0; in rio_request()
748 rio_enqueue(struct ifaltq *ifq, struct mbuf *m) in rio_enqueue() argument
751 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; in rio_enqueue()
759 ifq->ifq_len++; in rio_enqueue()
774 rio_dequeue(struct ifaltq *ifq, int op) in rio_dequeue() argument
776 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; in rio_dequeue()
784 ifq->ifq_len--; in rio_dequeue()
Daltq_cbq.c200 cbq_request(struct ifaltq *ifq, int req, void *arg) in cbq_request() argument
202 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_request()
496 cbq_enqueue(struct ifaltq *ifq, struct mbuf *m) in cbq_enqueue() argument
499 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_enqueue()
508 ifq->altq_ifp->if_xname); in cbq_enqueue()
516 else if (ifq->altq_flags & ALTQF_CLASSIFY) in cbq_enqueue()
545 IFQ_INC_LEN(ifq); in cbq_enqueue()
550 cbq_dequeue(struct ifaltq *ifq, int op) in cbq_dequeue() argument
552 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_dequeue()
559 IFQ_DEC_LEN(ifq); in cbq_dequeue()
[all …]
Daltq_red.c1009 red_enqueue(struct ifaltq *ifq, struct mbuf *m) in red_enqueue() argument
1012 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; in red_enqueue()
1020 ifq->ifq_len++; in red_enqueue()
1033 red_dequeue(struct ifaltq *ifq, int op) in red_dequeue() argument
1035 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; in red_dequeue()
1044 ifq->ifq_len--; in red_dequeue()
1049 red_request(struct ifaltq *ifq, int req, void *arg) in red_request() argument
1051 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; in red_request()
Daltq_hfsc.c358 hfsc_request(struct ifaltq *ifq, int req, void *arg) in hfsc_request() argument
360 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_request()
669 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m) in hfsc_enqueue() argument
672 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_enqueue()
681 ifq->altq_ifp->if_xname); in hfsc_enqueue()
689 else if ((ifq->altq_flags & ALTQF_CLASSIFY)) in hfsc_enqueue()
715 IFQ_INC_LEN(ifq); in hfsc_enqueue()
735 hfsc_dequeue(struct ifaltq *ifq, int op) in hfsc_dequeue() argument
737 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_dequeue()
809 IFQ_DEC_LEN(ifq); in hfsc_dequeue()
[all …]
Daltq_jobs.c150 jobs_attach(struct ifaltq *ifq, u_int bandwidth, u_int qlimit, u_int separate) in jobs_attach() argument
167 jif->jif_ifq = ifq; in jobs_attach()
230 jobs_request(struct ifaltq *ifq, int req, void *arg) in jobs_request() argument
232 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc; in jobs_request()
493 jobs_enqueue(struct ifaltq *ifq, struct mbuf *m) in jobs_enqueue() argument
495 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc; in jobs_enqueue()
513 if (IFQ_IS_EMPTY(ifq)) { in jobs_enqueue()
604 IFQ_INC_LEN(ifq); in jobs_enqueue()
655 jobs_dequeue(struct ifaltq *ifq, int op) in jobs_dequeue() argument
657 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc; in jobs_dequeue()
[all …]
Daltq_wfq.h116 struct ifaltq *ifq; member
/netbsd/src/sys/net/
Dif.h693 #define IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen) argument
694 #define IF_DROP(ifq) ((ifq)->ifq_drops++) argument
695 #define IF_ENQUEUE(ifq, m) do { \ argument
697 if ((ifq)->ifq_tail == 0) \
698 (ifq)->ifq_head = m; \
700 (ifq)->ifq_tail->m_nextpkt = m; \
701 (ifq)->ifq_tail = m; \
702 (ifq)->ifq_len++; \
704 #define IF_PREPEND(ifq, m) do { \ argument
705 (m)->m_nextpkt = (ifq)->ifq_head; \
[all …]
Dif.c856 struct ifqueue *const ifq = p; in if_percpuq_init_ifq() local
858 memset(ifq, 0, sizeof(*ifq)); in if_percpuq_init_ifq()
859 ifq->ifq_maxlen = IFQ_MAXLEN; in if_percpuq_init_ifq()
885 struct ifqueue *ifq; in if_percpuq_dequeue() local
888 ifq = percpu_getref(ipq->ipq_ifqs); in if_percpuq_dequeue()
889 IF_DEQUEUE(ifq, m); in if_percpuq_dequeue()
899 struct ifqueue *const ifq = p; in if_percpuq_purge_ifq() local
901 IF_PURGE(ifq); in if_percpuq_purge_ifq()
921 struct ifqueue *ifq; in if_percpuq_enqueue() local
926 ifq = percpu_getref(ipq->ipq_ifqs); in if_percpuq_enqueue()
[all …]
Dif_l2tp.c379 struct ifqueue *ifq; in l2tp_tx_enqueue() local
388 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); in l2tp_tx_enqueue()
389 if (IF_QFULL(ifq)) { in l2tp_tx_enqueue()
397 IF_ENQUEUE(ifq, m); in l2tp_tx_enqueue()
502 struct ifqueue *ifq; in l2tpintr() local
512 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); in l2tpintr()
513 IF_PURGE(ifq); in l2tpintr()
521 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); in l2tpintr()
523 IF_DEQUEUE(ifq, m); in l2tpintr()
Dif_ppp.c876 struct ifqueue *ifq; in pppoutput() local
1019 ifq = (m0->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL; in pppoutput()
1020 if ((error = ifq_enqueue2(&sc->sc_if, ifq, m0)) != 0) { in pppoutput()
1047 struct ifqueue *ifq; in ppp_requeue() local
1071 ifq = (m->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL; in ppp_requeue()
1072 if ((error = ifq_enqueue2(&sc->sc_if, ifq, m)) != 0) { in ppp_requeue()
Dif_sl.c477 struct ifqueue *ifq = NULL; in sloutput() local
529 ifq = &sc->sc_fastq; in sloutput()
531 if ((error = ifq_enqueue2(ifp, ifq, m)) != 0) { in sloutput()
/netbsd/src/sys/external/bsd/ipf/netinet/
Dfil.c5615 ipftq_t *ifq; in ipf_addtimeoutqueue() local
5621 for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) { in ipf_addtimeoutqueue()
5622 if (ifq->ifq_ttl == period) { in ipf_addtimeoutqueue()
5627 MUTEX_ENTER(&ifq->ifq_lock); in ipf_addtimeoutqueue()
5628 ifq->ifq_flags &= ~IFQF_DELETE; in ipf_addtimeoutqueue()
5629 ifq->ifq_ref++; in ipf_addtimeoutqueue()
5630 MUTEX_EXIT(&ifq->ifq_lock); in ipf_addtimeoutqueue()
5633 return ifq; in ipf_addtimeoutqueue()
5637 KMALLOC(ifq, ipftq_t *); in ipf_addtimeoutqueue()
5638 if (ifq != NULL) { in ipf_addtimeoutqueue()
[all …]
Dip_state.c430 ipftq_t *ifq, *ifqnext; in ipf_state_soft_fini() local
443 for (ifq = softs->ipf_state_usertq; ifq != NULL; ifq = ifqnext) { in ipf_state_soft_fini()
444 ifqnext = ifq->ifq_next; in ipf_state_soft_fini()
446 if (ipf_deletetimeoutqueue(ifq) == 0) in ipf_state_soft_fini()
447 ipf_freetimeoutqueue(softc, ifq); in ipf_state_soft_fini()
2977 ipftq_t *ifq; in ipf_state_lookup() local
2981 ifq = NULL; in ipf_state_lookup()
3045 ifq = &softs->ipf_state_icmpacktq; in ipf_state_lookup()
3047 ifq = &softs->ipf_state_icmptq; in ipf_state_lookup()
3110 ifq = &softs->ipf_state_icmpacktq; in ipf_state_lookup()
[all …]
Dip_nat.c535 ipftq_t *ifq, *ifqnext; in ipf_nat_soft_fini() local
547 for (ifq = softn->ipf_nat_utqe; ifq != NULL; ifq = ifqnext) { in ipf_nat_soft_fini()
548 ifqnext = ifq->ifq_next; in ipf_nat_soft_fini()
549 if (ipf_deletetimeoutqueue(ifq) == 0) in ipf_nat_soft_fini()
550 ipf_freetimeoutqueue(softc, ifq); in ipf_nat_soft_fini()
4721 ipftq_t *ifq, *ifq2; in ipf_nat_update() local
4726 ifq = tqe->tqe_ifq; in ipf_nat_update()
4756 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq2); in ipf_nat_update()
5801 ipftq_t *ifq, *ifqnext; in ipf_nat_expire() local
5808 for (ifq = softn->ipf_nat_tcptq, i = 0; ifq != NULL; in ipf_nat_expire()
[all …]
/netbsd/src/usr.bin/netstat/
Dmain.c768 struct ifqueue intrq, *ifq = &intrq; in print_softintrq() local
777 kread(off, (char *)ifq, sizeof(*ifq)); in print_softintrq()
779 printf("\tqueue length: %d\n", ifq->ifq_len); in print_softintrq()
780 printf("\tmaximum queue length: %d\n", ifq->ifq_maxlen); in print_softintrq()
781 printf("\tpackets dropped: %" PRIu64 "\n", ifq->ifq_drops); in print_softintrq()
/netbsd/src/sys/dev/ic/
Dhd64570.c799 struct ifqueue *ifq = NULL; in sca_output() local
825 ifq = &((sca_port_t *)ifp->if_softc)->fastq; in sca_output()
871 if (ifq != NULL) { in sca_output()
872 if (IF_QFULL(ifq)) { in sca_output()
873 IF_DROP(ifq); in sca_output()
877 IF_ENQUEUE(ifq, m); in sca_output()
/netbsd/src/sys/dev/pci/
Dxmm7360.c165 #define IFQ_SET_READY(ifq) /* nothing */ argument
249 #define ifq_deq_begin(ifq) ({ \ argument
251 IFQ_DEQUEUE(ifq, m0); \
254 #define ifq_deq_rollback(ifq, m) m_freem(m) argument
255 #define ifq_deq_commit(ifq, m) /* nothing to do */ argument
256 #define ifq_is_oactive(ifq) true /* always restart queue */ argument
257 #define ifq_clr_oactive(ifq) /* nothing to do */ argument
258 #define ifq_empty(ifq) IFQ_IS_EMPTY(ifq) argument
259 #define ifq_purge(ifq) IF_PURGE(ifq) argument
Dmpii.c1255 struct mpii_msg_iocfacts_request ifq; in mpii_iocfacts() local
1263 memset(&ifq, 0, sizeof(ifq)); in mpii_iocfacts()
1266 ifq.function = MPII_FUNCTION_IOC_FACTS; in mpii_iocfacts()
1268 if (mpii_handshake_send(sc, &ifq, dwordsof(ifq)) != 0) { in mpii_iocfacts()
2171 struct mpii_msg_iocfacts_request ifq; in mpii_board_info() local
2176 memset(&ifq, 0, sizeof(ifq)); in mpii_board_info()
2179 ifq.function = MPII_FUNCTION_IOC_FACTS; in mpii_board_info()
2181 if (mpii_handshake_send(sc, &ifq, dwordsof(ifq)) != 0) { in mpii_board_info()
/netbsd/src/share/doc/smm/18.net/
Dspell.ok189 ifq

12