X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fadd.c;h=9056e412ae07eda7200489ff8a0ff7b6f64df903;hb=a17df0e810578d593808c6afeb0cdea55a65633c;hp=6d9a89d9f647b7eb306d15ad345fe2a2ec0b9d4e;hpb=6c2f47ecd5c23ac4d8e68eb6005f111163f79720;p=openldap diff --git a/servers/slapd/add.c b/servers/slapd/add.c index 6d9a89d9f6..9056e412ae 100644 --- a/servers/slapd/add.c +++ b/servers/slapd/add.c @@ -1,10 +1,18 @@ /* $OpenLDAP$ */ -/* - * Copyright 1998-2003 The OpenLDAP Foundation, All Rights Reserved. - * COPYING RESTRICTIONS APPLY, see COPYRIGHT file +/* This work is part of OpenLDAP Software . + * + * Copyright 1998-2006 The OpenLDAP Foundation. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in the file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * . */ -/* - * Copyright (c) 1995 Regents of the University of Michigan. +/* Portions Copyright (c) 1995 Regents of the University of Michigan. * All rights reserved. * * Redistribution and use in source and binary forms are permitted @@ -22,36 +30,26 @@ #include #include -#include "ldap_pvt.h" +#include "lutil.h" #include "slap.h" -#ifdef LDAP_SLAPI -#include "slapi.h" -static void initAddPlugin( Operation *op, - struct berval *dn, Entry *e, int manageDSAit ); -static int doPreAddPluginFNs( Operation *op ); -static void doPostAddPluginFNs( Operation *op ); -#endif /* LDAP_SLAPI */ - int do_add( Operation *op, SlapReply *rs ) { BerElement *ber = op->o_ber; char *last; - struct berval dn = { 0, NULL }; + struct berval dn = BER_BVNULL; ber_len_t len; ber_tag_t tag; - Entry *e; Modifications *modlist = NULL; Modifications **modtail = &modlist; Modifications tmp; - int manageDSAit; + char textbuf[ SLAP_TEXT_BUFLEN ]; + size_t textlen = sizeof( textbuf ); + int rc = 0; + int freevals = 1; -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ENTRY, "do_add: conn %d enter\n", op->o_connid,0,0 ); -#else Debug( LDAP_DEBUG_TRACE, "do_add\n", 0, 0, 0 ); -#endif /* * Parse the add request. It looks like this: * @@ -66,40 +64,26 @@ do_add( Operation *op, SlapReply *rs ) /* get the name */ if ( ber_scanf( ber, "{m", /*}*/ &dn ) == LBER_ERROR ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ERR, - "do_add: conn %d ber_scanf failed\n", op->o_connid,0,0 ); -#else Debug( LDAP_DEBUG_ANY, "do_add: ber_scanf failed\n", 0, 0, 0 ); -#endif send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" ); - return -1; + return SLAPD_DISCONNECT; } - e = (Entry *) ch_calloc( 1, sizeof(Entry) ); + op->ora_e = (Entry *) ch_calloc( 1, sizeof(Entry) ); - rs->sr_err = dnPrettyNormal( NULL, &dn, &e->e_name, &e->e_nname ); + rs->sr_err = dnPrettyNormal( NULL, &dn, &op->o_req_dn, &op->o_req_ndn, + op->o_tmpmemctx ); - if( rs->sr_err != LDAP_SUCCESS ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ERR, - "do_add: conn %d invalid dn (%s)\n", op->o_connid, dn.bv_val, 0 ); -#else + if ( rs->sr_err != LDAP_SUCCESS ) { Debug( LDAP_DEBUG_ANY, "do_add: invalid dn (%s)\n", dn.bv_val, 0, 0 ); -#endif send_ldap_error( op, rs, LDAP_INVALID_DN_SYNTAX, "invalid DN" ); goto done; } -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ARGS, - "do_add: conn %d dn (%s)\n", op->o_connid, e->e_dn, 0 ); -#else - Debug( LDAP_DEBUG_ARGS, "do_add: dn (%s)\n", e->e_dn, 0, 0 ); -#endif + ber_dupbv( &op->ora_e->e_name, &op->o_req_dn ); + ber_dupbv( &op->ora_e->e_nname, &op->o_req_ndn ); - op->o_req_dn = e->e_name; - op->o_req_ndn = e->e_nname; + Debug( LDAP_DEBUG_ARGS, "do_add: dn (%s)\n", op->ora_e->e_dn, 0, 0 ); /* get the attrs */ for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT; @@ -108,91 +92,134 @@ do_add( Operation *op, SlapReply *rs ) Modifications *mod; ber_tag_t rtag; -#ifdef SLAP_NVALUES tmp.sml_nvalues = NULL; -#endif rtag = ber_scanf( ber, "{m{W}}", &tmp.sml_type, &tmp.sml_values ); if ( rtag == LBER_ERROR ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ERR, - "do_add: conn %d decoding error \n", op->o_connid, 0, 0 ); -#else Debug( LDAP_DEBUG_ANY, "do_add: decoding error\n", 0, 0, 0 ); -#endif send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" ); - rs->sr_err = -1; + rs->sr_err = SLAPD_DISCONNECT; goto done; } if ( tmp.sml_values == NULL ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, INFO, - "do_add: conn %d no values for type %s\n", - op->o_connid, tmp.sml_type.bv_val, 0 ); -#else Debug( LDAP_DEBUG_ANY, "no values for type %s\n", tmp.sml_type.bv_val, 0, 0 ); -#endif - send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, "no values for attribute type" ); + send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, + "no values for attribute type" ); goto done; } mod = (Modifications *) ch_malloc( sizeof(Modifications) ); mod->sml_op = LDAP_MOD_ADD; + mod->sml_flags = 0; mod->sml_next = NULL; mod->sml_desc = NULL; mod->sml_type = tmp.sml_type; mod->sml_values = tmp.sml_values; -#ifdef SLAP_NVALUES mod->sml_nvalues = NULL; -#endif *modtail = mod; modtail = &mod->sml_next; } if ( ber_scanf( ber, /*{*/ "}") == LBER_ERROR ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, ERR, - "do_add: conn %d ber_scanf failed\n", op->o_connid, 0, 0 ); -#else Debug( LDAP_DEBUG_ANY, "do_add: ber_scanf failed\n", 0, 0, 0 ); -#endif send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" ); - rs->sr_err = -1; + rs->sr_err = SLAPD_DISCONNECT; goto done; } - if( get_ctrls( op, rs, 1 ) != LDAP_SUCCESS ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, INFO, - "do_add: conn %d get_ctrls failed\n", op->o_connid, 0, 0 ); -#else + if ( get_ctrls( op, rs, 1 ) != LDAP_SUCCESS ) { Debug( LDAP_DEBUG_ANY, "do_add: get_ctrls failed\n", 0, 0, 0 ); -#endif goto done; } if ( modlist == NULL ) { - send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, "no attributes provided" ); + send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, + "no attributes provided" ); goto done; } - Statslog( LDAP_DEBUG_STATS, "conn=%lu op=%lu ADD dn=\"%s\"\n", - op->o_connid, op->o_opid, e->e_name.bv_val, 0, 0 ); + Statslog( LDAP_DEBUG_STATS, "%s ADD dn=\"%s\"\n", + op->o_log_prefix, op->ora_e->e_name.bv_val, 0, 0, 0 ); - if( e->e_nname.bv_len == 0 ) { + if ( dn_match( &op->ora_e->e_nname, &slap_empty_bv ) ) { /* protocolError may be a more appropriate error */ - send_ldap_error( op, rs, LDAP_ALREADY_EXISTS, "root DSE already exists" ); + send_ldap_error( op, rs, LDAP_ALREADY_EXISTS, + "root DSE already exists" ); goto done; - } else if ( bvmatch( &e->e_nname, &global_schemandn ) ) { - send_ldap_error( op, rs, LDAP_ALREADY_EXISTS, "subschema subentry already exists" ); + } else if ( dn_match( &op->ora_e->e_nname, &frontendDB->be_schemandn ) ) { + send_ldap_error( op, rs, LDAP_ALREADY_EXISTS, + "subschema subentry already exists" ); goto done; } + rs->sr_err = slap_mods_check( modlist, &rs->sr_text, + textbuf, textlen, NULL ); + + if ( rs->sr_err != LDAP_SUCCESS ) { + send_ldap_result( op, rs ); + goto done; + } + + /* temporary; remove if not invoking backend function */ + op->ora_modlist = modlist; + + /* call this so global overlays/SLAPI have access to ora_e */ + rs->sr_err = slap_mods2entry( op->ora_modlist, &op->ora_e, + 1, 0, &rs->sr_text, textbuf, textlen ); + if ( rs->sr_err != LDAP_SUCCESS ) { + send_ldap_result( op, rs ); + goto done; + } + + freevals = 0; + + op->o_bd = frontendDB; + rc = frontendDB->be_add( op, rs ); + if ( rc == 0 ) { + if ( op->ora_e != NULL && op->o_private != NULL ) { + BackendDB *bd = op->o_bd; + + op->o_bd = (BackendDB *)op->o_private; + op->o_private = NULL; + + be_entry_release_w( op, op->ora_e ); + + op->ora_e = NULL; + op->o_bd = bd; + op->o_private = NULL; + } + } + +done:; + if ( modlist != NULL ) { + /* in case of error, free the values as well */ + slap_mods_free( modlist, freevals ); + } + + if ( op->ora_e != NULL ) { + entry_free( op->ora_e ); + } + op->o_tmpfree( op->o_req_dn.bv_val, op->o_tmpmemctx ); + op->o_tmpfree( op->o_req_ndn.bv_val, op->o_tmpmemctx ); + + return rc; +} + +int +fe_op_add( Operation *op, SlapReply *rs ) +{ + int manageDSAit; + Modifications **modtail = &op->ora_modlist; + int rc = 0; + BackendDB *op_be; + char textbuf[ SLAP_TEXT_BUFLEN ]; + size_t textlen = sizeof( textbuf ); + manageDSAit = get_manageDSAit( op ); /* @@ -200,19 +227,35 @@ do_add( Operation *op, SlapReply *rs ) * appropriate one, or send a referral to our "referral server" * if we don't hold it. */ - op->o_bd = select_backend( &e->e_nname, manageDSAit, 0 ); + op->o_bd = select_backend( &op->ora_e->e_nname, manageDSAit, 1 ); if ( op->o_bd == NULL ) { rs->sr_ref = referral_rewrite( default_referral, - NULL, &e->e_name, LDAP_SCOPE_DEFAULT ); - - rs->sr_err = LDAP_REFERRAL; - if (!rs->sr_ref) rs->sr_ref = default_referral; - send_ldap_result( op, rs ); + NULL, &op->ora_e->e_name, LDAP_SCOPE_DEFAULT ); + if ( !rs->sr_ref ) rs->sr_ref = default_referral; + if ( rs->sr_ref ) { + 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 done; } + /* If we've got a glued backend, check the real backend */ + op_be = op->o_bd; + if ( SLAP_GLUE_INSTANCE( op->o_bd )) { + op->o_bd = select_backend( &op->ora_e->e_nname, manageDSAit, 0 ); + } + /* check restrictions */ if( backend_check_restrictions( op, rs, NULL ) != LDAP_SUCCESS ) { send_ldap_result( op, rs ); @@ -224,9 +267,13 @@ do_add( Operation *op, SlapReply *rs ) goto done; } -#ifdef LDAP_SLAPI - initAddPlugin( op, &dn, e, manageDSAit ); -#endif /* LDAP_SLAPI */ + rs->sr_err = slap_mods_obsolete_check( op, op->ora_modlist, + &rs->sr_text, textbuf, textlen ); + + if ( rs->sr_err != LDAP_SUCCESS ) { + send_ldap_result( op, rs ); + goto done; + } /* * do the add if 1 && (2 || 3) @@ -236,148 +283,127 @@ do_add( Operation *op, SlapReply *rs ) */ if ( op->o_bd->be_add ) { /* do the update here */ - int repl_user = be_isupdate(op->o_bd, &op->o_ndn ); + int repl_user = be_isupdate( op ); #ifndef SLAPD_MULTIMASTER - if ( !op->o_bd->be_update_ndn.bv_len || repl_user ) -#endif + if ( !SLAP_SHADOW(op->o_bd) || repl_user ) +#endif /* ! SLAPD_MULTIMASTER */ { - int update = op->o_bd->be_update_ndn.bv_len; - char textbuf[SLAP_TEXT_BUFLEN]; - size_t textlen = sizeof textbuf; + int update = !BER_BVISEMPTY( &op->o_bd->be_update_ndn ); + slap_callback cb = { NULL, slap_replog_cb, NULL, NULL }; - rs->sr_err = slap_mods_check( modlist, update, &rs->sr_text, - textbuf, textlen ); + op->o_bd = op_be; - if( rs->sr_err != LDAP_SUCCESS ) { - send_ldap_result( op, rs ); - goto done; + if ( !update ) { + rs->sr_err = slap_mods_no_user_mod_check( op, op->ora_modlist, + &rs->sr_text, textbuf, textlen ); + + if ( rs->sr_err != LDAP_SUCCESS ) { + send_ldap_result( op, rs ); + goto done; + } } if ( !repl_user ) { - for( modtail = &modlist; - *modtail != NULL; - modtail = &(*modtail)->sml_next ) + /* go to the last mod */ + for ( modtail = &op->ora_modlist; + *modtail != NULL; + modtail = &(*modtail)->sml_next ) { assert( (*modtail)->sml_op == LDAP_MOD_ADD ); assert( (*modtail)->sml_desc != NULL ); } - rs->sr_err = slap_mods_opattrs( op, modlist, modtail, - &rs->sr_text, textbuf, textlen ); - if( rs->sr_err != LDAP_SUCCESS ) { + + + /* check for duplicate values */ + rs->sr_err = slap_mods_no_repl_user_mod_check( op, + op->ora_modlist, &rs->sr_text, textbuf, textlen ); + if ( rs->sr_err != LDAP_SUCCESS ) { send_ldap_result( op, rs ); goto done; } - } - - rs->sr_err = slap_mods2entry( modlist, &e, repl_user, &rs->sr_text, - textbuf, textlen ); - if( rs->sr_err != LDAP_SUCCESS ) { - send_ldap_result( op, rs ); - goto done; - } -#ifdef LDAP_SLAPI - /* - * Call the preoperation plugin here, because the entry - * will actually contain something. - */ - rs->sr_err = doPreAddPluginFNs( op ); - if ( rs->sr_err != LDAP_SUCCESS ) { - /* plugin will have sent result */ - goto done; + rs->sr_err = slap_mods2entry( *modtail, &op->ora_e, + 0, 0, &rs->sr_text, textbuf, textlen ); + if ( rs->sr_err != LDAP_SUCCESS ) { + send_ldap_result( op, rs ); + goto done; + } } -#endif /* LDAP_SLAPI */ - op->oq_add.rs_e = e; - if ( (op->o_bd->be_add)( op, rs ) == 0 ) { #ifdef SLAPD_MULTIMASTER - if ( !repl_user ) -#endif - { - replog( op ); - } - be_entry_release_w( op, e ); - e = NULL; + if ( !repl_user ) +#endif /* SLAPD_MULTIMASTER */ + { + cb.sc_next = op->o_callback; + op->o_callback = &cb; + } + rc = op->o_bd->be_add( op, rs ); + if ( rc == LDAP_SUCCESS ) { + /* NOTE: be_entry_release_w() is + * called by do_add(), so that global + * overlays on the way back can + * at least read the entry */ + op->o_private = op->o_bd; } #ifndef SLAPD_MULTIMASTER } else { - BerVarray defref; - BerVarray ref; -#ifdef LDAP_SLAPI - /* - * SLAPI_ADD_ENTRY will be empty, but this may be acceptable - * on replicas (for now, it involves the minimum code intrusion). - */ - rs->sr_err = doPreAddPluginFNs( op ); - if ( rs->sr_err != LDAP_SUCCESS ) { - /* plugin will have sent result */ - goto done; - } -#endif /* LDAP_SLAPI */ + BerVarray defref = NULL; defref = op->o_bd->be_update_refs ? op->o_bd->be_update_refs : default_referral; - rs->sr_ref = referral_rewrite( defref, - NULL, &e->e_name, LDAP_SCOPE_DEFAULT ); - rs->sr_err = LDAP_REFERRAL; - if (!rs->sr_ref) rs->sr_ref = default_referral; - send_ldap_result( op, rs ); + if ( defref != NULL ) { + rs->sr_ref = referral_rewrite( defref, + NULL, &op->ora_e->e_name, LDAP_SCOPE_DEFAULT ); + if ( rs->sr_ref == NULL ) rs->sr_ref = defref; + rs->sr_err = LDAP_REFERRAL; + if (!rs->sr_ref) rs->sr_ref = default_referral; + send_ldap_result( op, rs ); - 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 { + send_ldap_error( op, rs, + LDAP_UNWILLING_TO_PERFORM, + "shadow context; no update referral" ); + } #endif /* SLAPD_MULTIMASTER */ } } else { -#ifdef LDAP_SLAPI - rs->sr_err = doPreAddPluginFNs( op ); - if ( rs->sr_err != LDAP_SUCCESS ) { - /* plugin will have sent result */ - goto done; - } -#endif -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, INFO, - "do_add: conn %d no backend support\n", op->o_connid, 0, 0 ); -#else Debug( LDAP_DEBUG_ARGS, " do_add: no backend support\n", 0, 0, 0 ); -#endif send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM, - "operation not supported within namingContext" ); - } - -#ifdef LDAP_SLAPI - doPostAddPluginFNs( op ); -#endif /* LDAP_SLAPI */ - -done: - if( modlist != NULL ) { - slap_mods_free( modlist ); - } - if( e != NULL ) { - entry_free( e ); + "operation not supported within namingContext" ); } - return rs->sr_err; +done:; + return rc; } int slap_mods2entry( Modifications *mods, Entry **e, - int repl_user, + int initial, + int dup, const char **text, char *textbuf, size_t textlen ) { - Attribute **tail = &(*e)->e_attrs; - assert( *tail == NULL ); + Attribute **tail; + + if ( initial ) { + assert( (*e)->e_attrs == NULL ); + } + + for ( tail = &(*e)->e_attrs; *tail != NULL; tail = &(*tail)->a_next ) + ; *text = textbuf; for( ; mods != NULL; mods = mods->sml_next ) { Attribute *attr; - assert( mods->sml_op == LDAP_MOD_ADD ); assert( mods->sml_desc != NULL ); attr = attr_find( (*e)->e_attrs, mods->sml_desc ); @@ -387,11 +413,15 @@ slap_mods2entry( #ifdef SLURPD_FRIENDLY ber_len_t i,j; - if( !repl_user ) { - snprintf( textbuf, textlen, - "attribute '%s' provided more than once", - mods->sml_desc->ad_cname.bv_val ); - return LDAP_TYPE_OR_VALUE_EXISTS; + if ( !initial ) { + /* + * This check allows overlays to override operational + * attributes by setting them directly in the entry. + * We assume slap_mods_no_user_mod_check() was called + * with the user modifications. + */ + *text = NULL; + return LDAP_SUCCESS; } for( i=0; attr->a_vals[i].bv_val; i++ ) { @@ -407,89 +437,76 @@ slap_mods2entry( /* should check for duplicates */ - AC_MEMCPY( &attr->a_vals[i], mods->sml_values, - sizeof( struct berval ) * j ); - - /* trim the mods array */ - ch_free( mods->sml_values ); - mods->sml_values = NULL; + if ( dup ) { + for ( j = 0; mods->sml_values[j].bv_val; j++ ) { + ber_dupbv( &attr->a_vals[i+j], &mods->sml_values[j] ); + } + BER_BVZERO( &attr->a_vals[i+j] ); + j++; + } else { + AC_MEMCPY( &attr->a_vals[i], mods->sml_values, + sizeof( struct berval ) * j ); + } -#ifdef SLAP_NVALUES if( mods->sml_nvalues ) { attr->a_nvals = ch_realloc( attr->a_nvals, sizeof( struct berval ) * (i+j) ); - - AC_MEMCPY( &attr->a_nvals[i], mods->sml_nvalues, - sizeof( struct berval ) * j ); - - /* trim the mods array */ - ch_free( mods->sml_nvalues ); - mods->sml_nvalues = NULL; + if ( dup ) { + for ( j = 0; mods->sml_nvalues[j].bv_val; j++ ) { + ber_dupbv( &attr->a_nvals[i+j], &mods->sml_nvalues[j] ); + } + BER_BVZERO( &attr->a_nvals[i+j] ); + } else { + AC_MEMCPY( &attr->a_nvals[i], mods->sml_nvalues, + sizeof( struct berval ) * j ); + } } else { attr->a_nvals = attr->a_vals; } -#endif continue; #else snprintf( textbuf, textlen, "attribute '%s' provided more than once", mods->sml_desc->ad_cname.bv_val ); + *text = textbuf; return LDAP_TYPE_OR_VALUE_EXISTS; #endif } if( mods->sml_values[1].bv_val != NULL ) { /* check for duplicates */ - int i, j; + int i, j, rc, match; MatchingRule *mr = mods->sml_desc->ad_type->sat_equality; - /* check if the values we're adding already exist */ - if( mr == NULL || !mr->smr_match ) { - for ( i = 0; mods->sml_bvalues[i].bv_val != NULL; i++ ) { - /* test asserted values against themselves */ - for( j = 0; j < i; j++ ) { - if ( bvmatch( &mods->sml_bvalues[i], - &mods->sml_bvalues[j] ) ) { - /* value exists already */ - snprintf( textbuf, textlen, - "%s: value #%d provided more than once", - mods->sml_desc->ad_cname.bv_val, j ); - return LDAP_TYPE_OR_VALUE_EXISTS; - } + for ( i = 1; mods->sml_values[i].bv_val != NULL; i++ ) { + /* test asserted values against themselves */ + for( j = 0; j < i; j++ ) { + rc = ordered_value_match( &match, mods->sml_desc, mr, + SLAP_MR_EQUALITY + | SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX + | SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH + | SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH, + mods->sml_nvalues + ? &mods->sml_nvalues[i] + : &mods->sml_values[i], + mods->sml_nvalues + ? &mods->sml_nvalues[j] + : &mods->sml_values[j], + text ); + + if ( rc == LDAP_SUCCESS && match == 0 ) { + /* value exists already */ + snprintf( textbuf, textlen, + "%s: value #%d provided more than once", + mods->sml_desc->ad_cname.bv_val, j ); + *text = textbuf; + return LDAP_TYPE_OR_VALUE_EXISTS; + + } else if ( rc != LDAP_SUCCESS ) { + return rc; } } - - } else { - int rc; -#ifdef SLAP_NVALUES - int match; - - for ( i = 0; mods->sml_nvalues[i].bv_val != NULL; i++ ) { - /* test asserted values against themselves */ - for( j = 0; j < i; j++ ) { - rc = value_match( &match, mods->sml_desc, mr, - SLAP_MR_EQUALITY | SLAP_MR_VALUE_OF_ASSERTION_SYNTAX - | SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH - | SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH, - &mods->sml_nvalues[i], &mods->sml_nvalues[j], text ); - if ( rc == LDAP_SUCCESS && match == 0 ) { - /* value exists already */ - snprintf( textbuf, textlen, - "%s: value #%d provided more than once", - mods->sml_desc->ad_cname.bv_val, j ); - return LDAP_TYPE_OR_VALUE_EXISTS; - } - } - } -#else - rc = modify_check_duplicates( mods->sml_desc, mr, - NULL, mods->sml_bvalues, 0, - text, textbuf, textlen ); -#endif - if ( rc != LDAP_SUCCESS ) { - return rc; - } } } @@ -497,81 +514,226 @@ slap_mods2entry( /* move ad to attr structure */ attr->a_desc = mods->sml_desc; - mods->sml_desc = NULL; /* move values to attr structure */ /* should check for duplicates */ - attr->a_vals = mods->sml_values; - mods->sml_values = NULL; + if ( dup ) { + int i; + for ( i = 0; mods->sml_values[i].bv_val; i++ ) /* EMPTY */; + attr->a_vals = (BerVarray) ch_calloc( i+1, sizeof( BerValue )); + for ( i = 0; mods->sml_values[i].bv_val; i++ ) { + ber_dupbv( &attr->a_vals[i], &mods->sml_values[i] ); + } + BER_BVZERO( &attr->a_vals[i] ); + } else { + attr->a_vals = mods->sml_values; + } -#ifdef SLAP_NVALUES if ( mods->sml_nvalues ) { - attr->a_nvals = mods->sml_nvalues; - mods->sml_nvalues = NULL; + if ( dup ) { + int i; + for ( i = 0; mods->sml_nvalues[i].bv_val; i++ ) /* EMPTY */; + attr->a_nvals = (BerVarray) ch_calloc( i+1, sizeof( BerValue )); + for ( i = 0; mods->sml_nvalues[i].bv_val; i++ ) { + ber_dupbv( &attr->a_nvals[i], &mods->sml_nvalues[i] ); + } + BER_BVZERO( &attr->a_nvals[i] ); + } else { + attr->a_nvals = mods->sml_nvalues; + } } else { attr->a_nvals = attr->a_vals; } -#endif *tail = attr; tail = &attr->a_next; } + *text = NULL; + return LDAP_SUCCESS; } -#ifdef LDAP_SLAPI -static void initAddPlugin( Operation *op, - struct berval *dn, Entry *e, int manageDSAit ) +int +slap_entry2mods( + Entry *e, + Modifications **mods, + const char **text, + char *textbuf, size_t textlen ) { - slapi_x_backend_set_pb( op->o_pb, op->o_bd ); - slapi_x_connection_set_pb( op->o_pb, op->o_conn ); - slapi_x_operation_set_pb( op->o_pb, op ); + Modifications *modhead = NULL; + Modifications *mod; + Modifications **modtail = &modhead; + Attribute *a_new; + AttributeDescription *a_new_desc; + int i, count; - slapi_pblock_set( op->o_pb, SLAPI_ADD_TARGET, (void *)dn->bv_val ); - slapi_pblock_set( op->o_pb, SLAPI_ADD_ENTRY, (void *)e ); - slapi_pblock_set( op->o_pb, SLAPI_MANAGEDSAIT, (void *)manageDSAit ); -} + a_new = e->e_attrs; -static int doPreAddPluginFNs( Operation *op ) -{ - int rc; + while ( a_new != NULL ) { + a_new_desc = a_new->a_desc; + mod = (Modifications *) malloc( sizeof( Modifications )); + + mod->sml_op = LDAP_MOD_REPLACE; + mod->sml_flags = 0; + + mod->sml_type = a_new_desc->ad_cname; + + for ( count = 0; a_new->a_vals[count].bv_val; count++ ) /* EMPTY */; - rc = doPluginFNs( op->o_bd, SLAPI_PLUGIN_PRE_ADD_FN, op->o_pb ); - if ( rc != 0 ) { - /* - * A preoperation plugin failure will abort the - * entire operation. + mod->sml_values = (struct berval*) malloc( + (count+1) * sizeof( struct berval) ); + + /* see slap_mods_check() comments... + * if a_vals == a_nvals, there is no normalizer. + * in this case, mod->sml_nvalues must be left NULL. */ -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, INFO, "do_add: add preoperation plugin failed\n", - 0, 0, 0); -#else - Debug(LDAP_DEBUG_TRACE, "do_add: add preoperation plugin failed.\n", - 0, 0, 0); - if ( slapi_pblock_get( op->o_pb, SLAPI_RESULT_CODE, (void *)&rc ) != 0 ) - rc = LDAP_OTHER; -#endif - } else { - rc = LDAP_SUCCESS; + if ( a_new->a_vals != a_new->a_nvals ) { + mod->sml_nvalues = (struct berval*) malloc( + (count+1) * sizeof( struct berval) ); + } else { + mod->sml_nvalues = NULL; + } + + for ( i = 0; i < count; i++ ) { + ber_dupbv(mod->sml_values+i, a_new->a_vals+i); + if ( mod->sml_nvalues ) { + ber_dupbv( mod->sml_nvalues+i, a_new->a_nvals+i ); + } + } + + mod->sml_values[count].bv_val = NULL; + mod->sml_values[count].bv_len = 0; + + if ( mod->sml_nvalues ) { + mod->sml_nvalues[count].bv_val = NULL; + mod->sml_nvalues[count].bv_len = 0; + } + + mod->sml_desc = a_new_desc; + mod->sml_next =NULL; + *modtail = mod; + modtail = &mod->sml_next; + a_new = a_new->a_next; } - return rc; + *mods = modhead; + + return LDAP_SUCCESS; } -static void doPostAddPluginFNs( Operation *op ) +int slap_add_opattrs( + Operation *op, + const char **text, + char *textbuf, + size_t textlen, + int manage_ctxcsn ) { - int rc; + struct berval name, timestamp, csn = BER_BVNULL; + struct berval nname, tmp; + char timebuf[ LDAP_LUTIL_GENTIME_BUFSIZE ]; + char csnbuf[ LDAP_LUTIL_CSNSTR_BUFSIZE ]; + Attribute *a; + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_structuralObjectClass ); + + if ( !a ) { + Attribute *oc; + int rc; + + oc = attr_find( op->ora_e->e_attrs, slap_schema.si_ad_objectClass ); + if ( oc ) { + rc = structural_class( oc->a_vals, &tmp, NULL, text, + textbuf, textlen ); + if( rc != LDAP_SUCCESS ) return rc; - rc = doPluginFNs( op->o_bd, SLAPI_PLUGIN_POST_ADD_FN, op->o_pb ); - if ( rc != 0 ) { -#ifdef NEW_LOGGING - LDAP_LOG( OPERATION, INFO, "do_add: add postoperation plugin failed\n", - 0, 0, 0); -#else - Debug(LDAP_DEBUG_TRACE, "do_add: add preoperation plugin failed.\n", - 0, 0, 0); -#endif + attr_merge_one( op->ora_e, slap_schema.si_ad_structuralObjectClass, + &tmp, NULL ); + } + } + + if ( SLAP_LASTMOD( op->o_bd ) ) { + char *ptr; + timestamp.bv_val = timebuf; + if ( BER_BVISEMPTY( &op->o_csn )) { + if ( SLAP_SHADOW( op->o_bd )) + manage_ctxcsn = 0; + csn.bv_val = csnbuf; + csn.bv_len = sizeof(csnbuf); + slap_get_csn( op, &csn, manage_ctxcsn ); + } else { + csn = op->o_csn; + } + ptr = ber_bvchr( &csn, '#' ); + if ( ptr ) { + timestamp.bv_len = ptr - csn.bv_val; + if ( timestamp.bv_len >= sizeof(timebuf) ) /* ?!? */ + timestamp.bv_len = sizeof(timebuf) - 1; + AC_MEMCPY( timebuf, csn.bv_val, timestamp.bv_len ); + timebuf[timestamp.bv_len] = '\0'; + } else { + time_t now = slap_get_time(); + + timestamp.bv_len = sizeof(timebuf); + + slap_timestamp( &now, ×tamp ); + } + + if ( BER_BVISEMPTY( &op->o_dn ) ) { + BER_BVSTR( &name, SLAPD_ANONYMOUS ); + nname = name; + } else { + name = op->o_dn; + nname = op->o_ndn; + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_entryUUID ); + if ( !a ) { + char uuidbuf[ LDAP_LUTIL_UUIDSTR_BUFSIZE ]; + + tmp.bv_len = lutil_uuidstr( uuidbuf, sizeof( uuidbuf ) ); + tmp.bv_val = uuidbuf; + + attr_merge_normalize_one( op->ora_e, + slap_schema.si_ad_entryUUID, &tmp, op->o_tmpmemctx ); + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_creatorsName ); + if ( !a ) { + attr_merge_one( op->ora_e, + slap_schema.si_ad_creatorsName, &name, &nname ); + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_createTimestamp ); + if ( !a ) { + attr_merge_one( op->ora_e, + slap_schema.si_ad_createTimestamp, ×tamp, NULL ); + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_entryCSN ); + if ( !a ) { + attr_merge_one( op->ora_e, + slap_schema.si_ad_entryCSN, &csn, NULL ); + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_modifiersName ); + if ( !a ) { + attr_merge_one( op->ora_e, + slap_schema.si_ad_modifiersName, &name, &nname ); + } + + a = attr_find( op->ora_e->e_attrs, + slap_schema.si_ad_modifyTimestamp ); + if ( !a ) { + attr_merge_one( op->ora_e, + slap_schema.si_ad_modifyTimestamp, ×tamp, NULL ); + } } + return LDAP_SUCCESS; } -#endif /* LDAP_SLAPI */