| /freebsd/sys/net/ |
| H A D | ifq.h | 69 #define IF_LOCK(ifq) mtx_lock(&(ifq)->ifq_mtx) argument
70 #define IF_UNLOCK(ifq) mtx_unlock(&(ifq)->ifq_mtx) argument
71 #define IF_LOCK_ASSERT(ifq) mtx_assert(&(ifq)->ifq_mtx, MA_OWNED) argument
72 #define _IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen) argument
73 #define _IF_QLEN(ifq) ((ifq)->ifq_len) argument
75 #define _IF_ENQUEUE(ifq, m) do { \ argument
77 if ((ifq)->ifq_tail == NULL) \
78 (ifq)->ifq_head = m; \
80 (ifq)->ifq_tail->m_nextpkt = m; \
81 (ifq)->ifq_tail = m; \
[all …]
|
| H A D | if.c | 722 ifq_init(struct ifaltq *ifq, struct ifnet *ifp) in ifq_init() argument
725 mtx_init(&ifq->ifq_mtx, ifp->if_xname, "if send queue", MTX_DEF); in ifq_init()
727 if (ifq->ifq_maxlen == 0) in ifq_init()
728 ifq->ifq_maxlen = ifqmaxlen; in ifq_init()
730 ifq->altq_type = 0; in ifq_init()
731 ifq->altq_disc = NULL; in ifq_init()
732 ifq->altq_flags &= ALTQF_CANTCHANGE; in ifq_init()
733 ifq->altq_tbr = NULL; in ifq_init()
734 ifq->altq_ifp = ifp; in ifq_init()
738 ifq_delete(struct ifaltq *ifq) in ifq_delete() argument
[all …]
|
| H A D | if_vlan.c | 1518 struct ifaltq *ifq = &ifp->if_snd; in vlan_altq_start() local
1521 IFQ_LOCK(ifq); in vlan_altq_start()
1522 IFQ_DEQUEUE_NOLOCK(ifq, m); in vlan_altq_start()
1525 IFQ_DEQUEUE_NOLOCK(ifq, m); in vlan_altq_start()
1527 IFQ_UNLOCK(ifq); in vlan_altq_start()
|
| H A D | if_bridge.c | 2309 struct ifaltq *ifq = &ifp->if_snd; in bridge_altq_start() local
2312 IFQ_LOCK(ifq); in bridge_altq_start()
2313 IFQ_DEQUEUE_NOLOCK(ifq, m); in bridge_altq_start()
2316 IFQ_DEQUEUE_NOLOCK(ifq, m); in bridge_altq_start()
2318 IFQ_UNLOCK(ifq); in bridge_altq_start()
|
| H A D | iflib.c | 4409 struct ifaltq *ifq = &ifp->if_snd; /* XXX - DRVAPI */ in iflib_altq_if_start() local
4412 IFQ_LOCK(ifq); in iflib_altq_if_start()
4413 IFQ_DEQUEUE_NOLOCK(ifq, m); in iflib_altq_if_start()
4416 IFQ_DEQUEUE_NOLOCK(ifq, m); in iflib_altq_if_start()
4418 IFQ_UNLOCK(ifq); in iflib_altq_if_start()
|
| /freebsd/sys/net/altq/ |
| H A D | if_altq.h | 139 #define ALTQ_IS_READY(ifq) ((ifq)->altq_flags & ALTQF_READY) argument
141 #define ALTQ_IS_ENABLED(ifq) ((ifq)->altq_flags & ALTQF_ENABLED) argument
143 #define ALTQ_IS_ENABLED(ifq) 0 argument
145 #define ALTQ_IS_CNDTNING(ifq) ((ifq)->altq_flags & ALTQF_CNDTNING) argument
147 #define ALTQ_SET_CNDTNING(ifq) ((ifq)->altq_flags |= ALTQF_CNDTNING) argument
148 #define ALTQ_CLEAR_CNDTNING(ifq) ((ifq)->altq_flags &= ~ALTQF_CNDTNING) argument
149 #define ALTQ_IS_ATTACHED(ifq) ((ifq)->altq_disc != NULL) argument
151 #define ALTQ_ENQUEUE(ifq, m, pa, err) \ argument
152 (err) = (*(ifq)->altq_enqueue)((ifq),(m),(pa))
153 #define ALTQ_DEQUEUE(ifq, m) \ argument
[all …]
|
| H A D | altq_subr.c | 164 altq_attach(struct ifaltq *ifq, int type, void *discipline, in altq_attach() argument
169 IFQ_LOCK(ifq); in altq_attach()
170 if (!ALTQ_IS_READY(ifq)) { in altq_attach()
171 IFQ_UNLOCK(ifq); in altq_attach()
175 ifq->altq_type = type; in altq_attach()
176 ifq->altq_disc = discipline; in altq_attach()
177 ifq->altq_enqueue = enqueue; in altq_attach()
178 ifq->altq_dequeue = dequeue; in altq_attach()
179 ifq->altq_request = request; in altq_attach()
180 ifq->altq_flags &= (ALTQF_CANTCHANGE|ALTQF_ENABLED); in altq_attach()
[all …]
|
| H A D | altq_cbq.c | 158 cbq_request(struct ifaltq *ifq, int req, void *arg) in cbq_request() argument
160 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_request()
162 IFQ_LOCK_ASSERT(ifq); in cbq_request()
457 cbq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in cbq_enqueue() argument
459 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_enqueue()
464 IFQ_LOCK_ASSERT(ifq); in cbq_enqueue()
470 ifq->altq_ifp->if_xname); in cbq_enqueue()
494 IFQ_INC_LEN(ifq); in cbq_enqueue()
499 cbq_dequeue(struct ifaltq *ifq, int op) in cbq_dequeue() argument
501 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_dequeue()
[all …]
|
| H A D | altq_codel.c | 180 codel_request(struct ifaltq *ifq, int req, void *arg) in codel_request() argument
182 struct codel_if *cif = (struct codel_if *)ifq->altq_disc; in codel_request()
185 IFQ_LOCK_ASSERT(ifq); in codel_request()
208 codel_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in codel_enqueue() argument
211 struct codel_if *cif = (struct codel_if *) ifq->altq_disc; in codel_enqueue()
213 IFQ_LOCK_ASSERT(ifq); in codel_enqueue()
219 ifq->altq_ifp->if_xname); in codel_enqueue()
229 IFQ_INC_LEN(ifq); in codel_enqueue()
235 codel_dequeue(struct ifaltq *ifq, int op) in codel_dequeue() argument
237 struct codel_if *cif = (struct codel_if *)ifq->altq_disc; in codel_dequeue()
[all …]
|
| H A D | altq_priq.c | 224 priq_request(struct ifaltq *ifq, int req, void *arg) in priq_request() argument
226 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_request()
228 IFQ_LOCK_ASSERT(ifq); in priq_request()
446 priq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in priq_enqueue() argument
448 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_enqueue()
453 IFQ_LOCK_ASSERT(ifq); in priq_enqueue()
459 ifq->altq_ifp->if_xname); in priq_enqueue()
480 IFQ_INC_LEN(ifq); in priq_enqueue()
496 priq_dequeue(struct ifaltq *ifq, int op) in priq_dequeue() argument
498 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_dequeue()
[all …]
|
| H A D | altq_fairq.c | 274 fairq_request(struct ifaltq *ifq, int req, void *arg) in fairq_request() argument
276 struct fairq_if *pif = (struct fairq_if *)ifq->altq_disc; in fairq_request()
278 IFQ_LOCK_ASSERT(ifq); in fairq_request()
482 fairq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in fairq_enqueue() argument
484 struct fairq_if *pif = (struct fairq_if *)ifq->altq_disc; in fairq_enqueue()
490 IFQ_LOCK_ASSERT(ifq); in fairq_enqueue()
496 ifq->altq_ifp->if_xname); in fairq_enqueue()
520 IFQ_INC_LEN(ifq); in fairq_enqueue()
535 fairq_dequeue(struct ifaltq *ifq, int op) in fairq_dequeue() argument
537 struct fairq_if *pif = (struct fairq_if *)ifq->altq_disc; in fairq_dequeue()
[all …]
|
| H A D | altq_hfsc.c | 326 hfsc_request(struct ifaltq *ifq, int req, void *arg) in hfsc_request() argument
328 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_request()
330 IFQ_LOCK_ASSERT(ifq); in hfsc_request()
655 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in hfsc_enqueue() argument
657 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_enqueue()
662 IFQ_LOCK_ASSERT(ifq); in hfsc_enqueue()
668 ifq->altq_ifp->if_xname); in hfsc_enqueue()
689 IFQ_INC_LEN(ifq); in hfsc_enqueue()
709 hfsc_dequeue(struct ifaltq *ifq, int op) in hfsc_dequeue() argument
711 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_dequeue()
[all …]
|
| H A D | altq_rmclass.c | 669 rmc_init(struct ifaltq *ifq, struct rm_ifdat *ifd, u_int nsecPerByte, in rmc_init() argument
681 mtu = ifq->altq_ifp->if_mtu; in rmc_init()
682 ifd->ifq_ = ifq; in rmc_init()
|
| /freebsd/sys/dev/usb/ |
| H A D | usb_mbuf.h | 47 #define USB_IF_ENQUEUE(ifq, m) do { \ argument
49 if ((ifq)->ifq_tail == NULL) \
50 (ifq)->ifq_head = (m); \
52 (ifq)->ifq_tail->usb_nextpkt = (m); \
53 (ifq)->ifq_tail = (m); \
54 (ifq)->ifq_len++; \
57 #define USB_IF_DEQUEUE(ifq, m) do { \ argument
58 (m) = (ifq)->ifq_head; \
60 if (((ifq)->ifq_head = (m)->usb_nextpkt) == NULL) { \
61 (ifq)->ifq_tail = NULL; \
[all …]
|
| H A D | usb_mbuf.c | 64 usb_alloc_mbufs(struct malloc_type *type, struct usb_ifqueue *ifq, in usb_alloc_mbufs() argument
89 USB_IF_ENQUEUE(ifq, m_ptr); in usb_alloc_mbufs()
|
| /freebsd/sys/net80211/ |
| H A D | ieee80211_freebsd.h | 157 #define _IF_PREPEND_LIST(ifq, mhead, mtail, mcount) do { \ argument
158 (mtail)->m_nextpkt = (ifq)->ifq_head; \
159 if ((ifq)->ifq_tail == NULL) \
160 (ifq)->ifq_tail = (mtail); \
161 (ifq)->ifq_head = (mhead); \
162 (ifq)->ifq_len += (mcount); \
164 #define IF_PREPEND_LIST(ifq, mhead, mtail, mcount) do { \ argument
165 IF_LOCK(ifq); \
166 _IF_PREPEND_LIST(ifq, mhead, mtail, mcount); \
167 IF_UNLOCK(ifq); \
|
| H A D | ieee80211_freebsd.c | 417 ieee80211_drain_ifq(struct ifqueue *ifq) in ieee80211_drain_ifq() argument
423 IF_DEQUEUE(ifq, m); in ieee80211_drain_ifq()
437 ieee80211_flush_ifq(struct ifqueue *ifq, struct ieee80211vap *vap) in ieee80211_flush_ifq() argument
442 IF_LOCK(ifq); in ieee80211_flush_ifq()
443 mprev = &ifq->ifq_head; in ieee80211_flush_ifq()
448 ifq->ifq_len--; in ieee80211_flush_ifq()
456 m = ifq->ifq_head; in ieee80211_flush_ifq()
459 ifq->ifq_tail = m; in ieee80211_flush_ifq()
460 IF_UNLOCK(ifq); in ieee80211_flush_ifq()
|
| /freebsd/sys/netpfil/ipfilter/netinet/ |
| H A D | ip_state.c | 418 ipftq_t *ifq, *ifqnext; in ipf_state_soft_fini() local
431 for (ifq = softs->ipf_state_usertq; ifq != NULL; ifq = ifqnext) { in ipf_state_soft_fini()
432 ifqnext = ifq->ifq_next; in ipf_state_soft_fini()
434 if (ipf_deletetimeoutqueue(ifq) == 0) in ipf_state_soft_fini()
435 ipf_freetimeoutqueue(softc, ifq); in ipf_state_soft_fini()
2963 ipftq_t *ifq; in ipf_state_lookup() local
2967 ifq = NULL; in ipf_state_lookup()
3031 ifq = &softs->ipf_state_icmpacktq; in ipf_state_lookup()
3033 ifq = &softs->ipf_state_icmptq; in ipf_state_lookup()
3096 ifq = &softs->ipf_state_icmpacktq; in ipf_state_lookup()
[all …]
|
| H A D | fil.c | 5597 ipftq_t *ifq; in ipf_addtimeoutqueue() local
5603 for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) { in ipf_addtimeoutqueue()
5604 if (ifq->ifq_ttl == period) { in ipf_addtimeoutqueue()
5609 MUTEX_ENTER(&ifq->ifq_lock); in ipf_addtimeoutqueue()
5610 ifq->ifq_flags &= ~IFQF_DELETE; in ipf_addtimeoutqueue()
5611 ifq->ifq_ref++; in ipf_addtimeoutqueue()
5612 MUTEX_EXIT(&ifq->ifq_lock); in ipf_addtimeoutqueue()
5615 return (ifq); in ipf_addtimeoutqueue()
5619 KMALLOC(ifq, ipftq_t *); in ipf_addtimeoutqueue()
5620 if (ifq != NULL) { in ipf_addtimeoutqueue()
[all …]
|
| H A D | ip_nat.c | 526 ipftq_t *ifq, *ifqnext; in ipf_nat_soft_fini() local
538 for (ifq = softn->ipf_nat_utqe; ifq != NULL; ifq = ifqnext) { in ipf_nat_soft_fini()
539 ifqnext = ifq->ifq_next; in ipf_nat_soft_fini()
540 if (ipf_deletetimeoutqueue(ifq) == 0) in ipf_nat_soft_fini()
541 ipf_freetimeoutqueue(softc, ifq); in ipf_nat_soft_fini()
4697 ipftq_t *ifq, *ifq2; in ipf_nat_update() local
4702 ifq = tqe->tqe_ifq; in ipf_nat_update()
4732 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq2); in ipf_nat_update()
5772 ipftq_t *ifq, *ifqnext; in ipf_nat_expire() local
5779 for (ifq = softn->ipf_nat_tcptq, i = 0; ifq != NULL; in ipf_nat_expire()
[all …]
|
| /freebsd/sys/netgraph/ |
| H A D | ng_source.c | 731 struct ifqueue *ifq; in ng_source_intr() local
743 ifq = (struct ifqueue *)&sc->output_ifp->if_snd; in ng_source_intr()
744 packets = ifq->ifq_maxlen - ifq->ifq_len; in ng_source_intr()
|
| /freebsd/share/doc/smm/18.net/ |
| H A D | spell.ok | 189 ifq
|
| /freebsd/tools/build/test-includes/ |
| H A D | badfiles.inc | 165 net/ifq.h \
|
| /freebsd/sys/conf/ |
| H A D | files | 4139 net/ifq.c standard
|