Lines Matching refs:qp

143 		struct nitrox_qp *qp = cdev->data->queue_pairs[qp_id];  in nitrox_sym_dev_stats_get()  local
145 if (!qp) in nitrox_sym_dev_stats_get()
148 stats->enqueued_count += qp->stats.enqueued_count; in nitrox_sym_dev_stats_get()
149 stats->dequeued_count += qp->stats.dequeued_count; in nitrox_sym_dev_stats_get()
150 stats->enqueue_err_count += qp->stats.enqueue_err_count; in nitrox_sym_dev_stats_get()
151 stats->dequeue_err_count += qp->stats.dequeue_err_count; in nitrox_sym_dev_stats_get()
161 struct nitrox_qp *qp = cdev->data->queue_pairs[qp_id]; in nitrox_sym_dev_stats_reset() local
163 if (!qp) in nitrox_sym_dev_stats_reset()
166 memset(&qp->stats, 0, sizeof(qp->stats)); in nitrox_sym_dev_stats_reset()
177 struct nitrox_qp *qp = NULL; in nitrox_sym_dev_qp_setup() local
193 qp = rte_zmalloc_socket("nitrox PMD qp", sizeof(*qp), in nitrox_sym_dev_qp_setup()
196 if (!qp) { in nitrox_sym_dev_qp_setup()
201 qp->qno = qp_id; in nitrox_sym_dev_qp_setup()
202 err = nitrox_qp_setup(qp, ndev->bar_addr, cdev->data->name, in nitrox_sym_dev_qp_setup()
208 qp->sr_mp = nitrox_sym_req_pool_create(cdev, qp->count, qp_id, in nitrox_sym_dev_qp_setup()
210 if (unlikely(!qp->sr_mp)) in nitrox_sym_dev_qp_setup()
213 cdev->data->queue_pairs[qp_id] = qp; in nitrox_sym_dev_qp_setup()
218 nitrox_qp_release(qp, ndev->bar_addr); in nitrox_sym_dev_qp_setup()
220 rte_free(qp); in nitrox_sym_dev_qp_setup()
229 struct nitrox_qp *qp; in nitrox_sym_dev_qp_release() local
239 qp = cdev->data->queue_pairs[qp_id]; in nitrox_sym_dev_qp_release()
240 if (!qp) { in nitrox_sym_dev_qp_release()
245 if (!nitrox_qp_is_empty(qp)) { in nitrox_sym_dev_qp_release()
251 err = nitrox_qp_release(qp, ndev->bar_addr); in nitrox_sym_dev_qp_release()
252 nitrox_sym_req_pool_free(qp->sr_mp); in nitrox_sym_dev_qp_release()
253 rte_free(qp); in nitrox_sym_dev_qp_release()
626 nitrox_enq_single_op(struct nitrox_qp *qp, struct rte_crypto_op *op) in nitrox_enq_single_op() argument
639 if (unlikely(rte_mempool_get(qp->sr_mp, (void **)&sr))) in nitrox_enq_single_op()
642 err = nitrox_process_se_req(qp->qno, op, ctx, sr); in nitrox_enq_single_op()
644 rte_mempool_put(qp->sr_mp, sr); in nitrox_enq_single_op()
649 nitrox_qp_enqueue(qp, nitrox_sym_instr_addr(sr), sr); in nitrox_enq_single_op()
657 struct nitrox_qp *qp = queue_pair; in nitrox_sym_dev_enq_burst() local
662 free_slots = nitrox_qp_free_count(qp); in nitrox_sym_dev_enq_burst()
667 if (unlikely(nitrox_enq_single_op(qp, ops[cnt]))) { in nitrox_sym_dev_enq_burst()
673 nitrox_ring_dbell(qp, cnt); in nitrox_sym_dev_enq_burst()
674 qp->stats.enqueued_count += cnt; in nitrox_sym_dev_enq_burst()
676 qp->stats.enqueue_err_count++; in nitrox_sym_dev_enq_burst()
682 nitrox_deq_single_op(struct nitrox_qp *qp, struct rte_crypto_op **op_ptr) in nitrox_deq_single_op() argument
688 sr = nitrox_qp_get_softreq(qp); in nitrox_deq_single_op()
694 nitrox_qp_dequeue(qp); in nitrox_deq_single_op()
695 rte_mempool_put(qp->sr_mp, sr); in nitrox_deq_single_op()
698 qp->stats.dequeued_count++; in nitrox_deq_single_op()
708 qp->stats.dequeue_err_count++; in nitrox_deq_single_op()
716 struct nitrox_qp *qp = queue_pair; in nitrox_sym_dev_deq_burst() local
717 uint16_t filled_slots = nitrox_qp_used_count(qp); in nitrox_sym_dev_deq_burst()
724 if (nitrox_deq_single_op(qp, &ops[cnt])) in nitrox_sym_dev_deq_burst()