X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=servers%2Fslapd%2Fback-bdb%2Fmodrdn.c;h=c93897525a528b882676180f5c36d6d3949ead93;hb=95d472aa9830a031821f2c6274aff38aa4eb0990;hp=bd63b054d0b37897a3c200f271fad0e44ce00481;hpb=bc478dee4630a37e5a222b14f36d5d6106a4867b;p=openldap diff --git a/servers/slapd/back-bdb/modrdn.c b/servers/slapd/back-bdb/modrdn.c index bd63b054d0..c93897525a 100644 --- a/servers/slapd/back-bdb/modrdn.c +++ b/servers/slapd/back-bdb/modrdn.c @@ -2,7 +2,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 2000-2004 The OpenLDAP Foundation. + * Copyright 2000-2008 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -29,32 +29,23 @@ bdb_modrdn( Operation *op, SlapReply *rs ) AttributeDescription *entry = slap_schema.si_ad_entry; struct berval p_dn, p_ndn; struct berval new_dn = {0, NULL}, new_ndn = {0, NULL}; - int isroot = -1; Entry *e = NULL; Entry *p = NULL; EntryInfo *ei = NULL, *eip = NULL, *nei = NULL, *neip = NULL; /* LDAP v2 supporting correct attribute handling. */ - LDAPRDN new_rdn = NULL; - LDAPRDN old_rdn = NULL; char textbuf[SLAP_TEXT_BUFLEN]; size_t textlen = sizeof textbuf; DB_TXN *ltid = NULL, *lt2; - struct bdb_op_info opinfo; + struct bdb_op_info opinfo = {0}; Entry dummy = {0}; - ID id; - Entry *np = NULL; /* newSuperior Entry */ struct berval *np_dn = NULL; /* newSuperior dn */ struct berval *np_ndn = NULL; /* newSuperior ndn */ struct berval *new_parent_dn = NULL; /* np_dn, p_dn, or NULL */ - /* Used to interface with bdb_modify_internal() */ - Modifications *mod = NULL; /* Used to delete old rdn */ - int manageDSAit = get_manageDSAit( op ); - u_int32_t locker = 0; DB_LOCK lock, plock, nplock; int num_retries = 0; @@ -64,22 +55,61 @@ bdb_modrdn( Operation *op, SlapReply *rs ) LDAPControl *ctrls[SLAP_MAX_RESPONSE_CONTROLS]; int num_ctrls = 0; - Operation *ps_list; - struct psid_entry *pm_list, *pm_prev; int rc; - EntryInfo *suffix_ei; - Entry *ctxcsn_e; - int ctxcsn_added = 0; int parent_is_glue = 0; int parent_is_leaf = 0; - ctrls[num_ctrls] = NULL; +#ifdef LDAP_X_TXN + int settle = 0; +#endif Debug( LDAP_DEBUG_TRACE, "==>" LDAP_XSTRING(bdb_modrdn) "(%s,%s,%s)\n", op->o_req_dn.bv_val,op->oq_modrdn.rs_newrdn.bv_val, op->oq_modrdn.rs_newSup ? op->oq_modrdn.rs_newSup->bv_val : "NULL" ); +#ifdef LDAP_X_TXN + if( op->o_txnSpec ) { + /* acquire connection lock */ + ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex ); + if( op->o_conn->c_txn == CONN_TXN_INACTIVE ) { + rs->sr_text = "invalid transaction identifier"; + rs->sr_err = LDAP_X_TXN_ID_INVALID; + goto txnReturn; + } else if( op->o_conn->c_txn == CONN_TXN_SETTLE ) { + settle=1; + goto txnReturn; + } + + if( op->o_conn->c_txn_backend == NULL ) { + op->o_conn->c_txn_backend = op->o_bd; + + } else if( op->o_conn->c_txn_backend != op->o_bd ) { + rs->sr_text = "transaction cannot span multiple database contexts"; + rs->sr_err = LDAP_AFFECTS_MULTIPLE_DSAS; + goto txnReturn; + } + + /* insert operation into transaction */ + + rs->sr_text = "transaction specified"; + rs->sr_err = LDAP_X_TXN_SPECIFY_OKAY; + +txnReturn: + /* release connection lock */ + ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex ); + + if( !settle ) { + send_ldap_result( op, rs ); + return rs->sr_err; + } + } +#endif + + ctrls[num_ctrls] = NULL; + + slap_mods_opattrs( op, &op->orr_modlist, 1 ); + if( 0 ) { retry: /* transaction retry */ if ( dummy.e_attrs ) { @@ -100,26 +130,23 @@ retry: /* transaction retry */ } Debug( LDAP_DEBUG_TRACE, "==>" LDAP_XSTRING(bdb_modrdn) ": retrying...\n", 0, 0, 0 ); - pm_list = LDAP_LIST_FIRST(&op->o_pm_list); - while ( pm_list != NULL ) { - LDAP_LIST_REMOVE ( pm_list, ps_link ); - pm_prev = pm_list; - pm_list = LDAP_LIST_NEXT ( pm_list, ps_link ); - ch_free( pm_prev ); - } rs->sr_err = TXN_ABORT( ltid ); ltid = NULL; - op->o_private = NULL; + LDAP_SLIST_REMOVE( &op->o_extra, &opinfo.boi_oe, OpExtra, oe_next ); + opinfo.boi_oe.oe_key = NULL; op->o_do_not_cache = opinfo.boi_acl_cache; if( rs->sr_err != 0 ) { rs->sr_err = LDAP_OTHER; rs->sr_text = "internal error"; goto return_results; } + if ( op->o_abandon ) { + rs->sr_err = SLAPD_ABANDON; + goto return_results; + } parent_is_glue = 0; parent_is_leaf = 0; - ldap_pvt_thread_yield(); bdb_trans_backoff( ++num_retries ); } @@ -136,18 +163,15 @@ retry: /* transaction retry */ goto return_results; } - locker = TXN_ID ( ltid ); - - opinfo.boi_bdb = op->o_bd; + opinfo.boi_oe.oe_key = bdb; opinfo.boi_txn = ltid; - opinfo.boi_locker = locker; opinfo.boi_err = 0; opinfo.boi_acl_cache = op->o_do_not_cache; - op->o_private = &opinfo; + LDAP_SLIST_INSERT_HEAD( &op->o_extra, &opinfo.boi_oe, oe_next ); /* get entry */ rs->sr_err = bdb_dn2entry( op, ltid, &op->o_req_ndn, &ei, 1, - locker, &lock ); + &lock ); switch( rs->sr_err ) { case 0: @@ -170,7 +194,6 @@ retry: /* transaction retry */ if (( rs->sr_err == DB_NOTFOUND ) || ( !manageDSAit && e && is_entry_glue( e ))) { - BerVarray deref = NULL; if( e != NULL ) { rs->sr_matched = ch_strdup( e->e_dn ); rs->sr_ref = is_entry_referral( e ) @@ -180,27 +203,14 @@ retry: /* transaction retry */ e = NULL; } else { - if ( !LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) { - syncinfo_t *si; - LDAP_STAILQ_FOREACH( si, &op->o_bd->be_syncinfo, si_next ) { - struct berval tmpbv; - ber_dupbv( &tmpbv, &si->si_provideruri_bv[0] ); - ber_bvarray_add( &deref, &tmpbv ); - } - } else { - deref = default_referral; - } - rs->sr_ref = referral_rewrite( deref, NULL, &op->o_req_dn, - LDAP_SCOPE_DEFAULT ); + rs->sr_ref = referral_rewrite( default_referral, NULL, + &op->o_req_dn, LDAP_SCOPE_DEFAULT ); } rs->sr_err = LDAP_REFERRAL; send_ldap_result( op, rs ); ber_bvarray_free( rs->sr_ref ); - if ( deref != default_referral ) { - ber_bvarray_free( deref ); - } free( (char *)rs->sr_matched ); rs->sr_ref = NULL; rs->sr_matched = NULL; @@ -277,18 +287,26 @@ retry: /* transaction retry */ } if ( be_issuffix( op->o_bd, &e->e_nname ) ) { +#ifdef BDB_MULTIPLE_SUFFIXES + /* Allow renaming one suffix entry to another */ p_ndn = slap_empty_bv; +#else + /* There can only be one suffix entry */ + rs->sr_err = LDAP_NAMING_VIOLATION; + rs->sr_text = "cannot rename suffix entry"; + goto return_results; +#endif } else { dnParent( &e->e_nname, &p_ndn ); } np_ndn = &p_ndn; - if ( p_ndn.bv_len != 0 ) { + eip = ei->bei_parent; + if ( eip && eip->bei_id ) { /* Make sure parent entry exist and we can write its * children. */ - eip = ei->bei_parent; rs->sr_err = bdb_cache_find_id( op, ltid, - eip->bei_id, &eip, 0, locker, &plock ); + eip->bei_id, &eip, 0, &plock ); switch( rs->sr_err ) { case 0: @@ -314,95 +332,48 @@ retry: /* transaction retry */ rs->sr_text = "old entry's parent does not exist"; goto return_results; } + } else { + p = (Entry *)&slap_entry_root; + } - /* check parent for "children" acl */ - rs->sr_err = access_allowed( op, p, - children, NULL, ACL_WRITE, NULL ); + /* check parent for "children" acl */ + rs->sr_err = access_allowed( op, p, + children, NULL, + op->oq_modrdn.rs_newSup == NULL ? + ACL_WRITE : ACL_WDEL, + NULL ); - if ( ! rs->sr_err ) { - switch( opinfo.boi_err ) { - case DB_LOCK_DEADLOCK: - case DB_LOCK_NOTGRANTED: - goto retry; - } - - rs->sr_err = LDAP_INSUFFICIENT_ACCESS; - Debug( LDAP_DEBUG_TRACE, "no access to parent\n", 0, - 0, 0 ); - rs->sr_text = "no write access to old parent's children"; - goto return_results; - } + if ( !p_ndn.bv_len ) + p = NULL; - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) ": wr to children " - "of entry %s OK\n", p_ndn.bv_val, 0, 0 ); - - if ( p_ndn.bv_val == slap_empty_bv.bv_val ) { - p_dn = slap_empty_bv; - } else { - dnParent( &e->e_name, &p_dn ); + if ( ! rs->sr_err ) { + switch( opinfo.boi_err ) { + case DB_LOCK_DEADLOCK: + case DB_LOCK_NOTGRANTED: + goto retry; } - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) ": parent dn=%s\n", - p_dn.bv_val, 0, 0 ); + rs->sr_err = LDAP_INSUFFICIENT_ACCESS; + Debug( LDAP_DEBUG_TRACE, "no access to parent\n", 0, + 0, 0 ); + rs->sr_text = "no write access to old parent's children"; + goto return_results; + } + Debug( LDAP_DEBUG_TRACE, + LDAP_XSTRING(bdb_modrdn) ": wr to children " + "of entry %s OK\n", p_ndn.bv_val, 0, 0 ); + + if ( p_ndn.bv_val == slap_empty_bv.bv_val ) { + p_dn = slap_empty_bv; } else { - /* no parent, modrdn entry directly under root */ - isroot = be_isroot( op ); - if ( ! isroot ) { - if ( be_issuffix( op->o_bd, (struct berval *)&slap_empty_bv ) - || be_shadow_update( op ) ) { - - p = (Entry *)&slap_entry_root; - - /* check parent for "children" acl */ - rs->sr_err = access_allowed( op, p, - children, NULL, ACL_WRITE, NULL ); - - p = NULL; - - if ( ! rs->sr_err ) { - switch( opinfo.boi_err ) { - case DB_LOCK_DEADLOCK: - case DB_LOCK_NOTGRANTED: - goto retry; - } - - rs->sr_err = LDAP_INSUFFICIENT_ACCESS; - Debug( LDAP_DEBUG_TRACE, - "no access to parent\n", - 0, 0, 0 ); - rs->sr_text = "no write access to old parent"; - goto return_results; - } - - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": wr to children of entry \"\" OK\n", - 0, 0, 0 ); - - p_dn.bv_val = ""; - p_dn.bv_len = 0; - - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": parent dn=\"\"\n", - 0, 0, 0 ); - - } else { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": no parent, not root " - "& \"\" is not suffix\n", - 0, 0, 0); - rs->sr_text = "no write access to old parent"; - rs->sr_err = LDAP_INSUFFICIENT_ACCESS; - goto return_results; - } - } + dnParent( &e->e_name, &p_dn ); } + Debug( LDAP_DEBUG_TRACE, + LDAP_XSTRING(bdb_modrdn) ": parent dn=%s\n", + p_dn.bv_val, 0, 0 ); + new_parent_dn = &p_dn; /* New Parent unless newSuperior given */ if ( op->oq_modrdn.rs_newSup != NULL ) { @@ -420,17 +391,31 @@ retry: /* transaction retry */ } } + /* There's a BDB_MULTIPLE_SUFFIXES case here that this code doesn't + * support. E.g., two suffixes dc=foo,dc=com and dc=bar,dc=net. + * We do not allow modDN + * dc=foo,dc=com + * newrdn dc=bar + * newsup dc=net + * and we probably should. But since MULTIPLE_SUFFIXES is deprecated + * I'm ignoring this problem for now. + */ if ( op->oq_modrdn.rs_newSup != NULL ) { if ( op->oq_modrdn.rs_newSup->bv_len ) { np_dn = op->oq_modrdn.rs_newSup; np_ndn = op->oq_modrdn.rs_nnewSup; - /* newSuperior == oldParent?, if so ==> ERROR */ + /* newSuperior == oldParent? - checked above */ /* newSuperior == entry being moved?, if so ==> ERROR */ + if ( dnIsSuffix( np_ndn, &e->e_nname )) { + rs->sr_err = LDAP_NO_SUCH_OBJECT; + rs->sr_text = "new superior not found"; + goto return_results; + } /* Get Entry with dn=newSuperior. Does newSuperior exist? */ rs->sr_err = bdb_dn2entry( op, ltid, np_ndn, - &neip, 0, locker, &nplock ); + &neip, 0, &nplock ); switch( rs->sr_err ) { case 0: np = neip->bei_e; @@ -454,7 +439,7 @@ retry: /* transaction retry */ ": newSup(ndn=%s) not here!\n", np_ndn->bv_val, 0, 0); rs->sr_text = "new superior not found"; - rs->sr_err = LDAP_OTHER; + rs->sr_err = LDAP_NO_SUCH_OBJECT; goto return_results; } @@ -465,7 +450,7 @@ retry: /* transaction retry */ /* check newSuperior for "children" acl */ rs->sr_err = access_allowed( op, np, children, - NULL, ACL_WRITE, NULL ); + NULL, ACL_WADD, NULL ); if( ! rs->sr_err ) { switch( opinfo.boi_err ) { @@ -506,62 +491,35 @@ retry: /* transaction retry */ } } else { - if ( isroot == -1 ) { - isroot = be_isroot( op ); - } - np_dn = NULL; /* no parent, modrdn entry directly under root */ - if ( ! isroot ) { - if ( be_issuffix( op->o_bd, (struct berval *)&slap_empty_bv ) - || be_isupdate( op ) ) { - np = (Entry *)&slap_entry_root; - - /* check parent for "children" acl */ - rs->sr_err = access_allowed( op, np, - children, NULL, ACL_WRITE, NULL ); - - np = NULL; - - if ( ! rs->sr_err ) { - switch( opinfo.boi_err ) { - case DB_LOCK_DEADLOCK: - case DB_LOCK_NOTGRANTED: - goto retry; - } - - rs->sr_err = LDAP_INSUFFICIENT_ACCESS; - Debug( LDAP_DEBUG_TRACE, - "no access to new superior\n", - 0, 0, 0 ); - rs->sr_text = - "no write access to new superior's children"; - goto return_results; + if ( be_issuffix( op->o_bd, (struct berval *)&slap_empty_bv ) + || be_isupdate( op ) ) { + np = (Entry *)&slap_entry_root; + + /* check parent for "children" acl */ + rs->sr_err = access_allowed( op, np, + children, NULL, ACL_WADD, NULL ); + + np = NULL; + + if ( ! rs->sr_err ) { + switch( opinfo.boi_err ) { + case DB_LOCK_DEADLOCK: + case DB_LOCK_NOTGRANTED: + goto retry; } - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": wr to children " - "of entry \"\" OK\n", - 0, 0, 0 ); - - } else { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": new superior=\"\", not root " - "& \"\" is not suffix\n", - 0, 0, 0 ); - rs->sr_text = "no write access to new superior's children"; rs->sr_err = LDAP_INSUFFICIENT_ACCESS; + Debug( LDAP_DEBUG_TRACE, + "no access to new superior\n", + 0, 0, 0 ); + rs->sr_text = + "no write access to new superior's children"; goto return_results; } } - - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": new superior=\"\"\n", - 0, 0, 0 ); } Debug( LDAP_DEBUG_TRACE, @@ -581,6 +539,8 @@ retry: /* transaction retry */ struct berval bv = {0, NULL}; dnNormalize( 0, NULL, NULL, &new_dn, &bv, op->o_tmpmemctx ); ber_dupbv( &new_ndn, &bv ); + /* FIXME: why not call dnNormalize() w/o ctx? */ + op->o_tmpfree( bv.bv_val, op->o_tmpmemctx ); } Debug( LDAP_DEBUG_TRACE, LDAP_XSTRING(bdb_modrdn) ": new ndn=%s\n", @@ -597,6 +557,9 @@ retry: /* transaction retry */ case DB_NOTFOUND: break; case 0: + /* Allow rename to same DN */ + if ( nei == ei ) + break; rs->sr_err = LDAP_ALREADY_EXISTS; goto return_results; default: @@ -605,48 +568,7 @@ retry: /* transaction retry */ goto return_results; } - /* Get attribute type and attribute value of our new rdn, we will - * need to add that to our new entry - */ - if ( !new_rdn && ldap_bv2rdn_x( &op->oq_modrdn.rs_newrdn, &new_rdn, - (char **)&rs->sr_text, LDAP_DN_FORMAT_LDAP, op->o_tmpmemctx ) ) - { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) ": can't figure out " - "type(s)/values(s) of newrdn\n", - 0, 0, 0 ); - rs->sr_err = LDAP_INVALID_DN_SYNTAX; - rs->sr_text = "unknown type(s) used in RDN"; - goto return_results; - } - - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": new_rdn_type=\"%s\", new_rdn_val=\"%s\"\n", - new_rdn[ 0 ]->la_attr.bv_val, - new_rdn[ 0 ]->la_value.bv_val, 0 ); - - if ( op->oq_modrdn.rs_deleteoldrdn ) { - if ( !old_rdn && ldap_bv2rdn_x( &op->o_req_dn, &old_rdn, - (char **)&rs->sr_text, LDAP_DN_FORMAT_LDAP, op->o_tmpmemctx ) ) - { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) ": can't figure out " - "the old_rdn type(s)/value(s)\n", - 0, 0, 0 ); - rs->sr_err = LDAP_OTHER; - rs->sr_text = "cannot parse RDN from old DN"; - goto return_results; - } - } - - /* prepare modlist of modifications from old/new rdn */ - if (!mod) { - rs->sr_err = slap_modrdn2mods( op, rs, e, old_rdn, new_rdn, &mod ); - if ( rs->sr_err != LDAP_SUCCESS ) { - goto return_results; - } - } + assert( op->orr_modlist != NULL ); if( op->o_preread ) { if( preread_ctrl == NULL ) { @@ -658,8 +580,12 @@ retry: /* transaction retry */ { Debug( LDAP_DEBUG_TRACE, "<=- " LDAP_XSTRING(bdb_modrdn) - ": post-read failed!\n", 0, 0, 0 ); - goto return_results; + ": pre-read failed!\n", 0, 0, 0 ); + if ( op->o_preread & SLAP_CONTROL_CRITICAL ) { + /* FIXME: is it correct to abort + * operation if control fails? */ + goto return_results; + } } } @@ -718,23 +644,8 @@ retry: /* transaction retry */ dummy.e_attrs = e->e_attrs; - if ( rs->sr_err == LDAP_SUCCESS && !op->o_noop && !op->o_no_psearch ) { - ldap_pvt_thread_rdwr_wlock( &bdb->bi_pslist_rwlock ); - LDAP_LIST_FOREACH ( ps_list, &bdb->bi_psearch_list, o_ps_link ) { - rc = bdb_psearch( op, rs, ps_list, &dummy, LDAP_PSEARCH_BY_PREMODIFY ); - if ( rc ) { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": persistent search failed (%d,%d)\n", - rc, rs->sr_err, 0 ); - } - } - ldap_pvt_thread_rdwr_wunlock( &bdb->bi_pslist_rwlock ); - } - - /* modify entry */ - rs->sr_err = bdb_modify_internal( op, lt2, &mod[0], &dummy, + rs->sr_err = bdb_modify_internal( op, lt2, op->orr_modlist, &dummy, &rs->sr_text, textbuf, textlen ); if( rs->sr_err != LDAP_SUCCESS ) { Debug(LDAP_DEBUG_TRACE, @@ -801,17 +712,6 @@ retry: /* transaction retry */ goto return_results; } - if ( LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) { - rc = bdb_csn_commit( op, rs, ltid, ei, &suffix_ei, - &ctxcsn_e, &ctxcsn_added, locker ); - switch ( rc ) { - case BDB_CSN_ABORT : - goto return_results; - case BDB_CSN_RETRY : - goto retry; - } - } - if( op->o_postread ) { if( postread_ctrl == NULL ) { postread_ctrl = &ctrls[num_ctrls++]; @@ -823,7 +723,11 @@ retry: /* transaction retry */ Debug( LDAP_DEBUG_TRACE, "<=- " LDAP_XSTRING(bdb_modrdn) ": post-read failed!\n", 0, 0, 0 ); - goto return_results; + if ( op->o_postread & SLAP_CONTROL_CRITICAL ) { + /* FIXME: is it correct to abort + * operation if control fails? */ + goto return_results; + } } } @@ -831,13 +735,16 @@ retry: /* transaction retry */ if(( rs->sr_err=TXN_ABORT( ltid )) != 0 ) { rs->sr_text = "txn_abort (no-op) failed"; } else { - rs->sr_err = LDAP_SUCCESS; + rs->sr_err = LDAP_X_NO_OPERATION; + ltid = NULL; + /* Only free attrs if they were dup'd. */ + if ( dummy.e_attrs == e->e_attrs ) dummy.e_attrs = NULL; goto return_results; } } else { - rc = bdb_cache_modrdn( e, &op->orr_nnewrdn, &dummy, neip, - bdb->bi_dbenv, locker, &lock ); + rc = bdb_cache_modrdn( bdb, e, &op->orr_nnewrdn, &dummy, neip, + ltid, &lock ); switch( rc ) { case DB_LOCK_DEADLOCK: case DB_LOCK_NOTGRANTED: @@ -847,45 +754,6 @@ retry: /* transaction retry */ new_dn.bv_val = NULL; new_ndn.bv_val = NULL; - if ( LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) { - if ( ctxcsn_added ) { - bdb_cache_add( bdb, suffix_ei, ctxcsn_e, - (struct berval *)&slap_ldapsync_cn_bv, locker ); - } - } - - if ( rs->sr_err == LDAP_SUCCESS ) { - /* Loop through in-scope entries for each psearch spec */ - ldap_pvt_thread_rdwr_wlock( &bdb->bi_pslist_rwlock ); - LDAP_LIST_FOREACH ( ps_list, &bdb->bi_psearch_list, o_ps_link ) { - rc = bdb_psearch( op, rs, ps_list, e, LDAP_PSEARCH_BY_MODIFY ); - if ( rc ) { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": persistent search failed " - "(%d,%d)\n", - rc, rs->sr_err, 0 ); - } - } - pm_list = LDAP_LIST_FIRST(&op->o_pm_list); - while ( pm_list != NULL ) { - rc = bdb_psearch(op, rs, pm_list->ps_op, - e, LDAP_PSEARCH_BY_SCOPEOUT); - if ( rc ) { - Debug( LDAP_DEBUG_TRACE, - LDAP_XSTRING(bdb_modrdn) - ": persistent search failed " - "(%d,%d)\n", - rc, rs->sr_err, 0 ); - } - pm_prev = pm_list; - LDAP_LIST_REMOVE ( pm_list, ps_link ); - pm_list = LDAP_LIST_NEXT ( pm_list, ps_link ); - ch_free( pm_prev ); - } - ldap_pvt_thread_rdwr_wunlock( &bdb->bi_pslist_rwlock ); - } - if(( rs->sr_err=TXN_COMMIT( ltid, 0 )) != 0 ) { rs->sr_text = "txn_commit failed"; } else { @@ -894,7 +762,8 @@ retry: /* transaction retry */ } ltid = NULL; - op->o_private = NULL; + LDAP_SLIST_REMOVE( &op->o_extra, &opinfo.boi_oe, OpExtra, oe_next ); + opinfo.boi_oe.oe_key = NULL; if( rs->sr_err != LDAP_SUCCESS ) { Debug( LDAP_DEBUG_TRACE, @@ -919,8 +788,7 @@ return_results: } send_ldap_result( op, rs ); - if( rs->sr_err == LDAP_SUCCESS && bdb->bi_txn_cp ) { - ldap_pvt_thread_yield(); + if( rs->sr_err == LDAP_SUCCESS && bdb->bi_txn_cp_kbyte ) { TXN_CHECKPOINT( bdb->bi_dbenv, bdb->bi_txn_cp_kbyte, bdb->bi_txn_cp_min, 0 ); } @@ -930,31 +798,11 @@ return_results: } done: + slap_graduate_commit_csn( op ); + if( new_dn.bv_val != NULL ) free( new_dn.bv_val ); if( new_ndn.bv_val != NULL ) free( new_ndn.bv_val ); - /* LDAP v2 supporting correct attribute handling. */ - if ( new_rdn != NULL ) { - ldap_rdnfree_x( new_rdn, op->o_tmpmemctx ); - } - if ( old_rdn != NULL ) { - ldap_rdnfree_x( old_rdn, op->o_tmpmemctx ); - } - if( mod != NULL ) { - Modifications *tmp; - for (; mod; mod=tmp ) { - tmp = mod->sml_next; - /* slap_modrdn2mods does things one way, - * slap_mods_opattrs does it differently - */ - if ( mod->sml_op != SLAP_MOD_SOFTADD && - mod->sml_op != LDAP_MOD_DELETE ) break; - if ( mod->sml_nvalues ) free( mod->sml_nvalues[0].bv_val ); - free( mod ); - } - slap_mods_free( mod ); - } - /* LDAP v3 Support */ if( np != NULL ) { /* free new parent and reader lock */ @@ -972,22 +820,17 @@ done: } if( ltid != NULL ) { - pm_list = LDAP_LIST_FIRST(&op->o_pm_list); - while ( pm_list != NULL ) { - LDAP_LIST_REMOVE ( pm_list, ps_link ); - pm_prev = pm_list; - pm_list = LDAP_LIST_NEXT ( pm_list, ps_link ); - ch_free( pm_prev ); - } TXN_ABORT( ltid ); - op->o_private = NULL; + } + if ( opinfo.boi_oe.oe_key ) { + LDAP_SLIST_REMOVE( &op->o_extra, &opinfo.boi_oe, OpExtra, oe_next ); } - if( preread_ctrl != NULL ) { + if( preread_ctrl != NULL && (*preread_ctrl) != NULL ) { slap_sl_free( (*preread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx ); slap_sl_free( *preread_ctrl, op->o_tmpmemctx ); } - if( postread_ctrl != NULL ) { + if( postread_ctrl != NULL && (*postread_ctrl) != NULL ) { slap_sl_free( (*postread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx ); slap_sl_free( *postread_ctrl, op->o_tmpmemctx ); }