Multi-function API allows user to chain xforms of various
types together in a single operation

Signed-off-by: Mairtin o Loingsigh <mairtin.oloings...@intel.com>
---
 drivers/raw/Makefile                               |    1 +
 drivers/raw/common/Makefile                        |    8 +
 drivers/raw/common/multi_fn/Makefile               |   26 ++
 .../multi_fn/rte_common_multi_fn_version.map       |    8 +
 drivers/raw/common/multi_fn/rte_multi_fn.c         |   98 +++++++
 drivers/raw/common/multi_fn/rte_multi_fn.h         |  297 ++++++++++++++++++++
 mk/rte.app.mk                                      |    1 +
 7 files changed, 439 insertions(+), 0 deletions(-)
 create mode 100644 drivers/raw/common/Makefile
 create mode 100644 drivers/raw/common/multi_fn/Makefile
 create mode 100644 drivers/raw/common/multi_fn/rte_common_multi_fn_version.map
 create mode 100644 drivers/raw/common/multi_fn/rte_multi_fn.c
 create mode 100644 drivers/raw/common/multi_fn/rte_multi_fn.h

diff --git a/drivers/raw/Makefile b/drivers/raw/Makefile
index 80b043e..e16da8d 100644
--- a/drivers/raw/Makefile
+++ b/drivers/raw/Makefile
@@ -14,5 +14,6 @@ DIRS-$(CONFIG_RTE_LIBRTE_PMD_IOAT_RAWDEV) += ioat
 DIRS-$(CONFIG_RTE_LIBRTE_PMD_NTB_RAWDEV) += ntb
 DIRS-$(CONFIG_RTE_LIBRTE_PMD_OCTEONTX2_DMA_RAWDEV) += octeontx2_dma
 DIRS-$(CONFIG_RTE_LIBRTE_PMD_OCTEONTX2_EP_RAWDEV) += octeontx2_ep
+DIRS-y += common
 
 include $(RTE_SDK)/mk/rte.subdir.mk
diff --git a/drivers/raw/common/Makefile b/drivers/raw/common/Makefile
new file mode 100644
index 0000000..26401de
--- /dev/null
+++ b/drivers/raw/common/Makefile
@@ -0,0 +1,8 @@
+# SPDX-License-Identifier: BSD-3-Clause
+# Copyright(c) 2020 Intel Corporation
+
+include $(RTE_SDK)/mk/rte.vars.mk
+
+DIRS-y += multi_fn
+
+include $(RTE_SDK)/mk/rte.subdir.mk
diff --git a/drivers/raw/common/multi_fn/Makefile 
b/drivers/raw/common/multi_fn/Makefile
new file mode 100644
index 0000000..dbf61a6
--- /dev/null
+++ b/drivers/raw/common/multi_fn/Makefile
@@ -0,0 +1,26 @@
+# SPDX-License-Identifier: BSD-3-Clause
+# Copyright(c) 2020 Intel Corporation
+
+include $(RTE_SDK)/mk/rte.vars.mk
+
+# library name
+LIB = librte_multi_fn.a
+
+# build flags
+CFLAGS += -O3
+CFLAGS += $(WERROR_FLAGS)
+CFLAGS += -DALLOW_EXPERIMENTAL_API
+
+# versioning export map
+EXPORT_MAP := rte_common_multi_fn_version.map
+
+# external library dependencies
+LDLIBS += -lrte_eal
+#LDLIBS += -lrte_rawdev
+#LDLIBS += -lrte_bus_vdev
+
+SRCS-y += rte_multi_fn.c
+
+SYMLINK-y-include += rte_multi_fn.h
+
+include $(RTE_SDK)/mk/rte.lib.mk
diff --git a/drivers/raw/common/multi_fn/rte_common_multi_fn_version.map 
b/drivers/raw/common/multi_fn/rte_common_multi_fn_version.map
new file mode 100644
index 0000000..8a22d01
--- /dev/null
+++ b/drivers/raw/common/multi_fn/rte_common_multi_fn_version.map
@@ -0,0 +1,8 @@
+EXPERIMENTAL {
+        global:
+
+       rte_multi_fn_session_create;
+       rte_multi_fn_session_destroy;
+
+        local: *;
+};
diff --git a/drivers/raw/common/multi_fn/rte_multi_fn.c 
b/drivers/raw/common/multi_fn/rte_multi_fn.c
new file mode 100644
index 0000000..51827c5
--- /dev/null
+++ b/drivers/raw/common/multi_fn/rte_multi_fn.c
@@ -0,0 +1,98 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright(c) 2020 Intel Corporation
+ */
+
+#include <ctype.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <stdarg.h>
+#include <errno.h>
+#include <stdint.h>
+#include <inttypes.h>
+#include <sys/types.h>
+#include <sys/queue.h>
+
+#include <rte_string_fns.h>
+#include <rte_byteorder.h>
+#include <rte_log.h>
+#include <rte_debug.h>
+#include <rte_dev.h>
+#include <rte_memory.h>
+#include <rte_memcpy.h>
+#include <rte_memzone.h>
+#include <rte_eal.h>
+#include <rte_per_lcore.h>
+#include <rte_lcore.h>
+#include <rte_atomic.h>
+#include <rte_branch_prediction.h>
+#include <rte_common.h>
+#include <rte_malloc.h>
+#include <rte_errno.h>
+
+#include "rte_rawdev.h"
+#include "rte_rawdev_pmd.h"
+#include "rte_multi_fn.h"
+
+/* Dynamic log identifier */
+static int librawmulti_fn_logtype;
+
+/* Logging Macros */
+#define MF_LOG(level, fmt, args...) \
+       rte_log(RTE_LOG_ ## level, librawmulti_fn_logtype, "%s(): " fmt "\n", \
+               __func__, ##args)
+
+#define MF_ERR(fmt, args...) \
+       MF_LOG(ERR, fmt, ## args)
+#define MF_DEBUG(fmt, args...) \
+       MF_LOG(DEBUG, fmt, ## args)
+#define MF_INFO(fmt, args...) \
+       MF_LOG(INFO, fmt, ## args)
+
+struct rte_multi_fn_session *
+rte_multi_fn_session_create(uint16_t dev_id,
+                               struct rte_rawdev_info *dev_info,
+                               struct rte_multi_fn_xform *xform,
+                               int socket_id)
+{
+       struct rte_rawdev *rawdev;
+       struct rte_multi_fn_device_info *dev_priv;
+
+       if (!rte_rawdev_pmd_is_valid_dev((dev_id))) {
+               MF_ERR("Invalid rawdev dev_id=%d", dev_id);
+               return NULL;
+       }
+
+       rawdev = &rte_rawdevs[dev_id];
+
+       dev_priv = dev_info->dev_private;
+
+       return dev_priv->create(rawdev, xform, socket_id);
+}
+
+int
+rte_multi_fn_session_destroy(uint16_t dev_id,
+                               struct rte_rawdev_info *dev_info,
+                               struct rte_multi_fn_session *sess)
+{
+       struct rte_rawdev *rawdev;
+       struct rte_multi_fn_device_info *dev_priv;
+
+       if (!rte_rawdev_pmd_is_valid_dev((dev_id))) {
+               MF_ERR("Invalid rawdev dev_id=%d", dev_id);
+               return -EINVAL;
+       }
+
+       rawdev = &rte_rawdevs[dev_id];
+
+       dev_priv = dev_info->dev_private;
+
+       return dev_priv->destroy(rawdev, sess);
+}
+
+RTE_INIT(libmulti_fn_dev_init_log)
+{
+       librawmulti_fn_logtype = rte_log_register("lib.multi_fn");
+       if (librawmulti_fn_logtype >= 0)
+               rte_log_set_level(librawmulti_fn_logtype, RTE_LOG_INFO);
+}
diff --git a/drivers/raw/common/multi_fn/rte_multi_fn.h 
b/drivers/raw/common/multi_fn/rte_multi_fn.h
new file mode 100644
index 0000000..789d119
--- /dev/null
+++ b/drivers/raw/common/multi_fn/rte_multi_fn.h
@@ -0,0 +1,297 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright(c) 2020 Intel Corporation.
+ */
+
+#ifndef _RTE_MULTI_FN_H_
+#define _RTE_MULTI_FN_H_
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <rte_compat.h>
+#include <rte_common.h>
+#include <rte_mbuf.h>
+#include <rte_memory.h>
+#include <rte_mempool.h>
+#include <rte_comp.h>
+#include <rte_crypto.h>
+#include <rte_rawdev.h>
+
+/** Error Detection Algorithms */
+enum rte_multi_fn_err_detect_algorithm {
+       RTE_MULTI_FN_ERR_DETECT_CRC32_ETH,
+       /**< CRC32 Ethernet */
+       RTE_MULTI_FN_ERR_DETECT_BIP32
+       /**< BIP32 */
+};
+
+/** Error Detection Operation Types */
+enum rte_multi_fn_err_detect_operation {
+       RTE_MULTI_FN_ERR_DETECT_OP_VERIFY,
+       /**< Verify error detection result */
+       RTE_MULTI_FN_ERR_DETECT_OP_GENERATE
+       /**< Generate error detection result */
+};
+
+/** Error Detection Status */
+enum rte_multi_fn_err_detect_op_status {
+       RTE_MULTI_FN_ERR_DETECT_OP_STATUS_NOT_PROCESSED,
+       /**< Operation has not yet been processed by a device */
+       RTE_MULTI_FN_ERR_DETECT_OP_STATUS_SUCCESS,
+       /**< Operation completed successfully */
+       RTE_MULTI_FN_ERR_DETECT_OP_STATUS_VERIFY_FAILED,
+       /**< Verification failed */
+       RTE_MULTI_FN_ERR_DETECT_OP_STATUS_ERROR
+       /**< Error handling operation */
+};
+
+struct rte_multi_fn_err_detect_xform {
+       enum rte_multi_fn_err_detect_operation op;
+       /**< Error detection operation type */
+       enum rte_multi_fn_err_detect_algorithm algo;
+       /**< Error detection algorithm */
+       uint16_t err_detect_length;
+};
+
+/** Error Detection Operation */
+struct rte_multi_fn_err_detect_op {
+       struct rte_mbuf *m_src; /**< Source mbuf */
+       enum rte_multi_fn_err_detect_op_status status;
+       /**< Operation status */
+
+       struct {
+               uint16_t offset;
+               /**<
+                * Starting point for error detection processing, specified
+                * as the number of bytes from start of the packet in the
+                * source mbuf
+                */
+               uint16_t length;
+               /**<
+                * The length, in bytes, of the source mbuf on which the error
+                * detection operation will be computed
+                */
+       } data; /**< Data offset and length for error detection */
+
+       struct {
+               uint8_t *data;
+               /**<
+                * This points to the location where the error detection
+                * result should be written (in the case of generation) or
+                * where the purported result exists (in the case of
+                * verification)
+                *
+                * The caller must ensure the required length of physically
+                * contiguous memory is available at this address
+                *
+                * For a CRC, this may point into the mbuf packet data. For
+                * an operation such as a BIP, this may point to a memory
+                * location after the op
+                *
+                * For generation, the result will overwrite any data at this
+                * location
+                */
+               rte_iova_t phys_addr;
+               /**< Physical address of output data */
+       } output; /**< Output location */
+};
+
+/**
+ * Multi-function transform types
+ */
+enum rte_multi_fn_xform_type {
+       RTE_MULTI_FN_XFORM_TYPE_UNDEFINED,
+       /**< Undefined transform type */
+       RTE_MULTI_FN_XFORM_TYPE_CRYPTO_SYM,
+       /**< Symmetric crypto transform type */
+       RTE_MULTI_FN_XFORM_TYPE_CRYPTO_ASYM,
+       /**< Asymmetric crypto transform type */
+       RTE_MULTI_FN_XFORM_TYPE_COMP,
+       /**< Compression transform type */
+       RTE_MULTI_FN_XFORM_TYPE_ERR_DETECT
+       /**< Error detection transform type */
+};
+
+/**
+ * Multi-function transform setup data
+ *
+ * This structure is used to specify the multi-function transforms required.
+ * Multiple transforms can be chained together to specify a chain of transforms
+ * such as symmetric crypto followed by error detection, or compression 
followed
+ * by symmetric crypto. Each transform structure holds a single transform, with
+ * the type field specifying which transform is contained within the union.
+ */
+struct rte_multi_fn_xform {
+       struct rte_multi_fn_xform *next;
+       /**<
+        * Next transform in the chain
+        * - the last transform in the chain MUST set this to NULL
+        */
+       enum rte_multi_fn_xform_type type;
+       /**< Transform type */
+
+       RTE_STD_C11
+       union {
+               struct rte_crypto_sym_xform crypto_sym;
+               /**< Symmetric crypto transform */
+               struct rte_crypto_asym_xform crypto_asym;
+               /**< Asymmetric crypto transform */
+               struct rte_comp_xform comp;
+               /**< Compression transform */
+               struct rte_multi_fn_err_detect_xform err_detect;
+               /**< Error detection transform */
+       };
+};
+
+/**
+ * Multi-function operation status
+ */
+enum rte_multi_fn_op_status {
+       RTE_MULTI_FN_OP_STATUS_SUCCESS = 0,
+       /**< Operation completed successfully */
+       RTE_MULTI_FN_OP_STATUS_FAILURE,
+       /**< Operation completed with failure */
+       RTE_MULTI_FN_STATUS_INVALID_SESSION,
+       /**< Operation failed due to invalid session arguments */
+       RTE_MULTI_FN_OP_STATUS_NOT_PROCESSED,
+       /**< Operation has not yet been processed by a device */
+};
+
+/**
+ * Multi-function session
+ */
+struct rte_multi_fn_session {
+       void *sess_private_data;
+};
+
+/**
+ * Operation data
+ */
+struct rte_multi_fn_op {
+       struct rte_multi_fn_op *next;
+       /**<
+        * Next operation in the chain
+        * - the last operation in the chain MUST set this to NULL
+        */
+       struct rte_multi_fn_session *sess;
+       /**< Handle for the associated multi fn session */
+
+       struct rte_mempool *mempool;
+       /**< Mempool from which the operation is allocated */
+
+       struct rte_mbuf *m_src; /**< Source mbuf */
+       struct rte_mbuf *m_dst; /**< Destination mbuf */
+
+       enum rte_multi_fn_op_status overall_status;
+       /**<
+        * Overall operation status
+        * - indicates if all the operations in the chain succeeded or if any
+        *   one of them failed
+        */
+
+       uint8_t op_status;
+       /**<
+        * Individual operation status
+        * - indicates the status of the individual operation in the chain
+        */
+
+       RTE_STD_C11
+       union {
+               struct rte_crypto_sym_op crypto_sym;
+               /**< Symmetric crypto operation */
+               struct rte_crypto_asym_op crypto_asym;
+               /**< Asymmetric crypto operation */
+               struct rte_comp_op comp;
+               /**< Compression operation */
+               struct rte_multi_fn_err_detect_op err_detect;
+               /**< Error detection operation */
+       };
+};
+
+/**<
+ * Typedef of session create function pointer
+ */
+typedef struct rte_multi_fn_session *(*session_create)(
+               struct rte_rawdev *rawdev,
+               struct rte_multi_fn_xform *,
+               int);
+
+/**<
+ * Typedef of session destroy function pointer
+ */
+typedef int (*session_destroy)(
+               struct rte_rawdev *rawdev,
+               struct rte_multi_fn_session *);
+
+/**<
+ * Structure containing session create and destroy function
+ * pointers and device configuration data.
+ */
+struct rte_multi_fn_device_info {
+       session_create create;
+       /**< Create session function pointer */
+       session_destroy destroy;
+       /**< Destroy session function pointer */
+       rte_rawdev_obj_t config;
+       /**< Device config info data pointer */
+};
+
+/**<
+ * Device configuration struct. Pass to rte_rawdev_configure()
+ */
+struct rte_multi_fn_dev_config {
+       uint16_t nb_queues; /**< Number of queue pairs to config */
+       unsigned int socket_id; /**< Socket to allocate queue on */
+};
+
+/**<
+ * Queue pair configuration struct. Passed to rte_rawdev_queue_setup()
+ */
+struct rte_multi_fn_qp_config {
+       uint32_t nb_descriptors; /**< Number of descriptors per queue pair */
+};
+
+/**
+ * Create multi-function session as specified by the transform chain
+ *
+ * @param   dev_id     The identifier of the device.
+ * @param   dev_info   Device info, obtained by calling rte_info_get()
+ * @param   xform      Pointer to the first element of the session transform
+ *                     chain
+ * @param   socket_id  Socket to allocate the session on
+ *
+ * @return
+ *  - Pointer to session, if successful
+ *  - NULL, on failure
+ */
+__rte_experimental
+struct rte_multi_fn_session *
+rte_multi_fn_session_create(uint16_t dev_id,
+                               struct rte_rawdev_info *dev_info,
+                               struct rte_multi_fn_xform *xform,
+                               int socket_id);
+
+/**
+ * Free memory associated with a multi-function session
+ *
+ * @param   dev_id     The identifier of the device.
+ * @param   dev_info   Device info, obtained by calling rte_info_get()
+ * @param   sess       Multi-function session to be freed
+ *
+ * @return
+ *  - 0, if successful
+ *  - -EINVAL, if session is NULL
+ *  - -EBUSY, if not all session data has been freed
+ */
+__rte_experimental
+int
+rte_multi_fn_session_destroy(uint16_t dev_id,
+                               struct rte_rawdev_info *dev_info,
+                               struct rte_multi_fn_session *sess);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* _RTE_MULTI_FN_H_ */
diff --git a/mk/rte.app.mk b/mk/rte.app.mk
index d295ca0..117fe6a 100644
--- a/mk/rte.app.mk
+++ b/mk/rte.app.mk
@@ -98,6 +98,7 @@ _LDLIBS-$(CONFIG_RTE_LIBRTE_CMDLINE)        += -lrte_cmdline
 _LDLIBS-$(CONFIG_RTE_LIBRTE_REORDER)        += -lrte_reorder
 _LDLIBS-$(CONFIG_RTE_LIBRTE_SCHED)          += -lrte_sched
 _LDLIBS-$(CONFIG_RTE_LIBRTE_RCU)            += -lrte_rcu
+_LDLIBS-y += -lrte_multi_fn
 
 ifeq ($(CONFIG_RTE_EXEC_ENV_LINUX),y)
 _LDLIBS-$(CONFIG_RTE_LIBRTE_KNI)            += -lrte_kni
-- 
1.7.0.7

Reply via email to