1 /* ldbm.c - ldap dbm compatibility routines */
3 /* Patched for Berkeley DB version 2.0; /KSp; 98/02/23
5 * - DB version 2.6.4b ; 1998/12/28, /KSp
6 * - DB_DBT_MALLOC ; 1998/03/22, /KSp
7 * - basic implementation; 1998/02/23, /KSp
16 #include <ac/string.h>
20 #include "ldap_pvt_thread.h"
24 ldbm_datum_free( LDBM ldbm, Datum data )
32 ldbm_datum_dup( LDBM ldbm, Datum data )
36 if ( data.dsize == 0 ) {
42 dup.dsize = data.dsize;
43 if ( (dup.dptr = (char *) malloc( data.dsize )) != NULL )
44 memcpy( dup.dptr, data.dptr, data.dsize );
49 static int ldbm_initialized = 0;
51 #ifndef HAVE_BERKELEY_DB2
52 /* Everything but DB2 is non-reentrant */
54 static ldap_pvt_thread_mutex_t ldbm_big_mutex;
55 #define LDBM_LOCK (ldap_pvt_thread_mutex_lock(&ldbm_big_mutex))
56 #define LDBM_UNLOCK (ldap_pvt_thread_mutex_unlock(&ldbm_big_mutex))
58 int ldbm_initialize( void )
60 if(ldbm_initialized++) return 1;
62 ldap_pvt_thread_mutex_init( &ldbm_big_mutex );
67 int ldbm_shutdown( void )
69 if( !ldbm_initialized ) return 1;
71 ldap_pvt_thread_mutex_destroy( &ldbm_big_mutex );
83 extern int syslog(int, char*, ...);
87 ldbm_malloc( size_t size )
89 return( calloc( 1, size ));
93 ldbm_db_errcall( const char *prefix, char *message )
95 syslog( LOG_INFO, "ldbm_db_errcall(): %s %s", prefix, message );
98 /* a dbEnv for BERKELEYv2 */
101 /* Berkeley DB 2.x is reentrant */
102 #define LDBM_LOCK ((void)0)
103 #define LDBM_UNLOCK ((void)0)
105 int ldbm_initialize( void )
110 if(ldbm_initialized++) return 1;
112 memset( &ldbm_Env, 0, sizeof( ldbm_Env ));
114 ldbm_Env.db_errcall = ldbm_db_errcall;
115 ldbm_Env.db_errpfx = "==>";
117 envFlags = DB_CREATE | DB_THREAD;
119 if ( ( err = db_appinit( NULL, NULL, &ldbm_Env, envFlags )) ) {
123 sprintf( error, "%ld\n", (long) err );
125 sprintf( error, "%s\n", strerror( err ));
129 "ldbm_initialize(): FATAL error in db_appinit() : %s\n",
137 int ldbm_shutdown( void )
139 if( !ldbm_initialized ) return 1;
141 db_appexit( &ldbm_Env );
148 #if defined( LDBM_USE_DBHASH ) || defined( LDBM_USE_DBBTREE )
150 /*****************************************************************
152 * use berkeley db hash or btree package *
154 *****************************************************************/
157 ldbm_open( char *name, int rw, int mode, int dbcachesize )
161 #ifdef HAVE_BERKELEY_DB2
164 memset( &dbinfo, 0, sizeof( dbinfo ));
165 if ( ldbm_Env.mp_info == NULL )
166 dbinfo.db_cachesize = dbcachesize;
167 dbinfo.db_pagesize = DEFAULT_DB_PAGE_SIZE;
168 dbinfo.db_malloc = ldbm_malloc;
171 (void) db_open( name, DB_TYPE, rw, mode, &ldbm_Env, &dbinfo, &ret );
179 if ( DB_TYPE == DB_HASH ) {
180 memset( (char *) &hinfo, '\0', sizeof(hinfo) );
181 hinfo.cachesize = dbcachesize;
183 } else if ( DB_TYPE == DB_BTREE ) {
184 memset( (char *) &binfo, '\0', sizeof(binfo) );
185 binfo.cachesize = dbcachesize;
192 ret = dbopen( name, rw, mode, DB_TYPE, info );
201 ldbm_close( LDBM ldbm )
204 #ifdef HAVE_BERKELEY_DB2
205 (*ldbm->close)( ldbm, 0 );
207 (*ldbm->close)( ldbm );
213 ldbm_sync( LDBM ldbm )
216 (*ldbm->sync)( ldbm, 0 );
221 ldbm_fetch( LDBM ldbm, Datum key )
228 #ifdef HAVE_BERKELEY_DB2
229 ldbm_datum_init( data );
231 data.flags = DB_DBT_MALLOC;
233 if ( (rc = (*ldbm->get)( ldbm, NULL, &key, &data, 0 )) != 0 ) {
234 if ( data.dptr ) free( data.dptr );
236 if ( (rc = (*ldbm->get)( ldbm, &key, &data, 0 )) == 0 ) {
237 /* Berkeley DB 1.85 don't malloc the data for us */
238 /* duplicate it for to ensure reentrancy */
239 data = ldbm_datum_dup( ldbm, data );
252 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
258 #ifdef HAVE_BERKELEY_DB2
259 rc = (*ldbm->put)( ldbm, NULL, &key, &data, flags & ~LDBM_SYNC );
262 rc = (*ldbm->put)( ldbm, &key, &data, flags & ~LDBM_SYNC );
265 if ( flags & LDBM_SYNC )
266 (*ldbm->sync)( ldbm, 0 );
274 ldbm_delete( LDBM ldbm, Datum key )
280 #ifdef HAVE_BERKELEY_DB2
281 rc = (*ldbm->del)( ldbm, NULL, &key, 0 );
284 rc = (*ldbm->del)( ldbm, &key, 0 );
286 (*ldbm->sync)( ldbm, 0 );
294 #ifdef HAVE_BERKELEY_DB2
295 ldbm_firstkey( LDBM ldbm, DBC **dbch )
297 ldbm_firstkey( LDBM ldbm )
302 #ifdef HAVE_BERKELEY_DB2
305 ldbm_datum_init( key );
306 ldbm_datum_init( data );
308 key.flags = data.flags = DB_DBT_MALLOC;
312 /* acquire a cursor for the DB */
314 # if defined( DB_VERSION_MAJOR ) && defined( DB_VERSION_MINOR ) && \
315 DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 6
317 if ( (*ldbm->cursor)( ldbm, NULL, &dbci ))
320 if ( (*ldbm->cursor)( ldbm, NULL, &dbci, 0 ))
326 if ( (*dbci->c_get)( dbci, &key, &data, DB_NEXT ) == 0 ) {
336 if ( (rc = (*ldbm->seq)( ldbm, &key, &data, R_FIRST )) == 0 ) {
337 key = ldbm_datum_dup( ldbm, key );
345 #ifdef HAVE_BERKELEY_DB2
355 #ifdef HAVE_BERKELEY_DB2
356 ldbm_nextkey( LDBM ldbm, Datum key, DBC *dbcp )
358 ldbm_nextkey( LDBM ldbm, Datum key )
363 #ifdef HAVE_BERKELEY_DB2
364 void *oldKey = key.dptr;
366 ldbm_datum_init( data );
368 data.flags = DB_DBT_MALLOC;
372 if ( (*dbcp->c_get)( dbcp, &key, &data, DB_NEXT ) == 0 ) {
373 if ( data.dptr ) free( data.dptr );
380 if ( (rc = (*ldbm->seq)( ldbm, &key, &data, R_NEXT )) == 0 ) {
381 key = ldbm_datum_dup( ldbm, key );
391 #ifdef HAVE_BERKELEY_DB2
392 if ( oldKey ) free( oldKey );
399 ldbm_errno( LDBM ldbm )
404 #elif defined( HAVE_GDBM )
406 #include <sys/stat.h>
408 /*****************************************************************
412 *****************************************************************/
415 ldbm_open( char *name, int rw, int mode, int dbcachesize )
422 if ( (db = gdbm_open( name, 0, rw | GDBM_FAST, mode, 0 )) == NULL ) {
426 if ( dbcachesize > 0 && stat( name, &st ) == 0 ) {
427 dbcachesize = (dbcachesize / st.st_blksize);
428 gdbm_setopt( db, GDBM_CACHESIZE, &dbcachesize, sizeof(int) );
437 ldbm_close( LDBM ldbm )
445 ldbm_sync( LDBM ldbm )
453 ldbm_fetch( LDBM ldbm, Datum key )
458 d = gdbm_fetch( ldbm, key );
465 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
470 rc = gdbm_store( ldbm, key, data, flags & ~LDBM_SYNC );
471 if ( flags & LDBM_SYNC )
479 ldbm_delete( LDBM ldbm, Datum key )
484 rc = gdbm_delete( ldbm, key );
492 ldbm_firstkey( LDBM ldbm )
497 d = gdbm_firstkey( ldbm );
504 ldbm_nextkey( LDBM ldbm, Datum key )
509 d = gdbm_nextkey( ldbm, key );
516 ldbm_errno( LDBM ldbm )
527 #elif defined( HAVE_NDBM )
529 /*****************************************************************
531 * if no gdbm, fall back to using ndbm, the standard unix thing *
533 *****************************************************************/
537 ldbm_open( char *name, int rw, int mode, int dbcachesize )
542 ldbm = dbm_open( name, rw, mode );
549 ldbm_close( LDBM ldbm )
558 ldbm_sync( LDBM ldbm )
564 ldbm_fetch( LDBM ldbm, Datum key )
569 d = ldbm_datum_dup( ldbm, dbm_fetch( ldbm, key ) );
576 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
581 rc = dbm_store( ldbm, key, data, flags );
588 ldbm_delete( LDBM ldbm, Datum key )
593 rc = dbm_delete( ldbm, key );
600 ldbm_firstkey( LDBM ldbm )
605 d = dbm_firstkey( ldbm );
612 ldbm_nextkey( LDBM ldbm, Datum key )
617 d = dbm_nextkey( ldbm );
624 ldbm_errno( LDBM ldbm )
629 err = dbm_error( ldbm );