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-2001 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
  21 int
  22 bdb_db_cache(
  23         Backend *be,
  24         const char *name,
  25         DB **dbout )
  26 {
  27         int i;
  28         int rc;
  29         struct bdb_info *bdb = (struct bdb_info *) be->be_private;
  30         struct bdb_db_info *db;
  31         char *file;
  32
  33         *dbout = NULL;
  34
  35         for( i=BDB_NDB; bdb->bi_databases[i]; i++ ) {
  36                 if( !strcmp( bdb->bi_databases[i]->bdi_name, name) ) {
  37                         *dbout = bdb->bi_databases[i]->bdi_db;
  38                         return 0;
  39                 }
  40         }
  41
  42         ldap_pvt_thread_mutex_lock( &bdb->bi_database_mutex );
  43
  44         /* check again! may have been added by another thread */
  45         for( i=BDB_NDB; bdb->bi_databases[i]; i++ ) {
  46                 if( !strcmp( bdb->bi_databases[i]->bdi_name, name) ) {
  47                         *dbout = bdb->bi_databases[i]->bdi_db;
  48                         ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  49                         return 0;
  50                 }
  51         }
  52
  53         if( i >= BDB_INDICES ) {
  54                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  55                 return -1;
  56         }
  57
  58         db = (struct bdb_db_info *) ch_calloc(1, sizeof(struct bdb_db_info));
  59
  60         db->bdi_name = ch_strdup( name );
  61
  62         rc = db_create( &db->bdi_db, bdb->bi_dbenv, 0 );
  63         if( rc != 0 ) {
  64                 Debug( LDAP_DEBUG_ANY,
  65                         "bdb_db_cache: db_create(%s) failed: %s (%d)\n",
  66                         bdb->bi_dbenv_home, db_strerror(rc), rc );
  67                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  68                 return rc;
  69         }
  70
  71         file = ch_malloc( strlen( name ) + sizeof(BDB_SUFFIX) );
  72         sprintf( file, "%s" BDB_SUFFIX, name );
  73
  74         rc = db->bdi_db->open( db->bdi_db,
  75                 file, name,
  76                 DB_BTREE, DB_CREATE|DB_THREAD,
  77                 bdb->bi_dbenv_mode );
  78
  79         ch_free( file );
  80
  81         if( rc != 0 ) {
  82                 Debug( LDAP_DEBUG_ANY,
  83                         "bdb_db_cache: db_open(%s) failed: %s (%d)\n",
  84                         name, db_strerror(rc), rc );
  85                 ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  86                 return rc;
  87         }
  88
  89         bdb->bi_databases[i+1] = NULL;
  90         bdb->bi_databases[i] = db;
  91
  92         *dbout = db->bdi_db;
  93
  94         ldap_pvt_thread_mutex_unlock( &bdb->bi_database_mutex );
  95         return 0;
  96 }