test basic functionality and demonstrate use of following thread
attributes api. additionally, test attributes are processed when
supplied to rte_thread_create().
* rte_thread_attr_init
* rte_thread_attr_set_affinity
* rte_thread_attr_get_affinity
* rte_thread_attr_set_priority
Signed-off-by: Narcisa Vasile <navas...@microsoft.com>
Signed-off-by: Tyler Retzlaff <roret...@linux.microsoft.com>
---
app/test/test_threads.c | 73 ++++++++++++++++++++++++++++++++++++++++++++++++-
1 file changed, 72 insertions(+), 1 deletion(-)
diff --git a/app/test/test_threads.c b/app/test/test_threads.c
index 9a30af5..92a149a 100644
--- a/app/test/test_threads.c
+++ b/app/test/test_threads.c
@@ -17,7 +17,9 @@
static void *
thread_main(void *arg)
{
- *(rte_thread_t *)arg = rte_thread_self();
+ if (arg != NULL)
+ *(rte_thread_t *)arg = rte_thread_self();
+
__atomic_store_n(&thread_id_ready, 1, __ATOMIC_RELEASE);
while (__atomic_load_n(&thread_id_ready, __ATOMIC_ACQUIRE) == 1)
@@ -166,6 +168,73 @@
return 0;
}
+static int
+test_thread_attributes_affinity(void)
+{
+ rte_thread_t thread_id;
+ rte_thread_attr_t attr;
+ rte_cpuset_t cpuset0;
+ rte_cpuset_t cpuset1;
+
+ RTE_TEST_ASSERT(rte_thread_attr_init(&attr) == 0,
+ "Failed to initialize thread attributes");
+
+ CPU_ZERO(&cpuset0);
+ RTE_TEST_ASSERT(rte_thread_get_affinity_by_id(rte_thread_self(),
&cpuset0) == 0,
+ "Failed to get thread affinity");
+ RTE_TEST_ASSERT(rte_thread_attr_set_affinity(&attr, &cpuset0) == 0,
+ "Failed to set thread attributes affinity");
+ RTE_TEST_ASSERT(rte_thread_attr_get_affinity(&attr, &cpuset1) == 0,
+ "Failed to get thread attributes affinity");
+ RTE_TEST_ASSERT(memcmp(&cpuset0, &cpuset1, sizeof(rte_cpuset_t)) == 0,
+ "Affinity should be stable");
+
+ thread_id_ready = 0;
+ RTE_TEST_ASSERT(rte_thread_create(&thread_id, &attr, thread_main, NULL)
== 0,
+ "Failed to create attributes affinity thread.");
+
+ while (__atomic_load_n(&thread_id_ready, __ATOMIC_ACQUIRE) == 0)
+ ;
+
+ RTE_TEST_ASSERT(rte_thread_get_affinity_by_id(thread_id, &cpuset1) == 0,
+ "Failed to get attributes thread affinity");
+ RTE_TEST_ASSERT(memcmp(&cpuset0, &cpuset1, sizeof(rte_cpuset_t)) == 0,
+ "Failed to apply affinity attributes");
+
+ __atomic_store_n(&thread_id_ready, 2, __ATOMIC_RELEASE);
+
+ return 0;
+}
+
+static int
+test_thread_attributes_priority(void)
+{
+ rte_thread_t thread_id;
+ rte_thread_attr_t attr;
+ enum rte_thread_priority priority;
+
+ RTE_TEST_ASSERT(rte_thread_attr_init(&attr) == 0,
+ "Failed to initialize thread attributes");
+ RTE_TEST_ASSERT(rte_thread_attr_set_priority(&attr,
RTE_THREAD_PRIORITY_NORMAL) == 0,
+ "Failed to set thread attributes priority");
+
+ thread_id_ready = 0;
+ RTE_TEST_ASSERT(rte_thread_create(&thread_id, &attr, thread_main, NULL)
== 0,
+ "Failed to create attributes priority thread.");
+
+ while (__atomic_load_n(&thread_id_ready, __ATOMIC_ACQUIRE) == 0)
+ ;
+
+ RTE_TEST_ASSERT(rte_thread_get_priority(thread_id, &priority) == 0,
+ "Failed to get thread priority");
+ RTE_TEST_ASSERT(priority == RTE_THREAD_PRIORITY_NORMAL,
+ "Failed to apply priority attributes");
+
+ __atomic_store_n(&thread_id_ready, 2, __ATOMIC_RELEASE);
+
+ return 0;
+}
+
static struct unit_test_suite threads_test_suite = {
.suite_name = "threads autotest",
.setup = NULL,
@@ -175,6 +244,8 @@
TEST_CASE(test_thread_create_detach),
TEST_CASE(test_thread_affinity),
TEST_CASE(test_thread_priority),
+ TEST_CASE(test_thread_attributes_affinity),
+ TEST_CASE(test_thread_attributes_priority),
TEST_CASES_END()
}
};
--
1.8.3.1
