d/numam-dpdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

compress/isal: support burst enqueue/dequeue

Browse Source 
This patchs adds support for the compressdev enqueue_burst
and dequeue_burst API operations.

Signed-off-by: Lee Daly <lee.daly@intel.com>
Reviewed-by: Pablo de Lara <pablo.de.lara.guarch@intel.com>
This commit is contained in:
Lee Daly 2018-05-09 17:14:31 +01:00 committed by Pablo de Lara
parent b0e23c458a
commit 21fd1e5949
2 changed files with 72 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
drivers/compress/isal/isal_compress_pmd.c
View File

@ -187,6 +187,72 @@ isal_comp_set_priv_xform_parameters(struct isal_priv_xform *priv_xform,
return 0;
}
/* Process compression/decompression operation */
static int
process_op(struct isal_comp_qp *qp __rte_unused,
struct rte_comp_op *op __rte_unused,
struct isal_priv_xform *priv_xform)
{
switch (priv_xform->type) {
case RTE_COMP_COMPRESS:
break;
case RTE_COMP_DECOMPRESS:
break;
default:
ISAL_PMD_LOG(ERR, "Operation Not Supported\n");
return -ENOTSUP;
}
return 0;
}
/* Enqueue burst */
static uint16_t
isal_comp_pmd_enqueue_burst(void *queue_pair, struct rte_comp_op **ops,
uint16_t nb_ops)
{
struct isal_comp_qp *qp = queue_pair;
uint16_t i;
int retval;
int16_t num_enq = RTE_MIN(qp->num_free_elements, nb_ops);
for (i = 0; i < num_enq; i++) {
if (unlikely(ops[i]->op_type != RTE_COMP_OP_STATELESS)) {
ops[i]->status = RTE_COMP_OP_STATUS_INVALID_ARGS;
ISAL_PMD_LOG(ERR, "Stateful operation not Supported\n");
qp->qp_stats.enqueue_err_count++;
continue;
}
retval = process_op(qp, ops[i], ops[i]->private_xform);
if (unlikely(retval < 0) ||
ops[i]->status != RTE_COMP_OP_STATUS_SUCCESS) {
qp->qp_stats.enqueue_err_count++;
}
}
retval = rte_ring_enqueue_burst(qp->processed_pkts, (void *)ops,
num_enq, NULL);
qp->num_free_elements -= retval;
qp->qp_stats.enqueued_count += retval;
return retval;
}
/* Dequeue burst */
static uint16_t
isal_comp_pmd_dequeue_burst(void *queue_pair, struct rte_comp_op **ops,
uint16_t nb_ops)
{
struct isal_comp_qp *qp = queue_pair;
uint16_t nb_dequeued;
nb_dequeued = rte_ring_dequeue_burst(qp->processed_pkts, (void **)ops,
nb_ops, NULL);
qp->num_free_elements += nb_dequeued;
qp->qp_stats.dequeued_count += nb_dequeued;
return nb_dequeued;
}
/* Create ISA-L compression device */
static int
compdev_isal_create(const char *name, struct rte_vdev_device *vdev,
@ -203,6 +269,10 @@ compdev_isal_create(const char *name, struct rte_vdev_device *vdev,
dev->dev_ops = isal_compress_pmd_ops;
/* register rx/tx burst functions for data path */
dev->dequeue_burst = isal_comp_pmd_dequeue_burst;
dev->enqueue_burst = isal_comp_pmd_enqueue_burst;
return 0;
}

2
drivers/compress/isal/isal_compress_pmd_ops.c
View File

@ -203,6 +203,8 @@ isal_comp_pmd_qp_setup(struct rte_compressdev *dev, uint16_t qp_id,
goto qp_setup_cleanup;
}
qp->num_free_elements = rte_ring_free_count(qp->processed_pkts);
memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
return 0;