X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=servers%2Fslapd%2Fback-mdb%2Fconfig.c;h=c6cb3cb0430e2ab39993642fa6adc21e766ce799;hb=b444ce47cefb43235a6104e5ce1646a2bff0c632;hp=6281032de260b449502e9ee80d50eb9751bcdd16;hpb=df0935319a1ab47d0eb6b7295d96dee765fc9534;p=openldap

diff --git a/servers/slapd/back-mdb/config.c b/servers/slapd/back-mdb/config.c
index 6281032de2..c6cb3cb043 100644
--- a/servers/slapd/back-mdb/config.c
+++ b/servers/slapd/back-mdb/config.c
@@ -35,6 +35,7 @@ enum {
 	MDB_DIRECTORY,
 	MDB_DBNOSYNC,
 	MDB_INDEX,
+	MDB_MAXREADERS,
 	MDB_MAXSIZE,
 	MDB_MODE,
 	MDB_SSTACK,
@@ -59,8 +60,12 @@ static ConfigTable mdbcfg[] = {
 		"DESC 'Attribute index parameters' "
 		"EQUALITY caseIgnoreMatch "
 		"SYNTAX OMsDirectoryString )", NULL, NULL },
+	{ "maxreaders", "num", 2, 2, 0, ARG_INT|ARG_MAGIC|MDB_MAXREADERS,
+		mdb_cf_gen, "( OLcfgDbAt:12.1 NAME 'olcDbMaxReaders' "
+		"DESC 'Maximum number of threads that may access the DB concurrently' "
+		"SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL },
 	{ "maxsize", "size", 2, 2, 0, ARG_ULONG|ARG_MAGIC|MDB_MAXSIZE,
-		mdb_cf_gen, "( OLcfgDbAt:12.1 NAME 'olcDbMaxSize' "
+		mdb_cf_gen, "( OLcfgDbAt:12.2 NAME 'olcDbMaxSize' "
 		"DESC 'Maximum size of DB in bytes' "
 		"SYNTAX OMsInteger SINGLE-VALUE )", NULL, NULL },
 	{ "mode", "mode", 2, 2, 0, ARG_MAGIC|MDB_MODE,
@@ -83,7 +88,7 @@ static ConfigOCs mdbocs[] = {
 		"SUP olcDatabaseConfig "
 		"MUST olcDbDirectory "
 		"MAY ( olcDbCheckpoint $ "
-		"olcDbNoSync $ olcDbIndex $ olcDbMaxsize $ "
+		"olcDbNoSync $ olcDbIndex $ olcDbMaxReaders $ olcDbMaxsize $ "
 		"olcDbMode $ olcDbSearchStack ) )",
 		 	Cft_Database, mdbcfg },
 	{ NULL, 0, NULL }
@@ -107,7 +112,6 @@ mdb_checkpoint( void *ctx, void *arg )
 static void *
 mdb_online_index( void *ctx, void *arg )
 {
-#if 0
 	struct re_s *rtask = arg;
 	BackendDB *be = rtask->arg;
 	struct mdb_info *mdb = be->be_private;
@@ -116,12 +120,11 @@ mdb_online_index( void *ctx, void *arg )
 	OperationBuffer opbuf;
 	Operation *op;
 
-	DBC *curs;
-	DBT key, data;
-	DB_TXN *txn;
-	DB_LOCK lock;
-	ID id, nid;
-	EntryInfo *ei;
+	MDB_cursor *curs;
+	MDB_val key, data;
+	MDB_txn *txn;
+	ID id;
+	Entry *e;
 	int rc, getnext = 1;
 	int i;
 
@@ -130,98 +133,72 @@ mdb_online_index( void *ctx, void *arg )
 
 	op->o_bd = be;
 
-	DBTzero( &key );
-	DBTzero( &data );
-
 	id = 1;
-	key.data = &nid;
-	key.size = key.ulen = sizeof(ID);
-	key.flags = DB_DBT_USERMEM;
-
-	data.flags = DB_DBT_USERMEM | DB_DBT_PARTIAL;
-	data.dlen = data.ulen = 0;
+	key.mv_data = &id;
+	key.mv_size = sizeof(ID);
 
 	while ( 1 ) {
 		if ( slapd_shutdown )
 			break;
 
-		rc = TXN_BEGIN( mdb->bi_dbenv, NULL, &txn, mdb->bi_db_opflags );
+		rc = mdb_txn_begin( mdb->mi_dbenv, 0, &txn );
 		if ( rc )
 			break;
 		if ( getnext ) {
 			getnext = 0;
-			MDB_ID2DISK( id, &nid );
-			rc = mdb->bi_id2entry->bdi_db->cursor(
-				mdb->bi_id2entry->bdi_db, txn, &curs, mdb->bi_db_opflags );
+			rc = mdb_cursor_open( txn, mdb->mi_id2entry, &curs );
 			if ( rc ) {
-				TXN_ABORT( txn );
+				mdb_txn_abort( txn );
 				break;
 			}
-			rc = curs->c_get( curs, &key, &data, DB_SET_RANGE );
-			curs->c_close( curs );
+			rc = mdb_cursor_get( curs, &key, &data, MDB_SET_RANGE );
+			memcpy( &id, key.mv_data, sizeof( id ));
+			mdb_cursor_close( curs );
 			if ( rc ) {
-				TXN_ABORT( txn );
-				if ( rc == DB_NOTFOUND )
+				mdb_txn_abort( txn );
+				if ( rc == MDB_NOTFOUND )
 					rc = 0;
-				if ( rc == DB_LOCK_DEADLOCK ) {
-					ldap_pvt_thread_yield();
-					continue;
-				}
 				break;
 			}
-			MDB_DISK2ID( &nid, &id );
 		}
 
-		ei = NULL;
-		rc = mdb_cache_find_id( op, txn, id, &ei, 0, &lock );
+		rc = mdb_id2entry( op, txn, id, &e );
 		if ( rc ) {
-			TXN_ABORT( txn );
-			if ( rc == DB_LOCK_DEADLOCK ) {
-				ldap_pvt_thread_yield();
-				continue;
-			}
-			if ( rc == DB_NOTFOUND ) {
+			mdb_txn_abort( txn );
+			if ( rc == MDB_NOTFOUND ) {
 				id++;
 				getnext = 1;
 				continue;
 			}
 			break;
 		}
-		if ( ei->bei_e ) {
-			rc = mdb_index_entry( op, txn, MDB_INDEX_UPDATE_OP, ei->bei_e );
-			if ( rc == DB_LOCK_DEADLOCK ) {
-				TXN_ABORT( txn );
-				ldap_pvt_thread_yield();
-				continue;
-			}
-			if ( rc == 0 ) {
-				rc = TXN_COMMIT( txn, 0 );
-				txn = NULL;
-			}
-			if ( rc )
-				break;
+		rc = mdb_index_entry( op, txn, MDB_INDEX_UPDATE_OP, e );
+		if ( rc == 0 ) {
+			rc = mdb_txn_commit( txn );
+			txn = NULL;
 		}
+		if ( rc )
+			break;
 		id++;
 		getnext = 1;
 	}
 
-	for ( i = 0; i < mdb->bi_nattrs; i++ ) {
-		if ( mdb->bi_attrs[ i ]->ai_indexmask & MDB_INDEX_DELETING
-			|| mdb->bi_attrs[ i ]->ai_newmask == 0 )
+	for ( i = 0; i < mdb->mi_nattrs; i++ ) {
+		if ( mdb->mi_attrs[ i ]->ai_indexmask & MDB_INDEX_DELETING
+			|| mdb->mi_attrs[ i ]->ai_newmask == 0 )
 		{
 			continue;
 		}
-		mdb->bi_attrs[ i ]->ai_indexmask = mdb->bi_attrs[ i ]->ai_newmask;
-		mdb->bi_attrs[ i ]->ai_newmask = 0;
+		mdb->mi_attrs[ i ]->ai_indexmask = mdb->mi_attrs[ i ]->ai_newmask;
+		mdb->mi_attrs[ i ]->ai_newmask = 0;
 	}
 
 	ldap_pvt_thread_mutex_lock( &slapd_rq.rq_mutex );
 	ldap_pvt_runqueue_stoptask( &slapd_rq, rtask );
-	mdb->bi_index_task = NULL;
+	mdb->mi_index_task = NULL;
 	ldap_pvt_runqueue_remove( &slapd_rq, rtask );
 	ldap_pvt_thread_mutex_unlock( &slapd_rq.rq_mutex );
 
-#endif
 	return NULL;
 }
 
@@ -321,6 +298,10 @@ mdb_cf_gen( ConfigArgs *c )
 			c->value_int = mdb->mi_search_stack_depth;
 			break;
 
+		case MDB_MAXREADERS:
+			c->value_int = mdb->mi_readers;
+			break;
+
 		case MDB_MAXSIZE:
 			c->value_ulong = mdb->mi_mapsize;
 			break;
@@ -339,6 +320,7 @@ mdb_cf_gen( ConfigArgs *c )
 
 		/* single-valued no-ops */
 		case MDB_SSTACK:
+		case MDB_MAXREADERS:
 		case MDB_MAXSIZE:
 			break;
 
@@ -579,6 +561,12 @@ mdb_cf_gen( ConfigArgs *c )
 		mdb->mi_search_stack_depth = c->value_int;
 		break;
 
+	case MDB_MAXREADERS:
+		mdb->mi_readers = c->value_int;
+		if ( mdb->mi_flags & MDB_IS_OPEN )
+			mdb->mi_flags |= MDB_RE_OPEN;
+		break;
+
 	case MDB_MAXSIZE:
 		mdb->mi_mapsize = c->value_ulong;
 		if ( mdb->mi_flags & MDB_IS_OPEN )