]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/back-bdb/modify.c
Set lock detector to DEFAULT, not NORUN.
[openldap] / servers / slapd / back-bdb / modify.c
index 336c2910560d6985433cfdc4602878979ef9b29a..b00b60236c36116fbc6f2c90a483af970aa38a13 100644 (file)
 #include "back-bdb.h"
 #include "external.h"
 
-static int add_values( Entry *e, Modification *mod, char *dn );
-static int delete_values( Entry *e, Modification *mod, char *dn );
-static int replace_values( Entry *e, Modification *mod, char *dn );
-
 int bdb_modify_internal(
        BackendDB *be,
        Connection *conn,
@@ -33,6 +29,7 @@ int bdb_modify_internal(
        Modification    *mod;
        Modifications   *ml;
        Attribute       *save_attrs;
+       Attribute       *ap;
 
        Debug( LDAP_DEBUG_TRACE, "bdb_modify_internal: 0x%08lx: %s\n",
                e->e_id, e->e_dn, 0);
@@ -50,10 +47,8 @@ int bdb_modify_internal(
                switch ( mod->sm_op ) {
                case LDAP_MOD_ADD:
                        Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: add\n", 0, 0, 0);
-                       err = add_values( e, mod, op->o_ndn.bv_val );
-
+                       err = modify_add_values( e, mod, text, textbuf, textlen );
                        if( err != LDAP_SUCCESS ) {
-                               *text = "modify: add values failed";
                                Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
                                        err, *text, 0);
                        }
@@ -61,10 +56,9 @@ int bdb_modify_internal(
 
                case LDAP_MOD_DELETE:
                        Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: delete\n", 0, 0, 0);
-                       err = delete_values( e, mod, op->o_ndn.bv_val );
+                       err = modify_delete_values( e, mod, text, textbuf, textlen );
                        assert( err != LDAP_TYPE_OR_VALUE_EXISTS );
                        if( err != LDAP_SUCCESS ) {
-                               *text = "modify: delete values failed";
                                Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
                                        err, *text, 0);
                        }
@@ -72,10 +66,9 @@ int bdb_modify_internal(
 
                case LDAP_MOD_REPLACE:
                        Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: replace\n", 0, 0, 0);
-                       err = replace_values( e, mod, op->o_ndn.bv_val );
+                       err = modify_replace_values( e, mod, text, textbuf, textlen );
                        assert( err != LDAP_TYPE_OR_VALUE_EXISTS );
                        if( err != LDAP_SUCCESS ) {
-                               *text = "modify: replace values failed";
                                Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
                                        err, *text, 0);
                        }
@@ -87,14 +80,13 @@ int bdb_modify_internal(
                         * We need to add index if necessary.
                         */
                        mod->sm_op = LDAP_MOD_ADD;
-                       err = add_values( e, mod, op->o_ndn.bv_val );
 
+                       err = modify_add_values( e, mod, text, textbuf, textlen );
                        if ( err == LDAP_TYPE_OR_VALUE_EXISTS ) {
                                err = LDAP_SUCCESS;
                        }
 
                        if( err != LDAP_SUCCESS ) {
-                               *text = "modify: (soft)add values failed";
                                Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
                                        err, *text, 0);
                        }
@@ -115,10 +107,25 @@ int bdb_modify_internal(
                        /* unlock entry, delete from cache */
                        return err; 
                }
+
+               /* If objectClass was modified, reset the flags */
+               if ( mod->sm_desc == slap_schema.si_ad_objectClass ) {
+                       e->e_ocflags = 0;
+               }
+
+               /* check if modified attribute was indexed */
+               err = bdb_index_is_indexed( be, mod->sm_desc );
+               if ( err == LDAP_SUCCESS ) {
+                       ap = attr_find( save_attrs, mod->sm_desc );
+                       if ( ap ) ap->a_flags |= SLAP_ATTR_IXDEL;
+
+                       ap = attr_find( e->e_attrs, mod->sm_desc );
+                       if ( ap ) ap->a_flags |= SLAP_ATTR_IXADD;
+               }
        }
 
        /* check that the entry still obeys the schema */
-       rc = entry_schema_check( e, save_attrs, text, textbuf, textlen );
+       rc = entry_schema_check( be, e, save_attrs, text, textbuf, textlen );
        if ( rc != LDAP_SUCCESS ) {
                attrs_free( e->e_attrs );
                e->e_attrs = save_attrs;
@@ -127,24 +134,40 @@ int bdb_modify_internal(
                return rc;
        }
 
-       /* delete indices for old attributes */
-       rc = bdb_index_entry_del( be, tid, e, save_attrs);
-       if ( rc != LDAP_SUCCESS ) {
-               attrs_free( e->e_attrs );
-               e->e_attrs = save_attrs;
-               Debug( LDAP_DEBUG_ANY, "entry index delete failed!\n",
-                       0, 0, 0 );
-               return rc;
+       /* update the indices of the modified attributes */
+
+       /* start with deleting the old index entries */
+       for ( ap = save_attrs; ap != NULL; ap = ap->a_next ) {
+               if ( ap->a_flags & SLAP_ATTR_IXDEL ) {
+                       rc = bdb_index_values( be, tid, ap->a_desc, ap->a_vals,
+                                              e->e_id, SLAP_INDEX_DELETE_OP );
+                       if ( rc != LDAP_SUCCESS ) {
+                               attrs_free( e->e_attrs );
+                               e->e_attrs = save_attrs;
+                               Debug( LDAP_DEBUG_ANY,
+                                      "Attribute index delete failure",
+                                      0, 0, 0 );
+                               return rc;
+                       }
+                       ap->a_flags &= ~SLAP_ATTR_IXDEL;
+               }
        }
 
-       /* add indices for new attributes */
-       rc = bdb_index_entry_add( be, tid, e, e->e_attrs); 
-       if ( rc != LDAP_SUCCESS ) {
-               attrs_free( e->e_attrs );
-               e->e_attrs = save_attrs;
-               Debug( LDAP_DEBUG_ANY, "entry index add failed!\n",
-                       0, 0, 0 );
-               return rc;
+       /* add the new index entries */
+       for ( ap = e->e_attrs; ap != NULL; ap = ap->a_next ) {
+               if (ap->a_flags & SLAP_ATTR_IXADD) {
+                       rc = bdb_index_values( be, tid, ap->a_desc, ap->a_vals,
+                                              e->e_id, SLAP_INDEX_ADD_OP );
+                       if ( rc != LDAP_SUCCESS ) {
+                               attrs_free( e->e_attrs );
+                               e->e_attrs = save_attrs;
+                               Debug( LDAP_DEBUG_ANY,
+                                      "Attribute index add failure",
+                                      0, 0, 0 );
+                               return rc;
+                       }
+                       ap->a_flags &= ~SLAP_ATTR_IXADD;
+               }
        }
 
        return rc;
@@ -185,6 +208,7 @@ retry:      /* transaction retry */
                        text = "internal error";
                        goto return_results;
                }
+               ldap_pvt_thread_yield();
        }
 
        if( bdb->bi_txn ) {
@@ -230,7 +254,7 @@ retry:      /* transaction retry */
        /* acquire and lock entry */
        if ( e == NULL ) {
                char* matched_dn = NULL;
-               BVarray refs;
+               BerVarray refs;
 
                if ( matched != NULL ) {
                        matched_dn = ch_strdup( matched->e_dn );
@@ -248,7 +272,7 @@ retry:      /* transaction retry */
                send_ldap_result( conn, op, rc = LDAP_REFERRAL,
                        matched_dn, NULL, refs, NULL );
 
-               bvarray_free( refs );
+               ber_bvarray_free( refs );
                free( matched_dn );
 
                return rc;
@@ -257,7 +281,7 @@ retry:      /* transaction retry */
        if ( !manageDSAit && is_entry_referral( e ) ) {
                /* parent is a referral, don't allow add */
                /* parent is an alias, don't allow add */
-               BVarray refs = get_entry_referrals( be,
+               BerVarray refs = get_entry_referrals( be,
                        conn, op, e );
 
                Debug( LDAP_DEBUG_TRACE,
@@ -267,7 +291,7 @@ retry:      /* transaction retry */
                send_ldap_result( conn, op, rc = LDAP_REFERRAL,
                        e->e_dn, NULL, refs, NULL );
 
-               bvarray_free( refs );
+               ber_bvarray_free( refs );
                goto done;
        }
        
@@ -345,185 +369,3 @@ done:
        return rc;
 }
 
-static int
-add_values(
-       Entry   *e,
-       Modification    *mod,
-       char    *dn
-)
-{
-       int             i;
-       Attribute       *a;
-
-       /* char *desc = mod->sm_desc->ad_cname.bv_val; */
-       MatchingRule *mr = mod->sm_desc->ad_type->sat_equality;
-
-       a = attr_find( e->e_attrs, mod->sm_desc );
-
-       /* check if the values we're adding already exist */
-       if ( a != NULL ) {
-               if( mr == NULL || !mr->smr_match ) {
-                       /* do not allow add of additional attribute
-                               if no equality rule exists */
-                       return LDAP_INAPPROPRIATE_MATCHING;
-               }
-
-               for ( i = 0; mod->sm_bvalues[i].bv_val != NULL; i++ ) {
-                       int rc;
-                       int j;
-                       const char *text = NULL;
-                       struct berval asserted;
-
-                       rc = value_normalize( mod->sm_desc,
-                               SLAP_MR_EQUALITY,
-                               &mod->sm_bvalues[i],
-                               &asserted,
-                               &text );
-
-                       if( rc != LDAP_SUCCESS ) return rc;
-
-                       for ( j = 0; a->a_vals[j].bv_val != NULL; j++ ) {
-                               int match;
-                               int rc = value_match( &match, mod->sm_desc, mr,
-                                       SLAP_MR_VALUE_SYNTAX_MATCH,
-                                       &a->a_vals[j], &asserted, &text );
-
-                               if( rc == LDAP_SUCCESS && match == 0 ) {
-                                       free( asserted.bv_val );
-                                       return LDAP_TYPE_OR_VALUE_EXISTS;
-                               }
-                       }
-
-                       free( asserted.bv_val );
-               }
-       }
-
-       /* no - add them */
-       if( attr_merge( e, mod->sm_desc, mod->sm_bvalues ) != 0 ) {
-               /* this should return result of attr_merge */
-               return LDAP_OTHER;
-       }
-
-       return LDAP_SUCCESS;
-}
-
-static int
-delete_values(
-       Entry   *e,
-       Modification    *mod,
-       char    *dn
-)
-{
-       int             i, j, k, found;
-       Attribute       *a;
-       char *desc = mod->sm_desc->ad_cname.bv_val;
-       MatchingRule *mr = mod->sm_desc->ad_type->sat_equality;
-
-       /* delete the entire attribute */
-       if ( mod->sm_bvalues == NULL ) {
-               Debug( LDAP_DEBUG_TRACE,
-                       "bdb_modify_delete: removing entire attribute %s\n",
-                       desc, 0, 0 );
-               return attr_delete( &e->e_attrs, mod->sm_desc )
-                       ? LDAP_NO_SUCH_ATTRIBUTE : LDAP_SUCCESS;
-       }
-
-       if( mr == NULL || !mr->smr_match ) {
-               /* disallow specific attributes from being deleted if
-                       no equality rule */
-               return LDAP_INAPPROPRIATE_MATCHING;
-       }
-
-       /* delete specific values - find the attribute first */
-       if ( (a = attr_find( e->e_attrs, mod->sm_desc )) == NULL ) {
-               Debug( LDAP_DEBUG_TRACE,
-                       "bdb_modify_delete: could not find attribute %s\n",
-                       desc, 0, 0 );
-               return LDAP_NO_SUCH_ATTRIBUTE;
-       }
-
-       /* find each value to delete */
-       for ( i = 0; mod->sm_bvalues[i].bv_val != NULL; i++ ) {
-               int rc;
-               const char *text = NULL;
-
-               struct berval asserted;
-
-               rc = value_normalize( mod->sm_desc,
-                       SLAP_MR_EQUALITY,
-                       &mod->sm_bvalues[i],
-                       &asserted,
-                       &text );
-
-               if( rc != LDAP_SUCCESS ) return rc;
-
-               found = 0;
-               for ( j = 0; a->a_vals[j].bv_val != NULL; j++ ) {
-                       int match;
-                       int rc = value_match( &match, mod->sm_desc, mr,
-                               SLAP_MR_VALUE_SYNTAX_MATCH,
-                               &a->a_vals[j], &asserted, &text );
-
-                       if( rc == LDAP_SUCCESS && match != 0 ) {
-                               continue;
-                       }
-
-                       /* found a matching value */
-                       found = 1;
-
-                       /* delete it */
-                       free( a->a_vals[j].bv_val );
-                       for ( k = j + 1; a->a_vals[k].bv_val != NULL; k++ ) {
-                               a->a_vals[k - 1] = a->a_vals[k];
-                       }
-                       a->a_vals[k - 1].bv_val = NULL;
-                       a->a_vals[k - 1].bv_len = 0;
-
-                       break;
-               }
-
-               free( asserted.bv_val );
-
-               /* looked through them all w/o finding it */
-               if ( ! found ) {
-                       Debug( LDAP_DEBUG_TRACE,
-                               "bdb_modify_delete: could not find value for attr %s\n",
-                               desc, 0, 0 );
-                       return LDAP_NO_SUCH_ATTRIBUTE;
-               }
-       }
-
-       /* if no values remain, delete the entire attribute */
-       if ( a->a_vals[0].bv_val == NULL ) {
-               Debug( LDAP_DEBUG_TRACE,
-                       "bdb_modify_delete: removing entire attribute %s\n",
-                       desc, 0, 0 );
-               if ( attr_delete( &e->e_attrs, mod->sm_desc ) ) {
-                       return LDAP_NO_SUCH_ATTRIBUTE;
-               }
-       }
-
-       return LDAP_SUCCESS;
-}
-
-static int
-replace_values(
-       Entry   *e,
-       Modification    *mod,
-       char    *dn
-)
-{
-       int rc = attr_delete( &e->e_attrs, mod->sm_desc );
-
-       if( rc != LDAP_SUCCESS && rc != LDAP_NO_SUCH_ATTRIBUTE ) {
-               return rc;
-       }
-
-       if ( mod->sm_bvalues != NULL &&
-               attr_merge( e, mod->sm_desc, mod->sm_bvalues ) != 0 )
-       {
-               return LDAP_OTHER;
-       }
-
-       return LDAP_SUCCESS;
-}