1 /* SPDX-License-Identifier: BSD-3-Clause
2 * Copyright(c) 2019 Intel Corporation
12 * This file is required to support the common code in eal_common_proc.c,
13 * eal_common_thread.c and common\include\rte_per_lcore.h as Microsoft libc
14 * does not contain pthread.h. This may be removed in future releases.
20 #include <rte_common.h>
21 #include <rte_windows.h>
23 #define PTHREAD_BARRIER_SERIAL_THREAD TRUE
25 /* defining pthread_t type on Windows since there is no in Microsoft libc*/
26 typedef uintptr_t pthread_t;
28 /* defining pthread_attr_t type on Windows since there is no in Microsoft libc*/
29 typedef void *pthread_attr_t;
31 typedef SYNCHRONIZATION_BARRIER pthread_barrier_t;
33 #define pthread_barrier_init(barrier, attr, count) \
34 InitializeSynchronizationBarrier(barrier, count, -1)
35 #define pthread_barrier_wait(barrier) EnterSynchronizationBarrier(barrier, \
36 SYNCHRONIZATION_BARRIER_FLAGS_BLOCK_ONLY)
37 #define pthread_barrier_destroy(barrier) \
38 DeleteSynchronizationBarrier(barrier)
39 #define pthread_cancel(thread) TerminateThread((HANDLE) thread, 0)
41 /* pthread function overrides */
42 #define pthread_self() \
43 ((pthread_t)GetCurrentThreadId())
46 pthread_setaffinity_np(pthread_t threadid, size_t cpuset_size,
52 if (cpuset == NULL || cpuset_size == 0)
55 thread_handle = OpenThread(THREAD_ALL_ACCESS, FALSE, threadid);
56 if (thread_handle == NULL) {
57 RTE_LOG_WIN32_ERR("OpenThread()");
61 ret = SetThreadAffinityMask(thread_handle, *cpuset->_bits);
63 RTE_LOG_WIN32_ERR("SetThreadAffinityMask()");
68 if (CloseHandle(thread_handle) == 0) {
69 RTE_LOG_WIN32_ERR("CloseHandle()");
72 return (ret == 0) ? -1 : 0;
76 pthread_getaffinity_np(pthread_t threadid, size_t cpuset_size,
79 /* Workaround for the lack of a GetThreadAffinityMask()
82 DWORD_PTR prev_affinity_mask;
86 if (cpuset == NULL || cpuset_size == 0)
89 thread_handle = OpenThread(THREAD_ALL_ACCESS, FALSE, threadid);
90 if (thread_handle == NULL) {
91 RTE_LOG_WIN32_ERR("OpenThread()");
95 /* obtain previous mask by setting dummy mask */
96 prev_affinity_mask = SetThreadAffinityMask(thread_handle, 0x1);
97 if (prev_affinity_mask == 0) {
98 RTE_LOG_WIN32_ERR("SetThreadAffinityMask()");
103 ret = SetThreadAffinityMask(thread_handle, prev_affinity_mask);
105 RTE_LOG_WIN32_ERR("SetThreadAffinityMask()");
109 memset(cpuset, 0, cpuset_size);
110 *cpuset->_bits = prev_affinity_mask;
113 if (CloseHandle(thread_handle) == 0) {
114 RTE_LOG_WIN32_ERR("SetThreadAffinityMask()");
117 return (ret == 0) ? -1 : 0;
121 pthread_create(void *threadid, const void *threadattr, void *threadfunc,
124 RTE_SET_USED(threadattr);
126 hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)threadfunc,
127 args, 0, (LPDWORD)threadid);
129 SetPriorityClass(GetCurrentProcess(), REALTIME_PRIORITY_CLASS);
130 SetThreadPriority(hThread, THREAD_PRIORITY_TIME_CRITICAL);
132 return ((hThread != NULL) ? 0 : E_FAIL);
136 pthread_join(__rte_unused pthread_t thread,
137 __rte_unused void **value_ptr)
146 #endif /* _PTHREAD_H_ */