| /linux/drivers/net/wwan/t7xx/ |
| H A D | t7xx_hif_dpmaif_rx.c | 84 struct dpmaif_rx_queue *rxq = &dpmaif_ctrl->rxq[q_num]; in t7xx_dpmaif_update_bat_wr_idx() local 85 struct dpmaif_bat_request *bat_req = rxq->bat_req; in t7xx_dpmaif_update_bat_wr_idx() 88 if (!rxq->que_started) { in t7xx_dpmaif_update_bat_wr_idx() 89 dev_err(dpmaif_ctrl->dev, "RX queue %d has not been started\n", rxq->index); in t7xx_dpmaif_update_bat_wr_idx() 236 static int t7xx_dpmaifq_release_pit_entry(struct dpmaif_rx_queue *rxq, in t7xx_dpmaifq_release_pit_entry() argument 239 struct dpmaif_hw_info *hw_info = &rxq->dpmaif_ctrl->hw_info; in t7xx_dpmaifq_release_pit_entry() 243 if (!rxq->que_started) in t7xx_dpmaifq_release_pit_entry() 246 if (rel_entry_num >= rxq->pit_size_cnt) { in t7xx_dpmaifq_release_pit_entry() 247 dev_err(rxq->dpmaif_ctrl->dev, "Invalid PIT release index\n"); in t7xx_dpmaifq_release_pit_entry() 251 old_rel_idx = rxq->pit_release_rd_idx; in t7xx_dpmaifq_release_pit_entry() [all …]
|
| H A D | t7xx_hif_dpmaif.c | 227 rx_q = &dpmaif_ctrl->rxq[rx_idx]; in t7xx_dpmaif_rxtx_sw_allocs() 267 rx_q = &dpmaif_ctrl->rxq[i]; in t7xx_dpmaif_rxtx_sw_allocs() 294 rx_q = &dpmaif_ctrl->rxq[i]; in t7xx_dpmaif_sw_release() 303 struct dpmaif_rx_queue *rxq; in t7xx_dpmaif_start() local 314 rxq = &dpmaif_ctrl->rxq[i]; in t7xx_dpmaif_start() 315 rxq->que_started = true; in t7xx_dpmaif_start() 316 rxq->index = i; in t7xx_dpmaif_start() 317 rxq->budget = rxq->bat_req->bat_size_cnt - 1; in t7xx_dpmaif_start() 319 hw_init_para.pkt_bat_base_addr[i] = rxq->bat_req->bat_bus_addr; in t7xx_dpmaif_start() 320 hw_init_para.pkt_bat_size_cnt[i] = rxq->bat_req->bat_size_cnt; in t7xx_dpmaif_start() [all …]
|
| H A D | t7xx_hif_cldma.c | 601 queue_work(md_ctrl->rxq[i].worker, &md_ctrl->rxq[i].cldma_work); in t7xx_cldma_irq_work_cb() 655 flush_work(&md_ctrl->rxq[i].cldma_work); in t7xx_cldma_stop() 704 cancel_work_sync(&md_ctrl->rxq[i].cldma_work); in t7xx_cldma_reset() 707 md_cd_queue_struct_reset(&md_ctrl->rxq[i], md_ctrl, MTK_RX, i); in t7xx_cldma_reset() 740 if (md_ctrl->rxq[i].tr_done) in t7xx_cldma_start() 742 md_ctrl->rxq[i].tr_done->gpd_addr, in t7xx_cldma_start() 778 struct cldma_queue *rxq = &md_ctrl->rxq[qnum]; in t7xx_cldma_clear_rxq() local 784 spin_lock_irqsave(&rxq->ring_lock, flags); in t7xx_cldma_clear_rxq() 785 t7xx_cldma_q_reset(rxq); in t7xx_cldma_clear_rxq() 786 list_for_each_entry(req, &rxq->tr_ring->gpd_ring, entry) { in t7xx_cldma_clear_rxq() [all …]
|
| /linux/drivers/net/ethernet/huawei/hinic/ |
| H A D | hinic_rx.c | 53 static void hinic_rxq_clean_stats(struct hinic_rxq *rxq) in hinic_rxq_clean_stats() argument 55 struct hinic_rxq_stats *rxq_stats = &rxq->rxq_stats; in hinic_rxq_clean_stats() 71 void hinic_rxq_get_stats(struct hinic_rxq *rxq, struct hinic_rxq_stats *stats) in hinic_rxq_get_stats() argument 73 struct hinic_rxq_stats *rxq_stats = &rxq->rxq_stats; in hinic_rxq_get_stats() 91 static void rxq_stats_init(struct hinic_rxq *rxq) in rxq_stats_init() argument 93 struct hinic_rxq_stats *rxq_stats = &rxq->rxq_stats; in rxq_stats_init() 96 hinic_rxq_clean_stats(rxq); in rxq_stats_init() 99 static void rx_csum(struct hinic_rxq *rxq, u32 status, in rx_csum() argument 102 struct net_device *netdev = rxq->netdev; in rx_csum() 115 rxq->rxq_stats.csum_errors++; in rx_csum() [all …]
|
| H A D | hinic_rx.h | 44 void hinic_rxq_get_stats(struct hinic_rxq *rxq, struct hinic_rxq_stats *stats); 46 int hinic_init_rxq(struct hinic_rxq *rxq, struct hinic_rq *rq, 49 void hinic_clean_rxq(struct hinic_rxq *rxq);
|
| /linux/drivers/net/wireless/intel/iwlwifi/pcie/gen1_2/ |
| H A D | rx.c | 120 static int iwl_rxq_space(const struct iwl_rxq *rxq) in iwl_rxq_space() argument 123 WARN_ON(rxq->queue_size & (rxq->queue_size - 1)); in iwl_rxq_space() 131 return (rxq->read - rxq->write - 1) & (rxq->queue_size - 1); in iwl_rxq_space() 168 struct iwl_rxq *rxq) in iwl_pcie_rxq_inc_wr_ptr() argument 172 lockdep_assert_held(&rxq->lock); in iwl_pcie_rxq_inc_wr_ptr() 188 rxq->need_update = true; in iwl_pcie_rxq_inc_wr_ptr() 193 rxq->write_actual = round_down(rxq->write, 8); in iwl_pcie_rxq_inc_wr_ptr() 195 iwl_write32(trans, FH_RSCSR_CHNL0_WPTR, rxq->write_actual); in iwl_pcie_rxq_inc_wr_ptr() 197 iwl_write32(trans, HBUS_TARG_WRPTR, rxq->write_actual | in iwl_pcie_rxq_inc_wr_ptr() 198 HBUS_TARG_WRPTR_RX_Q(rxq->id)); in iwl_pcie_rxq_inc_wr_ptr() [all …]
|
| /linux/drivers/net/ethernet/qlogic/qede/ |
| H A D | qede_fp.c | 28 int qede_alloc_rx_buffer(struct qede_rx_queue *rxq, bool allow_lazy) in qede_alloc_rx_buffer() argument 39 if (allow_lazy && likely(rxq->filled_buffers > 12)) { in qede_alloc_rx_buffer() 40 rxq->filled_buffers--; in qede_alloc_rx_buffer() 51 mapping = dma_map_page(rxq->dev, data, 0, in qede_alloc_rx_buffer() 52 PAGE_SIZE, rxq->data_direction); in qede_alloc_rx_buffer() 53 if (unlikely(dma_mapping_error(rxq->dev, mapping))) { in qede_alloc_rx_buffer() 58 sw_rx_data = &rxq->sw_rx_ring[rxq->sw_rx_prod & NUM_RX_BDS_MAX]; in qede_alloc_rx_buffer() 64 rx_bd = (struct eth_rx_bd *)qed_chain_produce(&rxq->rx_bd_ring); in qede_alloc_rx_buffer() 68 rxq->rx_headroom); in qede_alloc_rx_buffer() 70 rxq->sw_rx_prod++; in qede_alloc_rx_buffer() [all …]
|
| H A D | qede_main.c | 946 if (fp->rxq && xdp_rxq_info_is_reg(&fp->rxq->xdp_rxq)) in qede_free_fp_array() 947 xdp_rxq_info_unreg(&fp->rxq->xdp_rxq); in qede_free_fp_array() 948 kfree(fp->rxq); in qede_free_fp_array() 1014 fp->rxq = kzalloc_obj(*fp->rxq); in qede_alloc_fp_array() 1015 if (!fp->rxq) in qede_alloc_fp_array() 1501 struct qede_rx_queue *rxq) in qede_free_rx_buffers() argument 1505 for (i = rxq->sw_rx_cons; i != rxq->sw_rx_prod; i++) { in qede_free_rx_buffers() 1509 rx_buf = &rxq->sw_rx_ring[i & NUM_RX_BDS_MAX]; in qede_free_rx_buffers() 1513 rx_buf->mapping, PAGE_SIZE, rxq->data_direction); in qede_free_rx_buffers() 1520 static void qede_free_mem_rxq(struct qede_dev *edev, struct qede_rx_queue *rxq) in qede_free_mem_rxq() argument [all …]
|
| /linux/drivers/net/ethernet/intel/idpf/ |
| H A D | xdp.c | 11 int (*fn)(struct idpf_rx_queue *rxq, void *arg), in idpf_rxq_for_each() argument 33 q = &rx_qgrp->splitq.rxq_sets[j]->rxq; in idpf_rxq_for_each() 46 static int __idpf_xdp_rxq_info_init(struct idpf_rx_queue *rxq, void *arg) in __idpf_xdp_rxq_info_init() argument 48 const struct idpf_vport *vport = rxq->q_vector->vport; in __idpf_xdp_rxq_info_init() 54 if (idpf_queue_has(XSK, rxq)) in __idpf_xdp_rxq_info_init() 55 frag_size = rxq->bufq_sets[0].bufq.truesize; in __idpf_xdp_rxq_info_init() 57 err = __xdp_rxq_info_reg(&rxq->xdp_rxq, vport->netdev, rxq->idx, in __idpf_xdp_rxq_info_init() 58 rxq->q_vector->napi.napi_id, in __idpf_xdp_rxq_info_init() 66 if (idpf_queue_has(XSK, rxq)) { in __idpf_xdp_rxq_info_init() 67 err = xdp_rxq_info_reg_mem_model(&rxq->xdp_rxq, in __idpf_xdp_rxq_info_init() [all …]
|
| H A D | xsk.c | 13 struct idpf_rx_queue *rxq) in idpf_xsk_setup_rxq() argument 17 pool = xsk_get_pool_from_qid(vport->netdev, rxq->idx); in idpf_xsk_setup_rxq() 21 rxq->pool = pool; in idpf_xsk_setup_rxq() 23 idpf_queue_set(XSK, rxq); in idpf_xsk_setup_rxq() 38 qid = grp->splitq.rxq_sets[0]->rxq.idx; in idpf_xsk_setup_bufq() 128 struct idpf_rx_queue *rxq; in idpf_xsk_clear_queue() local 133 rxq = q; in idpf_xsk_clear_queue() 134 if (!idpf_queue_has_clear(XSK, rxq)) in idpf_xsk_clear_queue() 137 rxq->pool = NULL; in idpf_xsk_clear_queue() 467 int idpf_xskrq_poll(struct idpf_rx_queue *rxq, u32 budget) in idpf_xskrq_poll() argument [all …]
|
| H A D | idpf_txrx.c | 413 static void idpf_rx_buf_rel_all(struct idpf_rx_queue *rxq) in idpf_rx_buf_rel_all() argument 416 .fqes = rxq->rx_buf, in idpf_rx_buf_rel_all() 417 .pp = rxq->pp, in idpf_rx_buf_rel_all() 420 if (!rxq->rx_buf) in idpf_rx_buf_rel_all() 423 for (u32 i = 0; i < rxq->desc_count; i++) in idpf_rx_buf_rel_all() 424 idpf_rx_page_rel(&rxq->rx_buf[i]); in idpf_rx_buf_rel_all() 427 rxq->rx_buf = NULL; in idpf_rx_buf_rel_all() 428 rxq->pp = NULL; in idpf_rx_buf_rel_all() 439 static void idpf_rx_desc_rel(struct idpf_rx_queue *rxq, struct device *dev, in idpf_rx_desc_rel() argument 442 if (!rxq) in idpf_rx_desc_rel() [all …]
|
| /linux/drivers/net/ethernet/microsoft/mana/ |
| H A D | mana_en.c | 65 static void mana_put_rx_page(struct mana_rxq *rxq, struct page *page, in mana_put_rx_page() argument 69 page_pool_put_full_page(rxq->page_pool, page, false); in mana_put_rx_page() 716 static void *mana_get_rxbuf_pre(struct mana_rxq *rxq, dma_addr_t *da) in mana_get_rxbuf_pre() argument 718 struct net_device *ndev = rxq->ndev; in mana_get_rxbuf_pre() 730 if (mpc->rxbpre_datasize != rxq->datasize) { in mana_get_rxbuf_pre() 732 mpc->rxbpre_datasize, rxq->datasize); in mana_get_rxbuf_pre() 736 if (mpc->rxbpre_alloc_size != rxq->alloc_size) { in mana_get_rxbuf_pre() 738 mpc->rxbpre_alloc_size, rxq->alloc_size); in mana_get_rxbuf_pre() 742 if (mpc->rxbpre_headroom != rxq->headroom) { in mana_get_rxbuf_pre() 744 mpc->rxbpre_headroom, rxq->headroom); in mana_get_rxbuf_pre() [all …]
|
| H A D | mana_bpf.c | 80 u32 mana_run_xdp(struct net_device *ndev, struct mana_rxq *rxq, in mana_run_xdp() argument 88 prog = rcu_dereference(rxq->bpf_prog); in mana_run_xdp() 93 xdp_init_buff(xdp, PAGE_SIZE, &rxq->xdp_rxq); in mana_run_xdp() 98 rx_stats = &rxq->stats; in mana_run_xdp() 107 rxq->xdp_rc = xdp_do_redirect(ndev, xdp, prog); in mana_run_xdp() 108 if (!rxq->xdp_rc) { in mana_run_xdp() 109 rxq->xdp_flush = true; in mana_run_xdp()
|
| /linux/drivers/net/ethernet/marvell/ |
| H A D | mvneta.c | 109 #define MVNETA_VLAN_PRIO_RXQ_MAP(prio, rxq) ((rxq) << ((prio) * 3)) argument 134 #define MVNETA_CPU_RXQ_ACCESS(rxq) BIT(rxq) argument 857 struct mvneta_rx_queue *rxq, in mvneta_rxq_non_occup_desc_add() argument 864 mvreg_write(pp, MVNETA_RXQ_STATUS_UPDATE_REG(rxq->id), in mvneta_rxq_non_occup_desc_add() 870 mvreg_write(pp, MVNETA_RXQ_STATUS_UPDATE_REG(rxq->id), in mvneta_rxq_non_occup_desc_add() 876 struct mvneta_rx_queue *rxq) in mvneta_rxq_busy_desc_num_get() argument 880 val = mvreg_read(pp, MVNETA_RXQ_STATUS_REG(rxq->id)); in mvneta_rxq_busy_desc_num_get() 888 struct mvneta_rx_queue *rxq, in mvneta_rxq_desc_num_update() argument 896 mvreg_write(pp, MVNETA_RXQ_STATUS_UPDATE_REG(rxq->id), val); in mvneta_rxq_desc_num_update() 916 mvreg_write(pp, MVNETA_RXQ_STATUS_UPDATE_REG(rxq->id), val); in mvneta_rxq_desc_num_update() [all …]
|
| /linux/drivers/net/ethernet/huawei/hinic3/ |
| H A D | hinic3_irq.c | 19 struct hinic3_rxq *rxq = irq_cfg->rxq; in hinic3_net_dim() local 26 dim_update_sample(irq_cfg->total_events, rxq->rxq_stats.packets, in hinic3_net_dim() 27 rxq->rxq_stats.bytes, &sample); in hinic3_net_dim() 28 net_dim(&rxq->dim, &sample); in hinic3_net_dim() 46 work_done = hinic3_rx_poll(irq_cfg->rxq, budget); in hinic3_poll() 184 struct hinic3_rxq *rxq; in hinic3_rx_dim_work() local 188 rxq = container_of(dim, struct hinic3_rxq, dim); in hinic3_rx_dim_work() 192 hinic3_update_queue_coal(rxq->netdev, rxq->q_id, in hinic3_rx_dim_work() 216 irq_cfg->rxq = &nic_dev->rxqs[q_id]; in hinic3_qps_irq_init() 231 INIT_WORK(&irq_cfg->rxq->dim.work, hinic3_rx_dim_work); in hinic3_qps_irq_init() [all …]
|
| /linux/drivers/net/ethernet/atheros/alx/ |
| H A D | main.c | 73 struct alx_rx_queue *rxq = alx->qnapi[0]->rxq; in alx_refill_rx_ring() local 79 next = cur = rxq->write_idx; in alx_refill_rx_ring() 82 cur_buf = &rxq->bufs[cur]; in alx_refill_rx_ring() 84 while (!cur_buf->skb && next != rxq->read_idx) { in alx_refill_rx_ring() 85 struct alx_rfd *rfd = &rxq->rfd[cur]; in alx_refill_rx_ring() 127 cur_buf = &rxq->bufs[cur]; in alx_refill_rx_ring() 134 rxq->write_idx = cur; in alx_refill_rx_ring() 216 static int alx_clean_rx_irq(struct alx_rx_queue *rxq, int budget) in alx_clean_rx_irq() argument 225 alx = netdev_priv(rxq->netdev); in alx_clean_rx_irq() 228 rrd = &rxq->rrd[rxq->rrd_read_idx]; in alx_clean_rx_irq() [all …]
|
| /linux/tools/testing/selftests/bpf/ |
| H A D | xdp_hw_metadata.c | 73 int rxq; variable 444 static int verify_metadata(struct xsk *rx_xsk, int rxq, int server_fd, clockid_t clock_id) in verify_metadata() argument 447 struct pollfd fds[rxq + 1]; in verify_metadata() 455 for (i = 0; i < rxq; i++) { in verify_metadata() 461 fds[rxq].fd = server_fd; in verify_metadata() 462 fds[rxq].events = POLLIN; in verify_metadata() 463 fds[rxq].revents = 0; in verify_metadata() 468 for (i = 0; i < rxq; i++) { in verify_metadata() 474 ret = poll(fds, rxq + 1, 1000); in verify_metadata() 483 if (fds[rxq].revents) in verify_metadata() [all …]
|
| /linux/drivers/vhost/ |
| H A D | net.c | 131 struct vhost_net_buf rxq; member 154 static void *vhost_net_buf_get_ptr(struct vhost_net_buf *rxq) in vhost_net_buf_get_ptr() argument 156 if (rxq->tail != rxq->head) in vhost_net_buf_get_ptr() 157 return rxq->queue[rxq->head]; in vhost_net_buf_get_ptr() 162 static int vhost_net_buf_get_size(struct vhost_net_buf *rxq) in vhost_net_buf_get_size() argument 164 return rxq->tail - rxq->head; in vhost_net_buf_get_size() 167 static int vhost_net_buf_is_empty(struct vhost_net_buf *rxq) in vhost_net_buf_is_empty() argument 169 return rxq->tail == rxq->head; in vhost_net_buf_is_empty() 172 static void *vhost_net_buf_consume(struct vhost_net_buf *rxq) in vhost_net_buf_consume() argument 174 void *ret = vhost_net_buf_get_ptr(rxq); in vhost_net_buf_consume() [all …]
|
| /linux/drivers/net/ethernet/mellanox/mlx5/core/ |
| H A D | en_arfs.c | 90 int rxq; member 436 arfs_rule->rxq, arfs_rule->flow_id, in arfs_may_expire_flow() 448 priv->channel_stats[arfs_rule->rxq]->rq.arfs_expired++; in arfs_may_expire_flow() 527 priv->channel_stats[arfs_rule->rxq]->rq.arfs_err++; in arfs_add_rule() 596 dest.tir_num = mlx5e_rx_res_get_tirn_direct(priv->rx_res, arfs_rule->rxq); in arfs_add_rule() 600 priv->channel_stats[arfs_rule->rxq]->rq.arfs_err++; in arfs_add_rule() 603 __func__, arfs_rule->filter_id, arfs_rule->rxq, in arfs_add_rule() 613 struct mlx5_flow_handle *rule, u16 rxq) in arfs_modify_rule_rq() argument 619 dst.tir_num = mlx5e_rx_res_get_tirn_direct(priv->rx_res, rxq); in arfs_modify_rule_rq() 622 priv->channel_stats[rxq]->rq.arfs_err++; in arfs_modify_rule_rq() [all …]
|
| /linux/drivers/bluetooth/ |
| H A D | btintel_pcie.c | 482 static void btintel_pcie_prepare_rx(struct rxq *rxq, u16 frbd_index) in btintel_pcie_prepare_rx() argument 488 buf = &rxq->bufs[frbd_index]; in btintel_pcie_prepare_rx() 490 frbd = &rxq->frbds[frbd_index]; in btintel_pcie_prepare_rx() 501 struct rxq *rxq = &data->rxq; in btintel_pcie_submit_rx() local 505 if (frbd_index > rxq->count) in btintel_pcie_submit_rx() 511 btintel_pcie_prepare_rx(rxq, frbd_index); in btintel_pcie_submit_rx() 513 frbd_index = (frbd_index + 1) % rxq->count; in btintel_pcie_submit_rx() 526 struct rxq *rxq = &data->rxq; in btintel_pcie_start_rx() local 532 for (i = 0; i < rxq->count - 3; i++) { in btintel_pcie_start_rx() 1628 struct rxq *rxq; in btintel_pcie_msix_rx_handle() local [all …]
|
| /linux/drivers/net/ethernet/intel/ice/virt/ |
| H A D | queues.c | 802 if (!qci->qpair[i].rxq.crc_disable) in ice_vc_cfg_qs_msg() 813 qpi->rxq.vsi_id != qci->vsi_id || in ice_vc_cfg_qs_msg() 814 qpi->rxq.queue_id != qpi->txq.queue_id || in ice_vc_cfg_qs_msg() 817 !ice_vc_isvalid_ring_len(qpi->rxq.ring_len) || in ice_vc_cfg_qs_msg() 822 q_idx = qpi->rxq.queue_id; in ice_vc_cfg_qs_msg() 849 if (qpi->rxq.ring_len > 0) { in ice_vc_cfg_qs_msg() 854 ring->dma = qpi->rxq.dma_ring_addr; in ice_vc_cfg_qs_msg() 855 ring->count = qpi->rxq.ring_len; in ice_vc_cfg_qs_msg() 857 if (qpi->rxq.crc_disable) in ice_vc_cfg_qs_msg() 862 if (qpi->rxq.databuffer_size != 0 && in ice_vc_cfg_qs_msg() [all …]
|
| /linux/drivers/net/ethernet/chelsio/cxgb4vf/ |
| H A D | sge.c | 1564 static void do_gro(struct sge_eth_rxq *rxq, const struct pkt_gl *gl, in do_gro() argument 1567 struct adapter *adapter = rxq->rspq.adapter; in do_gro() 1573 skb = napi_get_frags(&rxq->rspq.napi); in do_gro() 1576 rxq->stats.rx_drops++; in do_gro() 1585 skb_record_rx_queue(skb, rxq->rspq.idx); in do_gro() 1591 rxq->stats.vlan_ex++; in do_gro() 1593 ret = napi_gro_frags(&rxq->rspq.napi); in do_gro() 1596 rxq->stats.lro_pkts++; in do_gro() 1598 rxq->stats.lro_merged++; in do_gro() 1599 rxq->stats.pkts++; in do_gro() [all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | test_xdp_bpf2bpf.c | 29 struct xdp_rxq_info *rxq; member 49 meta.ifindex = xdp->rxq->dev->ifindex; in BPF_PROG() 56 test_result_fentry = xdp->rxq->dev->ifindex; in BPF_PROG()
|
| /linux/drivers/net/ethernet/alacritech/ |
| H A D | slicoss.c | 120 static unsigned int slic_get_free_rx_descs(struct slic_rx_queue *rxq) in slic_get_free_rx_descs() argument 122 return slic_get_free_queue_descs(rxq->put_idx, rxq->done_idx, rxq->len); in slic_get_free_rx_descs() 396 struct slic_rx_queue *rxq = &sdev->rxq; in slic_refill_rx_queue() local 405 while (slic_get_free_rx_descs(rxq) > SLIC_MAX_REQ_RX_DESCS) { in slic_refill_rx_queue() 437 buff = &rxq->rxbuffs[rxq->put_idx]; in slic_refill_rx_queue() 446 rxq->put_idx = slic_next_queue_idx(rxq->put_idx, rxq->len); in slic_refill_rx_queue() 549 struct slic_rx_queue *rxq = &sdev->rxq; in slic_handle_receive() local 559 while (todo && (rxq->done_idx != rxq->put_idx)) { in slic_handle_receive() 560 buff = &rxq->rxbuffs[rxq->done_idx]; in slic_handle_receive() 613 rxq->done_idx = slic_next_queue_idx(rxq->done_idx, rxq->len); in slic_handle_receive() [all …]
|
| /linux/net/core/ |
| H A D | devmem.c | 128 struct netdev_rx_queue *rxq; in net_devmem_unbind_dmabuf() local 142 xa_for_each(&binding->bound_rxqs, xa_idx, rxq) { in net_devmem_unbind_dmabuf() 148 rxq_idx = get_netdev_rx_queue_index(rxq); in net_devmem_unbind_dmabuf() 164 struct netdev_rx_queue *rxq; in net_devmem_bind_dmabuf_to_queue() local 175 rxq = __netif_get_rx_queue(dev, rxq_idx); in net_devmem_bind_dmabuf_to_queue() 176 err = xa_alloc(&binding->bound_rxqs, &xa_idx, rxq, xa_limit_32b, in net_devmem_bind_dmabuf_to_queue() 516 struct netdev_rx_queue *rxq) in mp_dmabuf_devmem_nl_fill() argument 519 int type = rxq ? NETDEV_A_QUEUE_DMABUF : NETDEV_A_PAGE_POOL_DMABUF; in mp_dmabuf_devmem_nl_fill() 525 struct netdev_rx_queue *rxq) in mp_dmabuf_devmem_uninstall() argument 532 if (bound_rxq == rxq) { in mp_dmabuf_devmem_uninstall()
|