Home
last modified time | relevance | path

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

123

/dpdk/drivers/net/enic/base/
H A Dvnic_rq.c14 vdev = rq->vdev; in vnic_rq_free()
18 rq->ctrl = NULL; in vnic_rq_free()
28 rq->index = index; in vnic_rq_alloc()
29 rq->vdev = vdev; in vnic_rq_alloc()
32 if (!rq->ctrl) { in vnic_rq_alloc()
37 vnic_rq_disable(rq); in vnic_rq_alloc()
41 rq->socket_id, res_name); in vnic_rq_alloc()
87 rq->rxst_idx = 0; in vnic_rq_init()
88 rq->tot_pkts = 0; in vnic_rq_init()
90 rq->pkt_last_seg = NULL; in vnic_rq_init()
[all …]
H A Dvnic_rq.h81 return rq->ring.desc_avail; in vnic_rq_desc_avail()
87 return rq->ring.desc_count - rq->ring.desc_avail - 1; in vnic_rq_desc_used()
97 static inline int vnic_rq_fill(struct vnic_rq *rq, in vnic_rq_fill() argument
98 int (*buf_fill)(struct vnic_rq *rq)) in vnic_rq_fill() argument
102 while (vnic_rq_desc_avail(rq) > 0) { in vnic_rq_fill()
104 err = (*buf_fill)(rq); in vnic_rq_fill()
119 err = (*buf_fill)(rq); in vnic_rq_fill_count()
127 void vnic_rq_free(struct vnic_rq *rq);
139 void vnic_rq_enable(struct vnic_rq *rq);
140 int vnic_rq_disable(struct vnic_rq *rq);
[all …]
/dpdk/drivers/common/cnxk/
H A Droc_nix_queue.c114 aq->rq.sso_tt = rq->tt; in nix_rq_cn9k_cfg()
115 aq->rq.sso_grp = rq->hwgrp; in nix_rq_cn9k_cfg()
117 aq->rq.wqe_skip = rq->wqe_skip; in nix_rq_cn9k_cfg()
129 aq->rq.cq = rq->qid; in nix_rq_cn9k_cfg()
157 if (rq->red_pass && (rq->red_pass >= rq->red_drop)) { in nix_rq_cn9k_cfg()
202 if (rq->red_pass && (rq->red_pass >= rq->red_drop)) { in nix_rq_cn9k_cfg()
232 aq->rq.sso_tt = rq->tt; in nix_rq_cfg()
233 aq->rq.sso_grp = rq->hwgrp; in nix_rq_cfg()
256 aq->rq.cq = rq->qid; in nix_rq_cfg()
307 if (rq->red_pass && (rq->red_pass >= rq->red_drop)) { in nix_rq_cfg()
[all …]
H A Dcnxk_telemetry_nix.c107 node = nix_tel_node_get(rq->roc_nix); in nix_tel_node_add_rq()
111 node->rqs[rq->qid] = rq; in nix_tel_node_add_rq()
211 CNXK_TEL_DICT_INT(d, rq, qid); in cnxk_tel_nix_rq()
216 CNXK_TEL_DICT_INT(d, rq, lpb_size); in cnxk_tel_nix_rq()
217 CNXK_TEL_DICT_INT(d, rq, sso_ena); in cnxk_tel_nix_rq()
220 CNXK_TEL_DICT_INT(d, rq, tt); in cnxk_tel_nix_rq()
221 CNXK_TEL_DICT_INT(d, rq, hwgrp); in cnxk_tel_nix_rq()
227 CNXK_TEL_DICT_PTR(d, rq, roc_nix); in cnxk_tel_nix_rq()
781 int rq; in cnxk_nix_tel_handle_info_x() local
786 rq = strtol(tok, NULL, 10); in cnxk_nix_tel_handle_info_x()
[all …]
H A Droc_nix_inl.c591 int port_id = rq->roc_nix->port_id; in roc_nix_inl_dev_rq_get()
607 if (rq->inl_dev_refs) in roc_nix_inl_dev_rq_get()
617 rq->inl_dev_refs = 1; in roc_nix_inl_dev_rq_get()
627 inl_rq->lpb_size = rq->lpb_size; in roc_nix_inl_dev_rq_get()
629 inl_rq->spb_ena = rq->spb_ena; in roc_nix_inl_dev_rq_get()
631 inl_rq->spb_size = rq->spb_size; in roc_nix_inl_dev_rq_get()
679 inl_rq->tag_mask = rq->tag_mask; in roc_nix_inl_dev_rq_get()
702 rq->inl_dev_refs = 1; in roc_nix_inl_dev_rq_get()
710 int port_id = rq->roc_nix->port_id; in roc_nix_inl_dev_rq_put()
720 if (!rq->inl_dev_refs) in roc_nix_inl_dev_rq_put()
[all …]
H A Droc_nix_stats.c134 aq->rq.octs = 0; in nix_stat_rx_queue_reset()
135 aq->rq.pkts = 0; in nix_stat_rx_queue_reset()
136 aq->rq.drop_octs = 0; in nix_stat_rx_queue_reset()
137 aq->rq.drop_pkts = 0; in nix_stat_rx_queue_reset()
138 aq->rq.re_pkts = 0; in nix_stat_rx_queue_reset()
156 aq->rq.octs = 0; in nix_stat_rx_queue_reset()
157 aq->rq.pkts = 0; in nix_stat_rx_queue_reset()
158 aq->rq.drop_octs = 0; in nix_stat_rx_queue_reset()
159 aq->rq.drop_pkts = 0; in nix_stat_rx_queue_reset()
160 aq->rq.re_pkts = 0; in nix_stat_rx_queue_reset()
H A Droc_nix_debug.c339 *ctx_p = &rsp->rq; in nix_q_ctx_get()
361 *ctx_p = &rsp->rq; in nix_q_ctx_get()
664 int rc = -1, q, rq = nix->nb_rx_queues; in roc_nix_queues_ctx_dump() local
677 for (q = 0; q < rq; q++) { in roc_nix_queues_ctx_dump()
688 for (q = 0; q < rq; q++) { in roc_nix_queues_ctx_dump()
809 roc_nix_rq_dump(struct roc_nix_rq *rq) in roc_nix_rq_dump() argument
811 nix_dump("nix_rq@%p", rq); in roc_nix_rq_dump()
812 nix_dump(" qid = %d", rq->qid); in roc_nix_rq_dump()
818 nix_dump(" sso_ena = %d", rq->sso_ena); in roc_nix_rq_dump()
821 nix_dump(" tt = %d", rq->tt); in roc_nix_rq_dump()
[all …]
H A Droc_nix_irq.c182 nix_lf_rq_irq_get_and_clear(struct nix *nix, uint16_t rq) in nix_lf_rq_irq_get_and_clear() argument
184 return nix_lf_q_irq_get_and_clear(nix, rq, NIX_LF_RQ_OP_INT, ~0xff00); in nix_lf_rq_irq_get_and_clear()
254 int q, cq, rq, sq; in nix_lf_q_irq() local
267 rq = q % nix->qints; in nix_lf_q_irq()
268 irq = nix_lf_rq_irq_get_and_clear(nix, rq); in nix_lf_q_irq()
271 plt_err("RQ=%d NIX_RQINT_DROP", rq); in nix_lf_q_irq()
274 plt_err("RQ=%d NIX_RQINT_RED", rq); in nix_lf_q_irq()
H A Droc_nix_rss.c75 req->rss.rq = reta[idx]; in nix_cn9k_rss_reta_set()
96 req->rss.rq = reta[idx]; in nix_cn9k_rss_reta_set()
132 req->rss.rq = reta[idx]; in nix_rss_reta_set()
153 req->rss.rq = reta[idx]; in nix_rss_reta_set()
H A Droc_nix_priv.h396 int nix_rq_cn9k_cfg(struct dev *dev, struct roc_nix_rq *rq, uint16_t qints,
398 int nix_rq_cfg(struct dev *dev, struct roc_nix_rq *rq, uint16_t qints, bool cfg,
400 int nix_rq_ena_dis(struct dev *dev, struct roc_nix_rq *rq, bool enable);
404 void nix_rq_vwqe_flush(struct roc_nix_rq *rq, uint16_t vwqe_interval);
469 int nix_tel_node_add_rq(struct roc_nix_rq *rq);
/dpdk/drivers/net/ice/base/
H A Dice_controlq.c124 cq->rq.desc_buf.va = ice_alloc_dma_mem(hw, &cq->rq.desc_buf, size); in ice_alloc_ctrlq_rq_ring()
158 if (!cq->rq.dma_head) in ice_alloc_rq_bufs()
160 cq->rq.r.rq_bi = (struct ice_dma_mem *)cq->rq.dma_head; in ice_alloc_rq_bufs()
200 cq->rq.r.rq_bi = NULL; in ice_alloc_rq_bufs()
202 cq->rq.dma_head = NULL; in ice_alloc_rq_bufs()
524 if (!cq->rq.count) { in ice_shutdown_rq()
537 cq->rq.count = 0; in ice_shutdown_rq()
1088 if (rd32(hw, cq->rq.len) & cq->rq.len_crit_mask || in ice_sq_send_cmd_nolock()
1178 if (!cq->rq.count) { in ice_clean_rq_elem()
1185 ntu = (u16)(rd32(hw, cq->rq.head) & cq->rq.head_mask); in ice_clean_rq_elem()
[all …]
/dpdk/drivers/net/enic/
H A Denic_rxtx.c40 struct vnic_rq *rq; in enic_recv_pkts_common() local
106 rq = &enic->rq[rq_num]; in enic_recv_pkts_common()
145 if (rq->is_sop) { in enic_recv_pkts_common()
158 rq->rx_nb_hold++; in enic_recv_pkts_common()
254 struct vnic_rq *rq; in enic_noscatter_recv_pkts() local
260 rq = rx_queue; in enic_noscatter_recv_pkts()
270 if (rte_mempool_get_bulk(rq->mp, (void **)rq->free_mbufs, in enic_noscatter_recv_pkts()
335 memcpy(rxmb, rq->free_mbufs + ENIC_RX_BURST_MAX - rq->num_free_mbufs, in enic_noscatter_recv_pkts()
345 if (rq->rx_nb_hold > rq->rx_free_thresh) { in enic_noscatter_recv_pkts()
346 rq->posted_index = enic_ring_add(rq->ring.desc_count, in enic_noscatter_recv_pkts()
[all …]
H A Denic_main.c59 if (!rq || !rq->mbuf_ring) { in enic_rxmbuf_queue_release()
341 if (!rq->in_use || !rq->need_initial_post) in enic_initial_post_rx()
348 rq->posted_index = rq->ring.desc_count - 1; in enic_initial_post_rx()
353 enic->port_id, rq->index, rq->posted_index, rq->rx_nb_hold); in enic_initial_post_rx()
354 iowrite32(rq->posted_index, &rq->ctrl->posted_index); in enic_initial_post_rx()
1655 rq = &enic->rq[rq_idx]; in enic_set_mtu()
1656 if (rq->is_sop && rq->in_use) { in enic_set_mtu()
1679 rq = &enic->rq[enic_rte_rq_idx_to_sop_idx(rq_idx)]; in enic_set_mtu()
1685 rq->tot_nb_desc, rq->rx_free_thresh); in enic_set_mtu()
1708 rq = &enic->rq[enic_rte_rq_idx_to_sop_idx(rq_idx)]; in enic_set_mtu()
[all …]
H A Denic_rxtx_vec_avx2.c48 struct vnic_rq *rq; in enic_noscatter_vec_recv_pkts() local
52 rq = rx_queue; in enic_noscatter_vec_recv_pkts()
61 if (rq->num_free_mbufs == 0) { in enic_noscatter_vec_recv_pkts()
62 if (rte_mempool_get_bulk(rq->mp, (void **)rq->free_mbufs, in enic_noscatter_vec_recv_pkts()
779 rq->rx_nb_hold += nb_rx; in enic_noscatter_vec_recv_pkts()
787 memcpy(rxmb, rq->free_mbufs + ENIC_RX_BURST_MAX - rq->num_free_mbufs, in enic_noscatter_vec_recv_pkts()
796 if (rq->rx_nb_hold > rq->rx_free_thresh) { in enic_noscatter_vec_recv_pkts()
797 rq->posted_index = enic_ring_add(rq->ring.desc_count, in enic_noscatter_vec_recv_pkts()
798 rq->posted_index, in enic_noscatter_vec_recv_pkts()
799 rq->rx_nb_hold); in enic_noscatter_vec_recv_pkts()
[all …]
H A Denic_vf_representor.c103 (void *)&pf->rq[vf->pf_rq_sop_idx]; in enic_vf_dev_rx_queue_setup()
215 vnic_rq_init(&pf->rq[index], cq_idx, 1, 0); in enic_vf_dev_start()
216 data_rq = &pf->rq[vf->pf_rq_data_idx]; in enic_vf_dev_start()
252 struct vnic_rq *rq; in enic_vf_dev_stop() local
265 rq = &pf->rq[vf->pf_rq_sop_idx]; in enic_vf_dev_stop()
266 vnic_rq_disable(rq); in enic_vf_dev_stop()
267 vnic_rq_clean(rq, enic_free_rq_buf); in enic_vf_dev_stop()
268 rq = &pf->rq[vf->pf_rq_data_idx]; in enic_vf_dev_stop()
269 if (rq->in_use) { in enic_vf_dev_stop()
270 vnic_rq_disable(rq); in enic_vf_dev_stop()
[all …]
H A Denic.h144 struct vnic_rq *rq; member
279 static inline unsigned int enic_cq_rq(__rte_unused struct enic *enic, unsigned int rq) in enic_cq_rq() argument
281 return rq; in enic_cq_rq()
445 int enic_alloc_rx_queue_mbufs(struct enic *enic, struct vnic_rq *rq);
446 void enic_rxmbuf_queue_release(struct enic *enic, struct vnic_rq *rq);
/dpdk/drivers/event/cnxk/
H A Dcnxk_eventdev_adptr.c127 struct roc_nix_rq *rq; in cnxk_sso_rxq_enable() local
131 rq->sso_ena = 1; in cnxk_sso_rxq_enable()
135 rq->wqe_skip = 1; in cnxk_sso_rxq_enable()
168 struct roc_nix_rq *rq; in cnxk_sso_rxq_disable() local
171 rq->sso_ena = 0; in cnxk_sso_rxq_disable()
173 rq->tag_mask = 0; in cnxk_sso_rxq_disable()
183 struct roc_nix_rq *rq; in cnxk_sso_rx_adapter_vwqe_enable() local
187 if (!rq->sso_ena) in cnxk_sso_rx_adapter_vwqe_enable()
192 rq->vwqe_ena = 1; in cnxk_sso_rx_adapter_vwqe_enable()
196 rq->vwqe_wait_tmo = in cnxk_sso_rx_adapter_vwqe_enable()
[all …]
/dpdk/drivers/common/mlx5/
H A Dmlx5_common_devx.c424 if (rq->rq) { in mlx5_devx_rq_destroy()
425 claim_zero(mlx5_devx_cmd_destroy(rq->rq)); in mlx5_devx_rq_destroy()
426 rq->rq = NULL; in mlx5_devx_rq_destroy()
427 if (rq->rmp) in mlx5_devx_rq_destroy()
428 rq->rmp->ref_cnt--; in mlx5_devx_rq_destroy()
430 if (rq->rmp == NULL) { in mlx5_devx_rq_destroy()
539 struct mlx5_devx_obj *rq; in mlx5_devx_rq_std_create() local
548 if (!rq) { in mlx5_devx_rq_std_create()
553 rq_obj->rq = rq; in mlx5_devx_rq_std_create()
651 if (!rq) { in mlx5_devx_rq_shared_create()
[all …]
H A Dmlx5_common_devx.h64 struct mlx5_devx_obj *rq; /* The RQ DevX object. */ member
96 void mlx5_devx_rq_destroy(struct mlx5_devx_rq *rq);
/dpdk/drivers/net/thunderx/base/
H A Dnicvf_mbox.c279 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_config()
280 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_config()
281 mbx.rq.cfg = pf_rq_cfg->value; in nicvf_mbox_rq_config()
343 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_drop_config()
344 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_drop_config()
345 drop_cfg = (struct pf_rq_drop_cfg *)&mbx.rq.cfg; in nicvf_mbox_rq_drop_config()
372 mbx.rq.cfg = 0; in nicvf_mbox_rq_sync()
382 mbx.rq.qs_num = nic->vf_id; in nicvf_mbox_rq_bp_config()
383 mbx.rq.rq_num = qidx; in nicvf_mbox_rq_bp_config()
384 mbx.rq.cfg = 0; in nicvf_mbox_rq_bp_config()
[all …]
/dpdk/drivers/net/hinic/base/
H A Dhinic_pmd_nicio.c209 static void hinic_rq_prepare_ctxt(struct hinic_rq *rq, in hinic_rq_prepare_ctxt() argument
212 struct hinic_wq *wq = rq->wq; in hinic_rq_prepare_ctxt()
238 RQ_CTXT_PI_SET(rq->msix_entry_idx, INTR) | in hinic_rq_prepare_ctxt()
363 hinic_rq_prepare_ctxt(&qp->rq, &rq_ctxt[i]); in init_rq_ctxts()
723 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_get_rq_wqe() local
725 return hinic_get_wqe(rq->wq, 1, pi); in hinic_get_rq_wqe()
731 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_return_rq_wqe() local
733 rq->wq->delta += num_wqebbs; in hinic_return_rq_wqe()
734 rq->wq->prod_idx -= num_wqebbs; in hinic_return_rq_wqe()
748 struct hinic_rq *rq = &nic_io->qps[q_id].rq; in hinic_update_rq_local_ci() local
[all …]
/dpdk/drivers/net/cnxk/
H A Dcnxk_ethdev.c190 struct roc_nix_rq *rq; in nix_meter_fini() local
515 struct roc_nix_rq *rq; in cnxk_nix_rx_queue_setup() local
565 rq = &dev->rqs[qid]; in cnxk_nix_rx_queue_setup()
566 rq->qid = qid; in cnxk_nix_rx_queue_setup()
568 rq->flow_tag_width = 32; in cnxk_nix_rx_queue_setup()
569 rq->sso_ena = false; in cnxk_nix_rx_queue_setup()
582 rq->ipsech_ena = true; in cnxk_nix_rx_queue_setup()
613 rq->tag_mask = in cnxk_nix_rx_queue_setup()
658 struct roc_nix_rq *rq; in cnxk_nix_rx_queue_release() local
667 rq = &dev->rqs[qid]; in cnxk_nix_rx_queue_release()
[all …]
/dpdk/drivers/net/hinic/
H A Dhinic_pmd_rx.c218 struct hinic_rq *rq = &qp->rq; in hinic_create_rq() local
221 rq->msix_entry_idx = 1; in hinic_create_rq()
222 rq->q_id = q_id; in hinic_create_rq()
223 rq->rq_depth = rq_depth; in hinic_create_rq()
232 rq->wq = &nic_io->rq_wq[q_id]; in hinic_create_rq()
236 if (!rq->pi_virt_addr) { in hinic_create_rq()
254 struct hinic_rq *rq = &qp->rq; in hinic_destroy_rq() local
256 if (qp->rq.wq == NULL) in hinic_destroy_rq()
260 (volatile void *)rq->pi_virt_addr, in hinic_destroy_rq()
261 rq->pi_dma_addr); in hinic_destroy_rq()
[all …]
/dpdk/drivers/net/mlx5/
H A Dmlx5_devx.c51 return mlx5_devx_cmd_modify_rq(rxq->devx_rq.rq, &rq_attr); in mlx5_rxq_obj_modify_rq_vlan_strip()
166 if (rxq_obj->rq == NULL) in mlx5_rxq_devx_obj_release()
169 claim_zero(mlx5_devx_cmd_destroy(rxq_obj->rq)); in mlx5_rxq_devx_obj_release()
171 if (rxq->devx_rq.rq == NULL) in mlx5_rxq_devx_obj_release()
448 if (!tmpl->rq) { in mlx5_rxq_obj_hairpin_new()
526 rxq_ctrl->wqn = rxq->devx_rq.rq->id; in mlx5_rxq_devx_obj_new()
579 priv->drop_queue.rxq->devx_rq.rq->id; in mlx5_devx_ind_table_create_rqt_attr()
594 rqt_attr->rq_list[i] = rxq->ctrl->obj->rq->id; in mlx5_devx_ind_table_create_rqt_attr()
596 rqt_attr->rq_list[i] = rxq->devx_rq.rq->id; in mlx5_devx_ind_table_create_rqt_attr()
987 if (rxq != NULL && rxq->devx_rq.rq != NULL) in mlx5_rxq_devx_obj_drop_create()
[all …]
/dpdk/drivers/net/vmxnet3/
H A Dvmxnet3_rxtx.c187 vmxnet3_rx_queue_t *rq = dev->data->rx_queues[qid]; in vmxnet3_dev_rx_queue_release() local
189 if (rq != NULL) { in vmxnet3_dev_rx_queue_release()
196 vmxnet3_cmd_ring_release(&rq->cmd_ring[i]); in vmxnet3_dev_rx_queue_release()
199 rte_memzone_free(rq->mz); in vmxnet3_dev_rx_queue_release()
202 rte_free(rq); in vmxnet3_dev_rx_queue_release()
238 vmxnet3_rx_queue_t *rq = rxq; in vmxnet3_dev_rx_queue_reset() local
239 struct vmxnet3_hw *hw = rq->hw; in vmxnet3_dev_rx_queue_reset()
249 ring0 = &rq->cmd_ring[0]; in vmxnet3_dev_rx_queue_reset()
250 ring1 = &rq->cmd_ring[1]; in vmxnet3_dev_rx_queue_reset()
251 comp_ring = &rq->comp_ring; in vmxnet3_dev_rx_queue_reset()
[all …]

123