Home
last modified time | relevance | path

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

/trueos/sys/net/
HDif_var.h326 #define IF_LOCK(ifq) mtx_lock(&(ifq)->ifq_mtx) argument
327 #define IF_UNLOCK(ifq) mtx_unlock(&(ifq)->ifq_mtx) argument
328 #define IF_LOCK_ASSERT(ifq) mtx_assert(&(ifq)->ifq_mtx, MA_OWNED) argument
329 #define _IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen) argument
330 #define _IF_DROP(ifq) ((ifq)->ifq_drops++) argument
331 #define _IF_QLEN(ifq) ((ifq)->ifq_len) argument
333 #define _IF_ENQUEUE(ifq, m) do { \ argument
335 if ((ifq)->ifq_tail == NULL) \
336 (ifq)->ifq_head = m; \
338 (ifq)->ifq_tail->m_nextpkt = m; \
[all …]
HDif.c546 ifq_init(struct ifaltq *ifq, struct ifnet *ifp) in ifq_init() argument
549 mtx_init(&ifq->ifq_mtx, ifp->if_xname, "if send queue", MTX_DEF); in ifq_init()
551 if (ifq->ifq_maxlen == 0) in ifq_init()
552 ifq->ifq_maxlen = ifqmaxlen; in ifq_init()
554 ifq->altq_type = 0; in ifq_init()
555 ifq->altq_disc = NULL; in ifq_init()
556 ifq->altq_flags &= ALTQF_CANTCHANGE; in ifq_init()
557 ifq->altq_tbr = NULL; in ifq_init()
558 ifq->altq_ifp = ifp; in ifq_init()
562 ifq_delete(struct ifaltq *ifq) in ifq_delete() argument
[all …]
HDif_spppsubr.c377 static void sppp_qflush(struct ifqueue *ifq);
793 struct ifqueue *ifq = NULL; in sppp_output() local
872 ifq = &sp->pp_fastq; in sppp_output()
878 ifq = &sp->pp_fastq; in sppp_output()
880 ifq = &sp->pp_fastq; in sppp_output()
1004 if (ifq != NULL) in sppp_output()
1005 error = !(IF_HANDOFF_ADJ(ifq, m, ifp, 3)); in sppp_output()
4775 sppp_qflush(struct ifqueue *ifq) in sppp_qflush() argument
4779 n = ifq->ifq_head; in sppp_qflush()
4784 ifq->ifq_head = 0; in sppp_qflush()
[all …]
/trueos/sys/contrib/altq/altq/
HDif_altq.h154 #define ALTQ_IS_READY(ifq) ((ifq)->altq_flags & ALTQF_READY) argument
155 #define ALTQ_IS_ENABLED(ifq) ((ifq)->altq_flags & ALTQF_ENABLED) argument
156 #define ALTQ_NEEDS_CLASSIFY(ifq) ((ifq)->altq_flags & ALTQF_CLASSIFY) argument
157 #define ALTQ_IS_CNDTNING(ifq) ((ifq)->altq_flags & ALTQF_CNDTNING) argument
159 #define ALTQ_SET_CNDTNING(ifq) ((ifq)->altq_flags |= ALTQF_CNDTNING) argument
160 #define ALTQ_CLEAR_CNDTNING(ifq) ((ifq)->altq_flags &= ~ALTQF_CNDTNING) argument
161 #define ALTQ_IS_ATTACHED(ifq) ((ifq)->altq_disc != NULL) argument
163 #define ALTQ_ENQUEUE(ifq, m, pa, err) \ argument
164 (err) = (*(ifq)->altq_enqueue)((ifq),(m),(pa))
165 #define ALTQ_DEQUEUE(ifq, m) \ argument
[all …]
HDaltq_subr.c154 altq_attach(ifq, type, discipline, enqueue, dequeue, request, clfier, classify) in altq_attach() argument
155 struct ifaltq *ifq; in altq_attach()
164 IFQ_LOCK(ifq);
165 if (!ALTQ_IS_READY(ifq)) {
166 IFQ_UNLOCK(ifq);
176 if (ALTQ_IS_ENABLED(ifq)) {
177 IFQ_UNLOCK(ifq);
180 if (ALTQ_IS_ATTACHED(ifq)) {
181 IFQ_UNLOCK(ifq);
186 ifq->altq_type = type;
[all …]
HDaltq_rio.c770 rio_request(ifq, req, arg) in rio_request() argument
771 struct ifaltq *ifq; in rio_request()
775 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
777 IFQ_LOCK_ASSERT(ifq);
782 if (ALTQ_IS_ENABLED(ifq))
783 ifq->ifq_len = 0;
796 rio_enqueue(ifq, m, pktattr) in rio_enqueue() argument
797 struct ifaltq *ifq; in rio_enqueue()
801 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
804 IFQ_LOCK_ASSERT(ifq);
[all …]
HDaltq_cbq.c199 cbq_request(struct ifaltq *ifq, int req, void *arg) in cbq_request() argument
201 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_request()
203 IFQ_LOCK_ASSERT(ifq); in cbq_request()
499 cbq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in cbq_enqueue() argument
501 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; in cbq_enqueue()
506 IFQ_LOCK_ASSERT(ifq); in cbq_enqueue()
512 ifq->altq_ifp->if_xname); in cbq_enqueue()
520 else if ((ifq->altq_flags & ALTQF_CLASSIFY) && pktattr != NULL) in cbq_enqueue()
545 IFQ_INC_LEN(ifq); in cbq_enqueue()
550 cbq_dequeue(struct ifaltq *ifq, int op) in cbq_dequeue() argument
[all …]
HDaltq_priq.c257 priq_request(struct ifaltq *ifq, int req, void *arg) in priq_request() argument
259 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_request()
261 IFQ_LOCK_ASSERT(ifq); in priq_request()
459 priq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in priq_enqueue() argument
461 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; in priq_enqueue()
466 IFQ_LOCK_ASSERT(ifq); in priq_enqueue()
472 ifq->altq_ifp->if_xname); in priq_enqueue()
480 else if ((ifq->altq_flags & ALTQF_CLASSIFY) && pktattr != NULL) in priq_enqueue()
502 IFQ_INC_LEN(ifq); in priq_enqueue()
518 priq_dequeue(struct ifaltq *ifq, int op) in priq_dequeue() argument
[all …]
HDaltq_red.c1030 red_enqueue(ifq, m, pktattr) in red_enqueue() argument
1031 struct ifaltq *ifq; in red_enqueue()
1035 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1037 IFQ_LOCK_ASSERT(ifq);
1041 ifq->ifq_len++;
1054 red_dequeue(ifq, op) in red_dequeue() argument
1055 struct ifaltq *ifq; in red_dequeue()
1058 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1061 IFQ_LOCK_ASSERT(ifq);
1069 ifq->ifq_len--;
[all …]
HDaltq_hfsc.c348 hfsc_request(struct ifaltq *ifq, int req, void *arg) in hfsc_request() argument
350 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_request()
352 IFQ_LOCK_ASSERT(ifq); in hfsc_request()
670 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) in hfsc_enqueue() argument
672 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; in hfsc_enqueue()
677 IFQ_LOCK_ASSERT(ifq); in hfsc_enqueue()
683 ifq->altq_ifp->if_xname); in hfsc_enqueue()
691 else if ((ifq->altq_flags & ALTQF_CLASSIFY) && pktattr != NULL) in hfsc_enqueue()
713 IFQ_INC_LEN(ifq); in hfsc_enqueue()
733 hfsc_dequeue(struct ifaltq *ifq, int op) in hfsc_dequeue() argument
[all …]
HDaltq_cdnr.c423 top_create(ifq) in top_create() argument
424 struct ifaltq *ifq; in top_create()
431 top->tc_ifq = ifq;
437 ifq->altq_cdnr = top;
HDaltq_rmclass.c678 rmc_init(struct ifaltq *ifq, struct rm_ifdat *ifd, u_int nsecPerByte, in rmc_init() argument
690 mtu = ifq->altq_ifp->if_mtu; in rmc_init()
691 ifd->ifq_ = ifq; in rmc_init()
/trueos/sys/dev/usb/
HDusb_mbuf.h46 #define USB_IF_ENQUEUE(ifq, m) do { \ argument
48 if ((ifq)->ifq_tail == NULL) \
49 (ifq)->ifq_head = (m); \
51 (ifq)->ifq_tail->usb_nextpkt = (m); \
52 (ifq)->ifq_tail = (m); \
53 (ifq)->ifq_len++; \
56 #define USB_IF_DEQUEUE(ifq, m) do { \ argument
57 (m) = (ifq)->ifq_head; \
59 if (((ifq)->ifq_head = (m)->usb_nextpkt) == NULL) { \
60 (ifq)->ifq_tail = NULL; \
[all …]
HDusb_mbuf.c63 usb_alloc_mbufs(struct malloc_type *type, struct usb_ifqueue *ifq, in usb_alloc_mbufs() argument
94 USB_IF_ENQUEUE(ifq, m_ptr); in usb_alloc_mbufs()
/trueos/sys/net80211/
HDieee80211_freebsd.h140 #define _IF_PREPEND_LIST(ifq, mhead, mtail, mcount) do { \ argument
141 (mtail)->m_nextpkt = (ifq)->ifq_head; \
142 if ((ifq)->ifq_tail == NULL) \
143 (ifq)->ifq_tail = (mtail); \
144 (ifq)->ifq_head = (mhead); \
145 (ifq)->ifq_len += (mcount); \
147 #define IF_PREPEND_LIST(ifq, mhead, mtail, mcount) do { \ argument
148 IF_LOCK(ifq); \
149 _IF_PREPEND_LIST(ifq, mhead, mtail, mcount); \
150 IF_UNLOCK(ifq); \
HDieee80211_freebsd.c337 ieee80211_drain_ifq(struct ifqueue *ifq) in ieee80211_drain_ifq() argument
343 IF_DEQUEUE(ifq, m); in ieee80211_drain_ifq()
357 ieee80211_flush_ifq(struct ifqueue *ifq, struct ieee80211vap *vap) in ieee80211_flush_ifq() argument
362 IF_LOCK(ifq); in ieee80211_flush_ifq()
363 mprev = &ifq->ifq_head; in ieee80211_flush_ifq()
368 ifq->ifq_len--; in ieee80211_flush_ifq()
376 m = ifq->ifq_head; in ieee80211_flush_ifq()
379 ifq->ifq_tail = m; in ieee80211_flush_ifq()
380 IF_UNLOCK(ifq); in ieee80211_flush_ifq()
/trueos/sys/contrib/ipfilter/netinet/
HDfil.c5726 ipftq_t *ifq; local
5732 for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) {
5733 if (ifq->ifq_ttl == period) {
5738 MUTEX_ENTER(&ifq->ifq_lock);
5739 ifq->ifq_flags &= ~IFQF_DELETE;
5740 ifq->ifq_ref++;
5741 MUTEX_EXIT(&ifq->ifq_lock);
5744 return ifq;
5748 KMALLOC(ifq, ipftq_t *);
5749 if (ifq != NULL) {
[all …]
HDip_state.c427 ipftq_t *ifq, *ifqnext; local
440 for (ifq = softs->ipf_state_usertq; ifq != NULL; ifq = ifqnext) {
441 ifqnext = ifq->ifq_next;
443 if (ipf_deletetimeoutqueue(ifq) == 0)
444 ipf_freetimeoutqueue(softc, ifq);
3028 ipftq_t *ifq; local
3032 ifq = NULL;
3096 ifq = &softs->ipf_state_icmpacktq;
3098 ifq = &softs->ipf_state_icmptq;
3161 ifq = &softs->ipf_state_icmpacktq;
[all …]
HDip_nat.c542 ipftq_t *ifq, *ifqnext; local
554 for (ifq = softn->ipf_nat_utqe; ifq != NULL; ifq = ifqnext) {
555 ifqnext = ifq->ifq_next;
556 if (ipf_deletetimeoutqueue(ifq) == 0)
557 ipf_freetimeoutqueue(softc, ifq);
4801 ipftq_t *ifq, *ifq2; local
4806 ifq = tqe->tqe_ifq;
4836 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq2);
5883 ipftq_t *ifq, *ifqnext; local
5890 for (ifq = softn->ipf_nat_tcptq, i = 0; ifq != NULL;
[all …]
/trueos/sys/dev/lmc/
HDif_lmc.h1257 # define IF_DROP(ifq) _IF_DROP(ifq) argument
1258 # define IF_QFULL(ifq) _IF_QFULL(ifq) argument
1434 # define IFQ_ENQUEUE(ifq, m, pa, err) \ argument
1437 if (IF_QFULL(ifq)) \
1439 IF_DROP(ifq); \
1445 IF_ENQUEUE(ifq, m); \
1449 # define IFQ_DEQUEUE(ifq, m) do { IF_DEQUEUE((ifq), m) } while (0) argument
1450 # define IFQ_IS_EMPTY(ifq) ((ifq)->ifq_head == NULL) argument
1451 # define IFQ_SET_MAXLEN(ifq, len) (ifq)->ifq_maxlen = len argument
1452 # define IFQ_SET_READY(ifq) /* nothing */ argument
[all …]
/trueos/sys/netinet6/
HDmld6.c410 mld_dispatch_queue(struct ifqueue *ifq, int limit) in mld_dispatch_queue() argument
415 _IF_DEQUEUE(ifq, m); in mld_dispatch_queue()
418 CTR3(KTR_MLD, "%s: dispatch %p from %p", __func__, ifq, m); in mld_dispatch_queue()
1954 struct ifqueue *ifq; in mld_initial_join() local
2041 ifq = &inm->in6m_scq; in mld_initial_join()
2042 _IF_DRAIN(ifq); in mld_initial_join()
2043 retval = mld_v2_enqueue_group_record(ifq, inm, 1, in mld_initial_join()
2284 mld_v2_enqueue_group_record(struct ifqueue *ifq, struct in6_multi *inm, in mld_v2_enqueue_group_record() argument
2399 return (mld_v2_enqueue_filter_change(ifq, inm)); in mld_v2_enqueue_group_record()
2430 m0 = ifq->ifq_tail; in mld_v2_enqueue_group_record()
[all …]
/trueos/sys/netinet/
HDigmp.c477 igmp_dispatch_queue(struct ifqueue *ifq, int limit, const int loop) in igmp_dispatch_queue() argument
482 _IF_DEQUEUE(ifq, m); in igmp_dispatch_queue()
485 CTR3(KTR_IGMPV3, "%s: dispatch %p from %p", __func__, ifq, m); in igmp_dispatch_queue()
2341 struct ifqueue *ifq; in igmp_initial_join() local
2415 ifq = &inm->inm_scq; in igmp_initial_join()
2416 _IF_DRAIN(ifq); in igmp_initial_join()
2417 retval = igmp_v3_enqueue_group_record(ifq, inm, 1, in igmp_initial_join()
2644 igmp_v3_enqueue_group_record(struct ifqueue *ifq, struct in_multi *inm, in igmp_v3_enqueue_group_record() argument
2734 return (igmp_v3_enqueue_filter_change(ifq, inm)); in igmp_v3_enqueue_group_record()
2764 m0 = ifq->ifq_tail; in igmp_v3_enqueue_group_record()
[all …]
/trueos/sys/netgraph/
HDng_source.c721 struct ifqueue *ifq; in ng_source_intr() local
733 ifq = (struct ifqueue *)&sc->output_ifp->if_snd; in ng_source_intr()
734 packets = ifq->ifq_maxlen - ifq->ifq_len; in ng_source_intr()
/trueos/share/doc/smm/18.net/
HDspell.ok189 ifq
/trueos/sys/dev/ce/
HDif_ce.c111 #define IF_DRAIN(ifq) do { \ argument
114 IF_DEQUEUE(ifq, m); \
123 #define _IF_QLEN(ifq) ((ifq)->ifq_len) argument