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

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