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

12

/netbsd-current/sys/altq/
H A Dif_altq.h139 #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)
[all...]
H A Daltq_subr.c127 altq_attach(struct ifaltq *ifq, int type, void *discipline, argument
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
165 altq_detach(struct ifaltq *ifq) argument
191 altq_enable(struct ifaltq *ifq) argument
212 altq_disable(struct ifaltq *ifq) argument
250 tbr_dequeue(struct ifaltq *ifq, int op) argument
299 tbr_set(struct ifaltq *ifq, struct tb_profile *profile) argument
388 tbr_get(struct ifaltq *ifq, struct tb_profile *profile) argument
[all...]
H A Daltq_wfq.c101 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) argument
217 wfq_state_t *wfqp = (wfq_state_t *)ifq->altq_disc;
221 wfq_flush(wfqp->ifq);
229 wfq_flush(struct ifaltq *ifq) argument
251 wfq_ifenqueue(struct ifaltq *ifq, struct mbuf *mp) argument
435 wfq_ifdequeue(struct ifaltq *ifq, int op) argument
[all...]
H A Daltq_fifoq.c263 fifoq_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
265 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc;
284 ifq->ifq_len++;
304 fifoq_dequeue(struct ifaltq *ifq, int op) argument
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) argument
331 fifoq_state_t *q = (fifoq_state_t *)ifq->altq_disc;
H A Daltq_wfq.h116 struct ifaltq *ifq; member in struct:wfqstate
H A Daltq_rio.c727 rio_request(struct ifaltq *ifq, int req, void *arg) argument
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) argument
751 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
759 ifq->ifq_len++;
774 rio_dequeue(struct ifaltq *ifq, int op) argument
776 rio_queue_t *rqp = (rio_queue_t *)ifq->altq_disc;
784 ifq
[all...]
H A Daltq_blue.c389 blue_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
392 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc;
400 ifq->ifq_len++;
611 blue_dequeue(struct ifaltq * ifq, int op) argument
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) argument
649 blue_queue_t *rqp = (blue_queue_t *)ifq->altq_disc;
654 if (ALTQ_IS_ENABLED(ifq))
655 ifq
[all...]
H A Daltq_cbq.c200 cbq_request(struct ifaltq *ifq, int req, void *arg) argument
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) argument
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, in argument
576 cbqrestart(struct ifaltq *ifq) argument
[all...]
H A Daltq_priq.c256 priq_request(struct ifaltq *ifq, int req, void *arg) argument
258 struct priq_if *pif = (struct priq_if *)ifq->altq_disc;
428 priq_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
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) argument
492 struct priq_if *pif = (struct priq_if *)ifq->altq_disc;
497 if (IFQ_IS_EMPTY(ifq))
625 priq_attach(struct ifaltq *ifq, u_int bandwidth) argument
[all...]
H A Daltq_red.c1009 red_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
1012 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
1020 ifq->ifq_len++;
1033 red_dequeue(struct ifaltq *ifq, int op) argument
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) argument
1051 red_queue_t *rqp = (red_queue_t *)ifq->altq_disc;
H A Daltq_hfsc.c358 hfsc_request(struct ifaltq *ifq, int req, void *arg) argument
360 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc;
669 hfsc_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
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) argument
737 struct hfsc_if *hif = (struct hfsc_if *)ifq->altq_disc;
809 IFQ_DEC_LEN(ifq);
1712 hfsc_attach(struct ifaltq *ifq, u_int bandwidth) argument
[all...]
H A Daltq_jobs.c150 jobs_attach(struct ifaltq *ifq, u_int bandwidth, u_int qlimit, u_int separate) argument
167 jif->jif_ifq = ifq;
230 jobs_request(struct ifaltq *ifq, int req, void *arg) argument
232 struct jobs_if *jif = (struct jobs_if *)ifq->altq_disc;
493 jobs_enqueue(struct ifaltq *ifq, struct mbuf *m) argument
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) argument
657 struct jobs_if *jif = (struct jobs_if *)ifq
[all...]
H A Daltq_rmclass.c665 rmc_init(struct ifaltq *ifq, struct rm_ifdat *ifd, uint64_t psecPerByte, argument
676 mtu = ifq->altq_ifp->if_mtu;
679 ifq->altq_ifp->if_xname);
684 ifd->ifq_ = ifq;
/netbsd-current/sys/net/
H A Dif.h693 #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)
[all...]
H A Dif_l2tp.c379 struct ifqueue *ifq; local
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
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);
H A Dif.c856 struct ifqueue *const ifq = p; local
858 memset(ifq, 0, sizeof(*ifq));
859 ifq->ifq_maxlen = IFQ_MAXLEN;
885 struct ifqueue *ifq; local
888 ifq = percpu_getref(ipq->ipq_ifqs);
889 IF_DEQUEUE(ifq, m);
899 struct ifqueue *const ifq = p; local
901 IF_PURGE(ifq);
921 struct ifqueue *ifq; local
944 struct ifqueue *const ifq = p; local
3841 ifq_enqueue2(struct ifnet *ifp, struct ifqueue *ifq, struct mbuf *m) argument
3993 sysctl_sndq_setup(struct sysctllog **clog, const char *ifname, struct ifaltq *ifq) argument
[all...]
H A Dif_ppp.c876 struct ifqueue *ifq; local
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
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 */
/netbsd-current/sys/external/bsd/ipf/netinet/
H A Dip_state.c430 ipftq_t *ifq, *ifqnext; local
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
2981 ifq = NULL;
3045 ifq
3256 ipftq_t *ifq; local
3671 ipftq_t *ifq, *ifqnext; local
3744 ipftq_t *ifq; local
[all...]
H A Dfil.c5615 ipftq_t *ifq; local
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
5669 ipf_deletetimeoutqueue(ipftq_t *ifq) argument
5695 ipf_freetimeoutqueue(ipf_main_softc_t *softc, ipftq_t *ifq) argument
5734 ipftq_t *ifq; local
5768 ipftq_t *ifq; local
5804 ipftq_t *ifq; local
5845 ipf_queueappend(u_long ticks, ipftqent_t *tqe, ipftq_t *ifq, void *parent) argument
8735 ipftq_t *ifq, *ifqnext; local
[all...]
H A Dip_nat.c535 ipftq_t *ifq, *ifqnext; local
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
4726 ifq = tqe->tqe_ifq;
4756 ipf_movequeue(softc->ipf_ticks, tqe, ifq, ifq
5801 ipftq_t *ifq, *ifqnext; local
6668 ipftq_t *ifq; local
[all...]
/netbsd-current/usr.bin/netstat/
H A Dmain.c768 struct ifqueue intrq, *ifq = &intrq; local
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);
/netbsd-current/sys/dev/pci/igc/
H A Dif_igc.h286 struct ifqueue *ifq; member in struct:tx_ring
/netbsd-current/sys/dev/ic/
H A Dhd64570.c799 struct ifqueue *ifq = NULL; local
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);
/netbsd-current/sys/net80211/
H A Dieee80211_netbsd.c514 ieee80211_drain_ifq(struct ifqueue *ifq) argument
520 IF_DEQUEUE(ifq, m);
/netbsd-current/sys/arch/usermode/dev/
H A Dif_veth.c138 IFQ_SET_READY(&ifq->if_snd);

Completed in 465 milliseconds

12