Home
last modified time | relevance | path

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

123

/openbsd/src/sys/net/
Difq.c82 ifq_run_start(struct ifqueue *ifq) in ifq_run_start() argument
84 ifq_serialize(ifq, &ifq->ifq_start); in ifq_run_start()
88 ifq_serialize(struct ifqueue *ifq, struct task *t) in ifq_serialize() argument
95 mtx_enter(&ifq->ifq_task_mtx); in ifq_serialize()
98 TAILQ_INSERT_TAIL(&ifq->ifq_task_list, t, t_entry); in ifq_serialize()
101 if (ifq->ifq_serializer == NULL) { in ifq_serialize()
102 ifq->ifq_serializer = curcpu(); in ifq_serialize()
104 while ((t = TAILQ_FIRST(&ifq->ifq_task_list)) != NULL) { in ifq_serialize()
105 TAILQ_REMOVE(&ifq->ifq_task_list, t, t_entry); in ifq_serialize()
109 mtx_leave(&ifq->ifq_task_mtx); in ifq_serialize()
[all …]
Difq.h457 ifq_is_priq(struct ifqueue *ifq) in ifq_is_priq() argument
459 return (ifq->ifq_ops == ifq_priq_ops); in ifq_is_priq()
463 ifq_clr_oactive(struct ifqueue *ifq) in ifq_clr_oactive() argument
465 ifq->ifq_oactive = 0; in ifq_clr_oactive()
469 ifq_is_oactive(struct ifqueue *ifq) in ifq_is_oactive() argument
471 return (ifq->ifq_oactive); in ifq_is_oactive()
475 ifq_restart(struct ifqueue *ifq) in ifq_restart() argument
477 ifq_serialize(ifq, &ifq->ifq_restart); in ifq_restart()
481 ifq_idx(struct ifqueue *ifq, unsigned int nifqs, const struct mbuf *m) in ifq_idx() argument
483 return ((*ifq->ifq_ops->ifqop_idx)(nifqs, m)); in ifq_idx()
Dif_rport.c216 struct ifqueue *ifq = &ifp->if_snd; in rport_enqueue() local
219 error = ifq_enqueue(ifq, m); in rport_enqueue()
227 task_add(ifq->ifq_softnet, &ifq->ifq_bundle); in rport_enqueue()
233 rport_start(struct ifqueue *ifq) in rport_start() argument
235 struct ifnet *ifp = ifq->ifq_if; in rport_start()
242 ifq_purge(ifq); in rport_start()
248 while ((m = ifq_dequeue(ifq)) != NULL) { in rport_start()
Dif_sec.c343 struct ifqueue *ifq = &ifp->if_snd; in sec_enqueue() local
346 error = ifq_enqueue(ifq, m); in sec_enqueue()
360 struct ifqueue *ifq = &ifp->if_snd; in sec_send() local
376 while ((m = ifq_dequeue(ifq)) != NULL) { in sec_send()
404 counters_add(ifp->if_counters, ifc_oerrors, ifq_purge(ifq)); in sec_send()
408 sec_start(struct ifqueue *ifq) in sec_start() argument
410 struct ifnet *ifp = ifq->ifq_if; in sec_start()
Dif_vether.c119 vetherqstart(struct ifqueue *ifq) in vetherqstart() argument
123 while ((m = ifq_dequeue(ifq)) != NULL) { in vetherqstart()
125 struct ifnet *ifp = ifq->ifq_if; in vetherqstart()
Dfq_codel.c693 fqcodel_if_enq(struct ifqueue *ifq, struct mbuf *m) in fqcodel_if_enq() argument
695 return fqcodel_enq(ifq->ifq_q, m); in fqcodel_if_enq()
699 fqcodel_if_deq_begin(struct ifqueue *ifq, void **cookiep) in fqcodel_if_deq_begin() argument
704 m = fqcodel_deq_begin(ifq->ifq_q, cookiep, &free_ml); in fqcodel_if_deq_begin()
705 ifq_mfreeml(ifq, &free_ml); in fqcodel_if_deq_begin()
710 fqcodel_if_deq_commit(struct ifqueue *ifq, struct mbuf *m, void *cookie) in fqcodel_if_deq_commit() argument
712 return fqcodel_deq_commit(ifq->ifq_q, m, cookie); in fqcodel_if_deq_commit()
716 fqcodel_if_purge(struct ifqueue *ifq, struct mbuf_list *ml) in fqcodel_if_purge() argument
718 return fqcodel_purge(ifq->ifq_q, ml); in fqcodel_if_purge()
Dhfsc.h116 #define HFSC_ENABLED(ifq) ((ifq)->ifq_ops == ifq_hfsc_ops) argument
Dif_pair.c161 pairstart(struct ifqueue *ifq) in pairstart() argument
163 struct ifnet *ifp = ifq->ifq_if; in pairstart()
171 while ((m = ifq_dequeue(ifq)) != NULL) { in pairstart()
Dhfsc.c609 hfsc_purge(struct ifqueue *ifq, struct mbuf_list *ml) in hfsc_purge() argument
611 struct hfsc_if *hif = ifq->ifq_q; in hfsc_purge()
801 hfsc_enq(struct ifqueue *ifq, struct mbuf *m) in hfsc_enq() argument
803 struct hfsc_if *hif = ifq->ifq_q; in hfsc_enq()
831 hfsc_deq_begin(struct ifqueue *ifq, void **cookiep) in hfsc_deq_begin() argument
834 struct hfsc_if *hif = ifq->ifq_q; in hfsc_deq_begin()
875 ifq_mfreeml(ifq, &free_ml); in hfsc_deq_begin()
887 hfsc_deq_commit(struct ifqueue *ifq, struct mbuf *m, void *cookie) in hfsc_deq_commit() argument
889 struct hfsc_if *hif = ifq->ifq_q; in hfsc_deq_commit()
941 struct ifqueue *ifq = &ifp->if_snd; in hfsc_deferred() local
[all …]
Dif.c581 struct ifqueue *ifq; in if_attach_queues() local
593 ifq = malloc(sizeof(*ifq), M_DEVBUF, M_WAITOK|M_ZERO); in if_attach_queues()
594 ifq_init_maxlen(ifq, ifp->if_snd.ifq_maxlen); in if_attach_queues()
595 ifq_init(ifq, ifp, i); in if_attach_queues()
596 map[i] = ifq; in if_attach_queues()
700 if_qstart_compat(struct ifqueue *ifq) in if_qstart_compat() argument
702 struct ifnet *ifp = ifq->ifq_if; in if_qstart_compat()
750 struct ifqueue *ifq = &ifp->if_snd; in if_enqueue_ifq() local
762 ifq = ifp->if_ifqs[idx]; in if_enqueue_ifq()
765 error = ifq_enqueue(ifq, m); in if_enqueue_ifq()
[all …]
Dif_pppx.c822 pppx_if_qstart(struct ifqueue *ifq) in pppx_if_qstart() argument
824 struct ifnet *ifp = ifq->ifq_if; in pppx_if_qstart()
829 while ((m = ifq_dequeue(ifq)) != NULL) { in pppx_if_qstart()
1455 pppac_qstart(struct ifqueue *ifq) in pppac_qstart() argument
1457 struct ifnet *ifp = ifq->ifq_if; in pppac_qstart()
1464 while ((m = ifq_dequeue(ifq)) != NULL) { in pppac_qstart()
Dif_vlan.c122 void vlan_start(struct ifqueue *ifq);
317 vlan_start(struct ifqueue *ifq) in vlan_start() argument
319 struct ifnet *ifp = ifq->ifq_if; in vlan_start()
326 ifq_purge(ifq); in vlan_start()
330 while ((m = ifq_dequeue(ifq)) != NULL) in vlan_start()
Dif_vxlan.c491 struct ifqueue *ifq = &ifp->if_snd; in vxlan_enqueue() local
493 if (ifq_enqueue(ifq, m) != 0) in vxlan_enqueue()
496 task_add(ifq->ifq_softnet, &sc->sc_send_task); in vxlan_enqueue()
502 vxlan_start(struct ifqueue *ifq) in vxlan_start() argument
504 struct ifnet *ifp = ifq->ifq_if; in vxlan_start()
507 task_add(ifq->ifq_softnet, &sc->sc_send_task); in vxlan_start()
/openbsd/src/sys/dev/pci/
Dif_vmx.c126 struct ifqueue *ifq; member
456 sc->sc_q[i].tx.ifq = ifp->if_ifqs[i]; in vmxnet3_attach()
694 ifq_clr_oactive(tq->ifq); in vmxnet3_txinit()
825 struct ifqueue *ifq = tq->ifq; in vmxnet3_txstop() local
841 ifq_purge(ifq); in vmxnet3_txstop()
842 ifq_clr_oactive(ifq); in vmxnet3_txstop()
1028 struct ifqueue *ifq = tq->ifq; in vmxnet3_txintr() local
1081 if (ifq_is_oactive(ifq)) in vmxnet3_txintr()
1082 ifq_restart(ifq); in vmxnet3_txintr()
1596 vmxnet3_start(struct ifqueue *ifq) in vmxnet3_start() argument
[all …]
Dif_igc.c836 struct ifqueue *ifq = ifp->if_ifqs[i]; in igc_setup_interface() local
841 ifq->ifq_softc = txr; in igc_setup_interface()
842 txr->ifq = ifq; in igc_setup_interface()
959 igc_start(struct ifqueue *ifq) in igc_start() argument
961 struct ifnet *ifp = ifq->ifq_if; in igc_start()
963 struct igc_txring *txr = ifq->ifq_softc; in igc_start()
978 ifq_purge(ifq); in igc_start()
995 ifq_set_oactive(ifq); in igc_start()
999 m = ifq_dequeue(ifq); in igc_start()
1007 ifq->ifq_errors++; in igc_start()
[all …]
Dif_ixv.c93 void ixgbe_start(struct ifqueue *ifq);
737 struct ifqueue *ifq = ifp->if_ifqs[i]; in ixv_stop() local
738 ifq_barrier(ifq); in ixv_stop()
739 ifq_clr_oactive(ifq); in ixv_stop()
805 struct ifqueue *ifq = ifp->if_ifqs[i]; in ixv_setup_interface() local
810 ifq->ifq_softc = txr; in ixv_setup_interface()
811 txr->ifq = ifq; in ixv_setup_interface()
Dif_ix.c447 ixgbe_start(struct ifqueue *ifq) in ixgbe_start() argument
449 struct ifnet *ifp = ifq->ifq_if; in ixgbe_start()
451 struct ix_txring *txr = ifq->ifq_softc; in ixgbe_start()
474 ifq_set_oactive(ifq); in ixgbe_start()
478 m_head = ifq_dequeue(ifq); in ixgbe_start()
1651 struct ifqueue *ifq = ifp->if_ifqs[i]; in ixgbe_stop() local
1652 ifq_barrier(ifq); in ixgbe_stop()
1653 ifq_clr_oactive(ifq); in ixgbe_stop()
1950 struct ifqueue *ifq = ifp->if_ifqs[i]; in ixgbe_setup_interface() local
1955 ifq->ifq_softc = txr; in ixgbe_setup_interface()
[all …]
Dif_iavf.c1715 iavf_start(struct ifqueue *ifq) in iavf_start() argument
1717 struct ifnet *ifp = ifq->ifq_if; in iavf_start()
1719 struct iavf_tx_ring *txr = ifq->ifq_softc; in iavf_start()
1734 ifq_purge(ifq); in iavf_start()
1752 ifq_set_oactive(ifq); in iavf_start()
1756 m = ifq_dequeue(ifq); in iavf_start()
1766 ifq->ifq_errors++; in iavf_start()
1816 iavf_txeof(struct iavf_softc *sc, struct ifqueue *ifq) in iavf_txeof() argument
1818 struct iavf_tx_ring *txr = ifq->ifq_softc; in iavf_txeof()
1871 if (ifq_is_oactive(ifq)) in iavf_txeof()
[all …]
Dif_ix.h170 struct ifqueue *ifq; member
Dif_ngbe.c691 ngbe_start(struct ifqueue *ifq) in ngbe_start() argument
693 struct ifnet *ifp = ifq->ifq_if; in ngbe_start()
695 struct tx_ring *txr = ifq->ifq_softc; in ngbe_start()
714 ifq_set_oactive(ifq); in ngbe_start()
718 m = ifq_dequeue(ifq); in ngbe_start()
812 struct ifqueue *ifq = ifp->if_ifqs[i]; in ngbe_stop() local
813 ifq_barrier(ifq); in ngbe_stop()
814 ifq_clr_oactive(ifq); in ngbe_stop()
1048 struct ifqueue *ifq = ifp->if_ifqs[i]; in ngbe_setup_interface() local
1053 ifq->ifq_softc = txr; in ngbe_setup_interface()
[all …]
Dif_igc.h262 struct ifqueue *ifq; member
Dmpii.c1295 struct mpii_msg_iocfacts_request ifq; in mpii_iocfacts() local
1303 memset(&ifq, 0, sizeof(ifq)); in mpii_iocfacts()
1306 ifq.function = MPII_FUNCTION_IOC_FACTS; in mpii_iocfacts()
1308 if (mpii_handshake_send(sc, &ifq, dwordsof(ifq)) != 0) { in mpii_iocfacts()
2148 struct mpii_msg_iocfacts_request ifq; in mpii_board_info() local
2153 memset(&ifq, 0, sizeof(ifq)); in mpii_board_info()
2156 ifq.function = MPII_FUNCTION_IOC_FACTS; in mpii_board_info()
2158 if (mpii_handshake_send(sc, &ifq, dwordsof(ifq)) != 0) { in mpii_board_info()
/openbsd/src/sys/arch/octeon/dev/
Dif_cnmac.c902 cnmac_start(struct ifqueue *ifq) in cnmac_start() argument
904 struct ifnet *ifp = ifq->ifq_if; in cnmac_start()
909 ifq_purge(ifq); in cnmac_start()
928 ifq_set_oactive(ifq); in cnmac_start()
933 m = ifq_dequeue(ifq); in cnmac_start()
1321 struct ifqueue *ifq = &ifp->if_snd; in cnmac_free_task() local
1331 if (ifq_is_oactive(ifq)) { in cnmac_free_task()
1332 ifq_clr_oactive(ifq); in cnmac_free_task()
1333 cnmac_start(ifq); in cnmac_free_task()
1335 if (ifq_is_oactive(ifq)) { in cnmac_free_task()
/openbsd/src/sys/dev/fdt/
Dif_mvneta.c953 mvneta_start(struct ifqueue *ifq) in mvneta_start() argument
955 struct ifnet *ifp = ifq->ifq_if; in mvneta_start()
963 ifq_purge(ifq); in mvneta_start()
974 ifq_set_oactive(ifq); in mvneta_start()
978 m = ifq_dequeue(ifq); in mvneta_start()
1539 struct ifqueue *ifq = &ifp->if_snd; in mvneta_tx_proc() local
1603 if (ifq_is_oactive(ifq)) in mvneta_tx_proc()
1604 ifq_restart(ifq); in mvneta_tx_proc()
/openbsd/src/sys/dev/pv/
Dif_xnf.c484 xnf_start(struct ifqueue *ifq) in xnf_start() argument
486 struct ifnet *ifp = ifq->ifq_if; in xnf_start()
502 ifq_set_oactive(ifq); in xnf_start()
506 m = ifq_dequeue(ifq); in xnf_start()

123