X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=include%2Fldap_pvt_thread.h;h=ddc0302a83cf12cfdf58afb91760e6d024df3699;hb=de01a6e3d791d3458549d2ceeccf4d7e0477ff78;hp=f42af3880c39f655b18a07560b09e23fe9950035;hpb=b8961522901cdb4169d0fd21f2b74583ddd94627;p=openldap diff --git a/include/ldap_pvt_thread.h b/include/ldap_pvt_thread.h index f42af3880c..ddc0302a83 100644 --- a/include/ldap_pvt_thread.h +++ b/include/ldap_pvt_thread.h @@ -1,269 +1,283 @@ -/* - * Copyright 1998,1999 The OpenLDAP Foundation, Redwood City, California, USA +/* ldap_pvt_thread.h - ldap threads header file */ +/* $OpenLDAP$ */ +/* This work is part of OpenLDAP Software . + * + * Copyright 1998-2007 The OpenLDAP Foundation. * All rights reserved. * - * Redistribution and use in source and binary forms are permitted only - * as authorized by the OpenLDAP Public License. A copy of this - * license is available at http://www.OpenLDAP.org/license.html or - * in file LICENSE in the top-level directory of the distribution. + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * . */ -/* ldap_pvt_thread.h - ldap threads header file NG */ #ifndef _LDAP_PVT_THREAD_H -#define _LDAP_PVT_THREAD_H - -#include "portable.h" +#define _LDAP_PVT_THREAD_H /* libldap_r/ldap_thr_debug.h #undefines this */ -#if defined( HAVE_PTHREADS ) -/********************************** - * * - * definitions for POSIX Threads * - * * - **********************************/ - -#include -#ifdef HAVE_SCHED_H -#include -#endif +#include "ldap_cdefs.h" +#include "ldap_int_thread.h" LDAP_BEGIN_DECL -typedef pthread_t ldap_pvt_thread_t; -typedef pthread_attr_t ldap_pvt_thread_attr_t; -typedef pthread_mutex_t ldap_pvt_thread_mutex_t; -typedef pthread_mutexattr_t ldap_pvt_thread_mutexattr_t; -typedef pthread_cond_t ldap_pvt_thread_cond_t; -typedef pthread_condattr_t ldap_pvt_thread_condattr_t; - -#define LDAP_PVT_THREAD_CREATE_DETACHED PTHREAD_CREATE_DETACHED -#define LDAP_PVT_THREAD_CREATE_JOINABLE PTHREAD_CREATE_JOINABLE - -#if defined( _POSIX_REENTRANT_FUNCTIONS ) || \ - defined( _POSIX_THREAD_SAFE_FUNCTIONS ) || \ - defined( _POSIX_THREAD_SAFE_FUNCTIONS ) -#define HAVE_REENTRANT_FUNCTIONS 1 +#ifndef LDAP_PVT_THREAD_H_DONE +typedef ldap_int_thread_t ldap_pvt_thread_t; +#ifdef LDAP_THREAD_DEBUG_WRAP +typedef ldap_debug_thread_mutex_t ldap_pvt_thread_mutex_t; +typedef ldap_debug_thread_cond_t ldap_pvt_thread_cond_t; +typedef ldap_debug_thread_rdwr_t ldap_pvt_thread_rdwr_t; +#else +typedef ldap_int_thread_mutex_t ldap_pvt_thread_mutex_t; +typedef ldap_int_thread_cond_t ldap_pvt_thread_cond_t; +typedef ldap_int_thread_rdwr_t ldap_pvt_thread_rdwr_t; #endif +typedef ldap_int_thread_rmutex_t ldap_pvt_thread_rmutex_t; +#endif /* !LDAP_PVT_THREAD_H_DONE */ -LDAP_END_DECL - -#elif defined ( HAVE_MACH_CTHREADS ) -/********************************** - * * - * definitions for Mach CThreads * - * * - **********************************/ +#if 0 && defined(LDAP_DEVEL) +/* must also be defined in slapd.h */ +#define LDAP_PVT_THREAD_POOL_SEM_LOAD_CONTROL +#endif -#include +#define ldap_pvt_thread_equal ldap_int_thread_equal -LDAP_BEGIN_DECL +LDAP_F( int ) +ldap_pvt_thread_initialize LDAP_P(( void )); -typedef cthread_t ldap_pvt_thread_t; -typedef int ldap_pvt_thread_attr_t; -typedef struct mutex ldap_pvt_thread_mutex_t; -typedef int ldap_pvt_thread_mutexattr_t; -typedef struct condition ldap_pvt_thread_cond_t; -typedef int ldap_pvt_thread_condattr_t; +LDAP_F( int ) +ldap_pvt_thread_destroy LDAP_P(( void )); -#define LDAP_PVT_THREAD_CREATE_DETACHED 1 -#define LDAP_PVT_THREAD_CREATE_JOINABLE 0 +LDAP_F( unsigned int ) +ldap_pvt_thread_sleep LDAP_P(( unsigned int s )); -LDAP_END_DECL - -#elif defined( HAVE_THR ) -/************************************** - * * - * thread definitions for Solaris LWP * - * * - **************************************/ - -#include -#include - -LDAP_BEGIN_DECL +LDAP_F( int ) +ldap_pvt_thread_get_concurrency LDAP_P(( void )); -typedef thread_t ldap_pvt_thread_t; -typedef int ldap_pvt_thread_attr_t; -typedef mutex_t ldap_pvt_thread_mutex_t; -typedef int ldap_pvt_thread_mutexattr_t; -typedef cond_t ldap_pvt_thread_cond_t; -typedef int ldap_pvt_thread_condattr_t; +LDAP_F( int ) +ldap_pvt_thread_set_concurrency LDAP_P(( int )); -#define LDAP_PVT_THREAD_CREATE_DETACHED THR_DETACHED #define LDAP_PVT_THREAD_CREATE_JOINABLE 0 - -#define HAVE_REENTRANT_FUNCTIONS 1 - -LDAP_END_DECL - -#elif defined( HAVE_LWP ) -/************************************* - * * - * thread definitions for SunOS LWP * - * * - *************************************/ - -#include -#include - -LDAP_BEGIN_DECL - -typedef thread_t ldap_pvt_thread_t; -typedef int ldap_pvt_thread_attr_t; -typedef mon_t ldap_pvt_thread_mutex_t; -typedef int ldap_pvt_thread_mutexattr_t; -struct lwpcv { - int lcv_created; - cv_t lcv_cv; -}; -typedef struct lwpcv ldap_pvt_thread_cond_t; -typedef int ldap_pvt_thread_condattr_t; - #define LDAP_PVT_THREAD_CREATE_DETACHED 1 -#define LDAP_PVT_THREAD_CREATE_JOINABLE 0 - -#define HAVE_REENTRANT_FUNCTIONS 1 - -stkalign_t *ldap_pvt_thread_get_stack( int *stacknop ); -void ldap_pvt_thread_free_stack( int *stackno ); - -LDAP_END_DECL - -#elif HAVE_NT_THREADS - -#include -#include - -typedef HANDLE ldap_pvt_thread_t; -typedef int ldap_pvt_thread_attr_t; -typedef HANDLE ldap_pvt_thread_mutex_t; -typedef int ldap_pvt_thread_mutexattr_t; -typedef HANDLE ldap_pvt_thread_cond_t; -typedef int ldap_pvt_thread_condattr_t; -#define LDAP_PVT_THREAD_CREATE_DETACHED 0 -#define LDAP_PVT_THREAD_CREATE_JOINABLE 0 - -#else - -/*********************************** - * * - * thread definitions for no * - * underlying library support * - * * - ***********************************/ - -LDAP_BEGIN_DECL - -#ifndef NO_THREADS -#define NO_THREADS 1 +#ifndef LDAP_PVT_THREAD_H_DONE +#define LDAP_PVT_THREAD_SET_STACK_SIZE +#ifndef LDAP_PVT_THREAD_STACK_SIZE + /* LARGE stack. Will be twice as large on 64 bit machine. */ +#define LDAP_PVT_THREAD_STACK_SIZE ( 1 * 1024 * 1024 * sizeof(void *) ) +/* May be explicitly defined to zero to disable it */ +#elif LDAP_PVT_THREAD_STACK_SIZE == 0 +#undef LDAP_PVT_THREAD_SET_STACK_SIZE #endif +#endif /* !LDAP_PVT_THREAD_H_DONE */ -typedef int ldap_pvt_thread_t; -typedef int ldap_pvt_thread_attr_t; -typedef int ldap_pvt_thread_mutex_t; -typedef int ldap_pvt_thread_mutexattr_t; -typedef int ldap_pvt_thread_cond_t; -typedef int ldap_pvt_thread_condattr_t; - -#define LDAP_PVT_THREAD_CREATE_DETACHED 0 -#define LDAP_PVT_THREAD_CREATE_JOINABLE 0 +LDAP_F( int ) +ldap_pvt_thread_create LDAP_P(( + ldap_pvt_thread_t * thread, + int detach, + void *(*start_routine)( void * ), + void *arg)); -LDAP_END_DECL - -#endif /* no threads support */ - -#ifndef NO_THREADS -# define HAVE_THREADS 1 -#endif - -LDAP_F int -ldap_pvt_thread_create LDAP_P(( ldap_pvt_thread_t * thread, - ldap_pvt_thread_attr_t *attr, - void *(*start_routine)( void *), - void *arg)); - -LDAP_F void +LDAP_F( void ) ldap_pvt_thread_exit LDAP_P(( void *retval )); -LDAP_F int -ldap_pvt_thread_join LDAP_P(( ldap_pvt_thread_t thread, - void **thread_return )); +LDAP_F( int ) +ldap_pvt_thread_join LDAP_P(( ldap_pvt_thread_t thread, void **status )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_kill LDAP_P(( ldap_pvt_thread_t thread, int signo )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_yield LDAP_P(( void )); -LDAP_F int -ldap_pvt_thread_attr_init LDAP_P(( ldap_pvt_thread_attr_t *attr )); - -LDAP_F int -ldap_pvt_thread_attr_destroy LDAP_P(( ldap_pvt_thread_attr_t *attr )); - -LDAP_F int -ldap_pvt_thread_attr_setdetachstate LDAP_P(( ldap_pvt_thread_attr_t *attr, - int dstate )); +LDAP_F( int ) +ldap_pvt_thread_cond_init LDAP_P(( ldap_pvt_thread_cond_t *cond )); -LDAP_F int -ldap_pvt_thread_cond_init LDAP_P(( ldap_pvt_thread_cond_t *cond, - ldap_pvt_thread_condattr_t *attr )); +LDAP_F( int ) +ldap_pvt_thread_cond_destroy LDAP_P(( ldap_pvt_thread_cond_t *cond )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_cond_signal LDAP_P(( ldap_pvt_thread_cond_t *cond )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_cond_broadcast LDAP_P(( ldap_pvt_thread_cond_t *cond )); -LDAP_F int -ldap_pvt_thread_cond_wait LDAP_P(( ldap_pvt_thread_cond_t *cond, - ldap_pvt_thread_mutex_t *mutex )); +LDAP_F( int ) +ldap_pvt_thread_cond_wait LDAP_P(( + ldap_pvt_thread_cond_t *cond, + ldap_pvt_thread_mutex_t *mutex )); -LDAP_F int -ldap_pvt_thread_mutex_init LDAP_P(( ldap_pvt_thread_mutex_t *mutex, - ldap_pvt_thread_mutexattr_t *attr )); +LDAP_F( int ) +ldap_pvt_thread_mutex_init LDAP_P(( ldap_pvt_thread_mutex_t *mutex )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_mutex_destroy LDAP_P(( ldap_pvt_thread_mutex_t *mutex )); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_mutex_lock LDAP_P(( ldap_pvt_thread_mutex_t *mutex )); -LDAP_F int +LDAP_F( int ) +ldap_pvt_thread_mutex_trylock LDAP_P(( ldap_pvt_thread_mutex_t *mutex )); + +LDAP_F( int ) ldap_pvt_thread_mutex_unlock LDAP_P(( ldap_pvt_thread_mutex_t *mutex )); -#include +LDAP_F( int ) +ldap_pvt_thread_rmutex_init LDAP_P(( ldap_pvt_thread_rmutex_t *rmutex )); + +LDAP_F( int ) +ldap_pvt_thread_rmutex_destroy LDAP_P(( ldap_pvt_thread_rmutex_t *rmutex )); + +LDAP_F( int ) +ldap_pvt_thread_rmutex_lock LDAP_P(( ldap_pvt_thread_rmutex_t *rmutex, + ldap_pvt_thread_t owner)); + +LDAP_F( int ) +ldap_pvt_thread_rmutex_trylock LDAP_P(( ldap_pvt_thread_rmutex_t *rmutex, + ldap_pvt_thread_t owner)); + +LDAP_F( int ) +ldap_pvt_thread_rmutex_unlock LDAP_P(( ldap_pvt_thread_rmutex_t *rmutex, + ldap_pvt_thread_t owner)); + +LDAP_F( ldap_pvt_thread_t ) +ldap_pvt_thread_self LDAP_P(( void )); + +#ifdef LDAP_INT_THREAD_ASSERT_MUTEX_OWNER +#define LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER LDAP_INT_THREAD_ASSERT_MUTEX_OWNER +#else +#define LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER(mutex) ((void) 0) +#endif -typedef struct ldap_pvt_thread_rdwr_var { - int readers_reading; - int writer_writing; - ldap_pvt_thread_mutex_t mutex; - ldap_pvt_thread_cond_t lock_free; -} ldap_pvt_thread_rdwr_t; +LDAP_F( int ) +ldap_pvt_thread_rdwr_init LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -typedef void * ldap_pvt_thread_rdwrattr_t; +LDAP_F( int ) +ldap_pvt_thread_rdwr_destroy LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int -ldap_pvt_thread_rdwr_init LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp, - ldap_pvt_thread_rdwrattr_t *attrp)); -LDAP_F int +LDAP_F( int ) ldap_pvt_thread_rdwr_rlock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int + +LDAP_F( int ) +ldap_pvt_thread_rdwr_rtrylock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); + +LDAP_F( int ) ldap_pvt_thread_rdwr_runlock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int + +LDAP_F( int ) ldap_pvt_thread_rdwr_wlock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int + +LDAP_F( int ) +ldap_pvt_thread_rdwr_wtrylock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); + +LDAP_F( int ) ldap_pvt_thread_rdwr_wunlock LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); #ifdef LDAP_DEBUG -LDAP_F int -ldap_pvt_thread_rdwr_rchk LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int -ldap_pvt_thread_rdwr_wchk LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); -LDAP_F int -ldap_pvt_thread_rdwr_rwchk LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); +LDAP_F( int ) +ldap_pvt_thread_rdwr_readers LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); + +LDAP_F( int ) +ldap_pvt_thread_rdwr_writers LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); + +LDAP_F( int ) +ldap_pvt_thread_rdwr_active LDAP_P((ldap_pvt_thread_rdwr_t *rdwrp)); #endif /* LDAP_DEBUG */ +#define LDAP_PVT_THREAD_EINVAL EINVAL +#define LDAP_PVT_THREAD_EBUSY EINVAL + +#ifndef LDAP_PVT_THREAD_H_DONE +typedef ldap_int_thread_pool_t ldap_pvt_thread_pool_t; + +typedef void * (ldap_pvt_thread_start_t) LDAP_P((void *ctx, void *arg)); +typedef void (ldap_pvt_thread_pool_keyfree_t) LDAP_P((void *key, void *data)); +#endif /* !LDAP_PVT_THREAD_H_DONE */ + +LDAP_F( int ) +ldap_pvt_thread_pool_init LDAP_P(( + ldap_pvt_thread_pool_t *pool_out, + int max_threads, + int max_pending )); + +LDAP_F( int ) +ldap_pvt_thread_pool_submit LDAP_P(( + ldap_pvt_thread_pool_t *pool, + ldap_pvt_thread_start_t *start, + void *arg )); + +LDAP_F( int ) +ldap_pvt_thread_pool_maxthreads LDAP_P(( + ldap_pvt_thread_pool_t *pool, + int max_threads )); + +#ifndef LDAP_PVT_THREAD_H_DONE +typedef enum { + LDAP_PVT_THREAD_POOL_PARAM_UNKNOWN = -1, + LDAP_PVT_THREAD_POOL_PARAM_MAX, + LDAP_PVT_THREAD_POOL_PARAM_MAX_PENDING, + LDAP_PVT_THREAD_POOL_PARAM_OPEN, + LDAP_PVT_THREAD_POOL_PARAM_STARTING, + LDAP_PVT_THREAD_POOL_PARAM_ACTIVE, + LDAP_PVT_THREAD_POOL_PARAM_PENDING, + LDAP_PVT_THREAD_POOL_PARAM_BACKLOAD, + LDAP_PVT_THREAD_POOL_PARAM_ACTIVE_MAX, + LDAP_PVT_THREAD_POOL_PARAM_PENDING_MAX, + LDAP_PVT_THREAD_POOL_PARAM_BACKLOAD_MAX, + LDAP_PVT_THREAD_POOL_PARAM_STATE +} ldap_pvt_thread_pool_param_t; +#endif /* !LDAP_PVT_THREAD_H_DONE */ + +LDAP_F( int ) +ldap_pvt_thread_pool_query LDAP_P(( + ldap_pvt_thread_pool_t *pool, + ldap_pvt_thread_pool_param_t param, void *value )); + +LDAP_F( int ) +ldap_pvt_thread_pool_backload LDAP_P(( + ldap_pvt_thread_pool_t *pool )); + +LDAP_F( int ) +ldap_pvt_thread_pool_pause LDAP_P(( + ldap_pvt_thread_pool_t *pool )); + +LDAP_F( int ) +ldap_pvt_thread_pool_resume LDAP_P(( + ldap_pvt_thread_pool_t *pool )); + +LDAP_F( int ) +ldap_pvt_thread_pool_destroy LDAP_P(( + ldap_pvt_thread_pool_t *pool, + int run_pending )); + +LDAP_F( int ) +ldap_pvt_thread_pool_getkey LDAP_P(( + void *ctx, + void *key, + void **data, + ldap_pvt_thread_pool_keyfree_t **kfree )); + +LDAP_F( int ) +ldap_pvt_thread_pool_setkey LDAP_P(( + void *ctx, + void *key, + void *data, + ldap_pvt_thread_pool_keyfree_t *kfree )); + +LDAP_F( void ) +ldap_pvt_thread_pool_purgekey LDAP_P(( void *key )); + +LDAP_F( void *) +ldap_pvt_thread_pool_context LDAP_P(( void )); + +LDAP_F( void ) +ldap_pvt_thread_pool_context_reset LDAP_P(( void *key )); + +LDAP_F( ldap_pvt_thread_t ) +ldap_pvt_thread_pool_tid LDAP_P(( void *ctx )); + LDAP_END_DECL -#endif /* _LDAP_THREAD_H */ +#define LDAP_PVT_THREAD_H_DONE +#endif /* _LDAP_PVT_THREAD_H */