blob: 13ab769ba93d0eafc23eb1f3e87c90258d2e3c24 [file] [log] [blame]
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +00001// -*- C++ -*-
2//===----------------------------------------------------------------------===//
3//
4// The LLVM Compiler Infrastructure
5//
6// This file is dual licensed under the MIT and the University of Illinois Open
7// Source Licenses. See LICENSE.TXT for details.
8//
9//===----------------------------------------------------------------------===//
10
11#ifndef _LIBCPP_THREADING_SUPPORT
12#define _LIBCPP_THREADING_SUPPORT
13
14#include <__config>
15
16#ifndef _LIBCPP_HAS_NO_PRAGMA_SYSTEM_HEADER
17#pragma GCC system_header
18#endif
19
Asiri Rathnayake040945b2016-09-11 21:46:40 +000020#if defined(_LIBCPP_HAS_THREAD_API_EXTERNAL)
Eric Fiselier66134e82017-01-06 20:05:40 +000021# include <__external_threading>
22#elif !defined(_LIBCPP_HAS_NO_THREADS)
23
24#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD)
25# include <pthread.h>
26# include <sched.h>
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +000027#elif defined(_LIBCPP_HAS_THREAD_API_WIN32)
28#include <assert.h>
29#include <Windows.h>
30#include <process.h>
31#include <fibersapi.h>
32
33#include <chrono>
Eric Fiselier66134e82017-01-06 20:05:40 +000034#endif
35
36#if defined(_LIBCPP_HAS_THREAD_LIBRARY_EXTERNAL) || \
37 defined(_LIBCPP_BUILDING_THREAD_LIBRARY_EXTERNAL)
Asiri Rathnayake040945b2016-09-11 21:46:40 +000038#define _LIBCPP_THREAD_ABI_VISIBILITY _LIBCPP_FUNC_VIS
39#else
40#define _LIBCPP_THREAD_ABI_VISIBILITY inline _LIBCPP_INLINE_VISIBILITY
41#endif
42
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +000043_LIBCPP_BEGIN_NAMESPACE_STD
44
Eric Fiselier66134e82017-01-06 20:05:40 +000045#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +000046// Mutex
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +000047typedef pthread_mutex_t __libcpp_mutex_t;
Asiri Rathnayake040945b2016-09-11 21:46:40 +000048#define _LIBCPP_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +000049
Saleem Abdulrasool3451a652017-01-05 17:54:45 +000050typedef pthread_mutex_t __libcpp_recursive_mutex_t;
51
Saleem Abdulrasool1d192372017-01-03 02:00:31 +000052// Condition Variable
Asiri Rathnayake040945b2016-09-11 21:46:40 +000053typedef pthread_cond_t __libcpp_condvar_t;
54#define _LIBCPP_CONDVAR_INITIALIZER PTHREAD_COND_INITIALIZER
Saleem Abdulrasool1d192372017-01-03 02:00:31 +000055
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +000056// Execute once
57typedef pthread_once_t __libcpp_exec_once_flag;
58#define _LIBCPP_EXEC_ONCE_INITIALIZER PTHREAD_ONCE_INIT
59
60// Thread id
Saleem Abdulrasool1d192372017-01-03 02:00:31 +000061typedef pthread_t __libcpp_thread_id;
62
63// Thread
Asiri Rathnayakea1d7d2f2017-01-16 12:19:54 +000064#define _LIBCPP_NULL_THREAD 0U
65
Saleem Abdulrasool1d192372017-01-03 02:00:31 +000066typedef pthread_t __libcpp_thread_t;
67
68// Thrad Local Storage
69typedef pthread_key_t __libcpp_tls_key;
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +000070
71#define _LIBCPP_TLS_DESTRUCTOR_CC
72#else
73// Mutex
74typedef SRWLOCK __libcpp_mutex_t;
75#define _LIBCPP_MUTEX_INITIALIZER SRWLOCK_INIT
76
77typedef CRITICAL_SECTION __libcpp_recursive_mutex_t;
78
79// Condition Variable
80typedef CONDITION_VARIABLE __libcpp_condvar_t;
81#define _LIBCPP_CONDVAR_INITIALIZER CONDITION_VARIABLE_INIT
82
83// Execute Once
84typedef INIT_ONCE __libcpp_exec_once_flag;
85#define _LIBCPP_EXEC_ONCE_INITIALIZER INIT_ONCE_STATIC_INIT
86
87// Thread ID
88typedef DWORD __libcpp_thread_id;
89
90// Thread
Asiri Rathnayakea1d7d2f2017-01-16 12:19:54 +000091#define _LIBCPP_NULL_THREAD 0U
92
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +000093typedef HANDLE __libcpp_thread_t;
94
95// Thread Local Storage
96typedef DWORD __libcpp_tls_key;
97
98#define _LIBCPP_TLS_DESTRUCTOR_CC WINAPI
Saleem Abdulrasool1d192372017-01-03 02:00:31 +000099#endif
100
101// Mutex
102_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000103int __libcpp_recursive_mutex_init(__libcpp_recursive_mutex_t *__m);
104
105_LIBCPP_THREAD_ABI_VISIBILITY
106int __libcpp_recursive_mutex_lock(__libcpp_recursive_mutex_t *__m);
107
108_LIBCPP_THREAD_ABI_VISIBILITY
Eric Fiselier30d12e32017-01-14 10:27:12 +0000109bool __libcpp_recursive_mutex_trylock(__libcpp_recursive_mutex_t *__m);
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000110
111_LIBCPP_THREAD_ABI_VISIBILITY
112int __libcpp_recursive_mutex_unlock(__libcpp_recursive_mutex_t *__m);
113
114_LIBCPP_THREAD_ABI_VISIBILITY
115int __libcpp_recursive_mutex_destroy(__libcpp_recursive_mutex_t *__m);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000116
117_LIBCPP_THREAD_ABI_VISIBILITY
118int __libcpp_mutex_lock(__libcpp_mutex_t *__m);
119
120_LIBCPP_THREAD_ABI_VISIBILITY
Eric Fiselier30d12e32017-01-14 10:27:12 +0000121bool __libcpp_mutex_trylock(__libcpp_mutex_t *__m);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000122
123_LIBCPP_THREAD_ABI_VISIBILITY
124int __libcpp_mutex_unlock(__libcpp_mutex_t *__m);
125
126_LIBCPP_THREAD_ABI_VISIBILITY
127int __libcpp_mutex_destroy(__libcpp_mutex_t *__m);
128
129// Condition variable
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000130_LIBCPP_THREAD_ABI_VISIBILITY
131int __libcpp_condvar_signal(__libcpp_condvar_t* __cv);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000132
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000133_LIBCPP_THREAD_ABI_VISIBILITY
134int __libcpp_condvar_broadcast(__libcpp_condvar_t* __cv);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000135
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000136_LIBCPP_THREAD_ABI_VISIBILITY
137int __libcpp_condvar_wait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000138
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000139_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000140int __libcpp_condvar_timedwait(__libcpp_condvar_t *__cv, __libcpp_mutex_t *__m,
141 timespec *__ts);
142
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000143_LIBCPP_THREAD_ABI_VISIBILITY
144int __libcpp_condvar_destroy(__libcpp_condvar_t* __cv);
145
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +0000146// Execute once
147_LIBCPP_THREAD_ABI_VISIBILITY
148int __libcpp_execute_once(__libcpp_exec_once_flag *flag,
149 void (*init_routine)(void));
150
151// Thread id
152#if defined(__APPLE__) && !defined(__arm__)
153_LIBCPP_THREAD_ABI_VISIBILITY
154mach_port_t __libcpp_thread_get_port();
155#endif
156
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000157_LIBCPP_THREAD_ABI_VISIBILITY
158bool __libcpp_thread_id_equal(__libcpp_thread_id t1, __libcpp_thread_id t2);
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000159
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000160_LIBCPP_THREAD_ABI_VISIBILITY
161bool __libcpp_thread_id_less(__libcpp_thread_id t1, __libcpp_thread_id t2);
162
163// Thread
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000164_LIBCPP_THREAD_ABI_VISIBILITY
Asiri Rathnayakea1d7d2f2017-01-16 12:19:54 +0000165bool __libcpp_thread_isnull(const __libcpp_thread_t *__t);
166
167_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000168int __libcpp_thread_create(__libcpp_thread_t *__t, void *(*__func)(void *),
169 void *__arg);
170
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000171_LIBCPP_THREAD_ABI_VISIBILITY
172__libcpp_thread_id __libcpp_thread_get_current_id();
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000173
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000174_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000175__libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t *__t);
176
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000177_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000178int __libcpp_thread_join(__libcpp_thread_t *__t);
179
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000180_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000181int __libcpp_thread_detach(__libcpp_thread_t *__t);
182
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000183_LIBCPP_THREAD_ABI_VISIBILITY
184void __libcpp_thread_yield();
185
186// Thread local storage
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000187_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000188int __libcpp_tls_create(__libcpp_tls_key* __key,
189 void(_LIBCPP_TLS_DESTRUCTOR_CC* __at_exit)(void*));
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000190
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000191_LIBCPP_THREAD_ABI_VISIBILITY
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000192void *__libcpp_tls_get(__libcpp_tls_key __key);
193
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000194_LIBCPP_THREAD_ABI_VISIBILITY
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +0000195int __libcpp_tls_set(__libcpp_tls_key __key, void *__p);
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000196
Eric Fiselier66134e82017-01-06 20:05:40 +0000197#if !defined(_LIBCPP_HAS_THREAD_LIBRARY_EXTERNAL) || \
198 defined(_LIBCPP_BUILDING_THREAD_LIBRARY_EXTERNAL)
199
200#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD)
Asiri Rathnayake040945b2016-09-11 21:46:40 +0000201
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000202int __libcpp_recursive_mutex_init(__libcpp_recursive_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000203{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000204 pthread_mutexattr_t attr;
205 int __ec = pthread_mutexattr_init(&attr);
206 if (__ec)
207 return __ec;
208 __ec = pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
209 if (__ec) {
210 pthread_mutexattr_destroy(&attr);
211 return __ec;
212 }
213 __ec = pthread_mutex_init(__m, &attr);
214 if (__ec) {
215 pthread_mutexattr_destroy(&attr);
216 return __ec;
217 }
218 __ec = pthread_mutexattr_destroy(&attr);
219 if (__ec) {
220 pthread_mutex_destroy(__m);
221 return __ec;
222 }
223 return 0;
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000224}
225
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000226int __libcpp_recursive_mutex_lock(__libcpp_recursive_mutex_t *__m)
227{
228 return pthread_mutex_lock(__m);
229}
230
Eric Fiselier30d12e32017-01-14 10:27:12 +0000231bool __libcpp_recursive_mutex_trylock(__libcpp_recursive_mutex_t *__m)
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000232{
Eric Fiselier30d12e32017-01-14 10:27:12 +0000233 return pthread_mutex_trylock(__m) == 0;
Saleem Abdulrasool3451a652017-01-05 17:54:45 +0000234}
235
236int __libcpp_recursive_mutex_unlock(__libcpp_mutex_t *__m)
237{
238 return pthread_mutex_unlock(__m);
239}
240
241int __libcpp_recursive_mutex_destroy(__libcpp_recursive_mutex_t *__m)
242{
243 return pthread_mutex_destroy(__m);
244}
245
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000246int __libcpp_mutex_lock(__libcpp_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000247{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000248 return pthread_mutex_lock(__m);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000249}
250
Eric Fiselier30d12e32017-01-14 10:27:12 +0000251bool __libcpp_mutex_trylock(__libcpp_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000252{
Eric Fiselier30d12e32017-01-14 10:27:12 +0000253 return pthread_mutex_trylock(__m) == 0;
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000254}
255
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000256int __libcpp_mutex_unlock(__libcpp_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000257{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000258 return pthread_mutex_unlock(__m);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000259}
260
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000261int __libcpp_mutex_destroy(__libcpp_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000262{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000263 return pthread_mutex_destroy(__m);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000264}
265
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000266// Condition Variable
267int __libcpp_condvar_signal(__libcpp_condvar_t *__cv)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000268{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000269 return pthread_cond_signal(__cv);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000270}
271
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000272int __libcpp_condvar_broadcast(__libcpp_condvar_t *__cv)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000273{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000274 return pthread_cond_broadcast(__cv);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000275}
276
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000277int __libcpp_condvar_wait(__libcpp_condvar_t *__cv, __libcpp_mutex_t *__m)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000278{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000279 return pthread_cond_wait(__cv, __m);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000280}
281
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000282int __libcpp_condvar_timedwait(__libcpp_condvar_t *__cv, __libcpp_mutex_t *__m,
283 timespec *__ts)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000284{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000285 return pthread_cond_timedwait(__cv, __m, __ts);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000286}
287
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000288int __libcpp_condvar_destroy(__libcpp_condvar_t *__cv)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000289{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000290 return pthread_cond_destroy(__cv);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000291}
292
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +0000293// Execute once
294int __libcpp_execute_once(__libcpp_exec_once_flag *flag,
295 void (*init_routine)(void)) {
296 return pthread_once(flag, init_routine);
297}
298
299// Thread id
300#if defined(__APPLE__) && !defined(__arm__)
301mach_port_t __libcpp_thread_get_port() {
302 return pthread_mach_thread_np(pthread_self());
303}
304#endif
305
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000306// Returns non-zero if the thread ids are equal, otherwise 0
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000307bool __libcpp_thread_id_equal(__libcpp_thread_id t1, __libcpp_thread_id t2)
308{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000309 return pthread_equal(t1, t2) != 0;
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000310}
311
312// Returns non-zero if t1 < t2, otherwise 0
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000313bool __libcpp_thread_id_less(__libcpp_thread_id t1, __libcpp_thread_id t2)
314{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000315 return t1 < t2;
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000316}
317
318// Thread
Asiri Rathnayakea1d7d2f2017-01-16 12:19:54 +0000319bool __libcpp_thread_isnull(const __libcpp_thread_t *__t) {
320 return *__t == 0;
321}
322
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000323int __libcpp_thread_create(__libcpp_thread_t *__t, void *(*__func)(void *),
324 void *__arg)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000325{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000326 return pthread_create(__t, 0, __func, __arg);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000327}
328
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000329__libcpp_thread_id __libcpp_thread_get_current_id()
330{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000331 return pthread_self();
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000332}
333
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000334__libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t *__t)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000335{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000336 return *__t;
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000337}
338
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000339int __libcpp_thread_join(__libcpp_thread_t *__t)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000340{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000341 return pthread_join(*__t, 0);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000342}
343
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000344int __libcpp_thread_detach(__libcpp_thread_t *__t)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000345{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000346 return pthread_detach(*__t);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000347}
348
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000349void __libcpp_thread_yield()
350{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000351 sched_yield();
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000352}
353
354// Thread local storage
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000355int __libcpp_tls_create(__libcpp_tls_key *__key, void (*__at_exit)(void *))
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000356{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000357 return pthread_key_create(__key, __at_exit);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000358}
359
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000360void *__libcpp_tls_get(__libcpp_tls_key __key)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000361{
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000362 return pthread_getspecific(__key);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000363}
364
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +0000365int __libcpp_tls_set(__libcpp_tls_key __key, void *__p)
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000366{
Asiri Rathnayakee262e7b2017-01-03 12:59:50 +0000367 return pthread_setspecific(__key, __p);
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000368}
369
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000370#elif defined(_LIBCPP_HAS_THREAD_API_WIN32)
371
372// Mutex
373int __libcpp_recursive_mutex_init(__libcpp_recursive_mutex_t *__m)
374{
375 InitializeCriticalSection(__m);
376 return 0;
377}
378
379int __libcpp_recursive_mutex_lock(__libcpp_recursive_mutex_t *__m)
380{
381 EnterCriticalSection(__m);
382 return 0;
383}
384
Eric Fiselier30d12e32017-01-14 10:27:12 +0000385bool __libcpp_recursive_mutex_trylock(__libcpp_recursive_mutex_t *__m)
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000386{
Eric Fiselier30d12e32017-01-14 10:27:12 +0000387 return TryEnterCriticalSection(__m) != 0;
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000388}
389
390int __libcpp_recursive_mutex_unlock(__libcpp_recursive_mutex_t *__m)
391{
392 LeaveCriticalSection(__m);
393 return 0;
394}
395
396int __libcpp_recursive_mutex_destroy(__libcpp_recursive_mutex_t *__m)
397{
Saleem Abdulrasool1d324082017-01-10 04:18:47 +0000398 DeleteCriticalSection(__m);
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000399 return 0;
400}
401
402int __libcpp_mutex_lock(__libcpp_mutex_t *__m)
403{
404 AcquireSRWLockExclusive(__m);
405 return 0;
406}
407
Eric Fiselier30d12e32017-01-14 10:27:12 +0000408bool __libcpp_mutex_trylock(__libcpp_mutex_t *__m)
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000409{
Eric Fiselier30d12e32017-01-14 10:27:12 +0000410 return TryAcquireSRWLockExclusive(__m) != 0;
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000411}
412
413int __libcpp_mutex_unlock(__libcpp_mutex_t *__m)
414{
415 ReleaseSRWLockExclusive(__m);
416 return 0;
417}
418
419int __libcpp_mutex_destroy(__libcpp_mutex_t *__m)
420{
421 static_cast<void>(__m);
422 return 0;
423}
424
425// Condition Variable
426int __libcpp_condvar_signal(__libcpp_condvar_t *__cv)
427{
428 WakeConditionVariable(__cv);
429 return 0;
430}
431
432int __libcpp_condvar_broadcast(__libcpp_condvar_t *__cv)
433{
434 WakeAllConditionVariable(__cv);
435 return 0;
436}
437
438int __libcpp_condvar_wait(__libcpp_condvar_t *__cv, __libcpp_mutex_t *__m)
439{
440 SleepConditionVariableSRW(__cv, __m, INFINITE, 0);
441 return 0;
442}
443
444int __libcpp_condvar_timedwait(__libcpp_condvar_t *__cv, __libcpp_mutex_t *__m,
445 timespec *__ts)
446{
447 using namespace _VSTD::chrono;
448
449 auto duration = seconds(__ts->tv_sec) + nanoseconds(__ts->tv_nsec);
450 auto abstime =
451 system_clock::time_point(duration_cast<system_clock::duration>(duration));
452 auto timeout_ms = duration_cast<milliseconds>(abstime - system_clock::now());
453
454 if (!SleepConditionVariableSRW(__cv, __m,
455 timeout_ms.count() > 0 ? timeout_ms.count()
456 : 0,
457 0))
458 return GetLastError();
459 return 0;
460}
461
462int __libcpp_condvar_destroy(__libcpp_condvar_t *__cv)
463{
464 static_cast<void>(__cv);
465 return 0;
466}
467
468// Execute Once
469static inline _LIBCPP_ALWAYS_INLINE BOOL CALLBACK
470__libcpp_init_once_execute_once_thunk(PINIT_ONCE __init_once, PVOID __parameter,
471 PVOID *__context)
472{
473 static_cast<void>(__init_once);
474 static_cast<void>(__context);
475
476 void (*init_routine)(void) = reinterpret_cast<void (*)(void)>(__parameter);
477 init_routine();
478 return TRUE;
479}
480
481int __libcpp_execute_once(__libcpp_exec_once_flag *__flag,
482 void (*__init_routine)(void))
483{
484 if (!InitOnceExecuteOnce(__flag, __libcpp_init_once_execute_once_thunk,
485 reinterpret_cast<void *>(__init_routine), NULL))
486 return GetLastError();
487 return 0;
488}
489
490// Thread ID
491bool __libcpp_thread_id_equal(__libcpp_thread_id __lhs,
492 __libcpp_thread_id __rhs)
493{
494 return __lhs == __rhs;
495}
496
497bool __libcpp_thread_id_less(__libcpp_thread_id __lhs, __libcpp_thread_id __rhs)
498{
499 return __lhs < __rhs;
500}
501
502// Thread
503struct __libcpp_beginthreadex_thunk_data
504{
505 void *(*__func)(void *);
506 void *__arg;
507};
508
Eric Fiselier543e83b2017-01-14 20:19:00 +0000509static inline _LIBCPP_ALWAYS_INLINE unsigned WINAPI
Eric Fiselier433a3972017-01-14 19:11:07 +0000510__libcpp_beginthreadex_thunk(void *__raw_data)
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000511{
Eric Fiselier433a3972017-01-14 19:11:07 +0000512 auto *__data =
513 static_cast<__libcpp_beginthreadex_thunk_data *>(__raw_data);
514 auto *__func = __data->__func;
515 void *__arg = __data->__arg;
516 delete __data;
Eric Fiselier543e83b2017-01-14 20:19:00 +0000517 return static_cast<unsigned>(reinterpret_cast<uintptr_t>(__func(__arg)));
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000518}
519
Asiri Rathnayakea1d7d2f2017-01-16 12:19:54 +0000520bool __libcpp_thread_isnull(const __libcpp_thread_t *__t) {
521 return *__t == 0;
522}
523
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000524int __libcpp_thread_create(__libcpp_thread_t *__t, void *(*__func)(void *),
525 void *__arg)
526{
Eric Fiselier433a3972017-01-14 19:11:07 +0000527 auto *__data = new __libcpp_beginthreadex_thunk_data;
528 __data->__func = __func;
529 __data->__arg = __arg;
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000530
Eric Fiselier543e83b2017-01-14 20:19:00 +0000531 *__t = reinterpret_cast<HANDLE>(_beginthreadex(nullptr, 0,
532 __libcpp_beginthreadex_thunk,
533 __data, 0, nullptr));
534
Saleem Abdulrasool678eadd2017-01-07 03:07:45 +0000535 if (*__t)
536 return 0;
537 return GetLastError();
538}
539
540__libcpp_thread_id __libcpp_thread_get_current_id()
541{
542 return GetCurrentThreadId();
543}
544
545__libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t *__t)
546{
547 return GetThreadId(*__t);
548}
549
550int __libcpp_thread_join(__libcpp_thread_t *__t)
551{
552 if (WaitForSingleObjectEx(*__t, INFINITE, FALSE) == WAIT_FAILED)
553 return GetLastError();
554 if (!CloseHandle(*__t))
555 return GetLastError();
556 return 0;
557}
558
559int __libcpp_thread_detach(__libcpp_thread_t *__t)
560{
561 if (!CloseHandle(*__t))
562 return GetLastError();
563 return 0;
564}
565
566void __libcpp_thread_yield()
567{
568 SwitchToThread();
569}
570
571// Thread Local Storage
572int __libcpp_tls_create(__libcpp_tls_key* __key,
573 void(_LIBCPP_TLS_DESTRUCTOR_CC* __at_exit)(void*))
574{
575 *__key = FlsAlloc(__at_exit);
576 if (*__key == FLS_OUT_OF_INDEXES)
577 return GetLastError();
578 return 0;
579}
580
581void *__libcpp_tls_get(__libcpp_tls_key __key)
582{
583 return FlsGetValue(__key);
584}
585
586int __libcpp_tls_set(__libcpp_tls_key __key, void *__p)
587{
588 if (!FlsSetValue(__key, __p))
589 return GetLastError();
590 return 0;
591}
592
Saleem Abdulrasool1d192372017-01-03 02:00:31 +0000593#endif // _LIBCPP_HAS_THREAD_API_PTHREAD
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000594
Eric Fiselier66134e82017-01-06 20:05:40 +0000595#endif // !_LIBCPP_HAS_THREAD_LIBRARY_EXTERNAL || _LIBCPP_BUILDING_THREAD_LIBRARY_EXTERNAL
596
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000597_LIBCPP_END_NAMESPACE_STD
598
Eric Fiselier66134e82017-01-06 20:05:40 +0000599#endif // !_LIBCPP_HAS_NO_THREADS
Asiri Rathnayake35ff03b2016-05-06 14:06:29 +0000600
601#endif // _LIBCPP_THREADING_SUPPORT