Searched refs:qp (Results 1 - 25 of 31) sorted by relevance

12

/deb_dpdk/drivers/crypto/kasumi/
H A Drte_kasumi_pmd_ops.c126 struct kasumi_qp *qp = dev->data->queue_pairs[qp_id]; local
128 stats->enqueued_count += qp->qp_stats.enqueued_count;
129 stats->dequeued_count += qp->qp_stats.dequeued_count;
131 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
132 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
143 struct kasumi_qp *qp = dev->data->queue_pairs[qp_id]; local
145 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
170 struct kasumi_qp *qp = dev->data->queue_pairs[qp_id]; local
172 if (qp !
182 kasumi_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct kasumi_qp *qp) argument
197 kasumi_pmd_qp_create_processed_ops_ring(struct kasumi_qp *qp, unsigned ring_size, int socket_id) argument
227 struct kasumi_qp *qp = NULL; local
[all...]
H A Drte_kasumi_pmd.c162 kasumi_get_session(struct kasumi_qp *qp, struct rte_crypto_op *op) argument
175 if (rte_mempool_get(qp->sess_mp, (void **)&c_sess))
338 struct kasumi_qp *qp, uint8_t num_ops,
377 rte_mempool_put(qp->sess_mp, ops[i]->sym->session);
382 enqueued_ops = rte_ring_enqueue_burst(qp->processed_ops,
384 qp->qp_stats.enqueued_count += enqueued_ops;
393 struct kasumi_qp *qp, uint16_t *accumulated_enqueued_ops)
429 rte_mempool_put(qp->sess_mp, op->sym->session);
433 enqueued_op = rte_ring_enqueue_burst(qp->processed_ops, (void **)&op,
435 qp
337 process_ops(struct rte_crypto_op **ops, struct kasumi_session *session, struct kasumi_qp *qp, uint8_t num_ops, uint16_t *accumulated_enqueued_ops) argument
392 process_op_bit(struct rte_crypto_op *op, struct kasumi_session *session, struct kasumi_qp *qp, uint16_t *accumulated_enqueued_ops) argument
449 struct kasumi_qp *qp = queue_pair; local
548 struct kasumi_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/aesni_gcm/
H A Daesni_gcm_pmd_ops.c126 struct aesni_gcm_qp *qp = dev->data->queue_pairs[qp_id]; local
128 stats->enqueued_count += qp->qp_stats.enqueued_count;
129 stats->dequeued_count += qp->qp_stats.dequeued_count;
131 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
132 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
143 struct aesni_gcm_qp *qp = dev->data->queue_pairs[qp_id]; local
145 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
181 struct aesni_gcm_qp *qp)
183 unsigned n = snprintf(qp
180 aesni_gcm_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct aesni_gcm_qp *qp) argument
195 aesni_gcm_pmd_qp_create_processed_pkts_ring(struct aesni_gcm_qp *qp, unsigned ring_size, int socket_id) argument
223 struct aesni_gcm_qp *qp = NULL; local
[all...]
H A Daesni_gcm_pmd.c180 aesni_gcm_get_session(struct aesni_gcm_qp *qp, struct rte_crypto_sym_op *op) argument
193 if (rte_mempool_get(qp->sess_mp, &_sess))
199 if (unlikely(aesni_gcm_set_session_parameters(qp->ops,
201 rte_mempool_put(qp->sess_mp, _sess);
212 * @param qp queue pair
220 process_gcm_crypto_op(struct aesni_gcm_qp *qp, struct rte_crypto_sym_op *op, argument
265 (*qp->ops->gcm.enc)(&session->gdata, dst, src,
281 (*qp->ops->gcm.dec)(&session->gdata, dst, src,
341 * @param qp Queue Pair to process
348 handle_completed_gcm_crypto_op(struct aesni_gcm_qp *qp, argument
367 struct aesni_gcm_qp *qp = queue_pair; local
398 struct aesni_gcm_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/null/
H A Dnull_crypto_pmd_ops.c121 struct null_crypto_qp *qp = dev->data->queue_pairs[qp_id]; local
123 stats->enqueued_count += qp->qp_stats.enqueued_count;
124 stats->dequeued_count += qp->qp_stats.dequeued_count;
126 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
127 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
138 struct null_crypto_qp *qp = dev->data->queue_pairs[qp_id]; local
140 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
175 struct null_crypto_qp *qp)
177 unsigned n = snprintf(qp
174 null_crypto_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct null_crypto_qp *qp) argument
189 null_crypto_pmd_qp_create_processed_pkts_ring(struct null_crypto_qp *qp, unsigned ring_size, int socket_id) argument
220 struct null_crypto_qp *qp; local
[all...]
H A Dnull_crypto_pmd.c99 process_op(const struct null_crypto_qp *qp, struct rte_crypto_op *op, argument
109 return rte_ring_enqueue(qp->processed_pkts, (void *)op);
113 get_session(struct null_crypto_qp *qp, struct rte_crypto_sym_op *op) argument
126 if (rte_mempool_get(qp->sess_mp, (void **)&c_sess))
144 struct null_crypto_qp *qp = queue_pair; local
149 sess = get_session(qp, ops[i]->sym);
153 retval = process_op(qp, ops[i], sess);
158 qp->qp_stats.enqueued_count += i;
165 qp->qp_stats.enqueue_err_count++;
174 struct null_crypto_qp *qp local
[all...]
/deb_dpdk/drivers/crypto/snow3g/
H A Drte_snow3g_pmd_ops.c126 struct snow3g_qp *qp = dev->data->queue_pairs[qp_id]; local
128 stats->enqueued_count += qp->qp_stats.enqueued_count;
129 stats->dequeued_count += qp->qp_stats.dequeued_count;
131 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
132 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
143 struct snow3g_qp *qp = dev->data->queue_pairs[qp_id]; local
145 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
180 struct snow3g_qp *qp)
182 unsigned n = snprintf(qp
179 snow3g_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct snow3g_qp *qp) argument
194 snow3g_pmd_qp_create_processed_ops_ring(struct snow3g_qp *qp, unsigned ring_size, int socket_id) argument
224 struct snow3g_qp *qp = NULL; local
[all...]
H A Drte_snow3g_pmd.c162 snow3g_get_session(struct snow3g_qp *qp, struct rte_crypto_op *op) argument
175 if (rte_mempool_get(qp->sess_mp, (void **)&c_sess))
327 struct snow3g_qp *qp, uint8_t num_ops,
366 rte_mempool_put(qp->sess_mp, ops[i]->sym->session);
371 enqueued_ops = rte_ring_enqueue_burst(qp->processed_ops,
373 qp->qp_stats.enqueued_count += enqueued_ops;
382 struct snow3g_qp *qp, uint16_t *accumulated_enqueued_ops)
418 rte_mempool_put(qp->sess_mp, op->sym->session);
422 enqueued_op = rte_ring_enqueue_burst(qp->processed_ops,
424 qp
326 process_ops(struct rte_crypto_op **ops, struct snow3g_session *session, struct snow3g_qp *qp, uint8_t num_ops, uint16_t *accumulated_enqueued_ops) argument
381 process_op_bit(struct rte_crypto_op *op, struct snow3g_session *session, struct snow3g_qp *qp, uint16_t *accumulated_enqueued_ops) argument
438 struct snow3g_qp *qp = queue_pair; local
537 struct snow3g_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/zuc/
H A Drte_zuc_pmd_ops.c126 struct zuc_qp *qp = dev->data->queue_pairs[qp_id]; local
128 stats->enqueued_count += qp->qp_stats.enqueued_count;
129 stats->dequeued_count += qp->qp_stats.dequeued_count;
131 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
132 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
143 struct zuc_qp *qp = dev->data->queue_pairs[qp_id]; local
145 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
180 struct zuc_qp *qp)
182 unsigned n = snprintf(qp
179 zuc_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct zuc_qp *qp) argument
194 zuc_pmd_qp_create_processed_ops_ring(struct zuc_qp *qp, unsigned ring_size, int socket_id) argument
224 struct zuc_qp *qp = NULL; local
[all...]
H A Drte_zuc_pmd.c161 zuc_get_session(struct zuc_qp *qp, struct rte_crypto_op *op) argument
174 if (rte_mempool_get(qp->sess_mp, (void **)&c_sess))
305 struct zuc_qp *qp, uint8_t num_ops,
344 rte_mempool_put(qp->sess_mp, ops[i]->sym->session);
349 enqueued_ops = rte_ring_enqueue_burst(qp->processed_ops,
351 qp->qp_stats.enqueued_count += enqueued_ops;
365 struct zuc_qp *qp = queue_pair; local
374 curr_sess = zuc_get_session(qp, curr_c_op);
393 qp, burst_size, &enqueued_ops);
408 qp, burst_siz
304 process_ops(struct rte_crypto_op **ops, struct zuc_session *session, struct zuc_qp *qp, uint8_t num_ops, uint16_t *accumulated_enqueued_ops) argument
435 struct zuc_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/aesni_mb/
H A Drte_aesni_mb_pmd_ops.c270 struct aesni_mb_qp *qp = dev->data->queue_pairs[qp_id]; local
272 stats->enqueued_count += qp->stats.enqueued_count;
273 stats->dequeued_count += qp->stats.dequeued_count;
275 stats->enqueue_err_count += qp->stats.enqueue_err_count;
276 stats->dequeue_err_count += qp->stats.dequeue_err_count;
287 struct aesni_mb_qp *qp = dev->data->queue_pairs[qp_id]; local
289 memset(&qp->stats, 0, sizeof(qp->stats));
314 struct aesni_mb_qp *qp = dev->data->queue_pairs[qp_id]; local
317 if (qp !
329 aesni_mb_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct aesni_mb_qp *qp) argument
344 aesni_mb_pmd_qp_create_processed_ops_ring(struct aesni_mb_qp *qp, unsigned ring_size, int socket_id) argument
372 struct aesni_mb_qp *qp = NULL; local
[all...]
H A Drte_aesni_mb_pmd.c301 get_session(struct aesni_mb_qp *qp, struct rte_crypto_op *op) argument
314 if (rte_mempool_get(qp->sess_mp, (void **)&_sess))
320 if (unlikely(aesni_mb_set_session_parameters(qp->ops,
322 rte_mempool_put(qp->sess_mp, _sess);
335 * @param qp queue pair
344 process_crypto_op(struct aesni_mb_qp *qp, struct rte_crypto_op *op, argument
352 job = (*qp->ops->job.get_next)(&qp->mb_mgr);
456 post_process_mb_job(struct aesni_mb_qp *qp, JOB_AES_HMAC *job) argument
485 rte_mempool_put(qp
503 handle_completed_jobs(struct aesni_mb_qp *qp, JOB_AES_HMAC *job) argument
526 struct aesni_mb_qp *qp = queue_pair; local
587 struct aesni_mb_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/openssl/
H A Drte_openssl_pmd_ops.c486 struct openssl_qp *qp = dev->data->queue_pairs[qp_id]; local
488 stats->enqueued_count += qp->stats.enqueued_count;
489 stats->dequeued_count += qp->stats.dequeued_count;
491 stats->enqueue_err_count += qp->stats.enqueue_err_count;
492 stats->dequeue_err_count += qp->stats.dequeue_err_count;
503 struct openssl_qp *qp = dev->data->queue_pairs[qp_id]; local
505 memset(&qp->stats, 0, sizeof(qp->stats));
540 struct openssl_qp *qp)
542 unsigned int n = snprintf(qp
539 openssl_pmd_qp_set_unique_name(struct rte_cryptodev *dev, struct openssl_qp *qp) argument
555 openssl_pmd_qp_create_processed_ops_ring(struct openssl_qp *qp, unsigned int ring_size, int socket_id) argument
586 struct openssl_qp *qp = NULL; local
[all...]
H A Drte_openssl_pmd.c447 get_session(struct openssl_qp *qp, struct rte_crypto_op *op) argument
462 if (!rte_mempool_get(qp->sess_mp, (void **)&_sess)) {
469 rte_mempool_put(qp->sess_mp, _sess);
864 process_op(const struct openssl_qp *qp, struct rte_crypto_op *op, argument
902 rte_mempool_put(qp->sess_mp, op->sym->session);
911 retval = rte_ring_enqueue(qp->processed_ops, (void *)op);
930 struct openssl_qp *qp = queue_pair; local
934 sess = get_session(qp, ops[i]);
938 retval = process_op(qp, ops[i], sess);
943 qp
956 struct openssl_qp *qp = queue_pair; local
[all...]
/deb_dpdk/drivers/crypto/qat/
H A Dqat_qp.c137 struct qat_qp *qp; local
142 /* If qp is already in use free ring memory and qp metadata. */
151 PMD_DRV_LOG(ERR, "Can't create qp for %u descriptors",
171 qp = rte_zmalloc("qat PMD qp metadata",
172 sizeof(*qp), RTE_CACHE_LINE_SIZE);
173 if (qp == NULL) {
174 PMD_DRV_LOG(ERR, "Failed to alloc mem for qp struct");
177 qp
206 struct qat_qp *qp = local
410 adf_configure_queues(struct qat_qp *qp) argument
[all...]
H A Dqat_crypto.h130 qat_pmd_enqueue_op_burst(void *qp, struct rte_crypto_op **ops,
134 qat_pmd_dequeue_op_burst(void *qp, struct rte_crypto_op **ops,
H A Dqat_crypto.c844 qat_pmd_enqueue_op_burst(void *qp, struct rte_crypto_op **ops, argument
848 struct qat_qp *tmp_qp = (struct qat_qp *)qp;
897 qat_pmd_dequeue_op_burst(void *qp, struct rte_crypto_op **ops, argument
901 struct qat_qp *tmp_qp = (struct qat_qp *)qp;
1286 struct qat_qp **qp = (struct qat_qp **)(dev->data->queue_pairs); local
1294 if (qp[i] == NULL) {
1299 stats->enqueued_count += qp[i]->stats.enqueued_count;
1300 stats->dequeued_count += qp[i]->stats.dequeued_count;
1301 stats->enqueue_err_count += qp[i]->stats.enqueue_err_count;
1302 stats->dequeue_err_count += qp[
1309 struct qat_qp **qp = (struct qat_qp **)(dev->data->queue_pairs); local
[all...]
/deb_dpdk/drivers/net/mlx5/
H A Dmlx5_txq.c149 assert(txq_ctrl->qp != NULL);
168 if (txq_ctrl->qp != NULL)
169 claim_zero(ibv_destroy_qp(txq_ctrl->qp));
206 struct mlx5_qp *qp = to_mqp(tmpl->qp); local
220 tmpl->txq.qp_num_8s = qp->ctrl_seg.qp_num << 8;
223 (uintptr_t)qp->gen_data.sqstart;
224 tmpl->txq.wqe_n = log2above(qp->sq.wqe_cnt);
225 tmpl->txq.qp_db = &qp->gen_data.db[MLX5_SND_DBR];
226 tmpl->txq.bf_reg = qp
[all...]
H A Dmlx5_rxtx.h89 struct ibv_qp *qp; /* Associated RX QP. */ member in struct:fdir_queue
234 struct ibv_qp *qp; /* Hash RX QP. */ member in struct:hash_rxq
274 struct ibv_qp *qp; /* Queue Pair. */ member in struct:txq_ctrl
/deb_dpdk/examples/ipsec-secgw/
H A Dipsec.c69 "%u qp %u\n", sa->spi,
71 ipsec_ctx->tbl[cdev_id_qp].qp);
89 ret = rte_cryptodev_enqueue_burst(cqp->id, cqp->qp,
94 cqp->id, cqp->qp,
172 nb_cops = rte_cryptodev_dequeue_burst(cqp->id, cqp->qp,
H A Dipsec-secgw.c1115 uint16_t qp, struct lcore_params *params,
1145 ipsec_ctx->tbl[i].qp = qp;
1147 printf("%s cdev mapping: lcore %u using cdev %u qp %u "
1149 cdev_id, qp, i);
1155 "cdev %u, qp %u), errno %d\n",
1157 ipsec_ctx->tbl[i].qp, ret);
1166 uint16_t qp, struct lcore_params *params)
1208 ret |= add_mapping(map, str, cdev_id, qp, params,
1221 uint16_t idx, max_nb_qps, qp, local
1114 add_mapping(struct rte_hash *map, const char *str, uint16_t cdev_id, uint16_t qp, struct lcore_params *params, struct ipsec_ctx *ipsec_ctx, const struct rte_cryptodev_capabilities *cipher, const struct rte_cryptodev_capabilities *auth) argument
1165 add_cdev_mapping(struct rte_cryptodev_info *dev_info, uint16_t cdev_id, uint16_t qp, struct lcore_params *params) argument
[all...]
/deb_dpdk/lib/librte_eal/linuxapp/kni/ethtool/igb/
H A Digb_param.c647 unsigned int qp = QueuePairs[bd]; local
656 if (qp == OPTION_DISABLED) {
658 qp = OPTION_ENABLED;
661 qp = OPTION_ENABLED;
666 qp = OPTION_ENABLED;
670 qp = OPTION_ENABLED;
672 if (qp == OPTION_ENABLED)
676 igb_validate_option(&qp, &opt, adapter);
677 adapter->flags |= qp ? IGB_FLAG_QUEUE_PAIRS : 0;
/deb_dpdk/lib/librte_cryptodev/
H A Drte_cryptodev.c531 void **qp; local
562 CDEV_LOG_ERR("failed to get memory for qp meta data, "
571 qp = dev->data->queue_pairs;
582 qp = rte_realloc(qp, sizeof(qp[0]) * nb_qpairs,
584 if (qp == NULL) {
585 CDEV_LOG_ERR("failed to realloc qp meta data,"
593 memset(qp + old_nb_queues, 0,
594 sizeof(qp[
[all...]
H A Drte_cryptodev.h593 typedef uint16_t (*dequeue_pkt_burst_t)(void *qp,
597 typedef uint16_t (*enqueue_pkt_burst_t)(void *qp,
/deb_dpdk/drivers/net/mlx4/
H A Dmlx4.c179 struct ibv_qp *qp; /* Queue Pair. */ member in struct:rxq
226 struct ibv_qp *qp; /* Queue Pair. */ member in struct:txq
1114 assert(txq->qp != NULL);
1133 if (txq->qp != NULL)
1134 claim_zero(ibv_destroy_qp(txq->qp));
1713 (txq->qp,
1720 (txq->qp,
1742 (txq->qp,
1772 err = txq->if_qp->send_flush(txq->qp);
1927 tmpl.qp
[all...]

Completed in 27 milliseconds

12