git.sur5r.net Git - openldap/blob - servers/slapd/back-bdb/dbcache.c

   1 /* dbcache.c - manage cache of open databases */
   2 /* $OpenLDAP$ */
   3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
   4  *
   5  * Copyright 2000-2004 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
  17 #include "portable.h"
  18
  19 #include <stdio.h>
  20
  21 #include <ac/errno.h>
  22 #include <ac/socket.h>
  23 #include <ac/string.h>
  24 #include <ac/time.h>
  25 #include <sys/stat.h>
  26
  27 #include "slap.h"
  28 #include "back-bdb.h"
  29 #include "lutil_hash.h"
  30
  31 #ifdef BDB_INDEX_USE_HASH
  32 /* Pass-thru hash function. Since the indexer is already giving us hash
  33  * values as keys, we don't need BDB to re-hash them.
  34  */
  35 static u_int32_t
  36 bdb_db_hash(
  37         DB *db,
  38         const void *bytes,
  39         u_int32_t length
  40 )
  41 {
  42         u_int32_t ret = 0;
  43         unsigned char *dst = (unsigned char *)&ret;
  44         const unsigned char *src = (const unsigned char *)bytes;
  45
  46         if ( length > sizeof(u_int32_t) )
  47                 length = sizeof(u_int32_t);
  48
  49         while ( length ) {
  50                 *dst++ = *src++;
  51                 length--;
  52         }
  53         return ret;
  54 }
  55 #define BDB_INDEXTYPE   DB_HASH
  56 #else
  57 #define BDB_INDEXTYPE   DB_BTREE
  58 #endif
  59
  60 int
  61 bdb_db_cache(
  62         Backend *be,
  63         const char *name,
  64         DB **dbout )
  65 {
  66         int i;
  67         int rc;
  68         struct bdb_info *bdb = (struct bdb_info *) be->be_private;
  69         struct bdb_db_info *db;
  70         char *file;
  71
  72         *dbout = NULL;
  73
  74         for( i=BDB_NDB; i < bdb->bi_ndatabases; i++ ) {
  75                 if( !strcmp( bdb->bi_databases[i]->bdi_name, name) ) {
  76                         *dbout = bdb->bi_databases[i]->bdi_db;
  77                         return 0;
  78                 }
  79         }
  80
  81         ldap_pvt_thread_mutex_lock( &bdb->bi_database_mutex );
  82
  83         /* check again! may have been added by another thread */
  84         for( i=BDB_NDB; i < bdb->bi_ndatabases; i++ ) {
  85                 if( !strcmp( bdb->bi_databases[i]->bdi_name, name) ) {
  86                         *dbout = bdb->bi_databases[i]->bdi_db;
  87                         ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  88                         return 0;
  89                 }
  90         }
  91
  92         if( i >= BDB_INDICES ) {
  93                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  94                 return -1;
  95         }
  96
  97         db = (struct bdb_db_info *) ch_calloc(1, sizeof(struct bdb_db_info));
  98
  99         db->bdi_name = ch_strdup( name );
 100
 101         rc = db_create( &db->bdi_db, bdb->bi_dbenv, 0 );
 102         if( rc != 0 ) {
 103 #ifdef NEW_LOGGING
 104                 LDAP_LOG ( CACHE, ERR,
 105                         "bdb_db_cache: db_create(%s) failed: %s (%d)\n",
 106                         bdb->bi_dbenv_home, db_strerror(rc), rc );
 107 #else
 108                 Debug( LDAP_DEBUG_ANY,
 109                         "bdb_db_cache: db_create(%s) failed: %s (%d)\n",
 110                         bdb->bi_dbenv_home, db_strerror(rc), rc );
 111 #endif
 112                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
 113                 return rc;
 114         }
 115
 116         rc = db->bdi_db->set_pagesize( db->bdi_db, BDB_PAGESIZE );
 117 #ifdef BDB_INDEX_USE_HASH
 118         rc = db->bdi_db->set_h_hash( db->bdi_db, bdb_db_hash );
 119 #endif
 120         rc = db->bdi_db->set_flags( db->bdi_db, DB_DUP | DB_DUPSORT );
 121         rc = db->bdi_db->set_dup_compare( db->bdi_db, bdb_bt_compare );
 122
 123         file = ch_malloc( strlen( name ) + sizeof(BDB_SUFFIX) );
 124         sprintf( file, "%s" BDB_SUFFIX, name );
 125
 126 #ifdef HAVE_EBCDIC
 127         __atoe( file );
 128 #endif
 129         rc = DB_OPEN( db->bdi_db,
 130                 file, NULL /* name */,
 131                 BDB_INDEXTYPE, bdb->bi_db_opflags | DB_CREATE | DB_THREAD,
 132                 bdb->bi_dbenv_mode );
 133
 134         ch_free( file );
 135
 136         if( rc != 0 ) {
 137 #ifdef NEW_LOGGING
 138                 LDAP_LOG ( CACHE, ERR,
 139                         "bdb_db_cache: db_open(%s) failed: %s (%d)\n",
 140                         name, db_strerror(rc), rc );
 141 #else
 142                 Debug( LDAP_DEBUG_ANY,
 143                         "bdb_db_cache: db_open(%s) failed: %s (%d)\n",
 144                         name, db_strerror(rc), rc );
 145 #endif
 146                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
 147                 return rc;
 148         }
 149
 150         bdb->bi_databases[i] = db;
 151         bdb->bi_ndatabases = i+1;
 152
 153         *dbout = db->bdi_db;
 154
 155         ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
 156         return 0;
 157 }