X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fmodify.c;h=f84026220864d369fd6276fadf76659b3f2e2736;hb=c3960b98d3b5fbd6ebeb200ca7799ece7b766d50;hp=5dfe550d02518847713fa11ee540be16d27b92eb;hpb=d959a7a7b5fc8550b7103ed1e51b95ab0764d379;p=openldap diff --git a/servers/slapd/modify.c b/servers/slapd/modify.c index 5dfe550d02..f840262208 100644 --- a/servers/slapd/modify.c +++ b/servers/slapd/modify.c @@ -1,7 +1,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 1998-2005 The OpenLDAP Foundation. + * Copyright 1998-2006 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -171,7 +171,6 @@ do_modify( if( get_ctrls( op, rs, 1 ) != LDAP_SUCCESS ) { Debug( LDAP_DEBUG_ANY, "do_modify: get_ctrls failed\n", 0, 0, 0 ); - goto cleanup; } @@ -184,7 +183,7 @@ do_modify( goto cleanup; } - rs->sr_err = slap_mods_check( modlist, + rs->sr_err = slap_mods_check( op, modlist, &rs->sr_text, textbuf, textlen, NULL ); if ( rs->sr_err != LDAP_SUCCESS ) { @@ -199,6 +198,13 @@ do_modify( op->o_bd = frontendDB; rs->sr_err = frontendDB->be_modify( op, rs ); +#ifdef LDAP_X_TXN + if( rs->sr_err == LDAP_X_TXN_SPECIFY_OKAY ) { + /* skip cleanup */ + return rs->sr_err; + } +#endif + cleanup: op->o_tmpfree( op->o_req_dn.bv_val, op->o_tmpmemctx ); op->o_tmpfree( op->o_req_ndn.bv_val, op->o_tmpmemctx ); @@ -214,13 +220,11 @@ fe_op_modify( Operation *op, SlapReply *rs ) Modifications *tmp; #endif int manageDSAit; - Modifications *modlist = op->orm_modlist; - int increment = op->orm_increment; - BackendDB *op_be; + BackendDB *op_be, *bd = op->o_bd; char textbuf[ SLAP_TEXT_BUFLEN ]; size_t textlen = sizeof( textbuf ); - if( BER_BVISEMPTY( &op->o_req_ndn ) ) { + if ( BER_BVISEMPTY( &op->o_req_ndn ) ) { Debug( LDAP_DEBUG_ANY, "do_modify: root dse!\n", 0, 0, 0 ); send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, @@ -238,7 +242,7 @@ fe_op_modify( Operation *op, SlapReply *rs ) #ifdef LDAP_DEBUG Debug( LDAP_DEBUG_ARGS, "modifications:\n", 0, 0, 0 ); - for ( tmp = modlist; tmp != NULL; tmp = tmp->sml_next ) { + for ( tmp = op->orm_modlist; tmp != NULL; tmp = tmp->sml_next ) { Debug( LDAP_DEBUG_ARGS, "\t%s: %s\n", tmp->sml_op == LDAP_MOD_ADD ? "add" : (tmp->sml_op == LDAP_MOD_INCREMENT ? "increment" : @@ -267,12 +271,12 @@ fe_op_modify( Operation *op, SlapReply *rs ) Statslog( LDAP_DEBUG_STATS, "%s MOD dn=\"%s\"\n", op->o_log_prefix, op->o_req_dn.bv_val, 0, 0, 0 ); - for ( tmp = modlist; tmp != NULL; tmp = tmp->sml_next ) { + for ( tmp = op->orm_modlist; tmp != NULL; tmp = tmp->sml_next ) { if (len + 1 + tmp->sml_type.bv_len > sizeof(abuf)) { Statslog( LDAP_DEBUG_STATS, "%s MOD attr=%s\n", op->o_log_prefix, abuf, 0, 0, 0 ); - len = 0; + len = 0; ptr = abuf; if( 1 + tmp->sml_type.bv_len > sizeof(abuf)) { @@ -304,22 +308,24 @@ fe_op_modify( Operation *op, SlapReply *rs ) */ op->o_bd = select_backend( &op->o_req_ndn, manageDSAit, 1 ); if ( op->o_bd == NULL ) { + op->o_bd = bd; rs->sr_ref = referral_rewrite( default_referral, NULL, &op->o_req_dn, LDAP_SCOPE_DEFAULT ); - if (!rs->sr_ref) rs->sr_ref = default_referral; + if ( !rs->sr_ref ) { + rs->sr_ref = default_referral; + } - if (rs->sr_ref != NULL ) { + if ( rs->sr_ref != NULL ) { rs->sr_err = LDAP_REFERRAL; - op->o_bd = frontendDB; send_ldap_result( op, rs ); - op->o_bd = NULL; - if (rs->sr_ref != default_referral) ber_bvarray_free( rs->sr_ref ); + if ( rs->sr_ref != default_referral ) { + ber_bvarray_free( rs->sr_ref ); + } + } else { - op->o_bd = frontendDB; send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, "no global superior knowledge" ); - op->o_bd = NULL; } goto cleanup; } @@ -331,17 +337,17 @@ fe_op_modify( Operation *op, SlapReply *rs ) } /* check restrictions */ - if( backend_check_restrictions( op, rs, NULL ) != LDAP_SUCCESS ) { + if ( backend_check_restrictions( op, rs, NULL ) != LDAP_SUCCESS ) { send_ldap_result( op, rs ); goto cleanup; } /* check for referrals */ - if( backend_check_referrals( op, rs ) != LDAP_SUCCESS ) { + if ( backend_check_referrals( op, rs ) != LDAP_SUCCESS ) { goto cleanup; } - rs->sr_err = slap_mods_obsolete_check( op, modlist, + rs->sr_err = slap_mods_obsolete_check( op, op->orm_modlist, &rs->sr_text, textbuf, textlen ); if ( rs->sr_err != LDAP_SUCCESS ) { send_ldap_result( op, rs ); @@ -349,7 +355,7 @@ fe_op_modify( Operation *op, SlapReply *rs ) } /* check for modify/increment support */ - if( increment && !SLAP_INCREMENT( op->o_bd ) ) { + if ( op->orm_increment && !SLAP_INCREMENT( op->o_bd ) ) { send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, "modify/increment not supported in context" ); } @@ -364,20 +370,18 @@ fe_op_modify( Operation *op, SlapReply *rs ) /* do the update here */ int repl_user = be_isupdate( op ); - /* Multimaster slapd does not have to check for replicator dn + /* + * Multimaster slapd does not have to check for replicator dn * because it accepts each modify request */ -#ifndef SLAPD_MULTIMASTER - if ( !SLAP_SHADOW(op->o_bd) || repl_user ) -#endif - { - int update = !BER_BVISEMPTY( &op->o_bd->be_update_ndn ); - slap_callback cb = { NULL, slap_replog_cb, NULL, NULL }; + if ( !SLAP_SINGLE_SHADOW(op->o_bd) || repl_user ) { + int update = !BER_BVISEMPTY( &op->o_bd->be_update_ndn ); + slap_callback cb = { NULL, slap_replog_cb, NULL, NULL }; op->o_bd = op_be; if ( !update ) { - rs->sr_err = slap_mods_no_user_mod_check( op, modlist, + rs->sr_err = slap_mods_no_user_mod_check( op, op->orm_modlist, &rs->sr_text, textbuf, textlen ); if ( rs->sr_err != LDAP_SUCCESS ) { send_ldap_result( op, rs ); @@ -385,11 +389,7 @@ fe_op_modify( Operation *op, SlapReply *rs ) } } - op->orm_modlist = modlist; -#ifdef SLAPD_MULTIMASTER - if ( !repl_user ) -#endif - { + if ( !repl_user ) { /* but multimaster slapd logs only the ones * not from a replicator user */ cb.sc_next = op->o_callback; @@ -397,9 +397,7 @@ fe_op_modify( Operation *op, SlapReply *rs ) } op->o_bd->be_modify( op, rs ); -#ifndef SLAPD_MULTIMASTER - /* send a referral */ - } else { + } else { /* send a referral */ BerVarray defref = op->o_bd->be_update_refs ? op->o_bd->be_update_refs : default_referral; if ( defref != NULL ) { @@ -421,14 +419,15 @@ fe_op_modify( Operation *op, SlapReply *rs ) send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, "shadow context; no update referral" ); } -#endif } + } else { send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, "operation not supported within namingContext" ); } cleanup:; + op->o_bd = bd; return rs->sr_err; } @@ -443,7 +442,7 @@ slap_mods_obsolete_check( char *textbuf, size_t textlen ) { - if( get_manageDIT( op ) ) return LDAP_SUCCESS; + if( get_relax( op ) ) return LDAP_SUCCESS; for ( ; ml != NULL; ml = ml->sml_next ) { if ( is_at_obsolete( ml->sml_desc->ad_type ) && @@ -478,9 +477,11 @@ slap_mods_no_user_mod_check( size_t textlen ) { for ( ; ml != NULL; ml = ml->sml_next ) { - if ( !is_at_no_user_mod( ml->sml_desc->ad_type ) ) continue; + if ( !is_at_no_user_mod( ml->sml_desc->ad_type ) ) { + continue; + } - if ( get_manageDIT( op ) ) { + if ( get_relax( op ) ) { if ( ml->sml_desc->ad_type->sat_flags & SLAP_AT_MANAGEABLE ) { ml->sml_flags |= SLAP_MOD_MANAGING; continue; @@ -525,6 +526,7 @@ slap_mods_no_repl_user_mod_check( snprintf( textbuf, textlen, "attribute '%s' provided more than once", mods->sml_desc->ad_cname.bv_val ); + *text = textbuf; return LDAP_TYPE_OR_VALUE_EXISTS; } } @@ -537,6 +539,7 @@ slap_mods_no_repl_user_mod_check( * Do basic attribute type checking and syntax validation. */ int slap_mods_check( + Operation *op, Modifications *ml, const char **text, char *textbuf, @@ -551,6 +554,12 @@ int slap_mods_check( /* convert to attribute description */ if ( ml->sml_desc == NULL ) { rc = slap_bv2ad( &ml->sml_type, &ml->sml_desc, text ); + if( rc != LDAP_SUCCESS ) { + if ( get_no_schema_check( op )) { + rc = slap_bv2undef_ad( &ml->sml_type, &ml->sml_desc, + text, 0 ); + } + } if( rc != LDAP_SUCCESS ) { snprintf( textbuf, textlen, "%s: %s", ml->sml_type.bv_val, *text ); @@ -654,21 +663,11 @@ int slap_mods_check( struct berval pval; if ( pretty ) { -#ifdef SLAP_ORDERED_PRETTYNORM rc = ordered_value_pretty( ad, &ml->sml_values[nvals], &pval, ctx ); -#else /* ! SLAP_ORDERED_PRETTYNORM */ - rc = pretty( ad->ad_type->sat_syntax, - &ml->sml_values[nvals], &pval, ctx ); -#endif /* ! SLAP_ORDERED_PRETTYNORM */ } else { -#ifdef SLAP_ORDERED_PRETTYNORM rc = ordered_value_validate( ad, - &ml->sml_values[nvals] ); -#else /* ! SLAP_ORDERED_PRETTYNORM */ - rc = validate( ad->ad_type->sat_syntax, - &ml->sml_values[nvals] ); -#endif /* ! SLAP_ORDERED_PRETTYNORM */ + &ml->sml_values[nvals], ml->sml_op ); } if( rc != 0 ) { @@ -714,19 +713,11 @@ int slap_mods_check( (nvals+1)*sizeof(struct berval), ctx ); for ( nvals = 0; !BER_BVISNULL( &ml->sml_values[nvals] ); nvals++ ) { -#ifdef SLAP_ORDERED_PRETTYNORM rc = ordered_value_normalize( SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX, ad, ad->ad_type->sat_equality, &ml->sml_values[nvals], &ml->sml_nvalues[nvals], ctx ); -#else /* ! SLAP_ORDERED_PRETTYNORM */ - rc = ad->ad_type->sat_equality->smr_normalize( - SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX, - ad->ad_type->sat_syntax, - ad->ad_type->sat_equality, - &ml->sml_values[nvals], &ml->sml_nvalues[nvals], ctx ); -#endif /* ! SLAP_ORDERED_PRETTYNORM */ if ( rc ) { Debug( LDAP_DEBUG_ANY, "<= str2entry NULL (ssyn_normalize %d)\n", @@ -745,6 +736,8 @@ int slap_mods_check( /* check for duplicates, but ignore Deletes. */ if( nvals > 1 && ml->sml_op != LDAP_MOD_DELETE ) { +#define SLAP_MODS_CHECK_QUICKSORT +#ifndef SLAP_MODS_CHECK_QUICKSORT int i, j, rc, match; MatchingRule *mr = ad->ad_type->sat_equality; @@ -776,8 +769,164 @@ int slap_mods_check( } } } +#else /* SLAP_MODS_CHECK_QUICKSORT */ + +/* Quicksort + Insertion sort for small arrays */ + +#define SMALL 8 +#define SWAP(a,b,tmp) tmp=(a);(a)=(b);(b)=tmp +#define COMP(a,b) match=0; rc = ordered_value_match( &match, \ + ml->sml_desc, mr, SLAP_MR_EQUALITY \ + | SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX \ + | SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH \ + | SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH, \ + &(a), &(b), text ); + + MatchingRule *mr = ad->ad_type->sat_equality; + int istack[sizeof(int)*16]; + int i,j,k,l,ir,jstack, rc, match, *ix, itmp; + struct berval a, *cv; + +/* If PRESERVE_ORDER is defined only the index array is sorted; the + * actual values are left in their incoming order. Otherwise, the + * only reason to keep the index array is to identify the offending + * value when duplicates are found. + */ +#define PRESERVE_ORDER +#ifndef PRESERVE_ORDER + struct berval va, *v, *nv, bvtmp; + +#define IX(x) x +#define EXCH(x,y) SWAP(ix[x],ix[y],itmp); SWAP(cv[x],cv[y],bvtmp); \ + if (nv) {SWAP(v[x],v[y],bvtmp);} +#define SETA(x) itmp = ix[x]; a = cv[x]; if (nv) va=v[x] +#define GETA(x) ix[x] = itmp; cv[x] = a; if (nv) v[x]=va +#define SET(x,y) ix[x] = ix[y]; cv[x] = cv[y]; if (nv) v[x]=v[y] + + v = ml->sml_values; + nv = ml->sml_nvalues; + +#else /* PRESERVE_ORDER */ + +#define IX(x) ix[x] +#define EXCH(x,y) SWAP(ix[x],ix[y],itmp) +#define SETA(x) itmp = ix[x]; a = cv[itmp] +#define GETA(x) ix[x] = itmp; +#define SET(x,y) ix[x] = ix[y] + +#endif /* PRESERVE_ORDER */ + + cv = ml->sml_nvalues ? ml->sml_nvalues : ml->sml_values; + if ( ad == slap_schema.si_ad_objectClass ) + mr = NULL; /* shortcut matching */ + + /* record indices to preserve input ordering */ + ix = slap_sl_malloc( nvals * sizeof(int), ctx ); + for (i=0; i=0;i--) { + COMP(cv[IX(i)], a); + if ( match <= 0 ) + break; + SET(i+1,i); + } + GETA(i+1); + if ( match == 0 ) goto done; + } + if ( jstack == 0 ) break; + if ( match == 0 ) break; + ir = istack[jstack--]; + l = istack[jstack--]; + } else { + k = (l + ir) >> 1; /* Choose median of left, center, right */ + EXCH(k, l+1); + COMP( cv[IX(l)], cv[IX(ir)] ); + if ( match > 0 ) { + EXCH(l, ir); + } else if ( match == 0 ) { + i = ir; + break; + } + COMP( cv[IX(l+1)], cv[IX(ir)] ); + if ( match > 0 ) { + EXCH(l+1, ir); + } else if ( match == 0 ) { + i = ir; + break; + } + COMP( cv[IX(l)], cv[IX(l+1)] ); + if ( match > 0 ) { + EXCH(l, l+1); + } else if ( match == 0 ) { + i = l; + break; + } + i = l+1; + j = ir; + a = cv[IX(i)]; + for(;;) { + do { + i++; + COMP( cv[IX(i)], a ); + } while( match < 0 ); + while( match > 0 ) { + j--; + COMP( cv[IX(j)], a ); + } + if (j < i) { + match = 1; + break; + } + if ( match == 0 ) { + i = l+1; + break; + } + EXCH(i,j); + } + if ( match == 0 ) + break; + EXCH(l+1,j); + jstack += 2; + if (ir-i+1 >= j) { + istack[jstack] = ir; + istack[jstack-1] = i; + ir = j; + } else { + istack[jstack] = j; + istack[jstack-1] = l; + l = i; + } + } + } +done: + if ( i >= 0 ) + j = ix[i]; + + slap_sl_free( ix, ctx ); + + if ( rc != LDAP_SUCCESS ) { + return rc; + } else if ( match == 0 ) { + /* value exists already */ + assert( i >= 0 ); + assert( i < nvals ); + snprintf( textbuf, textlen, + "%s: value #%d provided more than once", + ml->sml_desc->ad_cname.bv_val, j ); + *text = textbuf; + return LDAP_TYPE_OR_VALUE_EXISTS; + } +#endif /* SLAP_MODS_CHECK_QUICKSORT */ } - } } @@ -806,11 +955,12 @@ void slap_timestamp( time_t *tm, struct berval *bv ) #endif } -/* modify only calls this for non-replicas. modrdn always calls. +/* Called for all modify and modrdn ops. If the current op was replicated + * from elsewhere, all of the attrs should already be present. */ void slap_mods_opattrs( Operation *op, - Modifications *mods, + Modifications **modsp, int manage_ctxcsn ) { struct berval name, timestamp, csn = BER_BVNULL; @@ -818,23 +968,43 @@ void slap_mods_opattrs( char timebuf[ LDAP_LUTIL_GENTIME_BUFSIZE ]; char csnbuf[ LDAP_LUTIL_CSNSTR_BUFSIZE ]; Modifications *mod, **modtail, *modlast; + int gotcsn = 0, gotmname = 0, gotmtime = 0; if ( SLAP_LASTMOD( op->o_bd ) ) { char *ptr; timestamp.bv_val = timebuf; + for ( modtail = modsp; *modtail; modtail = &(*modtail)->sml_next ) { + if ( (*modtail)->sml_op != LDAP_MOD_ADD && + (*modtail)->sml_op != LDAP_MOD_REPLACE ) continue; + if ( (*modtail)->sml_desc == slap_schema.si_ad_entryCSN ) { + csn = (*modtail)->sml_values[0]; + gotcsn = 1; + } else + if ( (*modtail)->sml_desc == slap_schema.si_ad_modifiersName ) { + gotmname = 1; + } else + if ( (*modtail)->sml_desc == slap_schema.si_ad_modifyTimestamp ) { + gotmtime = 1; + } + } if ( BER_BVISEMPTY( &op->o_csn )) { - csn.bv_val = csnbuf; - csn.bv_len = sizeof( csnbuf ); - slap_get_csn( op, &csn, manage_ctxcsn ); + if ( !gotcsn ) { + csn.bv_val = csnbuf; + csn.bv_len = sizeof( csnbuf ); + slap_get_csn( op, &csn, manage_ctxcsn ); + } else { + if ( manage_ctxcsn ) + slap_queue_csn( op, &csn ); + } } else { csn = op->o_csn; } - ptr = strchr( csn.bv_val, '#' ); - if ( ptr && ptr < &csn.bv_val[csn.bv_len] ) { + ptr = ber_bvchr( &csn, '#' ); + if ( ptr ) { timestamp.bv_len = ptr - csn.bv_val; - if ( timestamp.bv_len >= sizeof( timebuf )) + if ( timestamp.bv_len >= sizeof( timebuf )) /* ?!? */ timestamp.bv_len = sizeof( timebuf ) - 1; - strncpy( timebuf, csn.bv_val, timestamp.bv_len ); + AC_MEMCPY( timebuf, csn.bv_val, timestamp.bv_len ); timebuf[timestamp.bv_len] = '\0'; } else { time_t now = slap_get_time(); @@ -852,34 +1022,24 @@ void slap_mods_opattrs( nname = op->o_ndn; } - for ( mod = mods; mod->sml_next; mod = mod->sml_next ) - ; - modtail = &mod->sml_next; - - mod = (Modifications *) ch_malloc( sizeof( Modifications ) ); - mod->sml_op = LDAP_MOD_REPLACE; - mod->sml_flags = SLAP_MOD_INTERNAL; - mod->sml_next = NULL; - BER_BVZERO( &mod->sml_type ); - mod->sml_desc = slap_schema.si_ad_entryCSN; - mod->sml_values = (BerVarray) ch_malloc( 2 * sizeof( struct berval ) ); - ber_dupbv( &mod->sml_values[0], &csn ); - BER_BVZERO( &mod->sml_values[1] ); - assert( !BER_BVISNULL( &mod->sml_values[0] ) ); - mod->sml_nvalues = NULL; - *modtail = mod; - modlast = mod; - modtail = &mod->sml_next; - - if ( get_manageDIT( op ) ) { - for ( mod = mods; mod != modlast; mod = mod->sml_next ) { - if ( mod->sml_desc == slap_schema.si_ad_modifiersName ) { - break; - } - } + if ( !gotcsn ) { + mod = (Modifications *) ch_malloc( sizeof( Modifications ) ); + mod->sml_op = LDAP_MOD_REPLACE; + mod->sml_flags = SLAP_MOD_INTERNAL; + mod->sml_next = NULL; + BER_BVZERO( &mod->sml_type ); + mod->sml_desc = slap_schema.si_ad_entryCSN; + mod->sml_values = (BerVarray) ch_malloc( 2 * sizeof( struct berval ) ); + ber_dupbv( &mod->sml_values[0], &csn ); + BER_BVZERO( &mod->sml_values[1] ); + assert( !BER_BVISNULL( &mod->sml_values[0] ) ); + mod->sml_nvalues = NULL; + *modtail = mod; + modlast = mod; + modtail = &mod->sml_next; } - if ( mod->sml_desc != slap_schema.si_ad_modifiersName ) { + if ( !gotmname ) { mod = (Modifications *) ch_malloc( sizeof( Modifications ) ); mod->sml_op = LDAP_MOD_REPLACE; mod->sml_flags = SLAP_MOD_INTERNAL; @@ -899,15 +1059,7 @@ void slap_mods_opattrs( modtail = &mod->sml_next; } - if ( get_manageDIT( op ) ) { - for ( mod = mods; mod != modlast; mod = mod->sml_next ) { - if ( mod->sml_desc == slap_schema.si_ad_modifyTimestamp ) { - break; - } - } - } - - if ( mod->sml_desc != slap_schema.si_ad_modifyTimestamp ) { + if ( !gotmtime ) { mod = (Modifications *) ch_malloc( sizeof( Modifications ) ); mod->sml_op = LDAP_MOD_REPLACE; mod->sml_flags = SLAP_MOD_INTERNAL;