Home
last modified time | relevance | path

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

1234

/dragonfly/sys/net/altq/
HDif_altq.h96 #define ALTQ_SQ_ASSERT_LOCKED(ifsq) ASSERT_SERIALIZED(&(ifsq)->ifsq_lock) argument
97 #define ALTQ_SQ_LOCK_INIT(ifsq) lwkt_serialize_init(&(ifsq)->ifsq_lock) argument
98 #define ALTQ_SQ_LOCK(ifsq) \ argument
99 lwkt_serialize_adaptive_enter(&(ifsq)->ifsq_lock)
100 #define ALTQ_SQ_UNLOCK(ifsq) lwkt_serialize_exit(&(ifsq)->ifsq_lock) argument
102 #define ASSERT_ALTQ_SQ_SERIALIZED_HW(ifsq) \ argument
103 ASSERT_SERIALIZED((ifsq)->ifsq_hw_serialize)
104 #define ASSERT_ALTQ_SQ_NOT_SERIALIZED_HW(ifsq) \ argument
105 ASSERT_NOT_SERIALIZED((ifsq)->ifsq_hw_serialize)
107 #define ALTQ_SQ_PKTCNT_INC(ifsq) \ argument
[all …]
HDaltq_cbq.c166 cbq_request(struct ifaltq_subque *ifsq, int req, void *arg) in cbq_request() argument
168 struct ifaltq *ifq = ifsq->ifsq_altq; in cbq_request()
174 if (ifsq_get_index(ifsq) == CBQ_SUBQ_INDEX) { in cbq_request()
181 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in cbq_request()
525 cbq_enqueue(struct ifaltq_subque *ifsq, struct mbuf *m, in cbq_enqueue() argument
528 struct ifaltq *ifq = ifsq->ifsq_altq; in cbq_enqueue()
533 if (ifsq_get_index(ifsq) != CBQ_SUBQ_INDEX) { in cbq_enqueue()
538 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in cbq_enqueue()
568 ALTQ_SQ_PKTCNT_INC(ifsq); in cbq_enqueue()
574 cbq_dequeue(struct ifaltq_subque *ifsq, int op) in cbq_dequeue() argument
[all …]
HDaltq_priq.c277 priq_request(struct ifaltq_subque *ifsq, int req, void *arg) in priq_request() argument
279 struct ifaltq *ifq = ifsq->ifsq_altq; in priq_request()
285 if (ifsq_get_index(ifsq) == PRIQ_SUBQ_INDEX) { in priq_request()
292 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in priq_request()
445 priq_enqueue(struct ifaltq_subque *ifsq, struct mbuf *m, in priq_enqueue() argument
448 struct ifaltq *ifq = ifsq->ifsq_altq; in priq_enqueue()
454 if (ifsq_get_index(ifsq) != PRIQ_SUBQ_INDEX) { in priq_enqueue()
459 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in priq_enqueue()
488 ALTQ_SQ_PKTCNT_INC(ifsq); in priq_enqueue()
503 priq_dequeue(struct ifaltq_subque *ifsq, int op) in priq_dequeue() argument
[all …]
HDaltq_subr.c219 tbr_dequeue(struct ifaltq_subque *ifsq, int op) in tbr_dequeue() argument
221 struct ifaltq *ifq = ifsq->ifsq_altq; in tbr_dequeue()
227 if (ifsq_get_index(ifsq) != ALTQ_SUBQ_INDEX_DEFAULT) { in tbr_dequeue()
232 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in tbr_dequeue()
262 m = (*ifsq->ifsq_dequeue)(ifsq, op); in tbr_dequeue()
264 m = ifsq_classic_dequeue(ifsq, op); in tbr_dequeue()
364 struct ifaltq_subque *ifsq; in tbr_timeout_dispatch() local
369 ifsq = &ifp->if_snd.altq_subq[ALTQ_SUBQ_INDEX_DEFAULT]; in tbr_timeout_dispatch()
371 if (!ifsq_is_empty(ifsq) && ifp->if_start != NULL) { in tbr_timeout_dispatch()
372 ifsq_serialize_hw(ifsq); in tbr_timeout_dispatch()
[all …]
HDaltq_fairq.c338 fairq_request(struct ifaltq_subque *ifsq, int req, void *arg) in fairq_request() argument
340 struct ifaltq *ifq = ifsq->ifsq_altq; in fairq_request()
346 if (ifsq_get_index(ifsq) == FAIRQ_SUBQ_INDEX) { in fairq_request()
353 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in fairq_request()
536 fairq_enqueue(struct ifaltq_subque *ifsq, struct mbuf *m, in fairq_enqueue() argument
539 struct ifaltq *ifq = ifsq->ifsq_altq; in fairq_enqueue()
546 if (ifsq_get_index(ifsq) != FAIRQ_SUBQ_INDEX) { in fairq_enqueue()
551 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in fairq_enqueue()
587 ALTQ_SQ_PKTCNT_INC(ifsq); in fairq_enqueue()
602 fairq_dequeue(struct ifaltq_subque *ifsq, int op) in fairq_dequeue() argument
[all …]
HDaltq_hfsc.c364 hfsc_request(struct ifaltq_subque *ifsq, int req, void *arg) in hfsc_request() argument
366 struct ifaltq *ifq = ifsq->ifsq_altq; in hfsc_request()
372 if (ifsq_get_index(ifsq) == HFSC_SUBQ_INDEX) { in hfsc_request()
379 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in hfsc_request()
673 hfsc_enqueue(struct ifaltq_subque *ifsq, struct mbuf *m, in hfsc_enqueue() argument
676 struct ifaltq *ifq = ifsq->ifsq_altq; in hfsc_enqueue()
681 if (ifsq_get_index(ifsq) != HFSC_SUBQ_INDEX) { in hfsc_enqueue()
686 ifsq_classic_request(ifsq, ALTRQ_PURGE, NULL); in hfsc_enqueue()
714 ALTQ_SQ_PKTCNT_INC(ifsq); in hfsc_enqueue()
732 hfsc_dequeue(struct ifaltq_subque *ifsq, int op) in hfsc_dequeue() argument
[all …]
HDaltq_rmclass.c537 struct ifaltq_subque *ifsq = in rmc_delete_class() local
542 ALTQ_SQ_ASSERT_LOCKED(ifsq); in rmc_delete_class()
543 ALTQ_SQ_UNLOCK(ifsq); in rmc_delete_class()
550 ALTQ_SQ_LOCK(ifsq); in rmc_delete_class()
1563 struct ifaltq_subque *ifsq = in rmc_restart_dispatch() local
1572 ALTQ_SQ_LOCK(ifsq); in rmc_restart_dispatch()
1582 ALTQ_SQ_UNLOCK(ifsq); in rmc_restart_dispatch()
/dragonfly/sys/net/
HDif.c250 struct ifaltq_subque *ifsq = arg; in ifsq_ifstart_ipifunc() local
251 struct lwkt_msg *lmsg = ifsq_get_ifstart_lmsg(ifsq, mycpuid); in ifsq_ifstart_ipifunc()
282 ifsq_ifstart_schedule(struct ifaltq_subque *ifsq, int force) in ifsq_ifstart_schedule() argument
288 struct ifsubq_stage *stage = ifsq_get_stage(ifsq, mycpuid); in ifsq_ifstart_schedule()
298 cpu = ifsq_get_cpuid(ifsq); in ifsq_ifstart_schedule()
300 lwkt_send_ipiq(globaldata_find(cpu), ifsq_ifstart_ipifunc, ifsq); in ifsq_ifstart_schedule()
302 ifsq_ifstart_ipifunc(ifsq); in ifsq_ifstart_schedule()
311 ifsq_ifstart_need_schedule(struct ifaltq_subque *ifsq, int running) in ifsq_ifstart_need_schedule() argument
313 if (!running || ifsq_is_empty(ifsq) in ifsq_ifstart_need_schedule()
315 || ifsq->ifsq_altq->altq_tbr != NULL in ifsq_ifstart_need_schedule()
[all …]
HDifq_var.h55 #define ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq) \ argument
56 KASSERT(ifsq_get_ifp((ifsq)) == (ifp) && \
57 ifsq_get_index((ifsq)) == ALTQ_SUBQ_INDEX_DEFAULT, \
94 void ifsq_devstart(struct ifaltq_subque *ifsq);
95 void ifsq_devstart_sched(struct ifaltq_subque *ifsq);
HDif_loop.c292 lo_altqstart(struct ifnet *ifp, struct ifaltq_subque *ifsq) in lo_altqstart() argument
300 m = ifsq_dequeue(ifsq); in lo_altqstart()
/dragonfly/sys/netproto/802_11/wlan/
HDieee80211_dragonfly.c283 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in ieee80211_vap_xmitpkt() local
293 error = ifsq_enqueue(ifsq, m, NULL); in ieee80211_vap_xmitpkt()
297 ifp->if_start(ifp, ifsq); in ieee80211_vap_xmitpkt()
512 struct ifaltq_subque *ifsq = ifq_get_subq_default(ifq);
516 ALTQ_SQ_LOCK(ifsq);
521 mprev = &ifsq->ifsq_norm_head;
526 ALTQ_SQ_CNTR_DEC(ifsq, m->m_pkthdr.len);
534 m = ifsq->ifsq_norm_head;
537 ifsq->ifsq_norm_tail = m;
542 mprev = &ifsq->ifsq_prio_head;
[all …]
/dragonfly/sys/net/tap/
HDif_tap.c532 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in tapifinit() local
542 ifsq_clr_oactive(ifsq); in tapifinit()
545 tapifstart(ifp, ifsq); in tapifinit()
654 tapifstart(struct ifnet *ifp, struct ifaltq_subque *ifsq) in tapifstart() argument
661 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in tapifstart()
667 ifsq_purge(ifsq); in tapifstart()
671 ifsq_set_oactive(ifsq); in tapifstart()
674 while ((m = ifsq_dequeue(ifsq)) != NULL) { in tapifstart()
701 ifsq_clr_oactive(ifsq); in tapifstart()
/dragonfly/sys/net/sl/
HDif_sl.c451 sloutput_serialized(struct ifnet *ifp, struct ifaltq_subque *ifsq, in sloutput_serialized() argument
498 error = ifsq_enqueue(ifsq, m, &pktattr); in sloutput_serialized()
513 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in sloutput() local
516 ifsq_serialize_hw(ifsq); in sloutput()
517 error = sloutput_serialized(ifp, ifsq, m, dst, rtp); in sloutput()
518 ifsq_deserialize_hw(ifsq); in sloutput()
532 struct ifaltq_subque *ifsq = ifq_get_subq_default(&sc->sc_if.if_snd); in slstart() local
572 m = ifsq_dequeue(ifsq); in slstart()
/dragonfly/tools/tools/netrate/pktgen/
HDpktgen.c377 pktgen_start_ifsq(struct pktgen *pktg, struct ifaltq_subque *ifsq) in pktgen_start_ifsq() argument
385 np->np_ifsq = ifsq; in pktgen_start_ifsq()
387 lwkt_sendmsg(netisr_cpuport(ifsq_get_cpuid(ifsq)), &np->np_base.lmsg); in pktgen_start_ifsq()
421 struct ifaltq_subque *ifsq = np->np_ifsq; in pktgen_start_ifsq_handler() local
436 cpuid = ifsq_get_cpuid(ifsq); in pktgen_start_ifsq_handler()
486 pb->pb_ifsq = ifsq; in pktgen_start_ifsq_handler()
/dragonfly/sys/dev/virtual/virtio/net/
HDif_vtnet.c921 struct ifaltq_subque *ifsq; in vtnet_update_link_status() local
926 ifsq = ifq_get_subq_default(&ifp->if_snd); in vtnet_update_link_status()
936 if (!ifsq_is_empty(ifsq)) in vtnet_update_link_status()
937 ifsq_devstart_sched(ifsq); in vtnet_update_link_status()
949 vtnet_watchdog(struct ifaltq_subque *ifsq) in vtnet_watchdog() argument
954 ifp = ifsq_get_ifp(ifsq); in vtnet_watchdog()
987 ifsq_devstart_sched(ifsq); in vtnet_watchdog()
2114 vtnet_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in vtnet_start() argument
2125 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in vtnet_start()
2137 while (!ifsq_is_empty(ifsq)) { in vtnet_start()
[all …]
/dragonfly/sys/net/tun/
HDif_tun.c520 tunifstart(struct ifnet *ifp, struct ifaltq_subque *ifsq) in tunifstart() argument
525 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in tunifstart()
530 m = ifsq_poll(ifsq); in tunifstart()
538 ifsq_deserialize_hw(ifsq); in tunifstart()
540 ifsq_serialize_hw(ifsq); in tunifstart()
798 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in tunread() local
812 while ((m0 = ifsq_dequeue(ifsq)) == NULL) { in tunread()
/dragonfly/sys/dev/netif/emx/
HDif_emx.c408 if (!ifsq_is_empty(tdata->ifsq)) in emx_tx_intr()
409 ifsq_devstart(tdata->ifsq); in emx_tx_intr()
1087 ifsq_devstart_sched(sc->tx_data[i].ifsq); in emx_resume()
1095 emx_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in emx_start() argument
1098 struct emx_txdata *tdata = ifsq_get_priv(ifsq); in emx_start()
1102 KKASSERT(tdata->ifsq == ifsq); in emx_start()
1105 if ((ifp->if_flags & IFF_RUNNING) == 0 || ifsq_is_oactive(ifsq)) in emx_start()
1109 ifsq_purge(ifsq); in emx_start()
1113 while (!ifsq_is_empty(ifsq)) { in emx_start()
1118 ifsq_set_oactive(ifsq); in emx_start()
[all …]
/dragonfly/sys/net/pf/
HDif_pflog.c184 pflogstart(struct ifnet *ifp, struct ifaltq_subque *ifsq) in pflogstart() argument
188 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in pflogstart()
192 m = ifsq_dequeue(ifsq); in pflogstart()
/dragonfly/sys/bus/u4b/net/
HDusb_ethernet.c365 uether_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in uether_start() argument
368 ue_start(ifp, ifsq); in uether_start()
372 ue_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in ue_start() argument
376 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in ue_start()
/dragonfly/sys/dev/netif/igb/
HDif_igb.c310 if (!ifsq_is_empty(txr->ifsq)) in igb_tx_intr()
311 ifsq_devstart(txr->ifsq); in igb_tx_intr()
842 ifsq_devstart_sched(sc->tx_rings[i].ifsq); in igb_resume()
1068 ifsq_clr_oactive(txr->ifsq); in igb_init()
1442 ifsq_clr_oactive(txr->ifsq); in igb_stop()
1624 struct ifaltq_subque *ifsq = ifq_get_subq(&ifp->if_snd, i); in igb_setup_ifp() local
1627 ifsq_set_cpuid(ifsq, txr->tx_intr_cpuid); in igb_setup_ifp()
1628 ifsq_set_priv(ifsq, txr); in igb_setup_ifp()
1629 ifsq_set_hw_serialize(ifsq, &txr->tx_serialize); in igb_setup_ifp()
1630 txr->ifsq = ifsq; in igb_setup_ifp()
[all …]
/dragonfly/sys/netgraph/iface/
HDng_iface.c461 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in ng_iface_output() local
464 ifsq_serialize_hw(ifsq); in ng_iface_output()
466 ifsq_deserialize_hw(ifsq); in ng_iface_output()
476 ng_iface_start(struct ifnet *ifp, struct ifaltq_subque *ifsq __unused) in ng_iface_start()
/dragonfly/sys/dev/netif/bce/
HDif_bce.c1006 struct ifaltq_subque *ifsq = ifq_get_subq(&ifp->if_snd, i); in bce_attach() local
1009 ifsq_set_cpuid(ifsq, sc->bce_msix[i].msix_cpuid); in bce_attach()
1010 ifsq_set_priv(ifsq, txr); in bce_attach()
1011 ifsq_set_hw_serialize(ifsq, &txr->tx_serialize); in bce_attach()
1012 txr->ifsq = ifsq; in bce_attach()
1014 ifsq_watchdog_init(&txr->tx_watchdog, ifsq, bce_watchdog, 0); in bce_attach()
3453 ifsq_clr_oactive(sc->tx_rings[i].ifsq); in bce_stop()
4585 ifsq_clr_oactive(txr->ifsq); in bce_tx_intr()
4786 ifsq_clr_oactive(sc->tx_rings[i].ifsq); in bce_init()
4964 bce_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in bce_start() argument
[all …]
/dragonfly/sys/net/vlan/
HDif_vlan.c517 vlan_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in vlan_start() argument
524 ASSERT_ALTQ_SQ_DEFAULT(ifp, ifsq); in vlan_start()
525 ASSERT_ALTQ_SQ_SERIALIZED_HW(ifsq); in vlan_start()
528 ifsq_purge(ifsq); in vlan_start()
540 m = ifsq_dequeue(ifsq); in vlan_start()
/dragonfly/sys/dev/netif/mxge/
HDif_mxge.c1956 mxge_start(struct ifnet *ifp, struct ifaltq_subque *ifsq) in mxge_start() argument
1959 mxge_tx_ring_t *tx = ifsq_get_priv(ifsq); in mxge_start()
1963 KKASSERT(tx->ifsq == ifsq); in mxge_start()
1966 if ((ifp->if_flags & IFF_RUNNING) == 0 || ifsq_is_oactive(ifsq)) in mxge_start()
1974 m = ifsq_dequeue(ifsq); in mxge_start()
1987 ifsq_set_oactive(ifsq); in mxge_start()
1994 mxge_watchdog(struct ifaltq_subque *ifsq) in mxge_watchdog() argument
1996 struct ifnet *ifp = ifsq_get_ifp(ifsq); in mxge_watchdog()
1999 mxge_tx_ring_t *tx = ifsq_get_priv(ifsq); in mxge_watchdog()
2395 ifsq_clr_oactive(tx->ifsq); in mxge_tx_done()
[all …]
/dragonfly/sys/net/sppp/
HDif_spppsubr.c668 sppp_output_serialized(struct ifnet *ifp, struct ifaltq_subque *ifsq, in sppp_output_serialized() argument
882 rv = ifsq_enqueue(ifsq, m, &pktattr); in sppp_output_serialized()
889 if (!ifsq_is_oactive(ifsq)) in sppp_output_serialized()
890 (*ifp->if_start) (ifp, ifsq); in sppp_output_serialized()
915 struct ifaltq_subque *ifsq = ifq_get_subq_default(&ifp->if_snd); in sppp_output() local
918 ifsq_serialize_hw(ifsq); in sppp_output()
919 error = sppp_output_serialized(ifp, ifsq, m, dst, rt); in sppp_output()
920 ifsq_deserialize_hw(ifsq); in sppp_output()
1280 struct ifaltq_subque *ifsq; in sppp_cisco_send() local
1315 ifsq = ifq_get_subq_default(&ifp->if_snd); in sppp_cisco_send()
[all …]

1234