| /linux-6.15/drivers/infiniband/hw/hfi1/ |
| H A D | vnic_main.c | 205 u8 q_idx) in hfi1_vnic_maybe_stop_tx() argument 207 netif_stop_subqueue(vinfo->netdev, q_idx); in hfi1_vnic_maybe_stop_tx() 211 netif_start_subqueue(vinfo->netdev, q_idx); in hfi1_vnic_maybe_stop_tx() 218 u8 pad_len, q_idx = skb->queue_mapping; in hfi1_netdev_start_xmit() local 227 vinfo->stats[q_idx].tx_drop_state++; in hfi1_netdev_start_xmit() 235 vinfo->stats[q_idx].tx_dlid_zero++; in hfi1_netdev_start_xmit() 266 hfi1_vnic_maybe_stop_tx(vinfo, q_idx); in hfi1_netdev_start_xmit() 339 u8 q_idx; in hfi1_vnic_bypass_rcv() local 369 q_idx = packet->rcd->vnic_q_idx; in hfi1_vnic_bypass_rcv() 370 rxq = &vinfo->rxq[q_idx]; in hfi1_vnic_bypass_rcv() [all …]
|
| H A D | vnic_sdma.c | 126 int hfi1_vnic_send_dma(struct hfi1_devdata *dd, u8 q_idx, in hfi1_vnic_send_dma() argument 130 struct hfi1_vnic_sdma *vnic_sdma = &vinfo->sdma[q_idx]; in hfi1_vnic_send_dma() 224 if (__netif_subqueue_stopped(vinfo->netdev, vnic_sdma->q_idx)) in hfi1_vnic_sdma_wakeup() 225 netif_wake_subqueue(vinfo->netdev, vnic_sdma->q_idx); in hfi1_vnic_sdma_wakeup() 229 u8 q_idx) in hfi1_vnic_sdma_write_avail() argument 231 struct hfi1_vnic_sdma *vnic_sdma = &vinfo->sdma[q_idx]; in hfi1_vnic_sdma_write_avail() 249 vnic_sdma->q_idx = i; in hfi1_vnic_sdma_init()
|
| H A D | vnic.h | 49 u8 q_idx; member 113 u8 q_idx); 122 int hfi1_vnic_send_dma(struct hfi1_devdata *dd, u8 q_idx,
|
| H A D | ipoib_tx.c | 57 netif_stop_subqueue(txq->priv->netdev, txq->q_idx); in hfi1_ipoib_stop_txq() 64 netif_wake_subqueue(txq->priv->netdev, txq->q_idx); in hfi1_ipoib_wake_txq() 125 le64_to_cpu(tx->sdma_hdr->pbc), tx->txq->q_idx, in hfi1_ipoib_free_tx() 723 txq->q_idx = i; in hfi1_ipoib_txreq_init() 789 txq->q_idx, in hfi1_ipoib_drain_tx_list() 848 __netif_subqueue_stopped(dev, txq->q_idx), in hfi1_ipoib_tx_timeout()
|
| H A D | ipoib.h | 114 u8 q_idx; member
|
| /linux-6.15/drivers/net/ethernet/intel/ice/ |
| H A D | ice_xsk.c | 55 ice_clean_tx_ring(vsi->tx_rings[q_idx]); in ice_qp_clean_rings() 57 ice_clean_tx_ring(vsi->xdp_rings[q_idx]); in ice_qp_clean_rings() 58 ice_clean_rx_ring(vsi->rx_rings[q_idx]); in ice_qp_clean_rings() 172 if (q_idx >= vsi->num_rxq || q_idx >= vsi->num_txq) in ice_qp_dis() 175 tx_ring = vsi->tx_rings[q_idx]; in ice_qp_dis() 176 rx_ring = vsi->rx_rings[q_idx]; in ice_qp_dis() 202 ice_qp_clean_rings(vsi, q_idx); in ice_qp_dis() 203 ice_qp_reset_stats(vsi, q_idx); in ice_qp_dis() 233 ice_tx_xsk_pool(vsi, q_idx); in ice_qp_ena() 236 err = ice_vsi_cfg_single_rxq(vsi, q_idx); in ice_qp_ena() [all …]
|
| H A D | ice_base.c | 631 int ice_vsi_cfg_single_rxq(struct ice_vsi *vsi, u16 q_idx) in ice_vsi_cfg_single_rxq() argument 633 if (q_idx >= vsi->num_rxq) in ice_vsi_cfg_single_rxq() 636 return ice_vsi_cfg_rxq(vsi->rx_rings[q_idx]); in ice_vsi_cfg_single_rxq() 951 u16 q_idx) in ice_vsi_cfg_single_txq() argument 955 if (q_idx >= vsi->alloc_txq || !tx_rings || !tx_rings[q_idx]) in ice_vsi_cfg_single_txq() 960 return ice_vsi_cfg_txq(vsi, tx_rings[q_idx], qg_buf); in ice_vsi_cfg_single_txq() 977 u16 q_idx; in ice_vsi_cfg_txqs() local 981 for (q_idx = 0; q_idx < count; q_idx++) { in ice_vsi_cfg_txqs() 982 err = ice_vsi_cfg_txq(vsi, rings[q_idx], qg_buf); in ice_vsi_cfg_txqs()
|
| H A D | ice_base.h | 9 int ice_vsi_cfg_single_rxq(struct ice_vsi *vsi, u16 q_idx); 19 u16 q_idx);
|
| H A D | ice_lib.c | 1985 u16 q_idx; in ice_vsi_stop_tx_rings() local 1990 for (q_idx = 0; q_idx < count; q_idx++) { in ice_vsi_stop_tx_rings() 1994 if (!rings || !rings[q_idx]) in ice_vsi_stop_tx_rings() 1999 rings[q_idx], &txq_meta); in ice_vsi_stop_tx_rings() 2735 int q_idx, v_idx; in ice_vsi_set_napi_queues() local 2740 ice_for_each_rxq(vsi, q_idx) in ice_vsi_set_napi_queues() 2742 &vsi->rx_rings[q_idx]->q_vector->napi); in ice_vsi_set_napi_queues() 2744 ice_for_each_txq(vsi, q_idx) in ice_vsi_set_napi_queues() 2765 int q_idx, v_idx; in ice_vsi_clear_napi_queues() local 2777 ice_for_each_txq(vsi, q_idx) in ice_vsi_clear_napi_queues() [all …]
|
| H A D | ice_virtchnl.c | 1433 u32 pfq = vsi->txq_map[q_idx]; in ice_vf_ena_txq_interrupt() 1456 u32 pfq = vsi->rxq_map[q_idx]; in ice_vf_ena_rxq_interrupt() 2003 int i = -1, q_idx; in ice_vc_cfg_qs_msg() local 2057 q_idx = qpi->rxq.queue_id; in ice_vc_cfg_qs_msg() 2062 if (q_idx >= vsi->alloc_txq || q_idx >= vsi->alloc_rxq) { in ice_vc_cfg_qs_msg() 2069 vsi->tx_rings[q_idx]->count = qpi->txq.ring_len; in ice_vc_cfg_qs_msg() 2072 if (ice_vf_vsi_dis_single_txq(vf, vsi, q_idx)) in ice_vc_cfg_qs_msg() 2078 vf->vf_id, q_idx); in ice_vc_cfg_qs_msg() 2114 if (ice_vsi_cfg_single_rxq(vsi, q_idx)) { in ice_vc_cfg_qs_msg() 2116 vf->vf_id, q_idx); in ice_vc_cfg_qs_msg() [all …]
|
| /linux-6.15/drivers/accel/habanalabs/common/ |
| H A D | hw_queue.c | 420 u32 q_idx; in init_signal_cs() local 423 q_idx = job->hw_queue_id; in init_signal_cs() 432 cs_cmpl->hw_sob->sob_id, cs_cmpl->sob_val, q_idx, in init_signal_cs() 480 u32 q_idx; in init_wait_cs() local 482 q_idx = job->hw_queue_id; in init_wait_cs() 497 cs->encaps_sig_hdl->q_idx, in init_wait_cs() 533 prop->base_mon_id, q_idx, cs->sequence); in init_wait_cs() 540 wait_prop.q_idx = q_idx; in init_wait_cs() 617 encaps_sig_hdl->q_idx, in encaps_sig_first_staged_cs_handler() 967 hw_sob->q_idx = q_idx; in sync_stream_queue_init() [all …]
|
| H A D | command_submission.c | 156 hw_sob->q_idx, hw_sob->sob_id); in hl_sob_reset_error() 1831 q_idx); in hl_cs_signal_sob_wraparound_handler() 1975 job->hw_queue_id = q_idx; in cs_ioctl_signal_wait_create_jobs() 2004 u32 q_idx, u32 count, in cs_ioctl_reserve_signals() argument 2026 q_idx); in cs_ioctl_reserve_signals() 2036 q_idx); in cs_ioctl_reserve_signals() 2066 handle->q_idx = q_idx; in cs_ioctl_reserve_signals() 2132 u32 q_idx, sob_addr; in cs_ioctl_unreserve_signals() local 2146 q_idx = encaps_sig_hdl->q_idx; in cs_ioctl_unreserve_signals() 2241 q_idx = chunk->queue_index; in cs_ioctl_signal_wait() [all …]
|
| /linux-6.15/drivers/net/ethernet/microsoft/mana/ |
| H A D | mana_bpf.c | 36 u16 q_idx) in mana_xdp_xmit_fm() argument 44 skb_set_queue_mapping(skb, q_idx); in mana_xdp_xmit_fm() 57 u16 q_idx; in mana_xdp_xmit() local 62 q_idx = smp_processor_id() % ndev->real_num_tx_queues; in mana_xdp_xmit() 65 if (mana_xdp_xmit_fm(ndev, frames[i], q_idx)) in mana_xdp_xmit() 71 tx_stats = &apc->tx_qp[q_idx].txq.stats; in mana_xdp_xmit()
|
| /linux-6.15/drivers/net/hyperv/ |
| H A D | netvsc_bpf.c | 230 struct xdp_frame *frame, u16 q_idx) in netvsc_ndoxdp_xmit_fm() argument 240 skb_record_rx_queue(skb, q_idx); in netvsc_ndoxdp_xmit_fm() 256 u16 q_idx; in netvsc_ndoxdp_xmit() local 276 q_idx = smp_processor_id() % ndev->real_num_tx_queues; in netvsc_ndoxdp_xmit() 279 if (netvsc_ndoxdp_xmit_fm(ndev, frames[i], q_idx)) in netvsc_ndoxdp_xmit() 285 tx_stats = &nvsc_dev->chan_table[q_idx].tx_stats; in netvsc_ndoxdp_xmit()
|
| H A D | netvsc.c | 765 u16 q_idx = 0; in netvsc_send_tx_complete() local 786 q_idx = packet->q_idx; in netvsc_send_tx_complete() 788 tx_stats = &net_device->chan_table[q_idx].tx_stats; in netvsc_send_tx_complete() 1104 &net_device->chan_table[packet->q_idx]; in netvsc_send_pkt() 1249 nvchan = &net_device->chan_table[packet->q_idx]; in netvsc_send() 1408 struct netvsc_device *nvdev, u16 q_idx, in enq_receive_complete() argument 1411 struct netvsc_channel *nvchan = &nvdev->chan_table[q_idx]; in enq_receive_complete() 1425 q_idx, tid); in enq_receive_complete() 1448 u16 q_idx = channel->offermsg.offer.sub_channel_index; in netvsc_receive() local 1531 trace_rndis_recv(ndev, q_idx, data); in netvsc_receive() [all …]
|
| H A D | netvsc_drv.c | 255 int q_idx; in netvsc_get_tx_queue() local 261 if (q_idx != old_idx && in netvsc_get_tx_queue() 263 sk_tx_queue_set(sk, q_idx); in netvsc_get_tx_queue() 265 return q_idx; in netvsc_get_tx_queue() 281 int q_idx = sk_tx_queue_get(skb->sk); in netvsc_pick_tx() local 283 if (q_idx < 0 || skb->ooo_okay || q_idx >= ndev->real_num_tx_queues) { in netvsc_pick_tx() 288 q_idx = skb_get_rx_queue(skb); in netvsc_pick_tx() 290 q_idx = netvsc_get_tx_queue(ndev, skb, q_idx); in netvsc_pick_tx() 293 return q_idx; in netvsc_pick_tx() 499 packet->q_idx = skb_get_queue_mapping(skb); in netvsc_xmit() [all …]
|
| /linux-6.15/drivers/net/ethernet/cavium/thunder/ |
| H A D | nicvf_queues.h | 354 void nicvf_enable_intr(struct nicvf *nic, int int_type, int q_idx); 355 void nicvf_disable_intr(struct nicvf *nic, int int_type, int q_idx); 356 void nicvf_clear_intr(struct nicvf *nic, int int_type, int q_idx); 357 int nicvf_is_intr_enabled(struct nicvf *nic, int int_type, int q_idx);
|
| H A D | nicvf_queues.c | 1723 static u64 nicvf_int_type_to_mask(int int_type, int q_idx) in nicvf_int_type_to_mask() argument 1729 reg_val = ((1ULL << q_idx) << NICVF_INTR_CQ_SHIFT); in nicvf_int_type_to_mask() 1732 reg_val = ((1ULL << q_idx) << NICVF_INTR_SQ_SHIFT); in nicvf_int_type_to_mask() 1735 reg_val = ((1ULL << q_idx) << NICVF_INTR_RBDR_SHIFT); in nicvf_int_type_to_mask() 1757 void nicvf_enable_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_enable_intr() argument 1759 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_enable_intr() 1771 void nicvf_disable_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_disable_intr() argument 1773 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_disable_intr() 1785 void nicvf_clear_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_clear_intr() argument 1787 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_clear_intr() [all …]
|
| /linux-6.15/drivers/net/ethernet/ti/icssg/ |
| H A D | icssg_common.c | 565 unsigned int q_idx) in emac_xmit_xdp_frame() argument 576 if (q_idx >= PRUETH_MAX_TX_QUEUES) { in emac_xmit_xdp_frame() 581 tx_chn = &emac->tx_chns[q_idx]; in emac_xmit_xdp_frame() 664 int q_idx, err; in emac_run_xdp() local 679 q_idx = cpu % emac->tx_ch_num; in emac_run_xdp() 680 netif_txq = netdev_get_tx_queue(ndev, q_idx); in emac_run_xdp() 877 int i, ret = 0, q_idx; in icssg_ndo_start_xmit() local 883 q_idx = skb_get_queue_mapping(skb); in icssg_ndo_start_xmit() 885 tx_chn = &emac->tx_chns[q_idx]; in icssg_ndo_start_xmit() 886 netif_txq = netdev_get_tx_queue(ndev, q_idx); in icssg_ndo_start_xmit() [all …]
|
| /linux-6.15/drivers/net/ethernet/intel/fm10k/ |
| H A D | fm10k_pf.c | 503 u16 vsi, queue, pc, q_idx; in fm10k_configure_dglort_map_pf() local 520 q_idx = dglort->queue_b; in fm10k_configure_dglort_map_pf() 524 for (queue = 0; queue < queue_count; queue++, q_idx++) { in fm10k_configure_dglort_map_pf() 525 if (q_idx >= FM10K_MAX_QUEUES) in fm10k_configure_dglort_map_pf() 528 fm10k_write_reg(hw, FM10K_TX_SGLORT(q_idx), glort); in fm10k_configure_dglort_map_pf() 529 fm10k_write_reg(hw, FM10K_RX_SGLORT(q_idx), glort); in fm10k_configure_dglort_map_pf() 539 q_idx = pc + dglort->queue_b; in fm10k_configure_dglort_map_pf() 541 if (q_idx >= FM10K_MAX_QUEUES) in fm10k_configure_dglort_map_pf() 544 txqctl = fm10k_read_reg(hw, FM10K_TXQCTL(q_idx)); in fm10k_configure_dglort_map_pf() 547 fm10k_write_reg(hw, FM10K_TXQCTL(q_idx), txqctl); in fm10k_configure_dglort_map_pf() [all …]
|
| /linux-6.15/drivers/net/ethernet/meta/fbnic/ |
| H A D | fbnic_txrx.c | 106 return netdev_get_tx_queue(dev, ring->q_idx); in txring_txq() 1041 skb_record_rx_queue(skb, rcq->q_idx); in fbnic_populate_skb_fields() 1255 WARN_ON(fbn->tx[txr->q_idx] && fbn->tx[txr->q_idx] != txr); in fbnic_remove_tx_ring() 1256 fbn->tx[txr->q_idx] = NULL; in fbnic_remove_tx_ring() 1268 WARN_ON(fbn->rx[rxr->q_idx] && fbn->rx[rxr->q_idx] != rxr); in fbnic_remove_rx_ring() 1269 fbn->rx[rxr->q_idx] = NULL; in fbnic_remove_rx_ring() 1347 int q_idx, u8 flags) in fbnic_ring_init() argument 1351 ring->q_idx = q_idx; in fbnic_ring_init() 1808 netif_queue_set_napi(nv->napi.dev, qt->sub0.q_idx, in fbnic_set_netif_napi() 1816 netif_queue_set_napi(nv->napi.dev, qt->cmpl.q_idx, in fbnic_set_netif_napi() [all …]
|
| /linux-6.15/net/core/ |
| H A D | netdev-genl.c | 379 u32 q_idx, u32 q_type, const struct genl_info *info) in netdev_nl_queue_fill_one() argument 390 if (nla_put_u32(rsp, NETDEV_A_QUEUE_ID, q_idx) || in netdev_nl_queue_fill_one() 397 rxq = __netif_get_rx_queue(netdev, q_idx); in netdev_nl_queue_fill_one() 413 txq = netdev_get_tx_queue(netdev, q_idx); in netdev_nl_queue_fill_one() 449 netdev_nl_queue_fill(struct sk_buff *rsp, struct net_device *netdev, u32 q_idx, in netdev_nl_queue_fill() argument 457 err = netdev_nl_queue_validate(netdev, q_idx, q_type); in netdev_nl_queue_fill() 461 return netdev_nl_queue_fill_one(rsp, netdev, q_idx, q_type, info); in netdev_nl_queue_fill()
|
| /linux-6.15/net/sched/ |
| H A D | sch_api.c | 1832 int ret = 0, q_idx = *q_idx_p; in tc_dump_qdisc_root() local 1840 if (q_idx < s_q_idx) { in tc_dump_qdisc_root() 1841 q_idx++; in tc_dump_qdisc_root() 1848 q_idx++; in tc_dump_qdisc_root() 1861 if (q_idx < s_q_idx) { in tc_dump_qdisc_root() 1862 q_idx++; in tc_dump_qdisc_root() 1870 q_idx++; in tc_dump_qdisc_root() 1874 *q_idx_p = q_idx; in tc_dump_qdisc_root() 1884 int idx, q_idx; in tc_dump_qdisc() local 1909 q_idx = 0; in tc_dump_qdisc() [all …]
|
| /linux-6.15/drivers/net/wireless/realtek/rtlwifi/rtl8192ee/ |
| H A D | trx.c | 534 u16 rtl92ee_get_available_desc(struct ieee80211_hw *hw, u8 q_idx) in rtl92ee_get_available_desc() argument 542 get_desc_addr_fr_q_idx(q_idx)); in rtl92ee_get_available_desc() 889 u8 q_idx = *val; in rtl92ee_set_desc() local 900 struct rtl8192_tx_ring *ring = &rtlpci->tx_ring[q_idx]; in rtl92ee_set_desc() 903 if (q_idx == BEACON_QUEUE) { in rtl92ee_set_desc() 914 get_desc_addr_fr_q_idx(q_idx), in rtl92ee_set_desc()
|
| /linux-6.15/drivers/net/ethernet/intel/iavf/ |
| H A D | iavf_main.c | 1236 int q_idx; in iavf_napi_enable_all() local 1240 for (q_idx = 0; q_idx < q_vectors; q_idx++) { in iavf_napi_enable_all() 1243 q_vector = &adapter->q_vectors[q_idx]; in iavf_napi_enable_all() 1255 int q_idx; in iavf_napi_disable_all() local 1259 for (q_idx = 0; q_idx < q_vectors; q_idx++) { in iavf_napi_disable_all() 1849 int q_idx = 0, num_q_vectors; in iavf_alloc_q_vectors() local 1858 for (q_idx = 0; q_idx < num_q_vectors; q_idx++) { in iavf_alloc_q_vectors() 1862 q_vector->v_idx = q_idx; in iavf_alloc_q_vectors() 1863 q_vector->reg_idx = q_idx; in iavf_alloc_q_vectors() 1882 int q_idx, num_q_vectors; in iavf_free_q_vectors() local [all …]
|