The purpose of this testcase is to showcase the cryptodev
enqueue callback usage with RCU support.

Signed-off-by: Abhinandan Gujjar <abhinandan.guj...@intel.com>
---
 app/test/test_cryptodev.c | 123 +++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 122 insertions(+), 1 deletion(-)

diff --git a/app/test/test_cryptodev.c b/app/test/test_cryptodev.c
index 70bf6fe..735f501 100644
--- a/app/test/test_cryptodev.c
+++ b/app/test/test_cryptodev.c
@@ -17,6 +17,7 @@
 #include <rte_cryptodev.h>
 #include <rte_cryptodev_pmd.h>
 #include <rte_string_fns.h>
+#include <rte_rcu_qsbr.h>
 
 #ifdef RTE_LIBRTE_PMD_CRYPTO_SCHEDULER
 #include <rte_cryptodev_scheduler.h>
@@ -11889,6 +11890,123 @@ struct test_crypto_vector {
        return 0;
 }
 
+#ifdef RTE_CRYPTODEV_CALLBACKS
+static uint16_t
+test_enq_callback(uint16_t dev_id, uint16_t qp_id, struct rte_crypto_op **ops,
+             uint16_t nb_ops, void *user_param)
+{
+       RTE_SET_USED(dev_id);
+       RTE_SET_USED(qp_id);
+       RTE_SET_USED(ops);
+       RTE_SET_USED(user_param);
+
+       return nb_ops;
+}
+
+/*
+ * Thread using enqueue callback with RCU.
+ */
+static int
+test_enq_callback_rcu_thread(void *arg)
+{
+       uint16_t thread_id = 1;
+       struct rte_rcu_qsbr *qsbr = arg;
+
+       /* Register this thread to report quiescent state */
+       rte_rcu_qsbr_thread_register(qsbr, thread_id);
+       rte_rcu_qsbr_thread_online(qsbr, thread_id);
+
+
+       /* DP thread calls rte_cryptodev_enqueue_burst() and
+        * invokes enqueue callback.
+        */
+       test_null_burst_operation();
+
+       /* Update quiescent state */
+       rte_rcu_qsbr_quiescent(qsbr, thread_id);
+
+       rte_rcu_qsbr_thread_offline(qsbr, thread_id);
+       rte_rcu_qsbr_thread_unregister(qsbr, thread_id);
+
+       return 0;
+}
+
+static int
+test_enq_callback_setup(void)
+{
+       struct crypto_testsuite_params *ts_params = &testsuite_params;
+       struct rte_cryptodev_info dev_info;
+       struct rte_cryptodev_qp_conf qp_conf = {
+               .nb_descriptors = MAX_NUM_OPS_INFLIGHT
+       };
+
+       struct rte_cryptodev_enq_callback *cb;
+       uint16_t max_threads = 2;
+       uint16_t qp_id = 0;
+       struct rte_rcu_qsbr *qsbr;
+       size_t size;
+
+       /* Stop the device in case it's started so it can be configured */
+       rte_cryptodev_stop(ts_params->valid_devs[0]);
+
+       rte_cryptodev_info_get(ts_params->valid_devs[0], &dev_info);
+
+       TEST_ASSERT_SUCCESS(rte_cryptodev_configure(ts_params->valid_devs[0],
+                       &ts_params->conf),
+                       "Failed to configure cryptodev %u",
+                       ts_params->valid_devs[0]);
+
+       qp_conf.nb_descriptors = MAX_NUM_OPS_INFLIGHT;
+       qp_conf.mp_session = ts_params->session_mpool;
+       qp_conf.mp_session_private = ts_params->session_priv_mpool;
+
+       TEST_ASSERT_SUCCESS(rte_cryptodev_queue_pair_setup(
+                       ts_params->valid_devs[0], qp_id, &qp_conf,
+                       rte_cryptodev_socket_id(ts_params->valid_devs[0])),
+                       "Failed test for "
+                       "rte_cryptodev_queue_pair_setup: num_inflights "
+                       "%u on qp %u on cryptodev %u",
+                       qp_conf.nb_descriptors, qp_id,
+                       ts_params->valid_devs[0]);
+
+       cb = rte_cryptodev_add_enq_callback(ts_params->valid_devs[0],
+                       qp_id, test_enq_callback, NULL);
+       TEST_ASSERT_NOT_NULL(cb, "Failed test to add callback on "
+                       "qp %u on cryptodev %u",
+                       qp_id, ts_params->valid_devs[0]);
+
+       /* Create RCU QSBR variable */
+       size = rte_rcu_qsbr_get_memsize(max_threads);
+       qsbr = (struct rte_rcu_qsbr *)rte_zmalloc_socket(NULL, size,
+                               RTE_CACHE_LINE_SIZE, SOCKET_ID_ANY);
+       TEST_ASSERT_NOT_NULL(qsbr, "Failed to allocate memory for qsbr");
+
+       /* Assign QSBR to cryptodev */
+       TEST_ASSERT_SUCCESS(rte_cryptodev_rcu_qsbr_add(
+                       ts_params->valid_devs[0], qsbr),
+                       "Failed to setup RCU QSBR for cryptodev %u",
+                       ts_params->valid_devs[0]);
+
+       TEST_ASSERT_SUCCESS(rte_rcu_qsbr_init(qsbr, max_threads),
+                       "RCU QSBR init failed");
+
+       /* Launch a thread */
+       rte_eal_remote_launch(test_enq_callback_rcu_thread, qsbr,
+                               rte_get_next_lcore(-1, 1, 0));
+
+       /* Wait until reader exited. */
+       rte_eal_mp_wait_lcore();
+
+       TEST_ASSERT_SUCCESS(rte_cryptodev_remove_enq_callback(
+                       ts_params->valid_devs[0], qp_id, cb),
+                       "Failed test to remove callback on "
+                       "qp %u on cryptodev %u",
+                       qp_id, ts_params->valid_devs[0]);
+
+       return TEST_SUCCESS;
+}
+#endif
+
 static struct unit_test_suite cryptodev_scheduler_testsuite  = {
        .suite_name = "Crypto Device Scheduler Unit Test Suite",
        .setup = testsuite_setup,
@@ -11943,7 +12061,10 @@ struct test_crypto_vector {
                                test_queue_pair_descriptor_setup),
                TEST_CASE_ST(ut_setup, ut_teardown,
                                test_device_configure_invalid_queue_pair_ids),
-
+#ifdef RTE_CRYPTODEV_CALLBACKS
+               TEST_CASE_ST(ut_setup, ut_teardown,
+                               test_enq_callback_setup),
+#endif
                TEST_CASE_ST(ut_setup, ut_teardown,
                                test_multi_session),
                TEST_CASE_ST(ut_setup, ut_teardown,
-- 
1.9.1

Reply via email to