@@ -953,6 +953,20 @@ cpt_lf_fini(struct roc_cpt_lf *lf)
lf->iq_vaddr = NULL;
}
+void
+roc_cpt_lf_reset(struct roc_cpt_lf *lf)
+{
+ if (lf == NULL)
+ return;
+
+ cpt_lf_misc_intr_enb_dis(lf, false);
+ cpt_lf_done_intr_enb_dis(lf, false);
+ roc_cpt_iq_disable(lf);
+ roc_cpt_iq_reset(lf);
+ cpt_lf_misc_intr_enb_dis(lf, true);
+ cpt_lf_done_intr_enb_dis(lf, true);
+}
+
void
roc_cpt_lf_fini(struct roc_cpt_lf *lf)
{
@@ -187,6 +187,7 @@ int __roc_api roc_cpt_dev_configure(struct roc_cpt *roc_cpt, int nb_lf, bool rxc
void __roc_api roc_cpt_dev_clear(struct roc_cpt *roc_cpt);
int __roc_api roc_cpt_lf_init(struct roc_cpt *roc_cpt, struct roc_cpt_lf *lf);
void __roc_api roc_cpt_lf_fini(struct roc_cpt_lf *lf);
+void __roc_api roc_cpt_lf_reset(struct roc_cpt_lf *lf);
int __roc_api roc_cpt_lf_ctx_flush(struct roc_cpt_lf *lf, void *cptr,
bool inval);
int __roc_api roc_cpt_lf_ctx_reload(struct roc_cpt_lf *lf, void *cptr);
@@ -74,6 +74,7 @@ INTERNAL {
roc_cpt_lf_ctx_reload;
roc_cpt_lf_init;
roc_cpt_lf_fini;
+ roc_cpt_lf_reset;
roc_cpt_lfs_print;
roc_cpt_lmtline_init;
roc_cpt_parse_hdr_dump;
@@ -1976,6 +1976,7 @@ struct rte_cryptodev_ops cn10k_cpt_ops = {
.stats_reset = NULL,
.queue_pair_setup = cnxk_cpt_queue_pair_setup,
.queue_pair_release = cnxk_cpt_queue_pair_release,
+ .queue_pair_reset = cnxk_cpt_queue_pair_reset,
/* Symmetric crypto ops */
.sym_session_get_size = cnxk_cpt_sym_session_get_size,
@@ -707,6 +707,7 @@ struct rte_cryptodev_ops cn9k_cpt_ops = {
.stats_reset = NULL,
.queue_pair_setup = cnxk_cpt_queue_pair_setup,
.queue_pair_release = cnxk_cpt_queue_pair_release,
+ .queue_pair_reset = cnxk_cpt_queue_pair_reset,
/* Symmetric crypto ops */
.sym_session_get_size = cnxk_cpt_sym_session_get_size,
@@ -496,6 +496,27 @@ cnxk_cpt_queue_pair_setup(struct rte_cryptodev *dev, uint16_t qp_id,
return ret;
}
+int
+cnxk_cpt_queue_pair_reset(struct rte_cryptodev *dev, uint16_t qp_id,
+ const struct rte_cryptodev_qp_conf *conf, int socket_id)
+{
+ if (conf == NULL) {
+ struct cnxk_cpt_vf *vf = dev->data->dev_private;
+ struct roc_cpt_lf *lf;
+
+ if (vf == NULL)
+ return -ENOTSUP;
+
+ lf = vf->cpt.lf[qp_id];
+ roc_cpt_lf_reset(lf);
+ roc_cpt_iq_enable(lf);
+
+ return 0;
+ }
+
+ return cnxk_cpt_queue_pair_setup(dev, qp_id, conf, socket_id);
+}
+
uint32_t
cnxk_cpt_qp_depth_used(void *qptr)
{
@@ -120,6 +120,9 @@ int cnxk_cpt_queue_pair_setup(struct rte_cryptodev *dev, uint16_t qp_id,
const struct rte_cryptodev_qp_conf *conf,
int socket_id __rte_unused);
+int cnxk_cpt_queue_pair_reset(struct rte_cryptodev *dev, uint16_t qp_id,
+ const struct rte_cryptodev_qp_conf *conf, int socket_id);
+
int cnxk_cpt_queue_pair_release(struct rte_cryptodev *dev, uint16_t qp_id);
unsigned int cnxk_cpt_sym_session_get_size(struct rte_cryptodev *dev);