crypto/octeontx: add global resource init

[dpdk.git] / drivers / crypto / octeontx / otx_cryptodev_ops.c

diff --git a/drivers/crypto/octeontx/otx_cryptodev_ops.c b/drivers/crypto/octeontx/otx_cryptodev_ops.c
index 3bf6cd2..68c6b92 100644 (file)
--- a/drivers/crypto/octeontx/otx_cryptodev_ops.c
+++ b/drivers/crypto/octeontx/otx_cryptodev_ops.c
@@ -8,11 +8,69 @@
 #include <rte_malloc.h>
 
 #include "cpt_pmd_logs.h"
+#include "cpt_pmd_ops_helper.h"
 
 #include "otx_cryptodev.h"
 #include "otx_cryptodev_hw_access.h"
 #include "otx_cryptodev_ops.h"
 
+static int otx_cryptodev_probe_count;
+static rte_spinlock_t otx_probe_count_lock = RTE_SPINLOCK_INITIALIZER;
+
+static struct rte_mempool *otx_cpt_meta_pool;
+static int otx_cpt_op_mlen;
+static int otx_cpt_op_sb_mlen;
+
+/*
+ * Initializes global variables used by fast-path code
+ *
+ * @return
+ *   - 0 on success, errcode on error
+ */
+static int
+init_global_resources(void)
+{
+       /* Get meta len for scatter gather mode */
+       otx_cpt_op_mlen = cpt_pmd_ops_helper_get_mlen_sg_mode();
+
+       /* Extra 4B saved for future considerations */
+       otx_cpt_op_mlen += 4 * sizeof(uint64_t);
+
+       otx_cpt_meta_pool = rte_mempool_create("cpt_metabuf-pool", 4096 * 16,
+                                              otx_cpt_op_mlen, 512, 0,
+                                              NULL, NULL, NULL, NULL,
+                                              SOCKET_ID_ANY, 0);
+       if (!otx_cpt_meta_pool) {
+               CPT_LOG_ERR("cpt metabuf pool not created");
+               return -ENOMEM;
+       }
+
+       /* Get meta len for direct mode */
+       otx_cpt_op_sb_mlen = cpt_pmd_ops_helper_get_mlen_direct_mode();
+
+       /* Extra 4B saved for future considerations */
+       otx_cpt_op_sb_mlen += 4 * sizeof(uint64_t);
+
+       return 0;
+}
+
+void
+cleanup_global_resources(void)
+{
+       /* Take lock */
+       rte_spinlock_lock(&otx_probe_count_lock);
+
+       /* Decrement the cryptodev count */
+       otx_cryptodev_probe_count--;
+
+       /* Free buffers */
+       if (otx_cpt_meta_pool && otx_cryptodev_probe_count == 0)
+               rte_mempool_free(otx_cpt_meta_pool);
+
+       /* Free lock */
+       rte_spinlock_unlock(&otx_probe_count_lock);
+}
+
 /* Alarm routines */
 
 static void
@@ -31,6 +89,20 @@ otx_cpt_periodic_alarm_start(void *arg)
                                 otx_cpt_alarm_cb, arg);
 }
 
+static int
+otx_cpt_periodic_alarm_stop(void *arg)
+{
+       return rte_eal_alarm_cancel(otx_cpt_alarm_cb, arg);
+}
+
+static void
+otx_cpt_common_vars_init(struct cpt_vf *cptvf)
+{
+       cptvf->meta_info.cptvf_meta_pool = otx_cpt_meta_pool;
+       cptvf->meta_info.cptvf_op_mlen = otx_cpt_op_mlen;
+       cptvf->meta_info.cptvf_op_sb_mlen = otx_cpt_op_sb_mlen;
+}
+
 int
 otx_cpt_dev_create(struct rte_cryptodev *c_dev)
 {
@@ -78,6 +150,20 @@ otx_cpt_dev_create(struct rte_cryptodev *c_dev)
        /* Start off timer for mailbox interrupts */
        otx_cpt_periodic_alarm_start(cptvf);
 
+       rte_spinlock_lock(&otx_probe_count_lock);
+       if (!otx_cryptodev_probe_count) {
+               ret = init_global_resources();
+               if (ret) {
+                       rte_spinlock_unlock(&otx_probe_count_lock);
+                       goto init_fail;
+               }
+       }
+       otx_cryptodev_probe_count++;
+       rte_spinlock_unlock(&otx_probe_count_lock);
+
+       /* Initialize data path variables used by common code */
+       otx_cpt_common_vars_init(cptvf);
+
        c_dev->dev_ops = NULL;
 
        c_dev->enqueue_burst = NULL;
@@ -95,6 +181,10 @@ otx_cpt_dev_create(struct rte_cryptodev *c_dev)
 
        return 0;
 
+init_fail:
+       otx_cpt_periodic_alarm_stop(cptvf);
+       otx_cpt_deinit_device(cptvf);
+
 fail:
        if (cptvf) {
                /* Free private data allocated */