X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Finit.c;h=0990d4b533bfa5f201ece1ffef1612042e9dd8c1;hb=63498d1a2199eeca1db4ca7d27e665cbd73cb095;hp=7ba83187584a30403971bd7362ae2e87bf6225f1;hpb=b76c56ba3f45576b9c418ea9fe7f7b3440052904;p=openldap diff --git a/servers/slapd/init.c b/servers/slapd/init.c index 7ba8318758..0990d4b533 100644 --- a/servers/slapd/init.c +++ b/servers/slapd/init.c @@ -3,31 +3,169 @@ #include "portable.h" #include -#include -#include -#include -#include -#include -#include -#include -#include "portable.h" + +#include +#include +#include + #include "slap.h" -extern pthread_mutex_t active_threads_mutex; -extern pthread_mutex_t new_conn_mutex; -extern pthread_mutex_t currenttime_mutex; -extern pthread_mutex_t entry2str_mutex; -extern pthread_mutex_t replog_mutex; -extern pthread_mutex_t ops_mutex; -extern pthread_mutex_t num_sent_mutex; +/* + * read-only global variables or variables only written by the listener + * thread (after they are initialized) - no need to protect them with a mutex. + */ +int slap_debug = 0; + +#ifdef LDAP_DEBUG +int ldap_syslog = LDAP_DEBUG_STATS; +#else +int ldap_syslog; +#endif + +int ldap_syslog_level = LOG_DEBUG; +char *default_referral; +int g_argc; +char **g_argv; + +/* + * global variables that need mutex protection + */ +int active_threads; +ldap_pvt_thread_mutex_t active_threads_mutex; +ldap_pvt_thread_cond_t active_threads_cond; + +ldap_pvt_thread_mutex_t gmtime_mutex; +#ifdef SLAPD_CRYPT +ldap_pvt_thread_mutex_t crypt_mutex; +#endif + +int num_conns; +long num_ops_initiated; +long num_ops_completed; +ldap_pvt_thread_mutex_t num_ops_mutex; + +long num_entries_sent; +long num_bytes_sent; +ldap_pvt_thread_mutex_t num_sent_mutex; +/* + * these mutexes must be used when calling the entry2str() + * routine since it returns a pointer to static data. + */ +ldap_pvt_thread_mutex_t entry2str_mutex; +ldap_pvt_thread_mutex_t replog_mutex; + +static char* slap_name; +int slapMode = SLAP_UNDEFINED_MODE; + +static ldap_pvt_thread_mutex_t currenttime_mutex; + +int +slap_init( int mode, char *name ) +{ + int rc; + + if( slapMode != SLAP_UNDEFINED_MODE ) { + Debug( LDAP_DEBUG_ANY, + "%s init: init called twice (old=%d, new=%d)\n", + name, slapMode, mode ); + return 1; + } + + slapMode = mode; + + switch ( slapMode ) { + + case SLAP_SERVER_MODE: + case SLAP_TOOL_MODE: +#ifdef SLAPD_BDB2 + case SLAP_TIMEDSERVER_MODE: + case SLAP_TOOLID_MODE: +#endif + + Debug( LDAP_DEBUG_TRACE, + "%s init: initiated %s.\n", + name, mode == SLAP_TOOL_MODE ? "tool" : "server", 0 ); + + slap_name = name; + + (void) ldap_pvt_thread_initialize(); + + ldap_pvt_thread_mutex_init( &active_threads_mutex ); + ldap_pvt_thread_cond_init( &active_threads_cond ); + + ldap_pvt_thread_mutex_init( ¤ttime_mutex ); + ldap_pvt_thread_mutex_init( &entry2str_mutex ); + ldap_pvt_thread_mutex_init( &replog_mutex ); + ldap_pvt_thread_mutex_init( &num_ops_mutex ); + ldap_pvt_thread_mutex_init( &num_sent_mutex ); + + ldap_pvt_thread_mutex_init( &gmtime_mutex ); +#ifdef SLAPD_CRYPT + ldap_pvt_thread_mutex_init( &crypt_mutex ); +#endif + + rc = backend_init(); + break; + + default: + Debug( LDAP_DEBUG_ANY, + "%s init: undefined mode (%d).\n", name, mode, 0 ); + rc = 1; + break; + } + + return rc; +} + +int slap_startup(int dbnum) +{ + int rc; + + Debug( LDAP_DEBUG_TRACE, + "%s startup: initiated.\n", + slap_name, 0, 0 ); + + rc = backend_startup(dbnum); + + return rc; +} + +int slap_shutdown(int dbnum) +{ + int rc; + + Debug( LDAP_DEBUG_TRACE, + "%s shutdown: initiated\n", + slap_name, 0, 0 ); + + /* let backends do whatever cleanup they need to do */ + rc = backend_shutdown(dbnum); + + return rc; +} + +int slap_destroy(void) +{ + int rc; + + Debug( LDAP_DEBUG_TRACE, + "%s shutdown: freeing system resources.\n", + slap_name, 0, 0 ); + + rc = backend_destroy(); + + ldap_pvt_thread_destroy(); + + /* should destory the above mutex */ + return rc; +} -init() +/* should create a utils.c for these */ +time_t slap_get_time(void) { - pthread_mutex_init( &active_threads_mutex, pthread_mutexattr_default ); - pthread_mutex_init( &new_conn_mutex, pthread_mutexattr_default ); - pthread_mutex_init( ¤ttime_mutex, pthread_mutexattr_default ); - pthread_mutex_init( &entry2str_mutex, pthread_mutexattr_default ); - pthread_mutex_init( &replog_mutex, pthread_mutexattr_default ); - pthread_mutex_init( &ops_mutex, pthread_mutexattr_default ); - pthread_mutex_init( &num_sent_mutex, pthread_mutexattr_default ); + time_t t; + ldap_pvt_thread_mutex_lock( ¤ttime_mutex ); + time( &t ); + ldap_pvt_thread_mutex_unlock( ¤ttime_mutex ); + return t; }