Home
last modified time | relevance | path

Searched refs:qid (Results 1 – 25 of 184) sorted by relevance

12345678

/dpdk/drivers/event/sw/
H A Dsw_evdev_scheduler.c46 uint32_t qid_id = qid->id; in sw_schedule_atomic_to_cq()
57 if (qid->cq_next_tx >= qid->cq_num_mapped_cqs) in sw_schedule_atomic_to_cq()
58 qid->cq_next_tx = 0; in sw_schedule_atomic_to_cq()
97 qid->stats.tx_pkts++; in sw_schedule_atomic_to_cq()
98 qid->to_port[cq]++; in sw_schedule_atomic_to_cq()
162 qid->stats.tx_pkts++; in sw_schedule_parallel_to_cq()
224 int type = qid->type; in sw_schedule_qid_to_cq()
287 entry = &qid->reorder_buffer[qid->reorder_buffer_index]; in sw_schedule_reorder()
333 qid->reorder_buffer_index %= qid->window_size; in sw_schedule_reorder()
445 qid->stats.rx_pkts++; in __pull_port_lb()
[all …]
H A Dsw_evdev.c206 p->hist_list[i].qid = -1; in sw_port_setup()
240 qid->fids[i] = fid; in qid_init()
242 qid->id = idx; in qid_init()
243 qid->type = type; in qid_init()
295 qid->cq_next_tx = 0; in qid_init()
298 qid->initialized = 1; in qid_init()
326 memset(qid, 0, sizeof(*qid)); in sw_queue_release()
362 if (!qid->initialized) in sw_init_qid_iqs()
470 if (!qid->iq[j].head) in sw_clean_qid_iqs()
717 qid->stats.rx_pkts, qid->stats.rx_dropped, in sw_dump()
[all …]
H A Dsw_evdev_xstats.c111 case rx: return qid->stats.rx_pkts; in get_qid_stat()
119 infl += qid->fids[i].pcount; in get_qid_stat()
153 if (qid->fids[i].cq == port) in get_qid_port_stat()
159 return qid->to_port[port]; in get_qid_port_stat()
324 for (qid = 0; qid < sw->qid_count; qid++) { in sw_xstats_init()
331 .obj_idx = qid, in sw_xstats_init()
337 qid, qid_stats[i]); in sw_xstats_init()
343 .obj_idx = qid, in sw_xstats_init()
351 qid, iq, in sw_xstats_init()
359 .obj_idx = qid, in sw_xstats_init()
[all …]
/dpdk/lib/latencystats/
H A Drte_latencystats.c120 uint16_t qid __rte_unused, in add_time_stamps()
153 uint16_t qid __rte_unused, in calc_latency()
216 uint16_t qid; in rte_latencystats_init() local
273 for (qid = 0; qid < dev_info.nb_rx_queues; qid++) { in rte_latencystats_init()
274 cbs = &rx_cbs[pid][qid]; in rte_latencystats_init()
280 "qid=%d\n", pid, qid); in rte_latencystats_init()
282 for (qid = 0; qid < dev_info.nb_tx_queues; qid++) { in rte_latencystats_init()
283 cbs = &tx_cbs[pid][qid]; in rte_latencystats_init()
299 uint16_t qid; in rte_latencystats_uninit() local
317 for (qid = 0; qid < dev_info.nb_rx_queues; qid++) { in rte_latencystats_uninit()
[all …]
/dpdk/drivers/dma/idxd/
H A Didxd_pci.c26 uint16_t qid = idxd->qid; in idxd_pci_dev_command() local
30 qid = (1 << qid); in idxd_pci_dev_command()
78 idxd->qid, err_code); in idxd_pci_dev_stop()
93 IDXD_PMD_WARN("WQ %d already enabled", idxd->qid); in idxd_pci_dev_start()
105 idxd->qid, err_code); in idxd_pci_dev_start()
108 IDXD_PMD_DEBUG("Work queue %d enabled OK", idxd->qid); in idxd_pci_dev_start()
284 int qid, ret = 0; in idxd_dmadev_probe_pci() local
315 for (qid = 0; qid < nb_wqs; qid++) { in idxd_dmadev_probe_pci()
320 idxd.qid = qid; in idxd_dmadev_probe_pci()
322 qid * IDXD_PORTAL_SIZE); in idxd_dmadev_probe_pci()
[all …]
H A Didxd_internal.h72 uint8_t qid; member
92 int idxd_enqueue_copy(void *dev_private, uint16_t qid, rte_iova_t src,
94 int idxd_enqueue_fill(void *dev_private, uint16_t qid, uint64_t pattern,
96 int idxd_submit(void *dev_private, uint16_t qid);
97 uint16_t idxd_completed(void *dev_private, uint16_t qid, uint16_t max_ops,
99 uint16_t idxd_completed_status(void *dev_private, uint16_t qid __rte_unused,
/dpdk/drivers/raw/ioat/
H A Didxd_pci.c26 uint16_t qid = idxd->qid; in idxd_pci_dev_command() local
30 qid = (1 << qid); in idxd_pci_dev_command()
76 idxd->qid, err_code); in idxd_pci_dev_stop()
89 IOAT_PMD_WARN("WQ %d already enabled", idxd->qid); in idxd_pci_dev_start()
101 idxd->qid, err_code); in idxd_pci_dev_start()
105 IOAT_PMD_DEBUG("Work queue %d enabled OK", idxd->qid); in idxd_pci_dev_start()
255 int qid, ret = 0; in idxd_rawdev_probe_pci() local
281 for (qid = 0; qid < nb_wqs; qid++) { in idxd_rawdev_probe_pci()
286 idxd.qid = qid; in idxd_rawdev_probe_pci()
288 qid * IDXD_PORTAL_SIZE); in idxd_rawdev_probe_pci()
[all …]
/dpdk/drivers/common/cnxk/
H A Droc_nix_stats.c76 if (qid >= nb_queues) in queue_is_valid()
89 reg = (((uint64_t)qid) << 32); in qstat_read()
130 aq->qidx = qid; in nix_stat_rx_queue_reset()
152 aq->qidx = qid; in nix_stat_rx_queue_reset()
186 aq->qidx = qid; in nix_stat_tx_queue_reset()
205 aq->qidx = qid; in nix_stat_tx_queue_reset()
233 rc = queue_is_valid(nix, qid, is_rx); in roc_nix_stats_queue_get()
238 nix_stat_rx_queue_get(nix, qid, qstats); in roc_nix_stats_queue_get()
252 rc = queue_is_valid(nix, qid, is_rx); in roc_nix_stats_queue_reset()
257 rc = nix_stat_rx_queue_reset(nix, qid); in roc_nix_stats_queue_reset()
[all …]
H A Droc_nix_queue.c60 aq->qidx = rq->qid; in nix_rq_ena_dis()
73 aq->qidx = rq->qid; in nix_rq_ena_dis()
107 aq->qidx = rq->qid; in nix_rq_cn9k_cfg()
129 aq->rq.cq = rq->qid; in nix_rq_cn9k_cfg()
225 aq->qidx = rq->qid; in nix_rq_cfg()
717 aq->qidx = sq->qid; in sq_cn9k_init()
766 aq->qidx = sq->qid; in sq_cn9k_fini()
782 aq->qidx = sq->qid; in sq_cn9k_fini()
955 qid = sq->qid; in roc_nix_sq_init()
1016 uint16_t qid; in roc_nix_sq_fini() local
[all …]
H A Droc_nix_tm.c529 uint16_t qid = sq->qid; in roc_nix_tm_sq_flush_spin() local
596 uint16_t qid; in nix_tm_sq_flush_pre() local
606 qid = sq->qid; in nix_tm_sq_flush_pre()
655 qid = sibling->id; in nix_tm_sq_flush_pre()
656 sq = nix->sqs[qid]; in nix_tm_sq_flush_pre()
708 uint16_t qid, s_qid; in nix_tm_sq_flush_post() local
718 qid = sq->qid; in nix_tm_sq_flush_post()
734 if (sibling->id == qid) in nix_tm_sq_flush_post()
793 qid, smq, rr_quantum); in nix_tm_sq_sched_conf()
805 aq->qidx = qid; in nix_tm_sq_sched_conf()
[all …]
/dpdk/drivers/net/failsafe/
H A Dfailsafe_intr.c271 uint16_t qid; in failsafe_eth_rx_intr_ctl_subdevice() local
299 for (qid = 0; qid < dev->data->nb_rx_queues; qid++) { in failsafe_eth_rx_intr_ctl_subdevice()
300 fsrxq = fsdev->data->rx_queues[qid]; in failsafe_eth_rx_intr_ctl_subdevice()
306 pid, qid, epfd, rc); in failsafe_eth_rx_intr_ctl_subdevice()
326 int qid; in failsafe_rx_intr_install_subdevice() local
340 for (qid = 0; qid < ETH(sdev)->data->nb_rx_queues; qid++) { in failsafe_rx_intr_install_subdevice()
341 if (rxq[qid]->enable_events) { in failsafe_rx_intr_install_subdevice()
343 qid); in failsafe_rx_intr_install_subdevice()
366 int qid; in failsafe_rx_intr_uninstall_subdevice() local
371 for (qid = 0; qid < ETH(sdev)->data->nb_rx_queues; qid++) { in failsafe_rx_intr_uninstall_subdevice()
[all …]
/dpdk/drivers/net/sfc/
H A Dsfc_sw_stats.c254 unsigned int qid; in sfc_sw_stat_get_names() local
275 for (qid = 0; qid < nb_queues; ++qid) { in sfc_sw_stat_get_names()
379 unsigned int qid; in sfc_sw_xstat_get_values() local
402 for (qid = 0; qid < nb_queues; ++qid) { in sfc_sw_xstat_get_values()
433 unsigned int i, qid; in sfc_sw_xstat_get_values_by_id() local
459 qid = ids[i] - id_base_q; in sfc_sw_xstat_get_values_by_id()
469 for (qid = 0; qid < nb_queues; ++qid) { in sfc_sw_xstat_get_values_by_id()
474 qid); in sfc_sw_xstat_get_values_by_id()
624 unsigned int qid; in sfc_sw_xstat_reset() local
643 for (qid = 0; qid < nb_queues; ++qid) { in sfc_sw_xstat_reset()
[all …]
/dpdk/drivers/net/cnxk/
H A Dcnxk_ethdev.c438 sq = &dev->sqs[qid]; in cnxk_nix_tx_queue_setup()
439 sq->qid = qid; in cnxk_nix_tx_queue_setup()
459 txq_sp->qid = qid; in cnxk_nix_tx_queue_setup()
495 sq = &dev->sqs[qid]; in cnxk_nix_tx_queue_release()
555 cq = &dev->cqs[qid]; in cnxk_nix_rx_queue_setup()
556 cq->qid = qid; in cnxk_nix_rx_queue_setup()
565 rq = &dev->rqs[qid]; in cnxk_nix_rx_queue_setup()
566 rq->qid = qid; in cnxk_nix_rx_queue_setup()
601 rxq_sp->qid = qid; in cnxk_nix_rx_queue_setup()
667 rq = &dev->rqs[qid]; in cnxk_nix_rx_queue_release()
[all …]
H A Dcn9k_ethdev.c138 uint16_t qid) in nix_form_default_desc() argument
163 send_hdr_w0.sq = qid; in nix_form_default_desc()
189 sq = &dev->sqs[qid]; in cn9k_nix_tx_queue_setup()
191 txq = eth_dev->data->tx_queues[qid]; in cn9k_nix_tx_queue_setup()
200 crypto_qid = qid % dev->outb.nb_crypto_qs; in cn9k_nix_tx_queue_setup()
215 nix_form_default_desc(dev, txq, qid); in cn9k_nix_tx_queue_setup()
245 if (!qid) { in cn9k_nix_rx_queue_setup()
255 rq = &dev->rqs[qid]; in cn9k_nix_rx_queue_setup()
256 cq = &dev->cqs[qid]; in cn9k_nix_rx_queue_setup()
259 rxq = eth_dev->data->rx_queues[qid]; in cn9k_nix_rx_queue_setup()
[all …]
H A Dcn10k_ethdev.c138 uint16_t qid) in nix_form_default_desc() argument
163 send_hdr_w0.sq = qid; in nix_form_default_desc()
190 sq = &dev->sqs[qid]; in cn10k_nix_tx_queue_setup()
192 txq = eth_dev->data->tx_queues[qid]; in cn10k_nix_tx_queue_setup()
202 crypto_qid = qid % dev->outb.nb_crypto_qs; in cn10k_nix_tx_queue_setup()
221 nix_form_default_desc(dev, txq, qid); in cn10k_nix_tx_queue_setup()
252 if (!qid) { in cn10k_nix_rx_queue_setup()
262 rq = &dev->rqs[qid]; in cn10k_nix_rx_queue_setup()
263 cq = &dev->cqs[qid]; in cn10k_nix_rx_queue_setup()
266 rxq = eth_dev->data->rx_queues[qid]; in cn10k_nix_rx_queue_setup()
[all …]
H A Dcnxk_ethdev_ops.c230 cq = &dev->cqs[qid]; in nix_fc_cq_config_set()
235 fc_cfg.cq_cfg.rq = qid; in nix_fc_cq_config_set()
294 rc = nix_fc_cq_config_set(dev, rxq->qid, !!tx_pause); in cnxk_nix_flow_ctrl_set()
309 fc_cfg.tm_cfg.sq = txq->qid; in cnxk_nix_flow_ctrl_set()
722 void *rxq = eth_dev->data->rx_queues[qid]; in cnxk_nix_rxq_info_get()
738 void *txq = eth_dev->data->tx_queues[qid]; in cnxk_nix_txq_info_get()
1080 cq = &dev->cqs[rxq->qid]; in nix_priority_flow_ctrl_configure()
1084 fc_cfg.cq_cfg.rq = cq->qid; in nix_priority_flow_ctrl_configure()
1117 sq = &dev->sqs[txq->qid]; in nix_priority_flow_ctrl_configure()
1120 fc_cfg.tm_cfg.sq = sq->qid; in nix_priority_flow_ctrl_configure()
[all …]
/dpdk/lib/pdump/
H A Drte_pdump.c176 uint16_t qid; in pdump_register_rx_callbacks() local
179 for (; qid < end_q; qid++) { in pdump_register_rx_callbacks()
180 struct pdump_rxtx_cbs *cbs = &rx_cbs[port][qid]; in pdump_register_rx_callbacks()
186 port, qid); in pdump_register_rx_callbacks()
209 port, qid); in pdump_register_rx_callbacks()
234 uint16_t qid; in pdump_register_tx_callbacks() local
237 for (; qid < end_q; qid++) { in pdump_register_tx_callbacks()
244 port, qid); in pdump_register_tx_callbacks()
267 port, qid); in pdump_register_tx_callbacks()
712 uint16_t qid; in pdump_sum_stats() local
[all …]
/dpdk/drivers/vdpa/sfc/
H A Dsfc_vdpa_filter.c30 int qid, uint8_t *eth_addr) in sfc_vdpa_set_mac_filter() argument
39 spec->efs_dmaq_id = qid; in sfc_vdpa_set_mac_filter()
60 int qid; in sfc_vdpa_filter_config() local
87 qid = SFC_VDPA_GET_VI_INDEX(0); in sfc_vdpa_filter_config()
94 rc = sfc_vdpa_set_mac_filter(nic, spec, qid, in sfc_vdpa_filter_config()
106 rc = sfc_vdpa_set_mac_filter(nic, spec, qid, in sfc_vdpa_filter_config()
117 rc = sfc_vdpa_set_mac_filter(nic, spec, qid, NULL); in sfc_vdpa_filter_config()
/dpdk/drivers/vdpa/ifc/
H A Difcvf_vdpa.c433 uint32_t qid, q_num; in notify_relay() local
452 for (qid = 0; qid < q_num; qid++) { in notify_relay()
472 qid = events[i].data.u32; in notify_relay()
488 ifcvf_notify_queue(hw, qid); in notify_relay()
707 rte_vdpa_relay_vring_used(internal->vid, qid, &internal->m_vring[qid]); in update_used_ring()
717 uint16_t qid, q_num; in vring_relay() local
735 for (qid = 0; qid < q_num; qid++) { in vring_relay()
745 for (qid = 0; qid < q_num; qid += 2) { in vring_relay()
748 ev.data.u64 = 1 | qid << 1 | in vring_relay()
759 for (qid = 0; qid < q_num; qid++) in vring_relay()
[all …]
/dpdk/lib/vhost/
H A Dvdpa_driver.h60 int (*get_notify_area)(int vid, int qid,
69 int (*get_stats)(struct rte_vdpa_device *dev, int qid,
73 int (*reset_stats)(struct rte_vdpa_device *dev, int qid);
131 rte_vhost_host_notifier_ctrl(int vid, uint16_t qid, bool enable);
149 rte_vdpa_relay_vring_used(int vid, uint16_t qid, void *vring_m);
H A Drte_vdpa.h126 rte_vdpa_relay_vring_used(int vid, uint16_t qid, void *vring_m);
176 rte_vdpa_get_stats(struct rte_vdpa_device *dev, uint16_t qid,
189 rte_vdpa_reset_stats(struct rte_vdpa_device *dev, uint16_t qid);
H A Dvdpa.c132 rte_vdpa_relay_vring_used(int vid, uint16_t qid, void *vring_m) in rte_vdpa_relay_vring_used() argument
148 if (qid >= dev->nr_vring) in rte_vdpa_relay_vring_used()
155 vq = dev->virtqueue[qid]; in rte_vdpa_relay_vring_used()
275 rte_vdpa_get_stats(struct rte_vdpa_device *dev, uint16_t qid, in rte_vdpa_get_stats() argument
283 return dev->ops->get_stats(dev, qid, stats, n); in rte_vdpa_get_stats()
287 rte_vdpa_reset_stats(struct rte_vdpa_device *dev, uint16_t qid) in rte_vdpa_reset_stats() argument
294 return dev->ops->reset_stats(dev, qid); in rte_vdpa_reset_stats()
/dpdk/drivers/event/opdl/
H A Dopdl_test.c42 uint8_t qid[MAX_QIDS]; member
164 t->qid[i] = i; in create_queues_type()
256 ev.queue_id = t->qid[0]; in ordered_basic()
297 deq_ev[i].queue_id = t->qid[1]; in ordered_basic()
395 ev.queue_id = t->qid[0]; in atomic_basic()
592 t->qid[0]); in single_link_w_stats()
603 t->qid[1]); in single_link_w_stats()
625 ev.queue_id = t->qid[0]; in single_link_w_stats()
656 deq_ev[i].queue_id = t->qid[1]; in single_link_w_stats()
755 uint8_t qid, in populate_event_burst() argument
[all …]
/dpdk/lib/ethdev/
H A Dethdev_private.c351 eth_dev_rxq_release(struct rte_eth_dev *dev, uint16_t qid) in eth_dev_rxq_release() argument
355 if (rxq[qid] == NULL) in eth_dev_rxq_release()
359 (*dev->dev_ops->rx_queue_release)(dev, qid); in eth_dev_rxq_release()
360 rxq[qid] = NULL; in eth_dev_rxq_release()
364 eth_dev_txq_release(struct rte_eth_dev *dev, uint16_t qid) in eth_dev_txq_release() argument
368 if (txq[qid] == NULL) in eth_dev_txq_release()
372 (*dev->dev_ops->tx_queue_release)(dev, qid); in eth_dev_txq_release()
373 txq[qid] = NULL; in eth_dev_txq_release()
/dpdk/app/test/
H A Dtest_event_crypto_adapter.c630 uint8_t qid; in configure_eventdev() local
658 qid = TEST_APP_EV_QUEUE_ID; in configure_eventdev()
659 ret = rte_event_queue_setup(evdev, qid, NULL); in configure_eventdev()
660 TEST_ASSERT_SUCCESS(ret, "Failed to setup queue=%d\n", qid); in configure_eventdev()
668 qid = TEST_CRYPTO_EV_QUEUE_ID; in configure_eventdev()
669 ret = rte_event_queue_setup(evdev, qid, &queue_conf); in configure_eventdev()
682 qid = TEST_APP_EV_QUEUE_ID; in configure_eventdev()
827 uint8_t qid; in test_crypto_adapter_conf() local
835 qid = TEST_CRYPTO_EV_QUEUE_ID; in test_crypto_adapter_conf()
837 params.crypto_event_port_id, &qid, NULL, 1); in test_crypto_adapter_conf()
[all …]

12345678