1 /* thr_posix.c - wrapper around posix and posixish thread implementations. */
3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
5 * Copyright 1998-2005 The OpenLDAP Foundation.
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted only as authorized by the OpenLDAP
12 * A copy of this license is available in file LICENSE in the
13 * top-level directory of the distribution or, alternatively, at
14 * <http://www.OpenLDAP.org/license.html>.
19 #if defined( HAVE_PTHREADS )
23 #include "ldap_pvt_thread.h" /* Get the thread interface */
24 #define LDAP_THREAD_IMPLEMENTATION
25 #define LDAP_THREAD_RDWR_IMPLEMENTATION
26 #include "ldap_thr_debug.h" /* May rename the symbols defined below */
29 # define LDAP_INT_THREAD_ATTR_DEFAULT pthread_attr_default
30 # define LDAP_INT_THREAD_CONDATTR_DEFAULT pthread_condattr_default
31 # define LDAP_INT_THREAD_MUTEXATTR_DEFAULT pthread_mutexattr_default
33 # define LDAP_INT_THREAD_ATTR_DEFAULT NULL
34 # define LDAP_INT_THREAD_CONDATTR_DEFAULT NULL
35 # define LDAP_INT_THREAD_MUTEXATTR_DEFAULT NULL
38 #ifdef LDAP_THREAD_DEBUG
39 # if defined LDAP_INT_THREAD_MUTEXATTR /* May be defined in CPPFLAGS */
40 # elif defined HAVE_PTHREAD_KILL_OTHER_THREADS_NP
41 /* LinuxThreads hack */
42 # define LDAP_INT_THREAD_MUTEXATTR PTHREAD_MUTEX_ERRORCHECK_NP
44 # define LDAP_INT_THREAD_MUTEXATTR PTHREAD_MUTEX_ERRORCHECK
46 static pthread_mutexattr_t mutex_attr;
47 # undef LDAP_INT_THREAD_MUTEXATTR_DEFAULT
48 # define LDAP_INT_THREAD_MUTEXATTR_DEFAULT &mutex_attr
52 ldap_int_thread_initialize( void )
54 #ifdef LDAP_INT_THREAD_MUTEXATTR
55 pthread_mutexattr_init( &mutex_attr );
56 pthread_mutexattr_settype( &mutex_attr, LDAP_INT_THREAD_MUTEXATTR );
62 ldap_int_thread_destroy( void )
64 #ifdef HAVE_PTHREAD_KILL_OTHER_THREADS_NP
65 /* LinuxThreads: kill clones */
66 pthread_kill_other_threads_np();
68 #ifdef LDAP_INT_THREAD_MUTEXATTR
69 pthread_mutexattr_destroy( &mutex_attr );
74 #ifdef LDAP_THREAD_HAVE_SETCONCURRENCY
76 ldap_pvt_thread_set_concurrency(int n)
78 #ifdef HAVE_PTHREAD_SETCONCURRENCY
79 return pthread_setconcurrency( n );
80 #elif HAVE_THR_SETCONCURRENCY
81 return thr_setconcurrency( n );
88 #ifdef LDAP_THREAD_HAVE_GETCONCURRENCY
90 ldap_pvt_thread_get_concurrency(void)
92 #ifdef HAVE_PTHREAD_GETCONCURRENCY
93 return pthread_getconcurrency();
94 #elif HAVE_THR_GETCONCURRENCY
95 return thr_getconcurrency();
102 /* detachstate appeared in Draft 6, but without manifest constants.
103 * in Draft 7 they were called PTHREAD_CREATE_UNDETACHED and ...DETACHED.
104 * in Draft 8 on, ...UNDETACHED became ...JOINABLE.
106 #ifndef PTHREAD_CREATE_JOINABLE
107 #ifdef PTHREAD_CREATE_UNDETACHED
108 #define PTHREAD_CREATE_JOINABLE PTHREAD_CREATE_UNDETACHED
110 #define PTHREAD_CREATE_JOINABLE 0
114 #ifndef PTHREAD_CREATE_DETACHED
115 #define PTHREAD_CREATE_DETACHED 1
119 ldap_pvt_thread_create( ldap_pvt_thread_t * thread,
121 void *(*start_routine)( void * ),
127 /* Always create the thread attrs, so we can set stacksize if we need to */
128 #if HAVE_PTHREADS > 5
129 pthread_attr_init(&attr);
131 pthread_attr_create(&attr);
134 #ifdef LDAP_PVT_THREAD_SET_STACK_SIZE
135 /* this should be tunable */
136 pthread_attr_setstacksize( &attr, LDAP_PVT_THREAD_STACK_SIZE );
139 #if HAVE_PTHREADS > 5
140 detach = detach ? PTHREAD_CREATE_DETACHED : PTHREAD_CREATE_JOINABLE;
141 #if HAVE_PTHREADS == 6
142 pthread_attr_setdetachstate(&attr, &detach);
144 pthread_attr_setdetachstate(&attr, detach);
148 #if HAVE_PTHREADS < 5
149 rtn = pthread_create( thread, attr, start_routine, arg );
151 rtn = pthread_create( thread, &attr, start_routine, arg );
153 #if HAVE_PTHREADS > 5
154 pthread_attr_destroy(&attr);
156 pthread_attr_delete(&attr);
158 pthread_detach( thread );
162 #if HAVE_PTHREADS < 7
163 if ( rtn < 0 ) rtn = errno;
169 ldap_pvt_thread_exit( void *retval )
171 pthread_exit( retval );
175 ldap_pvt_thread_join( ldap_pvt_thread_t thread, void **thread_return )
177 #if HAVE_PTHREADS < 7
180 if (thread_return==NULL)
181 thread_return=&dummy;
183 if ( pthread_join( thread, thread_return ) < 0 ) return errno;
186 return pthread_join( thread, thread_return );
191 ldap_pvt_thread_kill( ldap_pvt_thread_t thread, int signo )
193 #if ( HAVE_PTHREAD_KILL && HAVE_PTHREADS > 6 )
194 /* MacOS 10.1 is detected as v10 but has no pthread_kill() */
195 return pthread_kill( thread, signo );
196 #elif ( HAVE_PTHREAD_KILL && HAVE_PTHREADS > 4 )
197 if ( pthread_kill( thread, signo ) < 0 ) return errno;
200 /* pthread package with DCE */
201 if (kill( getpid(), signo )<0)
208 ldap_pvt_thread_yield( void )
213 #elif HAVE_PTHREADS == 10
214 return sched_yield();
216 #elif defined(_POSIX_THREAD_IS_GNU_PTH)
220 #elif HAVE_PTHREADS == 6
230 ldap_pvt_thread_cond_init( ldap_pvt_thread_cond_t *cond )
232 #if HAVE_PTHREADS < 7
233 if ( pthread_cond_init( cond, LDAP_INT_THREAD_CONDATTR_DEFAULT ) < 0 )
237 return pthread_cond_init( cond, LDAP_INT_THREAD_CONDATTR_DEFAULT );
242 ldap_pvt_thread_cond_destroy( ldap_pvt_thread_cond_t *cond )
244 #if HAVE_PTHREADS < 7
245 if ( pthread_cond_destroy( cond ) < 0 ) return errno;
248 return pthread_cond_destroy( cond );
253 ldap_pvt_thread_cond_signal( ldap_pvt_thread_cond_t *cond )
255 #if HAVE_PTHREADS < 7
256 if ( pthread_cond_signal( cond ) < 0 ) return errno;
259 return pthread_cond_signal( cond );
264 ldap_pvt_thread_cond_broadcast( ldap_pvt_thread_cond_t *cond )
266 #if HAVE_PTHREADS < 7
267 if ( pthread_cond_broadcast( cond ) < 0 ) return errno;
270 return pthread_cond_broadcast( cond );
275 ldap_pvt_thread_cond_wait( ldap_pvt_thread_cond_t *cond,
276 ldap_pvt_thread_mutex_t *mutex )
278 #if HAVE_PTHREADS < 7
279 if ( pthread_cond_wait( cond, mutex ) < 0 ) return errno;
282 return pthread_cond_wait( cond, mutex );
287 ldap_pvt_thread_mutex_init( ldap_pvt_thread_mutex_t *mutex )
289 #if HAVE_PTHREADS < 7
290 if ( pthread_mutex_init( mutex, LDAP_INT_THREAD_MUTEXATTR_DEFAULT )<0)
294 return pthread_mutex_init( mutex, LDAP_INT_THREAD_MUTEXATTR_DEFAULT );
299 ldap_pvt_thread_mutex_destroy( ldap_pvt_thread_mutex_t *mutex )
301 #if HAVE_PTHREADS < 7
302 if ( pthread_mutex_destroy( mutex ) < 0 ) return errno;
305 return pthread_mutex_destroy( mutex );
310 ldap_pvt_thread_mutex_lock( ldap_pvt_thread_mutex_t *mutex )
312 #if HAVE_PTHREADS < 7
313 if ( pthread_mutex_lock( mutex ) < 0 ) return errno;
316 return pthread_mutex_lock( mutex );
321 ldap_pvt_thread_mutex_trylock( ldap_pvt_thread_mutex_t *mutex )
323 #if HAVE_PTHREADS < 7
324 if ( pthread_mutex_trylock( mutex ) < 0 ) return errno;
327 return pthread_mutex_trylock( mutex );
332 ldap_pvt_thread_mutex_unlock( ldap_pvt_thread_mutex_t *mutex )
334 #if HAVE_PTHREADS < 7
335 if ( pthread_mutex_unlock( mutex ) < 0 ) return errno;
338 return pthread_mutex_unlock( mutex );
342 ldap_pvt_thread_t ldap_pvt_thread_self( void )
344 return pthread_self();
347 #ifdef LDAP_THREAD_HAVE_RDWR
348 #ifdef HAVE_PTHREAD_RWLOCK_DESTROY
350 ldap_pvt_thread_rdwr_init( ldap_pvt_thread_rdwr_t *rw )
352 #if HAVE_PTHREADS < 7
353 if ( pthread_rwlock_init( rw, NULL ) < 0 ) return errno;
356 return pthread_rwlock_init( rw, NULL );
361 ldap_pvt_thread_rdwr_destroy( ldap_pvt_thread_rdwr_t *rw )
363 #if HAVE_PTHREADS < 7
364 if ( pthread_rwlock_destroy( rw ) < 0 ) return errno;
367 return pthread_rwlock_destroy( rw );
371 int ldap_pvt_thread_rdwr_rlock( ldap_pvt_thread_rdwr_t *rw )
373 #if HAVE_PTHREADS < 7
374 if ( pthread_rwlock_rdlock( rw ) < 0 ) return errno;
377 return pthread_rwlock_rdlock( rw );
381 int ldap_pvt_thread_rdwr_rtrylock( ldap_pvt_thread_rdwr_t *rw )
383 #if HAVE_PTHREADS < 7
384 if ( pthread_rwlock_tryrdlock( rw ) < 0 ) return errno;
387 return pthread_rwlock_tryrdlock( rw );
391 int ldap_pvt_thread_rdwr_runlock( ldap_pvt_thread_rdwr_t *rw )
393 #if HAVE_PTHREADS < 7
394 if ( pthread_rwlock_unlock( rw ) < 0 ) return errno;
397 return pthread_rwlock_unlock( rw );
401 int ldap_pvt_thread_rdwr_wlock( ldap_pvt_thread_rdwr_t *rw )
403 #if HAVE_PTHREADS < 7
404 if ( pthread_rwlock_wrlock( rw ) < 0 ) return errno;
407 return pthread_rwlock_wrlock( rw );
411 int ldap_pvt_thread_rdwr_wtrylock( ldap_pvt_thread_rdwr_t *rw )
413 #if HAVE_PTHREADS < 7
414 if ( pthread_rwlock_trywrlock( rw ) < 0 ) return errno;
417 return pthread_rwlock_trywrlock( rw );
421 int ldap_pvt_thread_rdwr_wunlock( ldap_pvt_thread_rdwr_t *rw )
423 #if HAVE_PTHREADS < 7
424 if ( pthread_rwlock_unlock( rw ) < 0 ) return errno;
427 return pthread_rwlock_unlock( rw );
431 #endif /* HAVE_PTHREAD_RWLOCK_DESTROY */
432 #endif /* LDAP_THREAD_HAVE_RDWR */
433 #endif /* HAVE_PTHREADS */