X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fadd.c;h=c69ccefd6c1dadd1c5faff0f596fa1bbce40eaed;hb=ef7f5f5e32e6e0f129aee7fa1626017a7dadcb48;hp=015466f12cef07c4575ea7863be368904761fae2;hpb=d918bc9983c454656ee90aaf34d2a9bb80b51f79;p=openldap diff --git a/servers/slapd/add.c b/servers/slapd/add.c index 015466f12c..c69ccefd6c 100644 --- a/servers/slapd/add.c +++ b/servers/slapd/add.c @@ -1,7 +1,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 1998-2007 The OpenLDAP Foundation. + * Copyright 1998-2011 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -48,6 +48,7 @@ do_add( Operation *op, SlapReply *rs ) size_t textlen = sizeof( textbuf ); int rc = 0; int freevals = 1; + OpExtraDB oex; Debug( LDAP_DEBUG_TRACE, "%s do_add\n", op->o_log_prefix, 0, 0 ); @@ -72,25 +73,8 @@ do_add( Operation *op, SlapReply *rs ) return SLAPD_DISCONNECT; } - rs->sr_err = dnPrettyNormal( NULL, &dn, &op->o_req_dn, &op->o_req_ndn, - op->o_tmpmemctx ); - - if ( rs->sr_err != LDAP_SUCCESS ) { - Debug( LDAP_DEBUG_ANY, "%s do_add: invalid dn (%s)\n", - op->o_log_prefix, dn.bv_val, 0 ); - send_ldap_error( op, rs, LDAP_INVALID_DN_SYNTAX, "invalid DN" ); - goto done; - } - - Statslog( LDAP_DEBUG_STATS, "%s ADD dn=\"%s\"\n", - op->o_log_prefix, op->o_req_dn.bv_val, 0, 0, 0 ); - - op->ora_e = entry_alloc(); - ber_dupbv( &op->ora_e->e_name, &op->o_req_dn ); - ber_dupbv( &op->ora_e->e_nname, &op->o_req_ndn ); - Debug( LDAP_DEBUG_ARGS, "%s do_add: dn (%s)\n", - op->o_log_prefix, op->ora_e->e_dn, 0 ); + op->o_log_prefix, dn.bv_val, 0 ); /* get the attrs */ for ( tag = ber_first_element( ber, &len, &last ); tag != LBER_DEFAULT; @@ -146,6 +130,23 @@ do_add( Operation *op, SlapReply *rs ) goto done; } + rs->sr_err = dnPrettyNormal( NULL, &dn, &op->o_req_dn, &op->o_req_ndn, + op->o_tmpmemctx ); + + if ( rs->sr_err != LDAP_SUCCESS ) { + Debug( LDAP_DEBUG_ANY, "%s do_add: invalid dn (%s)\n", + op->o_log_prefix, dn.bv_val, 0 ); + send_ldap_error( op, rs, LDAP_INVALID_DN_SYNTAX, "invalid DN" ); + goto done; + } + + op->ora_e = entry_alloc(); + ber_dupbv( &op->ora_e->e_name, &op->o_req_dn ); + ber_dupbv( &op->ora_e->e_nname, &op->o_req_ndn ); + + Statslog( LDAP_DEBUG_STATS, "%s ADD dn=\"%s\"\n", + op->o_log_prefix, op->o_req_dn.bv_val, 0, 0, 0 ); + if ( modlist == NULL ) { send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, "no attributes provided" ); @@ -185,8 +186,13 @@ do_add( Operation *op, SlapReply *rs ) freevals = 0; + oex.oe.oe_key = (void *)do_add; + oex.oe_db = NULL; + LDAP_SLIST_INSERT_HEAD(&op->o_extra, &oex.oe, oe_next); + op->o_bd = frontendDB; rc = frontendDB->be_add( op, rs ); + LDAP_SLIST_REMOVE(&op->o_extra, &oex.oe, OpExtra, oe_next); #ifdef LDAP_X_TXN if ( rc == LDAP_X_TXN_SPECIFY_OKAY ) { @@ -195,17 +201,15 @@ do_add( Operation *op, SlapReply *rs ) } else #endif if ( rc == 0 ) { - if ( op->ora_e != NULL && op->o_private != NULL ) { + if ( op->ora_e != NULL && oex.oe_db != NULL ) { BackendDB *bd = op->o_bd; - op->o_bd = (BackendDB *)op->o_private; - op->o_private = NULL; + op->o_bd = oex.oe_db; be_entry_release_w( op, op->ora_e ); op->ora_e = NULL; op->o_bd = bd; - op->o_private = NULL; } } @@ -329,11 +333,17 @@ fe_op_add( Operation *op, SlapReply *rs ) rc = op->o_bd->be_add( op, rs ); if ( rc == LDAP_SUCCESS ) { + OpExtra *oex; /* 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; + LDAP_SLIST_FOREACH(oex, &op->o_extra, oe_next) { + if ( oex->oe_key == (void *)do_add ) { + ((OpExtraDB *)oex)->oe_db = op->o_bd; + break; + } + } } } else { @@ -380,6 +390,7 @@ slap_mods2entry( char *textbuf, size_t textlen ) { Attribute **tail; + int i; if ( initial ) { assert( (*e)->e_attrs == NULL ); @@ -400,7 +411,7 @@ slap_mods2entry( if( attr != NULL ) { #define SLURPD_FRIENDLY #ifdef SLURPD_FRIENDLY - ber_len_t i,j; + int j; if ( !initial ) { /* @@ -413,12 +424,9 @@ slap_mods2entry( return LDAP_SUCCESS; } - for( i=0; attr->a_vals[i].bv_val; i++ ) { - /* count them */ - } - for( j=0; mods->sml_values[j].bv_val; j++ ) { - /* count them */ - } + i = attr->a_numvals; + j = mods->sml_numvals; + attr->a_numvals += j; j++; /* NULL */ attr->a_vals = ch_realloc( attr->a_vals, @@ -466,9 +474,9 @@ slap_mods2entry( attr = attr_alloc( mods->sml_desc ); /* move values to attr structure */ + i = mods->sml_numvals; + attr->a_numvals = mods->sml_numvals; 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] ); @@ -480,8 +488,7 @@ slap_mods2entry( if ( mods->sml_nvalues ) { if ( dup ) { - int i; - for ( i = 0; mods->sml_nvalues[i].bv_val; i++ ) /* EMPTY */; + i = mods->sml_numvals; 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] ); @@ -521,16 +528,17 @@ slap_entry2mods( while ( a_new != NULL ) { a_new_desc = a_new->a_desc; - mod = (Modifications *) malloc( sizeof( Modifications )); + mod = (Modifications *) ch_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 */; + count = a_new->a_numvals; + mod->sml_numvals = a_new->a_numvals; - mod->sml_values = (struct berval*) malloc( + mod->sml_values = (struct berval*) ch_malloc( (count+1) * sizeof( struct berval) ); /* see slap_mods_check() comments... @@ -538,7 +546,7 @@ slap_entry2mods( * in this case, mod->sml_nvalues must be left NULL. */ if ( a_new->a_vals != a_new->a_nvals ) { - mod->sml_nvalues = (struct berval*) malloc( + mod->sml_nvalues = (struct berval*) ch_malloc( (count+1) * sizeof( struct berval) ); } else { mod->sml_nvalues = NULL; @@ -581,7 +589,7 @@ int slap_add_opattrs( struct berval name, timestamp, csn = BER_BVNULL; struct berval nname, tmp; char timebuf[ LDAP_LUTIL_GENTIME_BUFSIZE ]; - char csnbuf[ LDAP_LUTIL_CSNSTR_BUFSIZE ]; + char csnbuf[ LDAP_PVT_CSNSTR_BUFSIZE ]; Attribute *a; if ( SLAP_LASTMOD( op->o_bd ) ) {