mirror/openldap
2
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2025-01-06 10:46:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

Support Sun DS 5.x thread abstraction layer

Browse Source
This commit is contained in:
Luke Howard 2003-01-24 05:19:57 +00:00
parent eb459f4339
commit 6a54a9db0f
2 changed files with 127 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

116
servers/slapd/slapi/slapi_utils.c
View File

@ -44,6 +44,15 @@ static struct timeval base_time;
ldap_pvt_thread_mutex_t slapi_hn_mutex;
ldap_pvt_thread_mutex_t slapi_time_mutex;
struct slapi_mutex {
ldap_pvt_thread_mutex_t mutex;
};
struct slapi_condvar {
ldap_pvt_thread_cond_t cond;
ldap_pvt_thread_mutex_t mutex;
};
/*
* This function converts an array of pointers to berval objects to
* an array of berval objects.
@ -2868,3 +2877,110 @@ int slapi_x_compute_get_pblock(computed_attr_context *c, Slapi_PBlock **pb)
#endif /* LDAP_SLAPI */
}
Slapi_Mutex *slapi_new_mutex( void )
{
#ifdef LDAP_SLAPI
Slapi_Mutex *m;
m = (Slapi_Mutex *)slapi_ch_malloc( sizeof(*m) );
if ( ldap_pvt_thread_mutex_init( &m->mutex ) != 0 ) {
slapi_ch_free( (void **)&m );
return NULL;
}
return m;
#else
return NULL;
#endif
}
void slapi_destroy_mutex( Slapi_Mutex *mutex )
{
#ifdef LDAP_SLAPI
if ( mutex != NULL ) {
ldap_pvt_thread_mutex_destroy( &mutex->mutex );
slapi_ch_free( (void **)&mutex);
}
#endif
}
void slapi_lock_mutex( Slapi_Mutex *mutex )
{
#ifdef LDAP_SLAPI
ldap_pvt_thread_mutex_lock( &mutex->mutex );
#endif
}
int slapi_unlock_mutex( Slapi_Mutex *mutex )
{
#ifdef LDAP_SLAPI
return ldap_pvt_thread_mutex_unlock( &mutex->mutex );
#else
return -1;
#endif
}
Slapi_CondVar *slapi_new_condvar( Slapi_Mutex *mutex )
{
#ifdef LDAP_SLAPI
Slapi_CondVar *cv;
if ( mutex == NULL ) {
return NULL;
}
cv = (Slapi_CondVar *)slapi_ch_malloc( sizeof(*cv) );
if ( ldap_pvt_thread_cond_init( &cv->cond ) != 0 ) {
slapi_ch_free( (void **)&cv );
return NULL;
}
/* XXX struct copy */
cv->mutex = mutex->mutex;
return cv;
#else
return NULL;
#endif
}
void slapi_destroy_condvar( Slapi_CondVar *cvar )
{
#ifdef LDAP_SLAPI
if ( cvar != NULL ) {
ldap_pvt_thread_cond_destroy( &cvar->cond );
slapi_ch_free( (void **)&cvar );
}
#endif
}
int slapi_wait_condvar( Slapi_CondVar *cvar, struct timeval *timeout )
{
#ifdef LDAP_SLAPI
if ( cvar == NULL ) {
return -1;
}
return ldap_pvt_thread_cond_wait( &cvar->cond, &cvar->mutex );
#else
return -1;
#endif
}
int slapi_notify_condvar( Slapi_CondVar *cvar, int notify_all )
{
#ifdef LDAP_SLAPI
if ( cvar == NULL ) {
return -1;
}
if ( notify_all ) {
return ldap_pvt_thread_cond_braodcast( &cvar->cond );
}
return ldap_pvt_thread_cond_signal( &cvar->cond );
#else
return -1;
#endif
}

11
servers/slapd/slapi/slapi_utils.h
View File

@ -123,6 +123,17 @@ int slapi_valueset_next_value( Slapi_ValueSet *vs, int index, Slapi_Value **v);
int slapi_valueset_count( const Slapi_ValueSet *vs);
void slapi_valueset_set_valueset(Slapi_ValueSet *vs1, const Slapi_ValueSet *vs2);
typedef struct slapi_mutex Slapi_Mutex;
typedef struct slapi_condvar Slapi_CondVar;
Slapi_Mutex *slapi_new_mutex( void );
void slapi_destroy_mutex( Slapi_Mutex *mutex );
void slapi_lock_mutex( Slapi_Mutex *mutex );
int slapi_unlock_mutex( Slapi_Mutex *mutex );
Slapi_CondVar *slapi_new_condvar( Slapi_Mutex *mutex );
void slapi_destroy_condvar( Slapi_CondVar *cvar );
int slapi_wait_condvar( Slapi_CondVar *cvar, struct timeval *timeout );
int slapi_notify_condvar( Slapi_CondVar *cvar, int notify_all );
char *slapi_ch_malloc( unsigned long size );
void slapi_ch_free( void **ptr );
void slapi_ch_free_string( char **s );