Home
last modified time | relevance | path

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

/dpdk/lib/rcu/
H A Drte_rcu_qsbr.c307 if (dq == NULL) { in rte_rcu_qsbr_dq_create()
330 if (dq->r == NULL) { in rte_rcu_qsbr_dq_create()
333 rte_free(dq); in rte_rcu_qsbr_dq_create()
337 dq->v = params->v; in rte_rcu_qsbr_dq_create()
343 dq->p = params->p; in rte_rcu_qsbr_dq_create()
345 return dq; in rte_rcu_qsbr_dq_create()
377 rte_rcu_qsbr_dq_reclaim(dq, dq->max_reclaim_size, in rte_rcu_qsbr_dq_enqueue()
393 if (rte_ring_enqueue_elem(dq->r, data, dq->esize) != 0) { in rte_rcu_qsbr_dq_enqueue()
452 dq->free_fn(dq->p, dq_elem->elem, 1); in rte_rcu_qsbr_dq_reclaim()
474 if (dq == NULL) { in rte_rcu_qsbr_dq_delete()
[all …]
H A Drte_rcu_qsbr.h781 rte_rcu_qsbr_dq_enqueue(struct rte_rcu_qsbr_dq *dq, void *e);
810 rte_rcu_qsbr_dq_reclaim(struct rte_rcu_qsbr_dq *dq, unsigned int n,
836 rte_rcu_qsbr_dq_delete(struct rte_rcu_qsbr_dq *dq);
/dpdk/drivers/bus/fslmc/qbman/include/
H A Dfsl_qbman_portal.h210 struct dq { struct
223 } dq; member
510 struct qbman_result *dq);
549 return !qbman_result_is_DQ(dq); in qbman_result_is_SCN()
673 const struct qbman_result *dq) in qbman_result_DQ_is_pull_complete() argument
771 #define qbman_result_FQDAN_fqid(dq) qbman_result_SCN_rid(dq) argument
773 #define qbman_result_FQRN_fqid(dq) qbman_result_SCN_rid(dq) argument
775 #define qbman_result_FQRNI_fqid(dq) qbman_result_SCN_rid(dq) argument
777 #define qbman_result_FQPN_fqid(dq) qbman_result_SCN_rid(dq) argument
779 #define qbman_result_CDAN_cid(dq) ((uint16_t)qbman_result_SCN_rid(dq)) argument
[all …]
/dpdk/drivers/net/octeontx/base/
H A Docteontx_pkovf.c204 dq++; in octeontx_pko_dq_range_lookup()
206 dq++; in octeontx_pko_dq_range_lookup()
234 int dq; in octeontx_pko_dq_claim() local
239 if (dq < 0 || (unsigned int)dq != dq_base) { in octeontx_pko_dq_claim()
262 dq++; in octeontx_pko_dq_free()
302 dq = 0; in octeontx_pko_chan_start()
312 dq++; in octeontx_pko_chan_start()
320 dq++; in octeontx_pko_chan_start()
346 dq = 0; in octeontx_pko_chan_stop()
356 dq++; in octeontx_pko_chan_stop()
[all …]
H A Docteontx_pkovf.h68 typedef void (*octeontx_pko_dq_getter_t)(octeontx_dq_t *dq, void *out);
/dpdk/app/test/
H A Dtest_rcu_qsbr.c633 struct rte_rcu_qsbr_dq *dq; in test_rcu_qsbr_dq_create() local
678 rte_rcu_qsbr_dq_delete(dq); in test_rcu_qsbr_dq_create()
684 rte_rcu_qsbr_dq_delete(dq); in test_rcu_qsbr_dq_create()
700 struct rte_rcu_qsbr_dq *dq; in test_rcu_qsbr_dq_enqueue() local
728 ret = rte_rcu_qsbr_dq_delete(dq); in test_rcu_qsbr_dq_enqueue()
743 struct rte_rcu_qsbr_dq *dq; in test_rcu_qsbr_dq_reclaim() local
778 struct rte_rcu_qsbr_dq *dq; in test_rcu_qsbr_dq_delete() local
798 ret = rte_rcu_qsbr_dq_delete(dq); in test_rcu_qsbr_dq_delete()
814 struct rte_rcu_qsbr_dq *dq; in test_rcu_qsbr_dq_functional() local
891 ret = rte_rcu_qsbr_dq_delete(dq); in test_rcu_qsbr_dq_functional()
[all …]
/dpdk/drivers/bus/fslmc/qbman/
H A Dqbman_portal.c2224 if (dq->dq.tok == 0) in qbman_result_has_new_result()
2251 if (dq->dq.tok == 0) in qbman_check_new_result()
2268 if (dq->dq.tok == 0) in qbman_check_command_complete()
2271 s = portal_idx_map[dq->dq.tok - 1]; in qbman_check_command_complete()
2353 return dq->dq.stat; in qbman_result_DQ_flags()
2358 return dq->dq.seqnum; in qbman_result_DQ_seqnum()
2363 return dq->dq.oprid; in qbman_result_DQ_odpid()
2368 return dq->dq.fqid; in qbman_result_DQ_fqid()
2373 return dq->dq.fq_byte_cnt; in qbman_result_DQ_byte_count()
2378 return dq->dq.fq_frm_cnt; in qbman_result_DQ_frame_count()
[all …]
/dpdk/drivers/bus/dpaa/base/qbman/
H A Dqman.c1009 if (unlikely(!dq)) in __poll_portal_fast()
1018 *shadow = *dq; in __poll_portal_fast()
1019 dq = shadow; in __poll_portal_fast()
1274 if (!dq) in qman_portal_dequeue()
1284 *shadow = *dq; in qman_portal_dequeue()
1285 dq = shadow; in qman_portal_dequeue()
1299 dq, &bufs[rx_number]); in qman_portal_dequeue()
1334 dq = qm_dqrr_current(&p->p); in qman_dequeue()
1335 if (!dq) in qman_dequeue()
1348 *shadow = *dq; in qman_dequeue()
[all …]
H A Dqman.h610 const struct qm_dqrr_entry *dq, in qm_dqrr_cdc_consume_1ptr() argument
614 u8 idx = DQRR_PTR2IDX(dq); in qm_dqrr_cdc_consume_1ptr()
/dpdk/drivers/net/dpaa/
H A Ddpaa_rxtx.c600 void *ptr = rte_dpaa_mem_ptov(qm_fd_addr(&dq->fd)); in dpaa_rx_cb_prepare()
698 struct qm_dqrr_entry *dq; in dpaa_eth_err_queue() local
715 dq = qman_dequeue(debug_fq); in dpaa_eth_err_queue()
716 if (!dq) in dpaa_eth_err_queue()
718 fd = &dq->fd; in dpaa_eth_err_queue()
730 qman_dqrr_consume(debug_fq, dq); in dpaa_eth_err_queue()
741 struct qm_dqrr_entry *dq; in dpaa_eth_queue_rx() local
783 dq = qman_dequeue(fq); in dpaa_eth_queue_rx()
784 if (!dq) in dpaa_eth_queue_rx()
787 dpaa_display_frame_info(&dq->fd, fq->fqid, true); in dpaa_eth_queue_rx()
[all …]
H A Ddpaa_rxtx.h286 void dpaa_rx_cb_prepare(struct qm_dqrr_entry *dq, void **bufs);
/dpdk/drivers/event/dpaa2/
H A Ddpaa2_eventdev.c223 const struct qbman_result *dq, in dpaa2_eventdev_process_parallel() argument
235 qbman_swp_dqrr_consume(swp, dq); in dpaa2_eventdev_process_parallel()
240 const struct qbman_result *dq, in dpaa2_eventdev_process_atomic() argument
246 uint8_t dqrr_index = qbman_get_dqrr_idx(dq); in dpaa2_eventdev_process_atomic()
263 const struct qbman_result *dq; in dpaa2_eventdev_dequeue_burst() local
326 dq = qbman_swp_dqrr_next(swp); in dpaa2_eventdev_dequeue_burst()
327 if (!dq) { in dpaa2_eventdev_dequeue_burst()
337 fd = qbman_result_DQ_fd(dq); in dpaa2_eventdev_dequeue_burst()
338 rxq = (struct dpaa2_queue *)(size_t)qbman_result_DQ_fqd_ctx(dq); in dpaa2_eventdev_dequeue_burst()
340 rxq->cb(swp, fd, dq, rxq, &ev[num_pkts]); in dpaa2_eventdev_dequeue_burst()
[all …]
/dpdk/drivers/net/dpaa2/
H A Ddpaa2_ethdev.h247 const struct qbman_result *dq,
252 const struct qbman_result *dq,
257 const struct qbman_result *dq,
H A Ddpaa2_rxtx.c858 const struct qbman_result *dq, in dpaa2_dev_process_parallel_event() argument
875 qbman_swp_dqrr_consume(swp, dq); in dpaa2_dev_process_parallel_event()
881 const struct qbman_result *dq, in dpaa2_dev_process_atomic_event() argument
900 dqrr_index = qbman_get_dqrr_idx(dq); in dpaa2_dev_process_atomic_event()
910 const struct qbman_result *dq, in dpaa2_dev_process_ordered_event() argument
928 *dpaa2_seqn(ev->mbuf) |= qbman_result_DQ_odpid(dq) << DPAA2_EQCR_OPRID_SHIFT; in dpaa2_dev_process_ordered_event()
929 *dpaa2_seqn(ev->mbuf) |= qbman_result_DQ_seqnum(dq) << DPAA2_EQCR_SEQNUM_SHIFT; in dpaa2_dev_process_ordered_event()
931 qbman_swp_dqrr_consume(swp, dq); in dpaa2_dev_process_ordered_event()
/dpdk/drivers/net/octeontx/
H A Docteontx_rxtx.h440 octeontx_dq_t *dq = &txq->dq; in __octeontx_xmit_pkts() local
445 if (unlikely(*((volatile int64_t *)dq->fc_status_va) < 0)) in __octeontx_xmit_pkts()
456 octeontx_reg_lmtst(dq->lmtline_va, dq->ioreg_va, cmd_buf, in __octeontx_xmit_pkts()
H A Docteontx_ethdev.c884 octeontx_dq_info_getter(octeontx_dq_t *dq, void *out) in octeontx_dq_info_getter() argument
886 ((octeontx_dq_t *)out)->lmtline_va = dq->lmtline_va; in octeontx_dq_info_getter()
887 ((octeontx_dq_t *)out)->ioreg_va = dq->ioreg_va; in octeontx_dq_info_getter()
888 ((octeontx_dq_t *)out)->fc_status_va = dq->fc_status_va; in octeontx_dq_info_getter()
906 &txq->dq, in octeontx_vf_start_tx_queue()
1023 &txq->dq, in octeontx_dev_tx_queue_setup()
1033 qidx, txq->queue_id, txq, nb_desc, txq->dq.lmtline_va, in octeontx_dev_tx_queue_setup()
1034 txq->dq.ioreg_va, in octeontx_dev_tx_queue_setup()
1035 txq->dq.fc_status_va); in octeontx_dev_tx_queue_setup()
H A Docteontx_ethdev.h151 octeontx_dq_t dq; member
/dpdk/lib/lpm/
H A Drte_lpm.c64 struct rte_rcu_qsbr_dq *dq; /* RCU QSBR defer queue. */ member
277 if (i_lpm->dq != NULL) in rte_lpm_free()
278 rte_rcu_qsbr_dq_delete(i_lpm->dq); in rte_lpm_free()
336 i_lpm->dq = rte_rcu_qsbr_dq_create(&params); in rte_lpm_rcu_qsbr_add()
337 if (i_lpm->dq == NULL) { in rte_lpm_rcu_qsbr_add()
533 if (group_idx == -ENOSPC && i_lpm->dq != NULL) { in tbl8_alloc()
535 if (rte_rcu_qsbr_dq_reclaim(i_lpm->dq, 1, in tbl8_alloc()
562 status = rte_rcu_qsbr_dq_enqueue(i_lpm->dq, in tbl8_free()
/dpdk/lib/hash/
H A Drte_cuckoo_hash.c512 if (h->dq) in rte_hash_free()
513 rte_rcu_qsbr_dq_delete(h->dq); in rte_hash_free()
624 if (h->dq) { in rte_hash_reset()
1054 if (h->dq) { in __rte_hash_add_key_with_hash()
1056 ret = rte_rcu_qsbr_dq_reclaim(h->dq, in __rte_hash_add_key_with_hash()
1160 if (h->dq) { in __rte_hash_add_key_with_hash()
1161 if (rte_rcu_qsbr_dq_reclaim(h->dq, in __rte_hash_add_key_with_hash()
1552 h->dq = rte_rcu_qsbr_dq_create(&params); in rte_hash_rcu_qsbr_add()
1553 if (h->dq == NULL) { in rte_hash_rcu_qsbr_add()
1763 if (h->dq == NULL) { in __rte_hash_del_key_with_hash()
[all …]
H A Drte_cuckoo_hash.h180 struct rte_rcu_qsbr_dq *dq; /**< RCU QSBR defer queue. */ member
/dpdk/drivers/crypto/dpaa_sec/
H A Ddpaa_sec_raw_dp.c870 struct qm_dqrr_entry *dq; in dpaa_sec_deq_raw() local
897 dq = qman_dequeue(fq); in dpaa_sec_deq_raw()
898 if (!dq) in dpaa_sec_deq_raw()
901 fd = &dq->fd; in dpaa_sec_deq_raw()
927 qman_dqrr_consume(fq, dq); in dpaa_sec_deq_raw()
H A Ddpaa_sec.c801 struct qm_dqrr_entry *dq; in dpaa_sec_deq() local
828 dq = qman_dequeue(fq); in dpaa_sec_deq()
829 if (!dq) in dpaa_sec_deq()
832 fd = &dq->fd; in dpaa_sec_deq()
874 qman_dqrr_consume(fq, dq); in dpaa_sec_deq()
/dpdk/drivers/bus/dpaa/include/
H A Dfsl_qman.h1149 typedef void (*qman_dpdk_cb_prepare)(struct qm_dqrr_entry *dq, void **bufs);
1429 struct qm_dqrr_entry *dq);
1522 void qman_dca(const struct qm_dqrr_entry *dq, int park_request);
/dpdk/drivers/bus/fslmc/portal/
H A Ddpaa2_hw_pvt.h146 const struct qbman_result *dq,
/dpdk/drivers/crypto/dpaa2_sec/
H A Ddpaa2_sec_dpseci.c3997 const struct qbman_result *dq, in dpaa2_sec_process_parallel_event() argument
4019 qbman_swp_dqrr_consume(swp, dq); in dpaa2_sec_process_parallel_event()
4024 const struct qbman_result *dq, in dpaa2_sec_process_atomic_event() argument
4048 dqrr_index = qbman_get_dqrr_idx(dq); in dpaa2_sec_process_atomic_event()
4059 const struct qbman_result *dq, in dpaa2_sec_process_ordered_event() argument
4084 *dpaa2_seqn(crypto_op->sym->m_src) |= qbman_result_DQ_odpid(dq) << in dpaa2_sec_process_ordered_event()
4086 *dpaa2_seqn(crypto_op->sym->m_src) |= qbman_result_DQ_seqnum(dq) << in dpaa2_sec_process_ordered_event()
4089 qbman_swp_dqrr_consume(swp, dq); in dpaa2_sec_process_ordered_event()