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
18 #include <ac/string.h>
22 #include "ldap_pvt_thread.h"
26 ldbm_datum_free( LDBM ldbm, Datum data )
34 ldbm_datum_dup( LDBM ldbm, Datum data )
38 if ( data.dsize == 0 ) {
44 dup.dsize = data.dsize;
45 if ( (dup.dptr = (char *) malloc( data.dsize )) != NULL )
46 memcpy( dup.dptr, data.dptr, data.dsize );
51 static int ldbm_initialized = 0;
53 #ifndef HAVE_BERKELEY_DB2
54 /* Everything but DB2 is non-reentrant */
56 static ldap_pvt_thread_mutex_t ldbm_big_mutex;
57 #define LDBM_LOCK (ldap_pvt_thread_mutex_lock(&ldbm_big_mutex))
58 #define LDBM_UNLOCK (ldap_pvt_thread_mutex_unlock(&ldbm_big_mutex))
60 int ldbm_initialize( void )
62 if(ldbm_initialized++) return 1;
64 ldap_pvt_thread_mutex_init( &ldbm_big_mutex );
69 int ldbm_shutdown( void )
71 if( !ldbm_initialized ) return 1;
73 ldap_pvt_thread_mutex_destroy( &ldbm_big_mutex );
81 ldbm_malloc( size_t size )
83 return( calloc( 1, size ));
87 ldbm_db_errcall( const char *prefix, char *message )
90 syslog( LOG_INFO, "ldbm_db_errcall(): %s %s", prefix, message );
94 /* a dbEnv for BERKELEYv2 */
97 /* Berkeley DB 2.x is reentrant */
98 #define LDBM_LOCK ((void)0)
99 #define LDBM_UNLOCK ((void)0)
101 int ldbm_initialize( void )
106 if(ldbm_initialized++) return 1;
108 memset( &ldbm_Env, 0, sizeof( ldbm_Env ));
110 ldbm_Env.db_errcall = ldbm_db_errcall;
111 ldbm_Env.db_errpfx = "==>";
113 envFlags = DB_CREATE | DB_THREAD;
115 if ( ( err = db_appinit( NULL, NULL, &ldbm_Env, envFlags )) ) {
119 sprintf( error, "%ld\n", (long) err );
121 sprintf( error, "%s\n", strerror( err ));
125 "ldbm_initialize(): FATAL error in db_appinit() : %s\n",
133 int ldbm_shutdown( void )
135 if( !ldbm_initialized ) return 1;
137 db_appexit( &ldbm_Env );
144 #if defined( LDBM_USE_DBHASH ) || defined( LDBM_USE_DBBTREE )
146 /*****************************************************************
148 * use berkeley db hash or btree package *
150 *****************************************************************/
153 ldbm_open( char *name, int rw, int mode, int dbcachesize )
157 #ifdef HAVE_BERKELEY_DB2
160 memset( &dbinfo, 0, sizeof( dbinfo ));
161 if ( ldbm_Env.mp_info == NULL )
162 dbinfo.db_cachesize = dbcachesize;
163 dbinfo.db_pagesize = DEFAULT_DB_PAGE_SIZE;
164 dbinfo.db_malloc = ldbm_malloc;
167 (void) db_open( name, DB_TYPE, rw, mode, &ldbm_Env, &dbinfo, &ret );
175 if ( DB_TYPE == DB_HASH ) {
176 memset( (char *) &hinfo, '\0', sizeof(hinfo) );
177 hinfo.cachesize = dbcachesize;
179 } else if ( DB_TYPE == DB_BTREE ) {
180 memset( (char *) &binfo, '\0', sizeof(binfo) );
181 binfo.cachesize = dbcachesize;
188 ret = dbopen( name, rw, mode, DB_TYPE, info );
197 ldbm_close( LDBM ldbm )
200 #ifdef HAVE_BERKELEY_DB2
201 (*ldbm->close)( ldbm, 0 );
203 (*ldbm->close)( ldbm );
209 ldbm_sync( LDBM ldbm )
212 (*ldbm->sync)( ldbm, 0 );
217 ldbm_fetch( LDBM ldbm, Datum key )
224 #ifdef HAVE_BERKELEY_DB2
225 ldbm_datum_init( data );
227 data.flags = DB_DBT_MALLOC;
229 if ( (rc = (*ldbm->get)( ldbm, NULL, &key, &data, 0 )) != 0 ) {
230 if ( data.dptr ) free( data.dptr );
232 if ( (rc = (*ldbm->get)( ldbm, &key, &data, 0 )) == 0 ) {
233 /* Berkeley DB 1.85 don't malloc the data for us */
234 /* duplicate it for to ensure reentrancy */
235 data = ldbm_datum_dup( ldbm, data );
248 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
254 #ifdef HAVE_BERKELEY_DB2
255 rc = (*ldbm->put)( ldbm, NULL, &key, &data, flags & ~LDBM_SYNC );
258 rc = (*ldbm->put)( ldbm, &key, &data, flags & ~LDBM_SYNC );
261 if ( flags & LDBM_SYNC )
262 (*ldbm->sync)( ldbm, 0 );
270 ldbm_delete( LDBM ldbm, Datum key )
276 #ifdef HAVE_BERKELEY_DB2
277 rc = (*ldbm->del)( ldbm, NULL, &key, 0 );
280 rc = (*ldbm->del)( ldbm, &key, 0 );
282 (*ldbm->sync)( ldbm, 0 );
290 #ifdef HAVE_BERKELEY_DB2
291 ldbm_firstkey( LDBM ldbm, DBC **dbch )
293 ldbm_firstkey( LDBM ldbm )
299 #ifdef HAVE_BERKELEY_DB2
302 ldbm_datum_init( key );
303 ldbm_datum_init( data );
305 key.flags = data.flags = DB_DBT_MALLOC;
309 /* acquire a cursor for the DB */
311 # if defined( DB_VERSION_MAJOR ) && defined( DB_VERSION_MINOR ) && \
312 DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 6
314 if ( (*ldbm->cursor)( ldbm, NULL, &dbci ))
317 if ( (*ldbm->cursor)( ldbm, NULL, &dbci, 0 ))
323 if ( (*dbci->c_get)( dbci, &key, &data, DB_NEXT ) == 0 ) {
332 if ( (rc = (*ldbm->seq)( ldbm, &key, &data, R_FIRST )) == 0 ) {
333 key = ldbm_datum_dup( ldbm, key );
341 #ifdef HAVE_BERKELEY_DB2
351 #ifdef HAVE_BERKELEY_DB2
352 ldbm_nextkey( LDBM ldbm, Datum key, DBC *dbcp )
354 ldbm_nextkey( LDBM ldbm, Datum key )
360 #ifdef HAVE_BERKELEY_DB2
361 void *oldKey = key.dptr;
363 ldbm_datum_init( data );
365 data.flags = DB_DBT_MALLOC;
369 if ( (*dbcp->c_get)( dbcp, &key, &data, DB_NEXT ) == 0 ) {
370 if ( data.dptr ) free( data.dptr );
376 if ( (rc = (*ldbm->seq)( ldbm, &key, &data, R_NEXT )) == 0 ) {
377 key = ldbm_datum_dup( ldbm, key );
387 #ifdef HAVE_BERKELEY_DB2
388 if ( oldKey ) free( oldKey );
395 ldbm_errno( LDBM ldbm )
400 #elif defined( HAVE_GDBM )
402 #include <sys/stat.h>
404 /*****************************************************************
408 *****************************************************************/
411 ldbm_open( char *name, int rw, int mode, int dbcachesize )
418 if ( (db = gdbm_open( name, 0, rw | GDBM_FAST, mode, 0 )) == NULL ) {
422 if ( dbcachesize > 0 && stat( name, &st ) == 0 ) {
423 dbcachesize = (dbcachesize / st.st_blksize);
424 gdbm_setopt( db, GDBM_CACHESIZE, &dbcachesize, sizeof(int) );
433 ldbm_close( LDBM ldbm )
441 ldbm_sync( LDBM ldbm )
449 ldbm_fetch( LDBM ldbm, Datum key )
454 d = gdbm_fetch( ldbm, key );
461 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
466 rc = gdbm_store( ldbm, key, data, flags & ~LDBM_SYNC );
467 if ( flags & LDBM_SYNC )
475 ldbm_delete( LDBM ldbm, Datum key )
480 rc = gdbm_delete( ldbm, key );
488 ldbm_firstkey( LDBM ldbm )
493 d = gdbm_firstkey( ldbm );
500 ldbm_nextkey( LDBM ldbm, Datum key )
505 d = gdbm_nextkey( ldbm, key );
512 ldbm_errno( LDBM ldbm )
523 #elif defined( HAVE_NDBM )
525 /*****************************************************************
527 * if no gdbm, fall back to using ndbm, the standard unix thing *
529 *****************************************************************/
533 ldbm_open( char *name, int rw, int mode, int dbcachesize )
538 ldbm = dbm_open( name, rw, mode );
545 ldbm_close( LDBM ldbm )
554 ldbm_sync( LDBM ldbm )
560 ldbm_fetch( LDBM ldbm, Datum key )
565 d = ldbm_datum_dup( ldbm, dbm_fetch( ldbm, key ) );
572 ldbm_store( LDBM ldbm, Datum key, Datum data, int flags )
577 rc = dbm_store( ldbm, key, data, flags );
584 ldbm_delete( LDBM ldbm, Datum key )
589 rc = dbm_delete( ldbm, key );
596 ldbm_firstkey( LDBM ldbm )
601 d = dbm_firstkey( ldbm );
608 ldbm_nextkey( LDBM ldbm, Datum key )
613 d = dbm_nextkey( ldbm );
620 ldbm_errno( LDBM ldbm )
625 err = dbm_error( ldbm );