Improve the robustness of setting thread affinity in DPDK
by adding detailed error logging.

Changes:
1. Check the return value of pthread_setaffinity_np() and log an error
if the call fails.
2. Include the current thread name, the intended CPU set, and a detailed
error message in the log.

Sample prints:
EAL: Cannot set affinity for thread dpdk-test with cpus 0,
ret: 22, errno: 0, error description: Success
EAL: Cannot set affinity for thread dpdk-worker1 with cpus 1,
ret: 22, errno: 0, error description: Success

Signed-off-by: Jianyue Wu <wujianyue...@163.com>
---
 lib/eal/unix/rte_thread.c | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/lib/eal/unix/rte_thread.c b/lib/eal/unix/rte_thread.c
index 1b4c73f58e..8f9eaf0dcf 100644
--- a/lib/eal/unix/rte_thread.c
+++ b/lib/eal/unix/rte_thread.c
@@ -369,8 +369,26 @@ int
 rte_thread_set_affinity_by_id(rte_thread_t thread_id,
                const rte_cpuset_t *cpuset)
 {
-       return pthread_setaffinity_np((pthread_t)thread_id.opaque_id,
-               sizeof(*cpuset), cpuset);
+       int ret;
+       char cpus_str[RTE_CPU_AFFINITY_STR_LEN] = {'\0'};
+       char thread_name[RTE_MAX_THREAD_NAME_LEN] = {'\0'};
+
+       errno = 0;
+       ret = pthread_setaffinity_np((pthread_t)thread_id.opaque_id,
+                               sizeof(*cpuset), cpuset);
+       if (ret != 0) {
+               if (pthread_getname_np((pthread_t)thread_id.opaque_id,
+                                       thread_name, sizeof(thread_name)) != 0)
+                       EAL_LOG(ERR, "pthread_getname_np failed!");
+               if (eal_thread_dump_affinity(cpuset, cpus_str, 
RTE_CPU_AFFINITY_STR_LEN) != 0)
+                       EAL_LOG(ERR, "eal_thread_dump_affinity failed!");
+               EAL_LOG(ERR, "Cannot set affinity for thread %s with cpus %s, "
+                       "ret: %d, errno: %d, error description: %s",
+                       thread_name, cpus_str,
+                       ret, errno, strerror(errno));
+       }
+
+       return ret;
 }
 
 int
-- 
2.34.1

Reply via email to