]> git.sur5r.net Git - openldap/blob - servers/slapd/back-meta/init.c
import resource cleanup from HEAD
[openldap] / servers / slapd / back-meta / init.c
1 /* $OpenLDAP$ */
2 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
3  *
4  * Copyright 1999-2006 The OpenLDAP Foundation.
5  * Portions Copyright 2001-2003 Pierangelo Masarati.
6  * Portions Copyright 1999-2003 Howard Chu.
7  * All rights reserved.
8  *
9  * Redistribution and use in source and binary forms, with or without
10  * modification, are permitted only as authorized by the OpenLDAP
11  * Public License.
12  *
13  * A copy of this license is available in the file LICENSE in the
14  * top-level directory of the distribution or, alternatively, at
15  * <http://www.OpenLDAP.org/license.html>.
16  */
17
18 #include "portable.h"
19
20 #include <stdio.h>
21
22 #include <ac/string.h>
23 #include <ac/socket.h>
24
25 #include "slap.h"
26 #include "../back-ldap/back-ldap.h"
27 #include "back-meta.h"
28
29 int
30 meta_back_open(
31         BackendInfo     *bi )
32 {
33         /* FIXME: need to remove the pagedResults, and likely more... */
34         bi->bi_controls = slap_known_controls;
35
36         return 0;
37 }
38
39 int
40 meta_back_initialize(
41         BackendInfo     *bi )
42 {
43         bi->bi_open = meta_back_open;
44         bi->bi_config = 0;
45         bi->bi_close = 0;
46         bi->bi_destroy = 0;
47
48         bi->bi_db_init = meta_back_db_init;
49         bi->bi_db_config = meta_back_db_config;
50         bi->bi_db_open = meta_back_db_open;
51         bi->bi_db_close = 0;
52         bi->bi_db_destroy = meta_back_db_destroy;
53
54         bi->bi_op_bind = meta_back_bind;
55         bi->bi_op_unbind = 0;
56         bi->bi_op_search = meta_back_search;
57         bi->bi_op_compare = meta_back_compare;
58         bi->bi_op_modify = meta_back_modify;
59         bi->bi_op_modrdn = meta_back_modrdn;
60         bi->bi_op_add = meta_back_add;
61         bi->bi_op_delete = meta_back_delete;
62         bi->bi_op_abandon = 0;
63
64         bi->bi_extended = 0;
65
66         bi->bi_chk_referrals = 0;
67
68         bi->bi_connection_init = 0;
69         bi->bi_connection_destroy = meta_back_conn_destroy;
70
71         return 0;
72 }
73
74 int
75 meta_back_db_init(
76         Backend         *be )
77 {
78         metainfo_t      *mi;
79
80         mi = ch_calloc( 1, sizeof( metainfo_t ) );
81         if ( mi == NULL ) {
82                 return -1;
83         }
84
85         /*
86          * At present the default is no default target;
87          * this may change
88          */
89         mi->mi_defaulttarget = META_DEFAULT_TARGET_NONE;
90         mi->mi_bind_timeout.tv_sec = 0;
91         mi->mi_bind_timeout.tv_usec = META_BIND_TIMEOUT;
92
93         ldap_pvt_thread_mutex_init( &mi->mi_conninfo.lai_mutex );
94         ldap_pvt_thread_mutex_init( &mi->mi_cache.mutex );
95
96         /* safe default */
97         mi->mi_nretries = META_RETRY_DEFAULT;
98         mi->mi_version = LDAP_VERSION3;
99         
100         be->be_private = mi;
101
102         return 0;
103 }
104
105 int
106 meta_back_db_open(
107         Backend         *be )
108 {
109         metainfo_t      *mi = (metainfo_t *)be->be_private;
110
111         int             i, rc;
112
113         for ( i = 0; i < mi->mi_ntargets; i++ ) {
114                 if ( mi->mi_targets[ i ].mt_flags & LDAP_BACK_F_SUPPORT_T_F_DISCOVER )
115                 {
116                         mi->mi_targets[ i ].mt_flags &= ~LDAP_BACK_F_SUPPORT_T_F_DISCOVER;
117                         rc = slap_discover_feature( mi->mi_targets[ i ].mt_uri,
118                                         mi->mi_targets[ i ].mt_version,
119                                         slap_schema.si_ad_supportedFeatures->ad_cname.bv_val,
120                                         LDAP_FEATURE_ABSOLUTE_FILTERS );
121                         if ( rc == LDAP_COMPARE_TRUE ) {
122                                 mi->mi_targets[ i ].mt_flags |= LDAP_BACK_F_SUPPORT_T_F;
123                         }
124                 }
125         }
126
127         return 0;
128 }
129
130 void
131 meta_back_conn_free( 
132         void            *v_mc )
133 {
134         metaconn_t              *mc = v_mc;
135         int                     i, ntargets;
136
137         assert( mc != NULL );
138         assert( mc->mc_refcnt == 0 );
139
140         if ( !BER_BVISNULL( &mc->mc_local_ndn ) ) {
141                 free( mc->mc_local_ndn.bv_val );
142         }
143
144         assert( mc->mc_conns != NULL );
145
146         /* at least one must be present... */
147         ntargets = mc->mc_conns[ 0 ].msc_info->mi_ntargets;
148
149         for ( i = 0; i < ntargets; i++ ) {
150                 (void)meta_clear_one_candidate( &mc->mc_conns[ i ] );
151         }
152
153         free( mc );
154 }
155
156 static void
157 mapping_free(
158         void            *v_mapping )
159 {
160         struct ldapmapping *mapping = v_mapping;
161         ch_free( mapping->src.bv_val );
162         ch_free( mapping->dst.bv_val );
163         ch_free( mapping );
164 }
165
166 static void
167 mapping_dst_free(
168         void            *v_mapping )
169 {
170         struct ldapmapping *mapping = v_mapping;
171
172         if ( BER_BVISEMPTY( &mapping->dst ) ) {
173                 mapping_free( &mapping[ -1 ] );
174         }
175 }
176
177 static void
178 target_free(
179         metatarget_t    *mt )
180 {
181         if ( mt->mt_uri ) {
182                 free( mt->mt_uri );
183         }
184         if ( mt->mt_subtree_exclude ) {
185                 ber_bvarray_free( mt->mt_subtree_exclude );
186         }
187         if ( !BER_BVISNULL( &mt->mt_psuffix ) ) {
188                 free( mt->mt_psuffix.bv_val );
189         }
190         if ( !BER_BVISNULL( &mt->mt_nsuffix ) ) {
191                 free( mt->mt_nsuffix.bv_val );
192         }
193         if ( !BER_BVISNULL( &mt->mt_binddn ) ) {
194                 free( mt->mt_binddn.bv_val );
195         }
196         if ( !BER_BVISNULL( &mt->mt_bindpw ) ) {
197                 free( mt->mt_bindpw.bv_val );
198         }
199         if ( !BER_BVISNULL( &mt->mt_pseudorootdn ) ) {
200                 free( mt->mt_pseudorootdn.bv_val );
201         }
202         if ( !BER_BVISNULL( &mt->mt_pseudorootpw ) ) {
203                 free( mt->mt_pseudorootpw.bv_val );
204         }
205         if ( mt->mt_rwmap.rwm_rw ) {
206                 rewrite_info_delete( &mt->mt_rwmap.rwm_rw );
207         }
208         avl_free( mt->mt_rwmap.rwm_oc.remap, mapping_dst_free );
209         avl_free( mt->mt_rwmap.rwm_oc.map, mapping_free );
210         avl_free( mt->mt_rwmap.rwm_at.remap, mapping_dst_free );
211         avl_free( mt->mt_rwmap.rwm_at.map, mapping_free );
212 }
213
214 int
215 meta_back_db_destroy(
216         Backend         *be )
217 {
218         metainfo_t      *mi;
219
220         if ( be->be_private ) {
221                 int i;
222
223                 mi = ( metainfo_t * )be->be_private;
224
225                 /*
226                  * Destroy the connection tree
227                  */
228                 ldap_pvt_thread_mutex_lock( &mi->mi_conninfo.lai_mutex );
229
230                 if ( mi->mi_conninfo.lai_tree ) {
231                         avl_free( mi->mi_conninfo.lai_tree, meta_back_conn_free );
232                 }
233
234                 /*
235                  * Destroy the per-target stuff (assuming there's at
236                  * least one ...)
237                  */
238                 if ( mi->mi_targets != NULL ) {
239                         for ( i = 0; i < mi->mi_ntargets; i++ ) {
240                                 target_free( &mi->mi_targets[ i ] );
241                         }
242
243                         free( mi->mi_targets );
244                 }
245
246                 ldap_pvt_thread_mutex_lock( &mi->mi_cache.mutex );
247                 if ( mi->mi_cache.tree ) {
248                         avl_free( mi->mi_cache.tree, meta_dncache_free );
249                 }
250                 
251                 ldap_pvt_thread_mutex_unlock( &mi->mi_cache.mutex );
252                 ldap_pvt_thread_mutex_destroy( &mi->mi_cache.mutex );
253
254                 ldap_pvt_thread_mutex_unlock( &mi->mi_conninfo.lai_mutex );
255                 ldap_pvt_thread_mutex_destroy( &mi->mi_conninfo.lai_mutex );
256
257                 if ( mi->mi_candidates != NULL ) {
258                         ber_memfree_x( mi->mi_candidates, NULL );
259                 }
260         }
261
262         free( be->be_private );
263         return 0;
264 }
265
266 #if SLAPD_META == SLAPD_MOD_DYNAMIC
267
268 /* conditionally define the init_module() function */
269 SLAP_BACKEND_INIT_MODULE( meta )
270
271 #endif /* SLAPD_META == SLAPD_MOD_DYNAMIC */
272
273