git.sur5r.net Git - openldap/blob - servers/slapd/back-mdb/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-2011 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-mdb.h"
  29
  30 int
  31 mdb_db_cache(
  32         Backend *be,
  33         struct berval *name,
  34         MDB_dbi *dbout )
  35 {
  36         int i, flags;
  37         int rc;
  38         struct mdb_info *mdb = (struct mdb_info *) be->be_private;
  39         struct mdb_db_info *db;
  40         char *file;
  41
  42         *dbout = 0;
  43
  44         for( i=MDB_NDB; i < mdb->mi_ndatabases; i++ ) {
  45                 if( !ber_bvcmp( &mdb->mi_databases[i]->mdi_name, name) ) {
  46                         *dbout = mdb->mi_databases[i]->mdi_dbi;
  47                         return 0;
  48                 }
  49         }
  50
  51         ldap_pvt_thread_mutex_lock( &mdb->mi_database_mutex );
  52
  53         /* check again! may have been added by another thread */
  54         for( i=MDB_NDB; i < mdb->mi_ndatabases; i++ ) {
  55                 if( !ber_bvcmp( &mdb->mi_databases[i]->mdi_name, name) ) {
  56                         *dbout = mdb->mi_databases[i]->mdi_dbi;
  57                         ldap_pvt_thread_mutex_unlock( &mdb->mi_database_mutex );
  58                         return 0;
  59                 }
  60         }
  61
  62         if( i >= MDB_INDICES ) {
  63                 ldap_pvt_thread_mutex_unlock( &mdb->mi_database_mutex );
  64                 return -1;
  65         }
  66
  67         db = (struct mdb_db_info *) ch_calloc(1, sizeof(struct mdb_db_info));
  68
  69         ber_dupbv( &db->mdi_name, name );
  70
  71         rc = db_create( &db->mdi_dbi, mdb->mi_dbenv, 0 );
  72         if( rc != 0 ) {
  73                 Debug( LDAP_DEBUG_ANY,
  74                         "mdb_db_cache: db_create(%s) failed: %s (%d)\n",
  75                         mdb->mi_dbenv_home, mdb_strerror(rc), rc );
  76                 ldap_pvt_thread_mutex_unlock( &mdb->mi_database_mutex );
  77                 ch_free( db );
  78                 return rc;
  79         }
  80
  81         file = ch_malloc( db->mdi_name.bv_len + sizeof(MDB_SUFFIX) );
  82         strcpy( file, db->mdi_name.bv_val );
  83         strcpy( file+db->mdi_name.bv_len, MDB_SUFFIX );
  84
  85 #ifdef HAVE_EBCDIC
  86         __atoe( file );
  87 #endif
  88         flags = DB_CREATE | DB_THREAD;
  89 #ifdef DB_AUTO_COMMIT
  90         if ( !( slapMode & SLAP_TOOL_QUICK ))
  91                 flags |= DB_AUTO_COMMIT;
  92 #endif
  93         /* Cannot Truncate when Transactions are in use */
  94         if ( (slapMode & (SLAP_TOOL_QUICK|SLAP_TRUNCATE_MODE)) ==
  95                 (SLAP_TOOL_QUICK|SLAP_TRUNCATE_MODE))
  96                         flags |= DB_TRUNCATE;
  97
  98         rc = DB_OPEN( db->mdi_dbi,
  99                 file, NULL /* name */,
 100                 MDB_INDEXTYPE, mdb->mi_db_opflags | flags, mdb->mi_dbenv_mode );
 101
 102         ch_free( file );
 103
 104         if( rc != 0 ) {
 105                 Debug( LDAP_DEBUG_ANY,
 106                         "mdb_db_cache: db_open(%s) failed: %s (%d)\n",
 107                         name->bv_val, mdb_strerror(rc), rc );
 108                 ldap_pvt_thread_mutex_unlock( &mdb->mi_database_mutex );
 109                 return rc;
 110         }
 111
 112         mdb->mi_databases[i] = db;
 113         mdb->mi_ndatabases = i+1;
 114
 115         *dbout = db->mdi_dbi;
 116
 117         ldap_pvt_thread_mutex_unlock( &mdb->mi_database_mutex );
 118         return 0;
 119 }