/freebsd-10.1-release/sys/dev/usb/ |
H A D | usb_mbuf.h | 46 #define USB_IF_ENQUEUE(ifq, m) do { \ 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 { \ 57 (m) = (ifq)->ifq_head; \ 59 if (((ifq)->ifq_head = (m)->usb_nextpkt) == NULL) { \ 60 (ifq) [all...] |
H A D | usb_mbuf.c | 63 usb_alloc_mbufs(struct malloc_type *type, struct usb_ifqueue *ifq, argument 94 USB_IF_ENQUEUE(ifq, m_ptr);
|
/freebsd-10.1-release/sys/contrib/altq/altq/ |
H A D | if_altq.h | 154 #define ALTQ_IS_READY(ifq) ((ifq)->altq_flags & ALTQF_READY) 155 #define ALTQ_IS_ENABLED(ifq) ((ifq)->altq_flags & ALTQF_ENABLED) 156 #define ALTQ_NEEDS_CLASSIFY(ifq) ((ifq)->altq_flags & ALTQF_CLASSIFY) 157 #define ALTQ_IS_CNDTNING(ifq) ((ifq)->altq_flags & ALTQF_CNDTNING) 159 #define ALTQ_SET_CNDTNING(ifq) ((ifq) [all...] |
H A D | altq_subr.c | 154 altq_attach(ifq, type, discipline, enqueue, dequeue, request, clfier, classify) 155 struct ifaltq *ifq; 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 [all...] |
H A D | altq_rio.c | 770 rio_request(ifq, req, arg) 771 struct ifaltq *ifq; 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) 797 struct ifaltq *ifq; 801 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; 804 IFQ_LOCK_ASSERT(ifq); [all...] |
H A D | altq_cbq.c | 199 cbq_request(struct ifaltq *ifq, int req, void *arg) argument 201 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; 203 IFQ_LOCK_ASSERT(ifq); 282 cbqp->ifnp.ifq_ = &ifp->if_snd; /* keep the ifq */ 485 * cbq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pattr) 499 cbq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) argument 501 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; 506 IFQ_LOCK_ASSERT(ifq); 512 ifq->altq_ifp->if_xname); 520 else if ((ifq 550 cbq_dequeue(struct ifaltq *ifq, int op) argument 578 cbqrestart(struct ifaltq *ifq) argument [all...] |
H A D | altq_priq.c | 257 priq_request(struct ifaltq *ifq, int req, void *arg) argument 259 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; 261 IFQ_LOCK_ASSERT(ifq); 459 priq_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) argument 461 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; 466 IFQ_LOCK_ASSERT(ifq); 472 ifq->altq_ifp->if_xname); 480 else if ((ifq->altq_flags & ALTQF_CLASSIFY) && pktattr != NULL) 502 IFQ_INC_LEN(ifq); 518 priq_dequeue(struct ifaltq *ifq, in argument [all...] |
H A D | altq_red.c | 1030 red_enqueue(ifq, m, pktattr) 1031 struct ifaltq *ifq; 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) 1055 struct ifaltq *ifq; 1058 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; 1061 IFQ_LOCK_ASSERT(ifq); 1069 ifq [all...] |
H A D | altq_hfsc.c | 348 hfsc_request(struct ifaltq *ifq, int req, void *arg) argument 350 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; 352 IFQ_LOCK_ASSERT(ifq); 670 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m, struct altq_pktattr *pktattr) argument 672 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; 677 IFQ_LOCK_ASSERT(ifq); 683 ifq->altq_ifp->if_xname); 691 else if ((ifq->altq_flags & ALTQF_CLASSIFY) && pktattr != NULL) 713 IFQ_INC_LEN(ifq); 733 hfsc_dequeue(struct ifaltq *ifq, in argument [all...] |
H A D | altq_cdnr.c | 423 top_create(ifq) 424 struct ifaltq *ifq; 431 top->tc_ifq = ifq; 437 ifq->altq_cdnr = top;
|
H A D | altq_rmclass.c | 678 rmc_init(struct ifaltq *ifq, struct rm_ifdat *ifd, u_int nsecPerByte, argument 690 mtu = ifq->altq_ifp->if_mtu; 691 ifd->ifq_ = ifq;
|
/freebsd-10.1-release/sys/net/ |
H A D | if_var.h | 284 #define IF_LOCK(ifq) mtx_lock(&(ifq)->ifq_mtx) 285 #define IF_UNLOCK(ifq) mtx_unlock(&(ifq)->ifq_mtx) 286 #define IF_LOCK_ASSERT(ifq) mtx_assert(&(ifq)->ifq_mtx, MA_OWNED) 287 #define _IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen) 288 #define _IF_DROP(ifq) ((if [all...] |
H A D | if.c | 545 ifq_init(struct ifaltq *ifq, struct ifnet *ifp) argument 548 mtx_init(&ifq->ifq_mtx, ifp->if_xname, "if send queue", MTX_DEF); 550 if (ifq->ifq_maxlen == 0) 551 ifq->ifq_maxlen = ifqmaxlen; 553 ifq->altq_type = 0; 554 ifq->altq_disc = NULL; 555 ifq->altq_flags &= ALTQF_CANTCHANGE; 556 ifq->altq_tbr = NULL; 557 ifq->altq_ifp = ifp; 561 ifq_delete(struct ifaltq *ifq) argument 2002 struct ifaltq *ifq; local 3413 if_handoff(struct ifqueue *ifq, struct mbuf *m, struct ifnet *ifp, int adjust) argument [all...] |
H A D | if_spppsubr.c | 377 static void sppp_qflush(struct ifqueue *ifq); 793 struct ifqueue *ifq = NULL; local 872 ifq = &sp->pp_fastq; 878 ifq = &sp->pp_fastq; 880 ifq = &sp->pp_fastq; 1004 if (ifq != NULL) 1005 error = !(IF_HANDOFF_ADJ(ifq, m, ifp, 3)); 4775 sppp_qflush(struct ifqueue *ifq) argument 4779 n = ifq->ifq_head; 4784 ifq [all...] |
/freebsd-10.1-release/sys/net80211/ |
H A D | ieee80211_freebsd.h | 140 #define _IF_PREPEND_LIST(ifq, mhead, mtail, mcount) do { \ 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 { \ 148 IF_LOCK(ifq); \ 149 _IF_PREPEND_LIST(ifq, mhead, mtail, mcount); \ 150 IF_UNLOCK(ifq); \ [all...] |
H A D | ieee80211_freebsd.c | 337 ieee80211_drain_ifq(struct ifqueue *ifq) argument 343 IF_DEQUEUE(ifq, m); 357 ieee80211_flush_ifq(struct ifqueue *ifq, struct ieee80211vap *vap) argument 362 IF_LOCK(ifq); 363 mprev = &ifq->ifq_head; 368 ifq->ifq_len--; 376 m = ifq->ifq_head; 379 ifq->ifq_tail = m; 380 IF_UNLOCK(ifq);
|
/freebsd-10.1-release/sys/contrib/ipfilter/netinet/ |
H A D | ip_state.c | 427 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 3309 ipftq_t *ifq; local 3733 ipftq_t *ifq, *ifqnext; local 3808 ipftq_t *ifq; local [all...] |
H A D | fil.c | 5691 ipftq_t *ifq; local 5697 for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) { 5698 if (ifq->ifq_ttl == period) { 5703 MUTEX_ENTER(&ifq->ifq_lock); 5704 ifq->ifq_flags &= ~IFQF_DELETE; 5705 ifq->ifq_ref++; 5706 MUTEX_EXIT(&ifq 5814 ipftq_t *ifq; local 5849 ipftq_t *ifq; local 5887 ipftq_t *ifq; local 8936 ipftq_t *ifq, *ifqnext; local [all...] |
H A D | ip_nat.c | 542 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); 4799 ipftq_t *ifq, *ifq2; local 4804 ifq = tqe->tqe_ifq; 4834 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq 5881 ipftq_t *ifq, *ifqnext; local 6775 ipftq_t *ifq; local [all...] |
/freebsd-10.1-release/sys/dev/lmc/ |
H A D | if_lmc.h | 1258 # define IF_DROP(ifq) _IF_DROP(ifq) 1259 # define IF_QFULL(ifq) _IF_QFULL(ifq) 1435 # define IFQ_ENQUEUE(ifq, m, pa, err) \ 1438 if (IF_QFULL(ifq)) \ 1440 IF_DROP(ifq); \ 1446 IF_ENQUEUE(ifq, m); \ 1450 # define IFQ_DEQUEUE(ifq, m) do { IF_DEQUEUE((ifq), [all...] |
/freebsd-10.1-release/sys/netinet6/ |
H A D | mld6.c | 410 mld_dispatch_queue(struct ifqueue *ifq, int limit) argument 415 _IF_DEQUEUE(ifq, m); 418 CTR3(KTR_MLD, "%s: dispatch %p from %p", __func__, ifq, m); 1954 struct ifqueue *ifq; local 2041 ifq = &inm->in6m_scq; 2042 _IF_DRAIN(ifq); 2043 retval = mld_v2_enqueue_group_record(ifq, inm, 1, 2284 mld_v2_enqueue_group_record(struct ifqueue *ifq, struct in6_multi *inm, argument 2399 return (mld_v2_enqueue_filter_change(ifq, inm)); 2430 m0 = ifq 2670 mld_v2_enqueue_filter_change(struct ifqueue *ifq, struct in6_multi *inm) argument [all...] |
/freebsd-10.1-release/sys/netinet/ |
H A D | igmp.c | 477 igmp_dispatch_queue(struct ifqueue *ifq, int limit, const int loop) argument 482 _IF_DEQUEUE(ifq, m); 485 CTR3(KTR_IGMPV3, "%s: dispatch %p from %p", __func__, ifq, m); 2341 struct ifqueue *ifq; local 2415 ifq = &inm->inm_scq; 2416 _IF_DRAIN(ifq); 2417 retval = igmp_v3_enqueue_group_record(ifq, inm, 1, 2644 igmp_v3_enqueue_group_record(struct ifqueue *ifq, struct in_multi *inm, argument 2734 return (igmp_v3_enqueue_filter_change(ifq, inm)); 2764 m0 = ifq 3007 igmp_v3_enqueue_filter_change(struct ifqueue *ifq, struct in_multi *inm) argument [all...] |
/freebsd-10.1-release/sys/netgraph/ |
H A D | ng_source.c | 721 struct ifqueue *ifq; local 733 ifq = (struct ifqueue *)&sc->output_ifp->if_snd; 734 packets = ifq->ifq_maxlen - ifq->ifq_len;
|
/freebsd-10.1-release/sys/dev/ce/ |
H A D | if_ce.c | 111 #define IF_DRAIN(ifq) do { \ 114 IF_DEQUEUE(ifq, m); \ 123 #define _IF_QLEN(ifq) ((ifq)->ifq_len)
|