]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/back-ldbm/idl.c
remove an entry from its parent's children ID list when it's deleted.
[openldap] / servers / slapd / back-ldbm / idl.c
index 88f089116f040a9a09941481d05a891d7d9aad2f..d1e38aa197627da0f01defe370f0e66ade2b7740 100644 (file)
@@ -55,13 +55,11 @@ idl_fetch_one(
     Datum              key
 )
 {
-       Datum   data, k2;
+       Datum   data;
        IDList  *idl;
-       IDList  **tmp;
-       char    *kstr;
-       int     i, nids;
 
 #ifdef HAVE_BERKELEY_DB2
+       Datum   k2;
        memset( &k2, 0, sizeof( k2 ) );
        memset( &data, 0, sizeof( data ) );
 #endif
@@ -131,7 +129,7 @@ idl_fetch(
        kstr = (char *) ch_malloc( key.dsize + 20 );
        nids = 0;
        for ( i = 0; idl->b_ids[i] != NOID; i++ ) {
-               sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr, idl->b_ids[i] );
+               sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr, idl->b_ids[i] );
                k2.dptr = kstr;
                k2.dsize = strlen( kstr ) + 1;
 
@@ -197,7 +195,7 @@ idl_store(
 #endif
 
        flags = LDBM_REPLACE;
-       if( li->li_flush_wrt ) flags |= LDBM_SYNC;
+       if( li->li_dbcachewsync ) flags |= LDBM_SYNC;
        rc = ldbm_cache_store( db, key, data, flags );
 
        /* Debug( LDAP_DEBUG_TRACE, "<= idl_store %d\n", rc, 0, 0 ); */
@@ -212,7 +210,7 @@ idl_split_block(
     IDList     **n2
 )
 {
-       int     i;
+       unsigned int    i;
 
        /* find where to split the block */
        for ( i = 0; i < b->b_nids && id > b->b_ids[i]; i++ )
@@ -272,7 +270,7 @@ idl_change_first(
        }
 
        /* write block with new key */
-       sprintf( bkey.dptr, "%c%s%d", CONT_PREFIX, hkey.dptr, b->b_ids[0] );
+       sprintf( bkey.dptr, "%c%s%ld", CONT_PREFIX, hkey.dptr, b->b_ids[0] );
        bkey.dsize = strlen( bkey.dptr ) + 1;
        if ( (rc = idl_store( be, db, bkey, b )) != 0 ) {
                Debug( LDAP_DEBUG_ANY,
@@ -361,14 +359,14 @@ idl_insert_key(
 
                        /* store the first id block */
                        kstr = (char *) ch_malloc( key.dsize + 20 );
-                       sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+                       sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr,
                            tmp->b_ids[0] );
                        k2.dptr = kstr;
                        k2.dsize = strlen( kstr ) + 1;
                        rc = idl_store( be, db, k2, tmp );
 
                        /* store the second id block */
-                       sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+                       sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr,
                            tmp2->b_ids[0] );
                        k2.dptr = kstr;
                        k2.dsize = strlen( kstr ) + 1;
@@ -404,7 +402,7 @@ idl_insert_key(
 
        /* get the block */
        kstr = (char *) ch_malloc( key.dsize + 20 );
-       sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr, idl->b_ids[i] );
+       sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr, idl->b_ids[i] );
        k2.dptr = kstr;
        k2.dsize = strlen( kstr ) + 1;
        if ( (tmp = idl_fetch_one( be, db, k2 )) == NULL ) {
@@ -446,7 +444,7 @@ idl_insert_key(
                /* is there a next block? */
                if ( !first && idl->b_ids[i + 1] != NOID ) {
                        /* read it in */
-                       sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+                       sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr,
                            idl->b_ids[i + 1] );
                        k2.dptr = kstr;
                        k2.dsize = strlen( kstr ) + 1;
@@ -505,7 +503,7 @@ idl_insert_key(
 
                        /* delete all indirect blocks */
                        for ( j = 0; idl->b_ids[j] != NOID; j++ ) {
-                               sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+                               sprintf( kstr,"%c%s%ld", CONT_PREFIX, key.dptr,
                                    idl->b_ids[j] );
                                k2.dptr = kstr;
                                k2.dsize = strlen( kstr ) + 1;
@@ -544,14 +542,14 @@ idl_insert_key(
                rc = idl_store( be, db, key, tmp );
 
                /* store the first id block */
-               sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+               sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr,
                    tmp2->b_ids[0] );
                k2.dptr = kstr;
                k2.dsize = strlen( kstr ) + 1;
                rc = idl_store( be, db, k2, tmp2 );
 
                /* store the second id block */
-               sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr,
+               sprintf( kstr, "%c%s%ld", CONT_PREFIX, key.dptr,
                    tmp3->b_ids[0] );
                k2.dptr = kstr;
                k2.dsize = strlen( kstr ) + 1;
@@ -579,7 +577,7 @@ idl_insert_key(
 int
 idl_insert( IDList **idl, ID id, int maxids )
 {
-       int     i, j;
+       unsigned int    i, j;
 
        if ( ALLIDS( *idl ) ) {
                return( 2 );    /* already there */
@@ -620,6 +618,93 @@ idl_insert( IDList **idl, ID id, int maxids )
        return( i == 0 ? 1 : 0 );       /* inserted - first id changed or not */
 }
 
+int
+idl_delete_key (
+       Backend         *be,
+       struct dbcache  *db,
+       Datum           key,
+       ID              id
+)
+{
+       Datum  k2;
+       IDList *idl, *tmp;
+       int i, j, nids;
+       char    *kstr;
+
+       if ( (idl = idl_fetch_one( be, db, key ) ) == NULL )
+       {
+               /* It wasn't found.  Hmm... */
+               return -1;
+       }
+
+       if ( ! INDIRECT_BLOCK( idl ) )
+       {
+               for ( i=0; i < idl->b_nids; i++ )
+               {
+                       if ( idl->b_ids[i] == id )
+                       {
+                               memcpy ( &idl->b_ids[i], &idl->b_ids[i+1], sizeof(ID)*(idl->b_nids-(i+1)));
+                               idl->b_ids[idl->b_nids-1] = NOID;
+                               idl->b_nids--;
+                               if ( idl->b_nids )
+                                       idl_store( be, db, key, idl );
+                               else
+                                       ldbm_cache_delete( db, key );
+                               return 0;
+                       }
+                       /*  We didn't find the ID.  Hmmm... */
+               }
+               return -1;
+       }
+       
+       /* We have to go through an indirect block and find the ID
+          in the list of IDL's
+          */
+       for ( nids = 0; idl->b_ids[nids] != NOID; nids++ )
+               ;       /* NULL */
+       kstr = (char *) ch_malloc( key.dsize + 20 );
+       for ( j = 0; idl->b_ids[j] != NOID; j++ ) 
+       {
+               memset( &k2, 0, sizeof(k2) );
+               sprintf( kstr, "%c%s%d", CONT_PREFIX, key.dptr, idl->b_ids[j] );
+               k2.dptr = kstr;
+               k2.dsize = strlen( kstr ) + 1;
+
+               if ( (tmp = idl_fetch_one( be, db, k2 )) == NULL ) {
+                       Debug( LDAP_DEBUG_ANY,
+                           "idl_fetch of (%s) returns NULL\n", k2.dptr, 0, 0 );
+                       continue;
+               }
+               /*
+                  Now try to find the ID in tmp
+               */
+               for ( i=0; i < tmp->b_nids; i++ )
+               {
+                       if ( tmp->b_ids[i] == id )
+                       {
+                               memcpy ( &tmp->b_ids[i], &tmp->b_ids[i+1], sizeof(ID)*(tmp->b_nids-(i+1)));
+                               tmp->b_ids[tmp->b_nids-1] = NOID;
+                               tmp->b_nids--;
+                               if ( tmp->b_nids )
+                                       idl_store ( be, db, k2, tmp );
+                               else
+                               {
+                                       ldbm_cache_delete( db, k2 );
+                                       memcpy ( &idl->b_ids[j], &idl->b_ids[j+1], sizeof(ID)*(nids-(j+1)));
+                                       idl->b_ids[nids-1] = NOID;
+                                       nids--;
+                                       if ( ! nids )
+                                               ldbm_cache_delete( db, key );
+                                       else
+                                               idl_store( be, db, key, idl );
+                               }
+                               return 0;
+                       }
+               }
+       }
+       return -1;
+}
+
 static IDList *
 idl_dup( IDList *idl )
 {
@@ -653,8 +738,8 @@ idl_intersection(
     IDList     *b
 )
 {
-       int     ai, bi, ni;
-       IDList  *n;
+       unsigned int    ai, bi, ni;
+       IDList          *n;
 
        if ( a == NULL || b == NULL ) {
                return( NULL );
@@ -701,8 +786,8 @@ idl_union(
     IDList     *b
 )
 {
-       int     ai, bi, ni;
-       IDList  *n;
+       unsigned int    ai, bi, ni;
+       IDList          *n;
 
        if ( a == NULL ) {
                return( idl_dup( b ) );
@@ -755,8 +840,8 @@ idl_notin(
     IDList     *b
 )
 {
-       int     ni, ai, bi;
-       IDList  *n;
+       unsigned int    ni, ai, bi;
+       IDList          *n;
 
        if ( a == NULL ) {
                return( NULL );
@@ -834,7 +919,7 @@ idl_firstid( IDList *idl )
 ID
 idl_nextid( IDList *idl, ID id )
 {
-       int     i;
+       unsigned int    i;
 
        if ( ALLIDS( idl ) ) {
                return( ++id < idl->b_nids ? id : NOID );