/src/sys/altq/ |
if_altq.h | 139 #define ALTQ_IS_READY(ifq) ((ifq)->altq_flags & ALTQF_READY) 140 #define ALTQ_IS_ENABLED(ifq) ((ifq)->altq_flags & ALTQF_ENABLED) 141 #define ALTQ_NEEDS_CLASSIFY(ifq) ((ifq)->altq_flags & ALTQF_CLASSIFY) 142 #define ALTQ_IS_CNDTNING(ifq) ((ifq)->altq_flags & ALTQF_CNDTNING) 144 #define ALTQ_SET_CNDTNING(ifq) ((ifq)->altq_flags |= ALTQF_CNDTNING [all...] |
altq_subr.c | 127 altq_attach(struct ifaltq *ifq, int type, void *discipline, 133 if (!ALTQ_IS_READY(ifq)) 142 if (ALTQ_IS_ENABLED(ifq)) 144 if (ALTQ_IS_ATTACHED(ifq)) 148 ifq->altq_type = type; 149 ifq->altq_disc = discipline; 150 ifq->altq_enqueue = enqueue; 151 ifq->altq_dequeue = dequeue; 152 ifq->altq_request = request; 153 ifq->altq_clfier = clfier [all...] |
altq_wfq.c | 101 error = altq_enable(wfqp->ifq); 104 error = altq_disable(wfqp->ifq); 144 /* keep the ifq */ 145 new_wfqp->ifq = &ifp->if_snd; 189 wfq_flush(wfqp->ifq); 192 (void)altq_disable(wfqp->ifq); 193 (void)altq_detach(wfqp->ifq); 215 wfq_request(struct ifaltq *ifq, int req, void *arg) 217 wfq_state_t *wfqp = (wfq_state_t *)ifq->altq_disc; 221 wfq_flush(wfqp->ifq); [all...] |
altq_fifoq.c | 263 fifoq_enqueue(struct ifaltq *ifq, struct mbuf *m) 265 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc; 284 ifq->ifq_len++; 304 fifoq_dequeue(struct ifaltq *ifq, int op) 306 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc; 319 ifq->ifq_len--; 329 fifoq_request(struct ifaltq *ifq, int req, void *arg) 331 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc;
|
altq_wfq.h | 116 struct ifaltq *ifq; member in struct:wfqstate
|
altq_blue.c | 389 blue_enqueue(struct ifaltq *ifq, struct mbuf *m) 392 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; 400 ifq->ifq_len++; 611 blue_dequeue(struct ifaltq * ifq, int op) 613 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; 621 ifq->ifq_len--; 647 blue_request(struct ifaltq *ifq, int req, void *arg) 649 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc; 654 if (ALTQ_IS_ENABLED(ifq)) 655 ifq->ifq_len = 0 [all...] |
altq_rio.c | 727 rio_request(struct ifaltq *ifq, int req, void *arg) 729 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; 734 if (ALTQ_IS_ENABLED(ifq)) 735 ifq->ifq_len = 0; 748 rio_enqueue(struct ifaltq *ifq, struct mbuf *m) 751 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; 759 ifq->ifq_len++; 774 rio_dequeue(struct ifaltq *ifq, int op) 776 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc; 784 ifq->ifq_len-- [all...] |
altq_cbq.c | 200 cbq_request(struct ifaltq *ifq, int req, void *arg) 202 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; 279 cbqp->ifnp.ifq_ = &ifp->if_snd; /* keep the ifq */ 482 * cbq_enqueue(struct ifaltq *ifq, struct mbuf *m) 496 cbq_enqueue(struct ifaltq *ifq, struct mbuf *m) 499 cbq_state_t *cbqp = (cbq_state_t *)ifq->altq_disc; 508 ifq->altq_ifp->if_xname); 516 else if (ifq->altq_flags & ALTQF_CLASSIFY) 545 IFQ_INC_LEN(ifq); 550 cbq_dequeue(struct ifaltq *ifq, int op [all...] |
altq_priq.c | 256 priq_request(struct ifaltq *ifq, int req, void *arg) 258 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; 428 priq_enqueue(struct ifaltq *ifq, struct mbuf *m) 431 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; 440 ifq->altq_ifp->if_xname); 448 else if (ifq->altq_flags & ALTQF_CLASSIFY) 474 IFQ_INC_LEN(ifq); 490 priq_dequeue(struct ifaltq *ifq, int op) 492 struct priq_if *pif = (struct priq_if *)ifq->altq_disc; 497 if (IFQ_IS_EMPTY(ifq)) [all...] |
altq_red.c | 1009 red_enqueue(struct ifaltq *ifq, struct mbuf *m) 1012 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; 1020 ifq->ifq_len++; 1033 red_dequeue(struct ifaltq *ifq, int op) 1035 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc; 1044 ifq->ifq_len--; 1049 red_request(struct ifaltq *ifq, int req, void *arg) 1051 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
|
altq_hfsc.c | 358 hfsc_request(struct ifaltq *ifq, int req, void *arg) 360 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; 669 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m) 672 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; 681 ifq->altq_ifp->if_xname); 689 else if ((ifq->altq_flags & ALTQF_CLASSIFY)) 715 IFQ_INC_LEN(ifq); 735 hfsc_dequeue(struct ifaltq *ifq, int op) 737 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc; 809 IFQ_DEC_LEN(ifq); [all...] |
altq_jobs.c | 150 jobs_attach(struct ifaltq *ifq, u_int bandwidth, u_int qlimit, u_int separate) 167 jif->jif_ifq = ifq; 230 jobs_request(struct ifaltq *ifq, int req, void *arg) 232 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc; 493 jobs_enqueue(struct ifaltq *ifq, struct mbuf *m) 495 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc; 513 if (IFQ_IS_EMPTY(ifq)) { 604 IFQ_INC_LEN(ifq); 655 jobs_dequeue(struct ifaltq *ifq, int op) 657 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc [all...] |
altq_rmclass.c | 665 rmc_init(struct ifaltq *ifq, struct rm_ifdat *ifd, uint64_t psecPerByte, 676 mtu = ifq->altq_ifp->if_mtu; 679 ifq->altq_ifp->if_xname); 684 ifd->ifq_ = ifq;
|
/src/sys/net/ |
if.h | 693 #define IF_QFULL(ifq) ((ifq)->ifq_len >= (ifq)->ifq_maxlen) 694 #define IF_DROP(ifq) ((ifq)->ifq_drops++) 695 #define IF_ENQUEUE(ifq, m) do { \ 697 if ((ifq)->ifq_tail == 0) \ 698 (ifq)->ifq_head = m; \ 700 (ifq)->ifq_tail->m_nextpkt = m; \ 701 (ifq)->ifq_tail = m; [all...] |
if_l2tp.c | 379 struct ifqueue *ifq; local in function:l2tp_tx_enqueue 388 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); 389 if (IF_QFULL(ifq)) { 397 IF_ENQUEUE(ifq, m); 502 struct ifqueue *ifq; local in function:l2tpintr 512 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); 513 IF_PURGE(ifq); 521 ifq = l2tp_ifq_percpu_getref(sc->l2tp_ifq_percpu); 523 IF_DEQUEUE(ifq, m);
|
if.c | 856 struct ifqueue *const ifq = p; local in function:if_percpuq_init_ifq 858 memset(ifq, 0, sizeof(*ifq)); 859 ifq->ifq_maxlen = IFQ_MAXLEN; 885 struct ifqueue *ifq; local in function:if_percpuq_dequeue 888 ifq = percpu_getref(ipq->ipq_ifqs); 889 IF_DEQUEUE(ifq, m); 899 struct ifqueue *const ifq = p; local in function:if_percpuq_purge_ifq 901 IF_PURGE(ifq); 921 struct ifqueue *ifq; local in function:if_percpuq_enqueue 945 struct ifqueue *const ifq = p; local in function:if_percpuq_drops [all...] |
if_ppp.c | 876 struct ifqueue *ifq; local in function:pppoutput 1019 ifq = (m0->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL; 1020 if ((error = ifq_enqueue2(&sc->sc_if, ifq, m0)) != 0) { 1047 struct ifqueue *ifq; local in function:ppp_requeue 1071 ifq = (m->m_flags & M_HIGHPRI) ? &sc->sc_fastq : NULL; 1072 if ((error = ifq_enqueue2(&sc->sc_if, ifq, m)) != 0) { 1741 /* ifq: other protocol cases */
|
/src/sys/external/bsd/ipf/netinet/ |
ip_state.c | 430 ipftq_t *ifq, *ifqnext; local in function:ipf_state_soft_fini 443 for (ifq = softs->ipf_state_usertq; ifq != NULL; ifq = ifqnext) { 444 ifqnext = ifq->ifq_next; 446 if (ipf_deletetimeoutqueue(ifq) == 0) 447 ipf_freetimeoutqueue(softc, ifq); 2977 ipftq_t *ifq; local in function:ipf_state_lookup 2981 ifq = NULL; 3045 ifq = &softs->ipf_state_icmpacktq 3256 ipftq_t *ifq; local in function:ipf_state_check 3671 ipftq_t *ifq, *ifqnext; local in function:ipf_state_expire 3744 ipftq_t *ifq; local in function:ipf_state_flush [all...] |
fil.c | 5615 ipftq_t *ifq; local in function:ipf_addtimeoutqueue 5621 for (ifq = *parent; ifq != NULL; ifq = ifq->ifq_next) { 5622 if (ifq->ifq_ttl == period) { 5627 MUTEX_ENTER(&ifq->ifq_lock); 5628 ifq->ifq_flags &= ~IFQF_DELETE; 5629 ifq->ifq_ref++; 5630 MUTEX_EXIT(&ifq->ifq_lock) 5734 ipftq_t *ifq; local in function:ipf_deletequeueentry 5768 ipftq_t *ifq; local in function:ipf_queuefront 5804 ipftq_t *ifq; local in function:ipf_queueback 8735 ipftq_t *ifq, *ifqnext; local in function:ipf_queueflush [all...] |
ip_nat.c | 535 ipftq_t *ifq, *ifqnext; local in function:ipf_nat_soft_fini 547 for (ifq = softn->ipf_nat_utqe; ifq != NULL; ifq = ifqnext) { 548 ifqnext = ifq->ifq_next; 549 if (ipf_deletetimeoutqueue(ifq) == 0) 550 ipf_freetimeoutqueue(softc, ifq); 4721 ipftq_t *ifq, *ifq2; local in function:ipf_nat_update 4726 ifq = tqe->tqe_ifq; 4756 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq2) 5801 ipftq_t *ifq, *ifqnext; local in function:ipf_nat_expire 6668 ipftq_t *ifq; local in function:ipf_nat_extraflush [all...] |
/src/usr.bin/netstat/ |
main.c | 768 struct ifqueue intrq, *ifq = &intrq; local in function:print_softintrq 777 kread(off, (char *)ifq, sizeof(*ifq)); 779 printf("\tqueue length: %d\n", ifq->ifq_len); 780 printf("\tmaximum queue length: %d\n", ifq->ifq_maxlen); 781 printf("\tpackets dropped: %" PRIu64 "\n", ifq->ifq_drops);
|
/src/sys/dev/pci/igc/ |
if_igc.h | 286 struct ifqueue *ifq; member in struct:tx_ring
|
/src/sys/dev/ic/ |
hd64570.c | 799 struct ifqueue *ifq = NULL; local in function:sca_output 825 ifq = &((sca_port_t *)ifp->if_softc)->fastq; 871 if (ifq != NULL) { 872 if (IF_QFULL(ifq)) { 873 IF_DROP(ifq); 877 IF_ENQUEUE(ifq, m);
|
/src/sys/net80211/ |
ieee80211_netbsd.c | 514 ieee80211_drain_ifq(struct ifqueue *ifq) 520 IF_DEQUEUE(ifq, m);
|
/src/sys/arch/usermode/dev/ |
if_veth.c | 138 IFQ_SET_READY(&ifq->if_snd);
|