]> git.sur5r.net Git - openldap/blob - servers/slapd/init.c
Sync with HEAD
[openldap] / servers / slapd / init.c
1 /* init.c - initialize various things */
2 /* $OpenLDAP$ */
3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
4  *
5  * Copyright 1998-2005 The OpenLDAP Foundation.
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted only as authorized by the OpenLDAP
10  * Public License.
11  *
12  * A copy of this license is available in the file LICENSE in the
13  * top-level directory of the distribution or, alternatively, at
14  * <http://www.OpenLDAP.org/license.html>.
15  */
16 /* Portions Copyright (c) 1995 Regents of the University of Michigan.
17  * All rights reserved.
18  *
19  * Redistribution and use in source and binary forms are permitted
20  * provided that this notice is preserved and that due credit is given
21  * to the University of Michigan at Ann Arbor. The name of the University
22  * may not be used to endorse or promote products derived from this
23  * software without specific prior written permission. This software
24  * is provided ``as is'' without express or implied warranty.
25  */
26
27 #include "portable.h"
28
29 #include <stdio.h>
30
31 #include <ac/socket.h>
32 #include <ac/string.h>
33 #include <ac/time.h>
34
35 #include "slap.h"
36 #include "lber_pvt.h"
37 #ifdef LDAP_SLAPI
38 #include "slapi/slapi.h"
39 #endif
40
41 /*
42  * read-only global variables or variables only written by the listener
43  * thread (after they are initialized) - no need to protect them with a mutex.
44  */
45 int             slap_debug = 0;
46
47 #ifdef LDAP_DEBUG
48 int             ldap_syslog = LDAP_DEBUG_STATS;
49 #else
50 int             ldap_syslog;
51 #endif
52
53 #ifdef LOG_DEBUG
54 int             ldap_syslog_level = LOG_DEBUG;
55 #endif
56
57 BerVarray default_referral = NULL;
58
59 struct berval AllUser = BER_BVC( LDAP_ALL_USER_ATTRIBUTES );
60 struct berval AllOper = BER_BVC( LDAP_ALL_OPERATIONAL_ATTRIBUTES );
61 struct berval NoAttrs = BER_BVC( LDAP_NO_ATTRS );
62
63 /*
64  * global variables that need mutex protection
65  */
66 ldap_pvt_thread_pool_t  connection_pool;
67 int                     connection_pool_max = SLAP_MAX_WORKER_THREADS;
68 #ifndef HAVE_GMTIME_R
69 ldap_pvt_thread_mutex_t gmtime_mutex;
70 #endif
71
72 slap_counters_t                 slap_counters;
73
74 /*
75  * these mutexes must be used when calling the entry2str()
76  * routine since it returns a pointer to static data.
77  */
78 ldap_pvt_thread_mutex_t entry2str_mutex;
79 ldap_pvt_thread_mutex_t replog_mutex;
80
81 static const char* slap_name = NULL;
82 int slapMode = SLAP_UNDEFINED_MODE;
83
84 int
85 slap_init( int mode, const char *name )
86 {
87         int rc;
88         int i;
89
90         assert( mode );
91
92         if ( slapMode != SLAP_UNDEFINED_MODE ) {
93                 Debug( LDAP_DEBUG_ANY,
94                  "%s init: init called twice (old=%d, new=%d)\n",
95                  name, slapMode, mode );
96
97                 return 1;
98         }
99
100         slapMode = mode;
101
102         switch ( slapMode & SLAP_MODE ) {
103         case SLAP_SERVER_MODE:
104         case SLAP_TOOL_MODE:
105                 Debug( LDAP_DEBUG_TRACE,
106                         "%s init: initiated %s.\n",     name,
107                         (mode & SLAP_MODE) == SLAP_TOOL_MODE ? "tool" : "server",
108                         0 );
109
110
111                 slap_name = name;
112
113                 ldap_pvt_thread_pool_init( &connection_pool,
114                                 connection_pool_max, 0);
115
116                 ldap_pvt_thread_mutex_init( &entry2str_mutex );
117                 ldap_pvt_thread_mutex_init( &replog_mutex );
118
119                 ldap_pvt_thread_mutex_init( &slap_counters.sc_sent_mutex );
120                 ldap_pvt_thread_mutex_init( &slap_counters.sc_ops_mutex );
121                 ldap_pvt_mp_init( slap_counters.sc_bytes );
122                 ldap_pvt_mp_init( slap_counters.sc_pdu );
123                 ldap_pvt_mp_init( slap_counters.sc_entries );
124                 ldap_pvt_mp_init( slap_counters.sc_refs );
125
126                 ldap_pvt_mp_init( slap_counters.sc_ops_initiated );
127                 ldap_pvt_mp_init( slap_counters.sc_ops_completed );
128
129 #ifdef SLAPD_MONITOR
130                 for ( i = 0; i < SLAP_OP_LAST; i++ ) {
131                         ldap_pvt_mp_init( slap_counters.sc_ops_initiated_[ i ] );
132                         ldap_pvt_mp_init( slap_counters.sc_ops_completed_[ i ] );
133                 }
134 #endif /* SLAPD_MONITOR */
135
136 #ifndef HAVE_GMTIME_R
137                 ldap_pvt_thread_mutex_init( &gmtime_mutex );
138 #endif
139                 slap_passwd_init();
140
141                 rc = slap_sasl_init();
142
143                 if( rc == 0 ) {
144                         rc = backend_init( );
145                 }
146
147                 break;
148
149         default:
150                 Debug( LDAP_DEBUG_ANY,
151                         "%s init: undefined mode (%d).\n", name, mode, 0 );
152
153                 rc = 1;
154                 break;
155         }
156
157         return rc;
158 }
159
160 int slap_startup( Backend *be )
161 {
162         int rc;
163
164         Debug( LDAP_DEBUG_TRACE,
165                 "%s startup: initiated.\n",
166                 slap_name, 0, 0 );
167
168
169         rc = backend_startup( be );
170
171 #ifdef LDAP_SLAPI
172         if( rc == 0 ) {
173                 Slapi_PBlock *pb = slapi_pblock_new();
174
175                 if ( slapi_int_call_plugins( NULL, SLAPI_PLUGIN_START_FN, pb ) < 0 ) {
176                         rc = -1;
177                 }
178                 slapi_pblock_destroy( pb );
179         }
180 #endif /* LDAP_SLAPI */
181
182         return rc;
183 }
184
185 int slap_shutdown( Backend *be )
186 {
187         int rc;
188 #ifdef LDAP_SLAPI
189         Slapi_PBlock *pb;
190 #endif
191
192         Debug( LDAP_DEBUG_TRACE,
193                 "%s shutdown: initiated\n",
194                 slap_name, 0, 0 );
195
196         /* let backends do whatever cleanup they need to do */
197         rc = backend_shutdown( be ); 
198
199 #ifdef LDAP_SLAPI
200         pb = slapi_pblock_new();
201         (void) slapi_int_call_plugins( NULL, SLAPI_PLUGIN_CLOSE_FN, pb );
202         slapi_pblock_destroy( pb );
203 #endif /* LDAP_SLAPI */
204
205         return rc;
206 }
207
208 int slap_destroy(void)
209 {
210         int rc;
211         int i;
212
213         Debug( LDAP_DEBUG_TRACE,
214                 "%s destroy: freeing system resources.\n",
215                 slap_name, 0, 0 );
216
217         if ( default_referral ) {
218                 ber_bvarray_free( default_referral );
219         }
220
221         rc = backend_destroy();
222
223         slap_sasl_destroy();
224
225         entry_destroy();
226
227         switch ( slapMode & SLAP_MODE ) {
228         case SLAP_SERVER_MODE:
229         case SLAP_TOOL_MODE:
230
231                 ldap_pvt_thread_mutex_destroy( &slap_counters.sc_sent_mutex );
232                 ldap_pvt_thread_mutex_destroy( &slap_counters.sc_ops_mutex );
233                 ldap_pvt_mp_clear( slap_counters.sc_bytes );
234                 ldap_pvt_mp_clear( slap_counters.sc_pdu );
235                 ldap_pvt_mp_clear( slap_counters.sc_entries );
236                 ldap_pvt_mp_clear( slap_counters.sc_refs );
237                 ldap_pvt_mp_clear( slap_counters.sc_ops_initiated );
238                 ldap_pvt_mp_clear( slap_counters.sc_ops_completed );
239
240 #ifdef SLAPD_MONITOR
241                 for ( i = 0; i < SLAP_OP_LAST; i++ ) {
242                         ldap_pvt_mp_clear( slap_counters.sc_ops_initiated_[ i ] );
243                         ldap_pvt_mp_clear( slap_counters.sc_ops_completed_[ i ] );
244                 }
245 #endif /* SLAPD_MONITOR */
246                 break;
247
248         default:
249                 Debug( LDAP_DEBUG_ANY,
250                         "slap_destroy(): undefined mode (%d).\n", slapMode, 0, 0 );
251
252                 rc = 1;
253                 break;
254
255         }
256
257         ldap_pvt_thread_destroy();
258
259         /* should destory the above mutex */
260         return rc;
261 }