Home
last modified time | relevance | path

Searched refs:q_idx (Results 1 – 25 of 54) sorted by relevance

123

/linux/tools/sched_ext/
H A Dscx_pair.bpf.c261 u32 *q_idx; in BPF_STRUCT_OPS() local
271 q_idx = bpf_map_lookup_elem(&cgrp_q_idx_hash, &cgid); in BPF_STRUCT_OPS()
272 if (!q_idx) { in BPF_STRUCT_OPS()
277 cgq = bpf_map_lookup_elem(&cgrp_q_arr, q_idx); in BPF_STRUCT_OPS()
280 cgid, *q_idx); in BPF_STRUCT_OPS()
290 cgq_len = MEMBER_VPTR(cgrp_q_len, [*q_idx]); in BPF_STRUCT_OPS()
368 s32 pid, q_idx; in try_dispatch() local
427 u32 *q_idx; in try_dispatch() local
436 q_idx = bpf_map_lookup_elem(&cgrp_q_idx_hash, &new_cgid); in try_dispatch()
437 if (!q_idx) in try_dispatch()
[all …]
/linux/drivers/net/ethernet/intel/ice/
H A Dice_base.c754 int ice_vsi_cfg_single_rxq(struct ice_vsi *vsi, u16 q_idx) in ice_vsi_cfg_single_rxq() argument
756 if (q_idx >= vsi->num_rxq) in ice_vsi_cfg_single_rxq()
759 return ice_vsi_cfg_rxq(vsi->rx_rings[q_idx]); in ice_vsi_cfg_single_rxq()
1133 u16 q_idx) in ice_vsi_cfg_single_txq() argument
1137 if (q_idx >= vsi->alloc_txq || !tx_rings || !tx_rings[q_idx]) in ice_vsi_cfg_single_txq()
1142 return ice_vsi_cfg_txq(vsi, tx_rings[q_idx], qg_buf); in ice_vsi_cfg_single_txq()
1159 u16 q_idx; in ice_vsi_cfg_txqs() local
1163 for (q_idx = 0; q_idx < count; q_idx++) { in ice_vsi_cfg_txqs()
1164 err = ice_vsi_cfg_txq(vsi, rings[q_idx], qg_buf); in ice_vsi_cfg_txqs()
1394 static void ice_qp_reset_stats(struct ice_vsi *vsi, u16 q_idx) in ice_qp_reset_stats() argument
[all …]
H A Dice_lib.c1987 u16 q_idx; in ice_vsi_stop_tx_rings() local
1992 for (q_idx = 0; q_idx < count; q_idx++) { in ice_vsi_stop_tx_rings()
1996 if (!rings || !rings[q_idx]) in ice_vsi_stop_tx_rings()
1999 ice_fill_txq_meta(vsi, rings[q_idx], &txq_meta); in ice_vsi_stop_tx_rings()
2001 rings[q_idx], &txq_meta); in ice_vsi_stop_tx_rings()
2786 int q_idx, v_idx; in ice_vsi_set_napi_queues() local
2792 ice_for_each_rxq(vsi, q_idx) in ice_vsi_set_napi_queues()
2793 if (vsi->rx_rings[q_idx] && vsi->rx_rings[q_idx]->q_vector) in ice_vsi_set_napi_queues()
2794 netif_queue_set_napi(netdev, q_idx, NETDEV_QUEUE_TYPE_RX, in ice_vsi_set_napi_queues()
2795 &vsi->rx_rings[q_idx]->q_vector->napi); in ice_vsi_set_napi_queues()
[all …]
/linux/drivers/accel/habanalabs/common/
H A Dhw_queue.c420 u32 q_idx; in init_signal_cs() local
423 q_idx = job->hw_queue_id; in init_signal_cs()
424 prop = &hdev->kernel_queues[q_idx].sync_stream_prop; in init_signal_cs()
432 cs_cmpl->hw_sob->sob_id, cs_cmpl->sob_val, q_idx, in init_signal_cs()
441 rc = hl_cs_signal_sob_wraparound_handler(hdev, q_idx, &hw_sob, 1, in init_signal_cs()
480 u32 q_idx; in init_wait_cs() local
482 q_idx = job->hw_queue_id; in init_wait_cs()
483 prop = &hdev->kernel_queues[q_idx].sync_stream_prop; 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()
[all …]
H A Dcommand_submission.c156 hw_sob->q_idx, hw_sob->sob_id); in hl_sob_reset_error()
1798 int hl_cs_signal_sob_wraparound_handler(struct hl_device *hdev, u32 q_idx, in hl_cs_signal_sob_wraparound_handler() argument
1806 prop = &hdev->kernel_queues[q_idx].sync_stream_prop; in hl_cs_signal_sob_wraparound_handler()
1829 q_idx); in hl_cs_signal_sob_wraparound_handler()
1870 prop->curr_sob_offset, q_idx); in hl_cs_signal_sob_wraparound_handler()
1938 enum hl_queue_type q_type, u32 q_idx, u32 encaps_signal_offset) in cs_ioctl_signal_wait_create_jobs() argument
1973 job->hw_queue_id = q_idx; in cs_ioctl_signal_wait_create_jobs()
2002 u32 q_idx, u32 count, in cs_ioctl_reserve_signals() argument
2022 if (q_idx >= hdev->asic_prop.max_queues) { in cs_ioctl_reserve_signals()
2024 q_idx); in cs_ioctl_reserve_signals()
[all …]
/linux/drivers/net/ethernet/intel/ice/virt/
H A Dqueues.c186 void ice_vf_ena_txq_interrupt(struct ice_vsi *vsi, u32 q_idx) in ice_vf_ena_txq_interrupt() argument
189 u32 pfq = vsi->txq_map[q_idx]; in ice_vf_ena_txq_interrupt()
209 void ice_vf_ena_rxq_interrupt(struct ice_vsi *vsi, u32 q_idx) in ice_vf_ena_rxq_interrupt() argument
212 u32 pfq = vsi->rxq_map[q_idx]; in ice_vf_ena_rxq_interrupt()
232 static void ice_vf_dis_rxq_interrupt(struct ice_vsi *vsi, u32 q_idx) in ice_vf_dis_rxq_interrupt() argument
235 u32 pfq = vsi->rxq_map[q_idx]; in ice_vf_dis_rxq_interrupt()
777 int i = -1, q_idx; in ice_vc_cfg_qs_msg() local
822 q_idx = qpi->rxq.queue_id; in ice_vc_cfg_qs_msg()
827 if (q_idx >= vsi->alloc_txq || q_idx >= vsi->alloc_rxq) { in ice_vc_cfg_qs_msg()
833 vsi->tx_rings[q_idx]->dma = qpi->txq.dma_ring_addr; in ice_vc_cfg_qs_msg()
[all …]
H A Dvirtchnl.h95 void ice_vf_ena_rxq_interrupt(struct ice_vsi *vsi, u32 q_idx);
96 void ice_vf_ena_txq_interrupt(struct ice_vsi *vsi, u32 q_idx);
106 static inline void ice_vf_ena_rxq_interrupt(struct ice_vsi *vsi, u32 q_idx) { } in ice_vf_ena_rxq_interrupt() argument
107 static inline void ice_vf_ena_txq_interrupt(struct ice_vsi *vsi, u32 q_idx) { } in ice_vf_ena_txq_interrupt() argument
/linux/drivers/net/ethernet/microsoft/mana/
H A Dmana_bpf.c36 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/drivers/net/hyperv/
H A Dnetvsc_bpf.c230 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 Dnetvsc.c347 int netvsc_alloc_recv_comp_ring(struct netvsc_device *net_device, u32 q_idx) in netvsc_alloc_recv_comp_ring() argument
349 struct netvsc_channel *nvchan = &net_device->chan_table[q_idx]; in netvsc_alloc_recv_comp_ring()
785 u16 q_idx = 0; in netvsc_send_tx_complete() local
806 q_idx = packet->q_idx; in netvsc_send_tx_complete()
808 tx_stats = &net_device->chan_table[q_idx].tx_stats; in netvsc_send_tx_complete()
820 atomic_dec_return(&net_device->chan_table[q_idx].queue_sends); in netvsc_send_tx_complete()
826 struct netdev_queue *txq = netdev_get_tx_queue(ndev, q_idx); in netvsc_send_tx_complete()
1133 &net_device->chan_table[packet->q_idx]; in netvsc_send_pkt()
1137 struct netdev_queue *txq = netdev_get_tx_queue(ndev, packet->q_idx); in netvsc_send_pkt()
1278 nvchan = &net_device->chan_table[packet->q_idx]; in netvsc_send()
[all …]
H A Dnetvsc_drv.c255 int q_idx; in netvsc_get_tx_queue() local
257 q_idx = ndc->tx_table[netvsc_get_hash(skb, ndc) & in netvsc_get_tx_queue()
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()
[all …]
/linux/drivers/net/ethernet/cavium/thunder/
H A Dnicvf_queues.h354 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 Dnicvf_queues.c1722 static u64 nicvf_int_type_to_mask(int int_type, int q_idx) in nicvf_int_type_to_mask() argument
1728 reg_val = ((1ULL << q_idx) << NICVF_INTR_CQ_SHIFT); in nicvf_int_type_to_mask()
1731 reg_val = ((1ULL << q_idx) << NICVF_INTR_SQ_SHIFT); in nicvf_int_type_to_mask()
1734 reg_val = ((1ULL << q_idx) << NICVF_INTR_RBDR_SHIFT); in nicvf_int_type_to_mask()
1756 void nicvf_enable_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_enable_intr() argument
1758 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_enable_intr()
1770 void nicvf_disable_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_disable_intr() argument
1772 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_disable_intr()
1784 void nicvf_clear_intr(struct nicvf *nic, int int_type, int q_idx) in nicvf_clear_intr() argument
1786 u64 mask = nicvf_int_type_to_mask(int_type, q_idx); in nicvf_clear_intr()
[all …]
/linux/drivers/net/ethernet/ti/icssg/
H A Dicssg_common.c97 unsigned int q_idx) in emac_xsk_xmit_zc() argument
99 struct prueth_tx_chn *tx_chn = &emac->tx_chns[q_idx]; in emac_xsk_xmit_zc()
141 dst_tag_id = emac->port_id | (q_idx << 8); in emac_xsk_xmit_zc()
697 unsigned int q_idx, in emac_xmit_xdp_frame() argument
711 if (q_idx >= PRUETH_MAX_TX_QUEUES) { in emac_xmit_xdp_frame()
712 netdev_err(ndev, "xdp tx: invalid q_id %d\n", q_idx); in emac_xmit_xdp_frame()
716 tx_chn = &emac->tx_chns[q_idx]; in emac_xmit_xdp_frame()
757 dst_tag_id = emac->port_id | (q_idx << 8); in emac_xmit_xdp_frame()
813 int q_idx, err; in emac_run_xdp() local
828 q_idx = cpu % emac->tx_ch_num; in emac_run_xdp()
[all …]
/linux/drivers/net/ethernet/meta/fbnic/
H A Dfbnic_txrx.c119 return netdev_get_tx_queue(dev, ring->q_idx); in txring_txq()
1246 skb_record_rx_queue(skb, rcq->q_idx); in fbnic_populate_skb_fields()
1497 WARN_ON(fbn->tx[txr->q_idx] && fbn->tx[txr->q_idx] != txr); in fbnic_remove_tx_ring()
1498 fbn->tx[txr->q_idx] = NULL; in fbnic_remove_tx_ring()
1510 WARN_ON(fbn->tx[xdpr->q_idx] && fbn->tx[xdpr->q_idx] != xdpr); in fbnic_remove_xdp_ring()
1511 fbn->tx[xdpr->q_idx] = NULL; in fbnic_remove_xdp_ring()
1523 WARN_ON(fbn->rx[rxr->q_idx] && fbn->rx[rxr->q_idx] != rxr); in fbnic_remove_rx_ring()
1524 fbn->rx[rxr->q_idx] = NULL; in fbnic_remove_rx_ring()
1631 int q_idx, u8 flags) in fbnic_ring_init() argument
1635 ring->q_idx = q_idx; in fbnic_ring_init()
[all …]
/linux/net/core/
H A Dnetdev-genl.c393 u32 q_idx, u32 q_type) in netdev_nl_queue_fill_lease() argument
400 rxq = __netif_get_rx_queue_lease(&netdev, &q_idx, NETIF_PHYS_TO_VIRT); in netdev_nl_queue_fill_lease()
411 if (nla_put_u32(rsp, NETDEV_A_QUEUE_ID, q_idx)) in netdev_nl_queue_fill_lease()
476 u32 q_idx, u32 q_type, const struct genl_info *info) in netdev_nl_queue_fill_one() argument
486 if (nla_put_u32(rsp, NETDEV_A_QUEUE_ID, q_idx) || in netdev_nl_queue_fill_one()
493 rxq = __netif_get_rx_queue(netdev, q_idx); in netdev_nl_queue_fill_one()
496 if (netdev_nl_queue_fill_lease(rsp, netdev, q_idx, q_type)) in netdev_nl_queue_fill_one()
502 txq = netdev_get_tx_queue(netdev, q_idx); in netdev_nl_queue_fill_one()
538 netdev_nl_queue_fill(struct sk_buff *rsp, struct net_device *netdev, u32 q_idx, in netdev_nl_queue_fill() argument
546 err = netdev_nl_queue_validate(netdev, q_idx, q_type); in netdev_nl_queue_fill()
[all …]
/linux/net/sched/
H A Dsch_api.c1859 int ret = 0, q_idx = *q_idx_p; in tc_dump_qdisc_root() local
1869 if (q_idx < s_q_idx) { in tc_dump_qdisc_root()
1870 q_idx++; in tc_dump_qdisc_root()
1879 q_idx++; in tc_dump_qdisc_root()
1892 if (q_idx < s_q_idx) { in tc_dump_qdisc_root()
1893 q_idx++; in tc_dump_qdisc_root()
1903 q_idx++; in tc_dump_qdisc_root()
1907 *q_idx_p = q_idx; in tc_dump_qdisc_root()
1918 int q_idx; in tc_dump_qdisc() member
1922 int s_q_idx, q_idx; in tc_dump_qdisc() local
[all …]
/linux/drivers/net/wireless/realtek/rtlwifi/rtl8192ee/
H A Dtrx.c534 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/drivers/infiniband/hw/hfi1/
H A Dipoib_tx.c57 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 Dipoib.h114 u8 q_idx; member
/linux/drivers/net/wireless/mediatek/mt76/mt7925/
H A Dmac.c754 u8 p_fmt, q_idx, omac_idx = 0, wmm_idx = 0, band_idx = 0; in mt7925_mac_write_txwi() local
776 q_idx = MT_LMAC_ALTX0; in mt7925_mac_write_txwi()
779 q_idx = MT_LMAC_BCN0; in mt7925_mac_write_txwi()
782 q_idx = MT_LMAC_ALTX0; in mt7925_mac_write_txwi()
785 q_idx = wmm_idx * MT76_CONNAC_MAX_WMM_SETS + in mt7925_mac_write_txwi()
795 FIELD_PREP(MT_TXD0_Q_IDX, q_idx); in mt7925_mac_write_txwi()
834 (q_idx >= MT_LMAC_ALTX0 && q_idx <= MT_LMAC_BCN0))) in mt7925_mac_write_txwi()
/linux/drivers/net/ethernet/fungible/funeth/
H A Dfuneth_tx.c576 int i, q_idx; in fun_xdp_xmit_frames() local
585 q_idx = smp_processor_id(); in fun_xdp_xmit_frames()
586 if (unlikely(q_idx >= fp->num_xdpqs)) in fun_xdp_xmit_frames()
589 for (q = xdpqs[q_idx], i = 0; i < n; i++) in fun_xdp_xmit_frames()
/linux/drivers/net/wireless/mediatek/mt76/
H A Dmt76_connac_mac.c513 u8 p_fmt, q_idx, omac_idx = 0, wmm_idx = 0, band_idx = 0; in mt76_connac2_mac_write_txwi() local
535 q_idx = MT_LMAC_ALTX0; in mt76_connac2_mac_write_txwi()
538 q_idx = MT_LMAC_BCN0; in mt76_connac2_mac_write_txwi()
541 q_idx = MT_LMAC_ALTX0; in mt76_connac2_mac_write_txwi()
544 q_idx = wmm_idx * MT76_CONNAC_MAX_WMM_SETS + in mt76_connac2_mac_write_txwi()
554 FIELD_PREP(MT_TXD0_Q_IDX, q_idx); in mt76_connac2_mac_write_txwi()
/linux/drivers/scsi/mpi3mr/
H A Dmpi3mr_fw.c1931 static void mpi3mr_free_op_req_q_segments(struct mpi3mr_ioc *mrioc, u16 q_idx) in mpi3mr_free_op_req_q_segments() argument
1937 segments = mrioc->req_qinfo[q_idx].q_segments; in mpi3mr_free_op_req_q_segments()
1943 if (mrioc->req_qinfo[q_idx].q_segment_list) { in mpi3mr_free_op_req_q_segments()
1946 mrioc->req_qinfo[q_idx].q_segment_list, in mpi3mr_free_op_req_q_segments()
1947 mrioc->req_qinfo[q_idx].q_segment_list_dma); in mpi3mr_free_op_req_q_segments()
1948 mrioc->req_qinfo[q_idx].q_segment_list = NULL; in mpi3mr_free_op_req_q_segments()
1951 size = mrioc->req_qinfo[q_idx].segment_qd * in mpi3mr_free_op_req_q_segments()
1954 for (j = 0; j < mrioc->req_qinfo[q_idx].num_segments; j++) { in mpi3mr_free_op_req_q_segments()
1961 kfree(mrioc->req_qinfo[q_idx].q_segments); in mpi3mr_free_op_req_q_segments()
1962 mrioc->req_qinfo[q_idx].q_segments = NULL; in mpi3mr_free_op_req_q_segments()
[all …]
/linux/drivers/gpu/drm/amd/amdkfd/
H A Dkfd_device_queue_manager.c3628 int q_idx = QUEUE_NOT_FOUND; in resume_queues() local
3631 q_idx = q_array_get_index( in resume_queues()
3636 if (!queue_ids || q_idx != QUEUE_NOT_FOUND) { in resume_queues()
3641 queue_ids[q_idx] &= in resume_queues()
3644 queue_ids[q_idx] |= in resume_queues()
3673 int q_idx = q_array_get_index( in resume_queues() local
3679 if (q_idx != QUEUE_NOT_FOUND) in resume_queues()
3680 queue_ids[q_idx] |= in resume_queues()
3732 int q_idx = q_array_get_index(q->properties.queue_id, in suspend_queues() local
3736 if (q_idx != QUEUE_NOT_FOUND) { in suspend_queues()
[all …]

123