| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094 |
- /** BEGIN COPYRIGHT BLOCK
- * This Program is free software; you can redistribute it and/or modify it under
- * the terms of the GNU General Public License as published by the Free Software
- * Foundation; version 2 of the License.
- *
- * This Program is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
- * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along with
- * this Program; if not, write to the Free Software Foundation, Inc., 59 Temple
- * Place, Suite 330, Boston, MA 02111-1307 USA.
- *
- * In addition, as a special exception, Red Hat, Inc. gives You the additional
- * right to link the code of this Program with code not covered under the GNU
- * General Public License ("Non-GPL Code") and to distribute linked combinations
- * including the two, subject to the limitations in this paragraph. Non-GPL Code
- * permitted under this exception must only link to the code of this Program
- * through those well defined interfaces identified in the file named EXCEPTION
- * found in the source code files (the "Approved Interfaces"). The files of
- * Non-GPL Code may instantiate templates or use macros or inline functions from
- * the Approved Interfaces without causing the resulting work to be covered by
- * the GNU General Public License. Only Red Hat, Inc. may make changes or
- * additions to the list of Approved Interfaces. You must obey the GNU General
- * Public License in all respects for all of the Program code and other code used
- * in conjunction with the Program except the Non-GPL Code covered by this
- * exception. If you modify this file, you may extend this exception to your
- * version of the file, but you are not obligated to do so. If you do not wish to
- * provide this exception without modification, you must delete this exception
- * statement from your version and license this file solely under the GPL without
- * exception.
- *
- *
- * Copyright (C) 2001 Sun Microsystems, Inc. Used by permission.
- * Copyright (C) 2005 Red Hat, Inc.
- * Copyright (C) 2009 Hewlett-Packard Development Company, L.P.
- * All rights reserved.
- * END COPYRIGHT BLOCK **/
- #ifdef HAVE_CONFIG_H
- # include <config.h>
- #endif
- /* modrdn.c - ldbm backend modrdn routine */
- #include "back-ldbm.h"
- static const char *moddn_get_newdn(Slapi_PBlock *pb, Slapi_DN *dn_olddn, Slapi_DN *dn_newrdn, Slapi_DN *dn_newsuperiordn);
- static void moddn_unlock_and_return_entry(backend *be,struct backentry **targetentry);
- static int moddn_newrdn_mods(Slapi_PBlock *pb, const char *olddn, struct backentry *ec, Slapi_Mods *smods_wsi, int is_repl_op);
- static IDList *moddn_get_children(back_txn *ptxn, Slapi_PBlock *pb, backend *be, struct backentry *parententry, Slapi_DN *parentdn, struct backentry ***child_entries, struct backdn ***child_dns);
- static int moddn_rename_children(back_txn *ptxn, Slapi_PBlock *pb, backend *be, IDList *children, Slapi_DN *dn_parentdn, Slapi_DN *dn_newsuperiordn, struct backentry *child_entries[]);
- static int modrdn_rename_entry_update_indexes(back_txn *ptxn, Slapi_PBlock *pb, struct ldbminfo *li, struct backentry *e, struct backentry **ec, Slapi_Mods *smods1, Slapi_Mods *smods2, Slapi_Mods *smods3, int *e_in_cache, int *ec_in_cache);
- static void mods_remove_nsuniqueid(Slapi_Mods *smods);
- #define MOD_SET_ERROR(rc, error, count) \
- { \
- (rc) = (error); \
- (count) = RETRY_TIMES; /* otherwise, the transaction may not be aborted */ \
- }
- int
- ldbm_back_modrdn( Slapi_PBlock *pb )
- {
- backend *be;
- ldbm_instance *inst = NULL;
- struct ldbminfo *li;
- struct backentry *e= NULL;
- struct backentry *ec= NULL;
- int ec_in_cache= 0;
- int e_in_cache= 0;
- back_txn txn;
- back_txnid parent_txn;
- int retval = -1;
- char *msg;
- Slapi_Entry *postentry = NULL;
- char *errbuf = NULL;
- int disk_full = 0;
- int retry_count = 0;
- int ldap_result_code= LDAP_SUCCESS;
- char *ldap_result_message= NULL;
- char *ldap_result_matcheddn= NULL;
- struct backentry *parententry= NULL;
- struct backentry *newparententry= NULL;
- struct backentry *original_entry = NULL;
- struct backentry *original_parent = NULL;
- struct backentry *original_newparent = NULL;
- modify_context parent_modify_context = {0};
- modify_context newparent_modify_context = {0};
- modify_context ruv_c = {0};
- int ruv_c_init = 0;
- int is_ruv = 0;
- IDList *children= NULL;
- struct backentry **child_entries = NULL;
- struct backdn **child_dns = NULL;
- Slapi_DN *sdn = NULL;
- Slapi_DN dn_newdn;
- Slapi_DN dn_newrdn;
- Slapi_DN *dn_newsuperiordn = NULL;
- Slapi_DN dn_parentdn;
- Slapi_DN *orig_dn_newsuperiordn = NULL;
- Slapi_Entry *target_entry = NULL;
- Slapi_Entry *original_targetentry = NULL;
- int rc;
- int isroot;
- LDAPMod **mods;
- Slapi_Mods smods_operation_wsi = {0};
- Slapi_Mods smods_generated = {0};
- Slapi_Mods smods_generated_wsi = {0};
- Slapi_Operation *operation;
- int is_replicated_operation= 0;
- int is_fixup_operation = 0;
- entry_address new_addr;
- entry_address *old_addr;
- entry_address oldparent_addr;
- entry_address *newsuperior_addr;
- char *original_newrdn = NULL;
- CSN *opcsn = NULL;
- const char *newdn = NULL;
- char *newrdn = NULL;
- int opreturn = 0;
- int free_modrdn_existing_entry = 0;
- int not_an_error = 0;
- /* sdn & parentsdn need to be initialized before "goto *_return" */
- slapi_sdn_init(&dn_newdn);
- slapi_sdn_init(&dn_newrdn);
- slapi_sdn_init(&dn_parentdn);
-
- slapi_pblock_get( pb, SLAPI_MODRDN_TARGET_SDN, &sdn );
- slapi_pblock_get( pb, SLAPI_BACKEND, &be);
- slapi_pblock_get( pb, SLAPI_PLUGIN_PRIVATE, &li );
- slapi_pblock_get( pb, SLAPI_TXN, (void**)&parent_txn );
- slapi_pblock_get( pb, SLAPI_REQUESTOR_ISROOT, &isroot );
- slapi_pblock_get( pb, SLAPI_OPERATION, &operation );
- slapi_pblock_get( pb, SLAPI_IS_REPLICATED_OPERATION, &is_replicated_operation );
- is_ruv = operation_is_flag_set(operation, OP_FLAG_REPL_RUV);
- is_fixup_operation = operation_is_flag_set(operation, OP_FLAG_REPL_FIXUP);
- if (NULL == sdn) {
- slapi_send_ldap_result( pb, LDAP_INVALID_DN_SYNTAX, NULL,
- "Null target DN", 0, NULL );
- return( -1 );
- }
- /* dblayer_txn_init needs to be called before "goto error_return" */
- dblayer_txn_init(li,&txn);
- /* the calls to perform searches require the parent txn if any
- so set txn to the parent_txn until we begin the child transaction */
- if (parent_txn) {
- txn.back_txn_txn = parent_txn;
- } else {
- parent_txn = txn.back_txn_txn;
- slapi_pblock_set( pb, SLAPI_TXN, parent_txn );
- }
- if (pb->pb_conn)
- {
- slapi_log_error (SLAPI_LOG_TRACE, "ldbm_back_modrdn", "enter conn=%" NSPRIu64 " op=%d\n", pb->pb_conn->c_connid, operation->o_opid);
- }
- inst = (ldbm_instance *) be->be_instance_info;
- {
- char *newrdn/* , *newsuperiordn */;
- /* newrdn is normalized, bu tno need to be case-ignored as
- * it's passed to slapi_sdn_init_normdn_byref */
- slapi_pblock_get( pb, SLAPI_MODRDN_NEWRDN, &newrdn );
- slapi_pblock_get( pb, SLAPI_MODRDN_NEWSUPERIOR_SDN, &dn_newsuperiordn );
- slapi_sdn_init_dn_byref(&dn_newrdn, newrdn);
- /* slapi_sdn_init_normdn_byref(&dn_newsuperiordn, newsuperiordn); */
- slapi_sdn_get_parent(sdn, &dn_parentdn);
- }
-
- /* if old and new superior are equals, newsuperior should not be set
- * Here we have to reset newsuperiordn in order to save processing and
- * avoid later deadlock when trying to fetch twice the same entry
- */
- if (slapi_sdn_compare(dn_newsuperiordn, &dn_parentdn) == 0)
- {
- slapi_sdn_done(dn_newsuperiordn);
- }
- /*
- * Even if subtree rename is off,
- * Replicated Operations are allowed to change the superior
- */
- if ( !entryrdn_get_switch() &&
- (!is_replicated_operation && !slapi_sdn_isempty(dn_newsuperiordn)))
- {
- slapi_send_ldap_result( pb, LDAP_UNWILLING_TO_PERFORM, NULL,
- "server does not support moving of entries", 0, NULL );
- return( -1 );
- }
- if (inst && inst->inst_ref_count) {
- slapi_counter_increment(inst->inst_ref_count);
- } else {
- LDAPDebug1Arg(LDAP_DEBUG_ANY,
- "ldbm_modrdn: instance \"%s\" does not exist.\n",
- inst ? inst->inst_name : "null instance");
- return( -1 );
- }
- /* The dblock serializes writes to the database,
- * which reduces deadlocking in the db code,
- * which means that we run faster.
- *
- * But, this lock is re-enterant for the fixup
- * operations that the URP code in the Replication
- * plugin generates.
- *
- * Also some URP post-op operations are called after
- * the backend has committed the change and released
- * the dblock. Acquire the dblock again for them
- * if OP_FLAG_ACTION_INVOKE_FOR_REPLOP is set.
- *
- * SERIALLOCK is moved to dblayer_txn_begin along with exposing be
- * transaction to plugins (see slapi_back_transaction_* APIs).
- *
- if(SERIALLOCK(li) &&
- (!operation_is_flag_set(operation,OP_FLAG_REPL_FIXUP) ||
- operation_is_flag_set(operation,OP_FLAG_ACTION_INVOKE_FOR_REPLOP)))
- {
- dblayer_lock_backend(be);
- dblock_acquired= 1;
- }
- */
- /*
- * So, we believe that no code up till here actually added anything
- * to persistent store. From now on, we're transacted
- */
- txn.back_txn_txn = NULL; /* ready to create the child transaction */
- for (retry_count = 0; retry_count < RETRY_TIMES; retry_count++)
- {
- if (txn.back_txn_txn && (txn.back_txn_txn != parent_txn))
- {
- Slapi_Entry *ent = NULL;
- /* don't release SERIAL LOCK */
- dblayer_txn_abort_ext(li, &txn, PR_FALSE);
- /* txn is no longer valid - reset slapi_txn to the parent */
- slapi_pblock_set(pb, SLAPI_TXN, parent_txn);
- slapi_pblock_get(pb, SLAPI_MODRDN_NEWRDN, &newrdn);
- slapi_ch_free_string(&newrdn);
- slapi_pblock_set(pb, SLAPI_MODRDN_NEWRDN, original_newrdn);
- slapi_sdn_set_dn_byref(&dn_newrdn, original_newrdn);
- original_newrdn = slapi_ch_strdup(original_newrdn);
- slapi_pblock_get(pb, SLAPI_MODRDN_NEWSUPERIOR_SDN, &dn_newsuperiordn);
- slapi_sdn_free(&dn_newsuperiordn);
- slapi_pblock_set(pb, SLAPI_MODRDN_NEWSUPERIOR_SDN, orig_dn_newsuperiordn);
- orig_dn_newsuperiordn = slapi_sdn_dup(orig_dn_newsuperiordn);
- if (ec_in_cache) {
- /* New entry 'ec' is in the entry cache.
- * Remove it from the cache . */
- CACHE_REMOVE(&inst->inst_cache, ec);
- CACHE_RETURN(&inst->inst_cache, &ec);
- #ifdef DEBUG_CACHE
- PR_ASSERT(ec == NULL);
- #endif
- ec_in_cache = 0;
- } else {
- backentry_free(&ec);
- }
- /* make sure the original entry is back in the cache if it was removed */
- if (!e_in_cache) {
- CACHE_ADD(&inst->inst_cache, e, NULL);
- e_in_cache = 1;
- }
- slapi_pblock_get( pb, SLAPI_MODRDN_EXISTING_ENTRY, &ent );
- if (ent && (ent != original_entry->ep_entry)) {
- slapi_entry_free(ent);
- slapi_pblock_set( pb, SLAPI_MODRDN_EXISTING_ENTRY, NULL );
- }
- ec = original_entry;
- if ( (original_entry = backentry_dup( ec )) == NULL ) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
- slapi_pblock_set( pb, SLAPI_MODRDN_EXISTING_ENTRY, original_entry->ep_entry );
- free_modrdn_existing_entry = 0; /* owned by original_entry now */
- if (!ec_in_cache) {
- /* Put the resetted entry 'ec' into the cache again. */
- if (cache_add_tentative( &inst->inst_cache, ec, NULL ) != 0) {
- ec_in_cache = 0; /* not in cache */
- /* allow modrdn even if the src dn and dest dn are identical */
- if ( 0 != slapi_sdn_compare((const Slapi_DN *)&dn_newdn,
- (const Slapi_DN *)sdn) ) {
- LDAPDebug1Arg(LDAP_DEBUG_ANY,
- "ldbm_back_modrdn: adding %s to cache failed\n",
- slapi_entry_get_dn_const(ec->ep_entry));
- ldap_result_code = LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
- /* so if the old dn is the same as the new dn, the entry will not be cached
- until it is replaced with cache_replace */
- } else {
- ec_in_cache = 1;
- }
- }
- slapi_pblock_get(pb, SLAPI_MODRDN_TARGET_ENTRY, &target_entry );
- slapi_entry_free(target_entry);
- slapi_pblock_set( pb, SLAPI_MODRDN_TARGET_ENTRY, original_targetentry );
- if ( (original_targetentry = slapi_entry_dup( original_targetentry )) == NULL ) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
- if (ruv_c_init) {
- /* reset the ruv txn stuff */
- modify_term(&ruv_c, be);
- ruv_c_init = 0;
- }
- /* We're re-trying */
- LDAPDebug0Args(LDAP_DEBUG_BACKLDBM,
- "Modrdn Retrying Transaction\n");
- #ifndef LDBM_NO_BACKOFF_DELAY
- {
- PRIntervalTime interval;
- interval = PR_MillisecondsToInterval(slapi_rand() % 100);
- DS_Sleep(interval);
- }
- #endif
- }
- if (0 == retry_count) {
- /* First time, hold SERIAL LOCK */
- retval = dblayer_txn_begin(be, parent_txn, &txn);
- } else {
- /* Otherwise, no SERIAL LOCK */
- retval = dblayer_txn_begin_ext(li, parent_txn, &txn, PR_FALSE);
- }
- if (0 != retval) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- goto error_return;
- }
- /* stash the transaction */
- slapi_pblock_set(pb, SLAPI_TXN, (void *)txn.back_txn_txn);
- if (0 == retry_count) { /* just once */
- rc = 0;
- rc= slapi_setbit_int(rc,SLAPI_RTN_BIT_FETCH_EXISTING_DN_ENTRY);
- rc= slapi_setbit_int(rc,SLAPI_RTN_BIT_FETCH_PARENT_ENTRY);
- rc= slapi_setbit_int(rc,SLAPI_RTN_BIT_FETCH_NEWPARENT_ENTRY);
- rc= slapi_setbit_int(rc,SLAPI_RTN_BIT_FETCH_TARGET_ENTRY);
- while(rc!=0)
- {
- /* JCM - copying entries can be expensive... should optimize */
- /*
- * Some present state information is passed through the PBlock to the
- * backend pre-op plugin. To ensure a consistent snapshot of this state
- * we wrap the reading of the entry with the dblock.
- */
- /* <new rdn>,<new superior> */
- if(slapi_isbitset_int(rc,SLAPI_RTN_BIT_FETCH_EXISTING_DN_ENTRY))
- {
- /* see if an entry with the new name already exists */
- done_with_pblock_entry(pb,SLAPI_MODRDN_EXISTING_ENTRY); /* Could be through this multiple times */
- /* newrdn is normalized, bu tno need to be case-ignored as
- * it's passed to slapi_sdn_init_normdn_byref */
- slapi_pblock_get(pb, SLAPI_MODRDN_NEWRDN, &newrdn);
- slapi_sdn_init_dn_byref(&dn_newrdn, newrdn);
- newdn = moddn_get_newdn(pb,sdn, &dn_newrdn, dn_newsuperiordn);
- slapi_sdn_set_dn_passin(&dn_newdn,newdn);
- new_addr.sdn = &dn_newdn;
- new_addr.udn = NULL;
- /* check dn syntax on newdn */
- ldap_result_code = slapi_dn_syntax_check(pb,
- (char *)slapi_sdn_get_ndn(&dn_newdn), 1);
- if (ldap_result_code)
- {
- ldap_result_code = LDAP_INVALID_DN_SYNTAX;
- slapi_pblock_get(pb, SLAPI_PB_RESULT_TEXT, &ldap_result_message);
- goto error_return;
- }
- new_addr.uniqueid = NULL;
- ldap_result_code= get_copy_of_entry(pb, &new_addr, &txn, SLAPI_MODRDN_EXISTING_ENTRY, 0);
- if(ldap_result_code==LDAP_OPERATIONS_ERROR ||
- ldap_result_code==LDAP_INVALID_DN_SYNTAX)
- {
- goto error_return;
- }
- free_modrdn_existing_entry = 1; /* need to free it */
- }
-
- /* <old superior> */
- if(slapi_isbitset_int(rc,SLAPI_RTN_BIT_FETCH_PARENT_ENTRY))
- {
- /* find and lock the old parent entry */
- done_with_pblock_entry(pb,SLAPI_MODRDN_PARENT_ENTRY); /* Could be through this multiple times */
- oldparent_addr.sdn = &dn_parentdn;
- oldparent_addr.uniqueid = NULL;
- ldap_result_code= get_copy_of_entry(pb, &oldparent_addr, &txn, SLAPI_MODRDN_PARENT_ENTRY, !is_replicated_operation);
- }
-
- /* <new superior> */
- if(slapi_sdn_get_ndn(dn_newsuperiordn)!=NULL &&
- slapi_isbitset_int(rc,SLAPI_RTN_BIT_FETCH_NEWPARENT_ENTRY))
- {
- /* find and lock the new parent entry */
- done_with_pblock_entry(pb,SLAPI_MODRDN_NEWPARENT_ENTRY); /* Could be through this multiple times */
- /* Check that this really is a new superior,
- * and not the same old one. Compare parentdn & newsuperior */
- if (slapi_sdn_compare(dn_newsuperiordn, &dn_parentdn) == 0)
- {
- slapi_sdn_done(dn_newsuperiordn);
- }
- else
- {
- entry_address my_addr;
- if (is_replicated_operation)
- {
- /* If this is a replicated operation,
- * then should fetch new superior with uniqueid */
- slapi_pblock_get (pb, SLAPI_MODRDN_NEWSUPERIOR_ADDRESS,
- &newsuperior_addr);
- }
- else
- {
- my_addr.sdn = dn_newsuperiordn;
- my_addr.uniqueid = NULL;
- newsuperior_addr = &my_addr;
- }
- ldap_result_code= get_copy_of_entry(pb, newsuperior_addr, &txn, SLAPI_MODRDN_NEWPARENT_ENTRY, !is_replicated_operation);
- }
- }
-
- /* <old rdn>,<old superior> */
- if(slapi_isbitset_int(rc,SLAPI_RTN_BIT_FETCH_TARGET_ENTRY))
- {
- /* find and lock the entry we are about to modify */
- done_with_pblock_entry(pb,SLAPI_MODRDN_TARGET_ENTRY); /* Could be through this multiple times */
- slapi_pblock_get (pb, SLAPI_TARGET_ADDRESS, &old_addr);
- ldap_result_code= get_copy_of_entry(pb, old_addr, &txn, SLAPI_MODRDN_TARGET_ENTRY, !is_replicated_operation);
- if(ldap_result_code==LDAP_OPERATIONS_ERROR ||
- ldap_result_code==LDAP_INVALID_DN_SYNTAX)
- {
- /* JCM - Usually the call to find_entry2modify would generate the result code. */
- /* JCM !!! */
- goto error_return;
- }
- }
- /* Call the Backend Pre ModRDN plugins */
- slapi_pblock_set(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- rc= plugin_call_plugins(pb, SLAPI_PLUGIN_BE_PRE_MODRDN_FN);
- if (rc) {
- if (SLAPI_PLUGIN_NOOP == rc) {
- not_an_error = 1;
- rc = LDAP_SUCCESS;
- }
- /*
- * Plugin indicated some kind of failure,
- * or that this Operation became a No-Op.
- */
- if (!ldap_result_code) {
- slapi_pblock_get(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- if (!opreturn) {
- slapi_pblock_get(pb, SLAPI_PLUGIN_OPRETURN, &opreturn);
- }
- if (!opreturn) {
- slapi_pblock_set( pb, SLAPI_PLUGIN_OPRETURN, ldap_result_code ? &ldap_result_code : &rc );
- }
- goto error_return;
- }
- /*
- * (rc!=-1) means that the plugin changed things, so we go around
- * the loop once again to get the new present state.
- */
- /* JCMREPL - Warning: A Plugin could cause an infinite loop by always returning a result code that requires some action. */
- }
-
- /* find and lock the entry we are about to modify */
- /* JCMREPL - Argh, what happens about the stinking referrals? */
- slapi_pblock_get (pb, SLAPI_TARGET_ADDRESS, &old_addr);
- e = find_entry2modify( pb, be, old_addr, &txn );
- if ( e == NULL )
- {
- ldap_result_code= -1;
- goto error_return; /* error result sent by find_entry2modify() */
- }
- e_in_cache = 1; /* e is in the cache and locked */
- if (slapi_entry_flag_is_set(e->ep_entry, SLAPI_ENTRY_FLAG_TOMBSTONE) ) {
- ldap_result_code = LDAP_UNWILLING_TO_PERFORM;
- ldap_result_message = "Operation not allowed on tombstone entry.";
- slapi_log_error(SLAPI_LOG_FATAL, "ldbm_back_modrdn",
- "Attempt to rename a tombstone entry %s\n", slapi_sdn_get_dn(slapi_entry_get_sdn_const( e->ep_entry )));
- goto error_return;
- }
- /* Check that an entry with the same DN doesn't already exist. */
- {
- Slapi_Entry *entry;
- slapi_pblock_get( pb, SLAPI_MODRDN_EXISTING_ENTRY, &entry);
- if((entry != NULL) &&
- /* allow modrdn even if the src dn and dest dn are identical */
- (0 != slapi_sdn_compare((const Slapi_DN *)&dn_newdn,
- (const Slapi_DN *)sdn)))
- {
- ldap_result_code= LDAP_ALREADY_EXISTS;
- goto error_return;
- }
- }
-
- /* Fetch and lock the parent of the entry that is moving */
- oldparent_addr.sdn = &dn_parentdn;
- oldparent_addr.uniqueid = NULL;
- parententry = find_entry2modify_only( pb, be, &oldparent_addr, &txn );
- modify_init(&parent_modify_context,parententry);
-
- /* Fetch and lock the new parent of the entry that is moving */
- if(slapi_sdn_get_ndn(dn_newsuperiordn) != NULL)
- {
- slapi_pblock_get (pb, SLAPI_MODRDN_NEWSUPERIOR_ADDRESS, &newsuperior_addr);
- newparententry = find_entry2modify_only( pb, be, newsuperior_addr, &txn );
- modify_init(&newparent_modify_context,newparententry);
- }
-
- opcsn = operation_get_csn (operation);
- if (!is_fixup_operation)
- {
- if ( opcsn == NULL && operation->o_csngen_handler)
- {
- /*
- * Current op is a user request. Opcsn will be assigned
- * if the dn is in an updatable replica.
- */
- opcsn = entry_assign_operation_csn ( pb, e->ep_entry, parententry ? parententry->ep_entry : NULL );
- }
- if ( opcsn != NULL )
- {
- entry_set_maxcsn (e->ep_entry, opcsn);
- }
- }
-
- /*
- * Now that we have the old entry, we reset the old DN and recompute
- * the new DN. Why? Because earlier when we computed the new DN, we did
- * not have the old entry, so we used the DN that was presented as the
- * target DN in the ModRDN operation itself, and we would prefer to
- * preserve the case and spacing that are in the actual entry's DN
- * instead. Otherwise, a ModRDN operation will potentially change an
- * entry's entire DN (at least with respect to case and spacing).
- */
- slapi_sdn_copy( slapi_entry_get_sdn_const( e->ep_entry ), sdn );
- slapi_pblock_set( pb, SLAPI_MODRDN_TARGET_SDN, sdn );
- if (newparententry != NULL) {
- /* don't forget we also want to preserve case of new superior */
- if (NULL == dn_newsuperiordn) {
- dn_newsuperiordn = slapi_sdn_dup(
- slapi_entry_get_sdn_const(newparententry->ep_entry));
- } else {
- slapi_sdn_copy(slapi_entry_get_sdn_const(newparententry->ep_entry),
- dn_newsuperiordn);
- }
- slapi_pblock_set( pb, SLAPI_MODRDN_NEWSUPERIOR_SDN, dn_newsuperiordn );
- }
- slapi_sdn_set_dn_passin(&dn_newdn,
- moddn_get_newdn(pb, sdn, &dn_newrdn, dn_newsuperiordn));
-
- /* Check that we're allowed to add an entry below the new superior */
- if ( newparententry == NULL )
- {
- /* There may not be a new parent because we don't intend there to be one. */
- if (slapi_sdn_get_dn(dn_newsuperiordn))
- {
- /* If the new entry is not to be a suffix,
- * return an error no matter who requested this modrdn */
- if (!slapi_be_issuffix(pb->pb_backend, &dn_newdn))
- {
- /* Here means that we didn't find the parent */
- int err = 0;
- Slapi_DN ancestorsdn;
- struct backentry *ancestorentry;
- slapi_sdn_init(&ancestorsdn);
- ancestorentry= dn2ancestor(be,&dn_newdn,&ancestorsdn,&txn,&err);
- CACHE_RETURN( &inst->inst_cache, &ancestorentry );
- ldap_result_matcheddn= slapi_ch_strdup((char *) slapi_sdn_get_dn(&ancestorsdn));
- ldap_result_code= LDAP_NO_SUCH_OBJECT;
- LDAPDebug( LDAP_DEBUG_TRACE, "ldbm_back_modrdn: New superior "
- "does not exist matched %s, newsuperior = %s\n",
- ldap_result_matcheddn == NULL ? "NULL" :
- ldap_result_matcheddn,
- slapi_sdn_get_ndn(dn_newsuperiordn), 0 );
- slapi_sdn_done(&ancestorsdn);
- goto error_return;
- }
- }
- }
- else
- {
- ldap_result_code= plugin_call_acl_plugin (pb, newparententry->ep_entry, NULL, NULL, SLAPI_ACL_ADD, ACLPLUGIN_ACCESS_DEFAULT, &errbuf );
- if ( ldap_result_code != LDAP_SUCCESS )
- {
- ldap_result_message= errbuf;
- LDAPDebug( LDAP_DEBUG_TRACE, "No access to new superior.\n", 0, 0, 0 );
- goto error_return;
- }
- }
-
- /* Check that the target entry has a parent */
- if ( parententry == NULL )
- {
- /* If the entry a suffix, and we're root, then it's OK that the parent doesn't exist */
- if (!(slapi_be_issuffix(pb->pb_backend, sdn)) && !isroot)
- {
- /* Here means that we didn't find the parent */
- ldap_result_matcheddn = "NULL";
- ldap_result_code= LDAP_NO_SUCH_OBJECT;
- LDAPDebug( LDAP_DEBUG_TRACE, "Parent does not exist matched %s, parentdn = %s\n",
- ldap_result_matcheddn, slapi_sdn_get_ndn(&dn_parentdn), 0 );
- goto error_return;
- }
- }
-
- /* If it is a replicated Operation or "subtree-rename" is on,
- * it's allowed to rename entries with children */
- if ( !is_replicated_operation && !entryrdn_get_switch() &&
- slapi_entry_has_children( e->ep_entry ))
- {
- ldap_result_code = LDAP_NOT_ALLOWED_ON_NONLEAF;
- goto error_return;
- }
-
- /*
- * JCM - All the child entries must be locked in the cache, so the size of
- * subtree that can be renamed is limited by the cache size.
- */
-
- /* Save away a copy of the entry, before modifications */
- slapi_pblock_set( pb, SLAPI_ENTRY_PRE_OP, slapi_entry_dup( e->ep_entry ));
-
- /* create a copy of the entry and apply the changes to it */
- if ( (ec = backentry_dup( e )) == NULL )
- {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
-
- /* JCMACL - Should be performed before the child check. */
- /* JCMACL - Why is the check performed against the copy, rather than the existing entry? */
- ldap_result_code = plugin_call_acl_plugin (pb, ec->ep_entry,
- NULL /*attr*/, NULL /*value*/, SLAPI_ACL_WRITE,
- ACLPLUGIN_ACCESS_MODRDN, &errbuf );
- if ( ldap_result_code != LDAP_SUCCESS )
- {
- goto error_return;
- }
-
- /* Set the new dn to the copy of the entry */
- slapi_entry_set_sdn( ec->ep_entry, &dn_newdn );
- if (entryrdn_get_switch()) { /* subtree-rename: on */
- Slapi_RDN srdn;
- /* Set the new rdn to the copy of the entry; store full dn in e_srdn */
- slapi_rdn_init_all_sdn(&srdn, &dn_newdn);
- slapi_entry_set_srdn(ec->ep_entry, &srdn);
- slapi_rdn_done(&srdn);
- }
-
- /* create it in the cache - prevents others from creating it */
- if (( cache_add_tentative( &inst->inst_cache, ec, NULL ) != 0 ) ) {
- ec_in_cache = 0; /* not in cache */
- /* allow modrdn even if the src dn and dest dn are identical */
- if ( 0 != slapi_sdn_compare((const Slapi_DN *)&dn_newdn,
- (const Slapi_DN *)sdn) ) {
- /* somebody must've created it between dn2entry() and here */
- /* JCMREPL - Hmm... we can't permit this to happen...? */
- ldap_result_code= LDAP_ALREADY_EXISTS;
- goto error_return;
- }
- /* so if the old dn is the same as the new dn, the entry will not be cached
- until it is replaced with cache_replace */
- } else {
- ec_in_cache = 1;
- }
-
- /* Build the list of modifications required to the existing entry */
- {
- slapi_mods_init(&smods_generated,4);
- slapi_mods_init(&smods_generated_wsi,4);
- ldap_result_code = moddn_newrdn_mods(pb, slapi_sdn_get_ndn(sdn),
- ec, &smods_generated_wsi, is_replicated_operation);
- if (ldap_result_code != LDAP_SUCCESS) {
- if (ldap_result_code == LDAP_UNWILLING_TO_PERFORM)
- ldap_result_message = "Modification of old rdn attribute type not allowed.";
- goto error_return;
- }
- if (!entryrdn_get_switch()) /* subtree-rename: off */
- {
- /*
- * Remove the old entrydn index entry, and add the new one.
- */
- slapi_mods_add( &smods_generated, LDAP_MOD_DELETE, LDBM_ENTRYDN_STR,
- strlen(backentry_get_ndn(e)), backentry_get_ndn(e));
- slapi_mods_add( &smods_generated, LDAP_MOD_REPLACE, LDBM_ENTRYDN_STR,
- strlen(backentry_get_ndn(ec)), backentry_get_ndn(ec));
- }
-
- /*
- * Update parentid if we have a new superior.
- */
- if(slapi_sdn_get_dn(dn_newsuperiordn)!=NULL) {
- char buf[40]; /* Enough for an ID */
-
- if (parententry != NULL) {
- sprintf( buf, "%lu", (u_long)parententry->ep_id );
- slapi_mods_add_string(&smods_generated, LDAP_MOD_DELETE, LDBM_PARENTID_STR, buf);
- }
- if (newparententry != NULL) {
- sprintf( buf, "%lu", (u_long)newparententry->ep_id );
- slapi_mods_add_string(&smods_generated, LDAP_MOD_REPLACE, LDBM_PARENTID_STR, buf);
- }
- }
- }
-
- slapi_pblock_get( pb, SLAPI_MODIFY_MODS, &mods );
- slapi_mods_init_byref(&smods_operation_wsi,mods);
-
- /*
- * We are about to pass the last abandon test, so from now on we are
- * committed to finish this operation. Set status to "will complete"
- * before we make our last abandon check to avoid race conditions in
- * the code that processes abandon operations.
- */
- if (operation) {
- operation->o_status = SLAPI_OP_STATUS_WILL_COMPLETE;
- }
- if ( slapi_op_abandoned( pb ) ) {
- goto error_return;
- }
-
- /*
- * First, we apply the generated mods that do not involve any state information.
- */
- if ( entry_apply_mods( ec->ep_entry, slapi_mods_get_ldapmods_byref(&smods_generated) ) != 0 )
- {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- LDAPDebug( LDAP_DEBUG_TRACE, "ldbm_modrdn: entry_apply_mods failed for entry %s\n",
- slapi_entry_get_dn_const(ec->ep_entry), 0, 0);
- goto error_return;
- }
-
- /*
- * Now we apply the generated mods that do involve state information.
- */
- if (slapi_mods_get_num_mods(&smods_generated_wsi)>0)
- {
- if (entry_apply_mods_wsi(ec->ep_entry, &smods_generated_wsi, operation_get_csn(operation), is_replicated_operation)!=0)
- {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- LDAPDebug( LDAP_DEBUG_TRACE, "ldbm_modrdn: entry_apply_mods_wsi failed for entry %s\n",
- slapi_entry_get_dn_const(ec->ep_entry), 0, 0);
- goto error_return;
- }
- }
-
- /*
- * Now we apply the operation mods that do involve state information.
- * (Operational attributes).
- * The following block looks redundent to the one above. But it may
- * be necessary - check the comment for version 1.3.16.22.2.76 of
- * this file and compare that version with its previous one.
- */
- if (slapi_mods_get_num_mods(&smods_operation_wsi)>0)
- {
- if (entry_apply_mods_wsi(ec->ep_entry, &smods_operation_wsi, operation_get_csn(operation), is_replicated_operation)!=0)
- {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- LDAPDebug( LDAP_DEBUG_TRACE, "ldbm_modrdn: entry_apply_mods_wsi (operational attributes) failed for entry %s\n",
- slapi_entry_get_dn_const(ec->ep_entry), 0, 0);
- goto error_return;
- }
- }
- /* check that the entry still obeys the schema */
- if ( slapi_entry_schema_check( pb, ec->ep_entry ) != 0 ) {
- ldap_result_code = LDAP_OBJECT_CLASS_VIOLATION;
- slapi_pblock_get(pb, SLAPI_PB_RESULT_TEXT, &ldap_result_message);
- goto error_return;
- }
-
- /* Check attribute syntax if any new values are being added for the new RDN */
- if (slapi_mods_get_num_mods(&smods_operation_wsi)>0)
- {
- if (slapi_mods_syntax_check(pb, smods_generated_wsi.mods, 0) != 0)
- {
- ldap_result_code = LDAP_INVALID_SYNTAX;
- slapi_pblock_get(pb, SLAPI_PB_RESULT_TEXT, &ldap_result_message);
- goto error_return;
- }
- }
-
- /*
- * Update the DN CSN of the entry.
- */
- entry_add_dncsn(ec->ep_entry,operation_get_csn(operation));
- entry_add_rdn_csn(ec->ep_entry,operation_get_csn(operation));
-
- /*
- * If the entry has a new superior then the subordinate count
- * of the parents must be updated.
- */
- if(slapi_sdn_get_dn(dn_newsuperiordn)!=NULL)
- {
- /*
- * Update the subordinate count of the parents to reflect the moved child.
- */
- if ( parententry!=NULL )
- {
- retval = parent_update_on_childchange(&parent_modify_context,
- PARENTUPDATE_DEL, NULL);
- /* The parent modify context now contains info needed later */
- if (0 != retval)
- {
- goto error_return;
- }
- }
- if ( newparententry!=NULL )
- {
- retval = parent_update_on_childchange(&newparent_modify_context,
- PARENTUPDATE_ADD, NULL);
- /* The newparent modify context now contains info needed later */
- if (0 != retval)
- {
- goto error_return;
- }
- }
- }
-
- /*
- * If the entry has children then we're going to have to rename them all.
- */
- if (slapi_entry_has_children( e->ep_entry ))
- {
- /* JCM - This is where the subtree lock will appear */
- if (entryrdn_get_switch()) /* subtree-rename: on */
- {
- children = moddn_get_children(&txn, pb, be, e, sdn,
- &child_entries, &child_dns);
- }
- else
- {
- children = moddn_get_children(&txn, pb, be, e, sdn,
- &child_entries, NULL);
- }
-
- /* JCM - Shouldn't we perform an access control check on all the children. */
- /* JCMREPL - But, the replication client has total rights over its subtree, so no access check needed. */
- /* JCM - A subtree move could break ACIs, static groups, and dynamic groups. */
- }
-
- /*
- * make copies of the originals, no need to copy the mods because
- * we have already copied them
- */
- if ( (original_entry = backentry_dup( ec )) == NULL ) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
- slapi_pblock_get(pb, SLAPI_MODRDN_TARGET_ENTRY, &target_entry);
- if ( (original_targetentry = slapi_entry_dup(target_entry)) == NULL ) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
-
- slapi_pblock_get(pb, SLAPI_MODRDN_NEWRDN, &newrdn);
- original_newrdn = slapi_ch_strdup(newrdn);
- slapi_pblock_get(pb, SLAPI_MODRDN_NEWSUPERIOR_SDN, &dn_newsuperiordn);
- orig_dn_newsuperiordn = slapi_sdn_dup(dn_newsuperiordn);
- } /* if (0 == retry_count) just once */
- /* call the transaction pre modrdn plugins just after creating the transaction */
- retval = plugin_call_plugins(pb, SLAPI_PLUGIN_BE_TXN_PRE_MODRDN_FN);
- if (retval) {
- LDAPDebug1Arg( LDAP_DEBUG_TRACE, "SLAPI_PLUGIN_BE_TXN_PRE_MODRDN_FN plugin "
- "returned error code %d\n", retval );
- if (SLAPI_PLUGIN_NOOP == retval) {
- not_an_error = 1;
- rc = retval = LDAP_SUCCESS;
- }
- if (!ldap_result_code) {
- slapi_pblock_get(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- if (!opreturn) {
- slapi_pblock_get(pb, SLAPI_PLUGIN_OPRETURN, &opreturn);
- }
- if (!opreturn) {
- slapi_pblock_set( pb, SLAPI_PLUGIN_OPRETURN, ldap_result_code ? &ldap_result_code : &retval );
- }
- goto error_return;
- }
- /*
- * Update the indexes for the entry.
- */
- retval = modrdn_rename_entry_update_indexes(&txn, pb, li, e, &ec, &smods_generated, &smods_generated_wsi, &smods_operation_wsi, &e_in_cache, &ec_in_cache);
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- continue;
- }
- if (retval != 0 )
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "modrdn_rename_entry_update_indexes failed, err=%d %s\n",
- retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code, LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
-
- /*
- * add new name to index
- */
- {
- char **rdns;
- int i;
- if ( (rdns = slapi_ldap_explode_rdn( slapi_sdn_get_dn(&dn_newrdn), 0 )) != NULL )
- {
- for ( i = 0; rdns[i] != NULL; i++ )
- {
- char *type;
- Slapi_Value *svp[2];
- Slapi_Value sv;
- memset(&sv,0,sizeof(Slapi_Value));
- if ( slapi_rdn2typeval( rdns[i], &type, &sv.bv ) != 0 )
- {
- LDAPDebug( LDAP_DEBUG_ANY, "modrdn: rdn2typeval (%s) failed\n",
- rdns[i], 0, 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- svp[0] = &sv;
- svp[1] = NULL;
- retval = index_addordel_values_sv( be, type, svp, NULL, ec->ep_id, BE_INDEX_ADD, &txn );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* To retry txn, once break "for loop" */
- break;
- }
- else if (retval != 0 )
- {
- LDAPDebug( LDAP_DEBUG_ANY, "modrdn: could not add new value to index, err=%d %s\n",
- retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- }
- slapi_ldap_value_free( rdns );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- continue;
- }
- }
- }
- if (slapi_sdn_get_dn(dn_newsuperiordn)!=NULL)
- {
- /* Push out the db modifications from the parent entry */
- retval = modify_update_all(be, pb, &parent_modify_context, &txn);
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- continue;
- }
- else if (0 != retval)
- {
- LDAPDebug( LDAP_DEBUG_ANY, "modrdn: "
- "could not update parent, err=%d %s\n", retval,
- (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- /* Push out the db modifications from the new parent entry */
- else /* retval == 0 */
- {
- retval = modify_update_all(be, pb, &newparent_modify_context, &txn);
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- continue;
- }
- if (0 != retval)
- {
- LDAPDebug( LDAP_DEBUG_ANY, "modrdn: "
- "could not update parent, err=%d %s\n", retval,
- (msg = dblayer_strerror( retval )) ? msg : "",
- 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- }
- }
- /*
- * Update ancestorid index.
- */
- if (slapi_sdn_get_dn(dn_newsuperiordn)!=NULL) {
- retval = ldbm_ancestorid_move_subtree(be, sdn, &dn_newdn, e->ep_id, children, &txn);
- if (retval != 0) {
- if (retval == DB_LOCK_DEADLOCK) continue;
- if (retval == DB_RUNRECOVERY || LDBM_OS_ERR_IS_DISKFULL(retval))
- disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- }
- /*
- * Update entryrdn index
- */
- if (entryrdn_get_switch()) /* subtree-rename: on */
- {
- Slapi_RDN newsrdn;
- slapi_rdn_init_sdn(&newsrdn, (const Slapi_DN *)&dn_newdn);
- retval = entryrdn_rename_subtree(be, (const Slapi_DN *)sdn, &newsrdn,
- (const Slapi_DN *)dn_newsuperiordn,
- e->ep_id, &txn);
- slapi_rdn_done(&newsrdn);
- if (retval != 0) {
- if (retval == DB_LOCK_DEADLOCK) continue;
- if (retval == DB_RUNRECOVERY || LDBM_OS_ERR_IS_DISKFULL(retval))
- disk_full = 1;
- MOD_SET_ERROR(ldap_result_code,
- LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- }
- /*
- * If the entry has children, then rename them all.
- */
- if (!entryrdn_get_switch() && children) /* subtree-rename: off */
- {
- retval= moddn_rename_children(&txn, pb, be, children, sdn,
- &dn_newdn, child_entries);
- }
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- continue;
- }
- if (retval != 0)
- {
- if (retval == DB_RUNRECOVERY || LDBM_OS_ERR_IS_DISKFULL(retval))
- disk_full = 1;
- MOD_SET_ERROR(ldap_result_code, LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- if (!is_ruv && !is_fixup_operation && !NO_RUV_UPDATE(li)) {
- ruv_c_init = ldbm_txn_ruv_modify_context( pb, &ruv_c );
- if (-1 == ruv_c_init) {
- LDAPDebug( LDAP_DEBUG_ANY,
- "ldbm_back_modrdn: ldbm_txn_ruv_modify_context "
- "failed to construct RUV modify context\n",
- 0, 0, 0);
- ldap_result_code = LDAP_OPERATIONS_ERROR;
- retval = 0;
- goto error_return;
- }
- }
- if (ruv_c_init) {
- retval = modify_update_all( be, pb, &ruv_c, &txn );
- if (DB_LOCK_DEADLOCK == retval) {
- /* Abort and re-try */
- continue;
- }
- if (0 != retval) {
- LDAPDebug( LDAP_DEBUG_ANY,
- "modify_update_all failed, err=%d %s\n", retval,
- (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) {
- disk_full = 1;
- }
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- goto error_return;
- }
- }
- break; /* retval==0, Done, Terminate the loop */
- }
- if (retry_count == RETRY_TIMES)
- {
- /* Failed */
- LDAPDebug( LDAP_DEBUG_ANY, "Retry count exceeded in modrdn\n", 0, 0, 0 );
- ldap_result_code= LDAP_BUSY;
- goto error_return;
- }
- postentry = slapi_entry_dup( ec->ep_entry );
- if(parententry!=NULL)
- {
- modify_switch_entries( &parent_modify_context,be);
- }
- if(newparententry!=NULL)
- {
- modify_switch_entries( &newparent_modify_context,be);
- }
- slapi_pblock_set( pb, SLAPI_ENTRY_POST_OP, postentry );
- /* call the transaction post modrdn plugins just before the commit */
- if ((retval = plugin_call_plugins(pb, SLAPI_PLUGIN_BE_TXN_POST_MODRDN_FN))) {
- LDAPDebug1Arg( LDAP_DEBUG_TRACE, "SLAPI_PLUGIN_BE_TXN_POST_MODRDN_FN plugin "
- "returned error code %d\n", retval );
- if (!ldap_result_code) {
- slapi_pblock_get(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- if (!ldap_result_code) {
- LDAPDebug0Args( LDAP_DEBUG_ANY, "SLAPI_PLUGIN_BE_TXN_POST_MODRDN_FN plugin "
- "returned error but did not set SLAPI_RESULT_CODE\n" );
- ldap_result_code = LDAP_OPERATIONS_ERROR;
- slapi_pblock_set(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- if (!opreturn) {
- slapi_pblock_get(pb, SLAPI_PLUGIN_OPRETURN, &opreturn);
- }
- if (!opreturn) {
- slapi_pblock_set( pb, SLAPI_PLUGIN_OPRETURN, ldap_result_code ? &ldap_result_code : &retval );
- }
- goto error_return;
- }
- /* Release SERIAL LOCK */
- retval = dblayer_txn_commit(be, &txn);
- /* after commit - txn is no longer valid - replace SLAPI_TXN with parent */
- slapi_pblock_set(pb, SLAPI_TXN, parent_txn);
- if (0 != retval)
- {
- if (LDBM_OS_ERR_IS_DISKFULL(retval)) disk_full = 1;
- MOD_SET_ERROR(ldap_result_code, LDAP_OPERATIONS_ERROR, retry_count);
- goto error_return;
- }
- if(children)
- {
- int i = 0;
- if (child_entries && *child_entries)
- {
- if (entryrdn_get_switch()) /* subtree-rename: on */
- {
- /*
- * If subtree-rename is on, delete subordinate entries from the
- * entry cache. Next time the entries are read from the db,
- * "renamed" dn is generated based upon the moved subtree.
- */
- for (i = 0; child_entries[i] != NULL; i++) {
- CACHE_REMOVE( &inst->inst_cache, child_entries[i] );
- cache_unlock_entry( &inst->inst_cache, child_entries[i] );
- CACHE_RETURN( &inst->inst_cache, &child_entries[i] );
- }
- }
- else
- {
- for (; child_entries[i]!=NULL; i++) {
- cache_unlock_entry( &inst->inst_cache, child_entries[i] );
- CACHE_RETURN( &inst->inst_cache, &(child_entries[i]) );
- }
- }
- }
- if (entryrdn_get_switch() && child_dns && *child_dns)
- {
- for (i = 0; child_dns[i] != NULL; i++) {
- CACHE_REMOVE( &inst->inst_dncache, child_dns[i] );
- CACHE_RETURN( &inst->inst_dncache, &child_dns[i] );
- }
- }
- }
- if (ruv_c_init) {
- if (modify_switch_entries(&ruv_c, be) != 0 ) {
- ldap_result_code= LDAP_OPERATIONS_ERROR;
- LDAPDebug( LDAP_DEBUG_ANY,
- "ldbm_back_modrdn: modify_switch_entries failed\n", 0, 0, 0);
- goto error_return;
- }
- }
- retval= 0;
- goto common_return;
- error_return:
- /* result already sent above - just free stuff */
- if ( NULL != postentry )
- {
- slapi_entry_free( postentry );
- postentry= NULL;
- /* make sure caller doesn't attempt to free this */
- slapi_pblock_set( pb, SLAPI_ENTRY_POST_OP, postentry );
- }
- if (e && entryrdn_get_switch() && inst)
- {
- struct backdn *bdn = dncache_find_id(&inst->inst_dncache, e->ep_id);
- CACHE_REMOVE(&inst->inst_dncache, bdn);
- CACHE_RETURN(&inst->inst_dncache, &bdn);
- }
- if(children)
- {
- int i = 0;
- if (child_entries && *child_entries && inst)
- {
- if (entryrdn_get_switch()) /* subtree-rename: on */
- {
- /*
- * If subtree-rename is on, delete subordinate entries from the
- * entry cache even if the procedure was not successful.
- */
- for (i = 0; child_entries[i] != NULL; i++) {
- CACHE_REMOVE( &inst->inst_cache, child_entries[i] );
- cache_unlock_entry( &inst->inst_cache, child_entries[i] );
- CACHE_RETURN( &inst->inst_cache, &child_entries[i] );
- }
- }
- else
- {
- for(;child_entries[i]!=NULL;i++) {
- cache_unlock_entry( &inst->inst_cache, child_entries[i] );
- CACHE_RETURN( &inst->inst_cache, &(child_entries[i]) );
- }
- }
- }
- if (entryrdn_get_switch() && child_dns && *child_dns && inst)
- {
- for (i = 0; child_dns[i] != NULL; i++) {
- CACHE_REMOVE( &inst->inst_dncache, child_dns[i] );
- CACHE_RETURN( &inst->inst_dncache, &child_dns[i] );
- }
- }
- }
- if (retval == DB_RUNRECOVERY) {
- dblayer_remember_disk_filled(li);
- ldbm_nasty("ModifyDN",82,retval);
- disk_full = 1;
- }
- if (disk_full)
- {
- retval = return_on_disk_full(li);
- }
- else
- {
- /* It is safer not to abort when the transaction is not started. */
- if (txn.back_txn_txn && (txn.back_txn_txn != parent_txn))
- {
- /* make sure SLAPI_RESULT_CODE and SLAPI_PLUGIN_OPRETURN are set */
- int val = 0;
- slapi_pblock_get(pb, SLAPI_RESULT_CODE, &val);
- if (!val) {
- if (!ldap_result_code) {
- ldap_result_code = LDAP_OPERATIONS_ERROR;
- }
- slapi_pblock_set(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- slapi_pblock_get( pb, SLAPI_PLUGIN_OPRETURN, &val );
- if (!val) {
- opreturn = -1;
- slapi_pblock_set( pb, SLAPI_PLUGIN_OPRETURN, &opreturn );
- }
- /* call the transaction post modrdn plugins just before the abort */
- if ((retval = plugin_call_plugins(pb, SLAPI_PLUGIN_BE_TXN_POST_MODRDN_FN))) {
- LDAPDebug1Arg( LDAP_DEBUG_TRACE, "SLAPI_PLUGIN_BE_TXN_POST_MODRDN_FN plugin "
- "returned error code %d\n", retval );
- if (!ldap_result_code) {
- slapi_pblock_get(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- }
- if (!opreturn) {
- slapi_pblock_get(pb, SLAPI_PLUGIN_OPRETURN, &opreturn);
- }
- if (!opreturn) {
- slapi_pblock_set( pb, SLAPI_PLUGIN_OPRETURN, ldap_result_code ? &ldap_result_code : &retval );
- }
- }
- /* Release SERIAL LOCK */
- dblayer_txn_abort(be, &txn); /* abort crashes in case disk full */
- /* txn is no longer valid - reset the txn pointer to the parent */
- slapi_pblock_set(pb, SLAPI_TXN, parent_txn);
- }
- if (!not_an_error) {
- retval = SLAPI_FAIL_GENERAL;
- }
- }
- common_return:
- /* result code could be used in the bepost plugin functions. */
- slapi_pblock_set(pb, SLAPI_RESULT_CODE, &ldap_result_code);
- /*
- * The bepostop is called even if the operation fails.
- */
- plugin_call_plugins (pb, SLAPI_PLUGIN_BE_POST_MODRDN_FN);
- /* Free up the resource we don't need any more */
- if (ec) {
- /* remove the new entry from the cache if the op failed -
- otherwise, leave it in */
- if (ec_in_cache && inst) {
- if (retval) {
- CACHE_REMOVE( &inst->inst_cache, ec );
- }
- CACHE_RETURN( &inst->inst_cache, &ec );
- } else {
- backentry_free( &ec );
- }
- ec = NULL;
- ec_in_cache = 0;
- }
- /* put e back in the cache if the modrdn failed */
- if (e) {
- if (!e_in_cache && retval && inst) {
- CACHE_ADD(&inst->inst_cache, e, NULL);
- e_in_cache = 1;
- }
- }
- if (inst && inst->inst_ref_count) {
- slapi_counter_decrement(inst->inst_ref_count);
- }
- moddn_unlock_and_return_entry(be,&e);
- if (ruv_c_init) {
- modify_term(&ruv_c, be);
- }
- if (ldap_result_code!=-1)
- {
- if (not_an_error) {
- /* This is mainly used by urp. Solved conflict is not an error.
- * And we don't want the supplier to halt sending the updates. */
- ldap_result_code = LDAP_SUCCESS;
- }
- slapi_send_ldap_result( pb, ldap_result_code, ldap_result_matcheddn,
- ldap_result_message, 0,NULL );
- }
- slapi_mods_done(&smods_operation_wsi);
- slapi_mods_done(&smods_generated);
- slapi_mods_done(&smods_generated_wsi);
- slapi_ch_free((void**)&child_entries);
- slapi_ch_free((void**)&child_dns);
- if (ldap_result_matcheddn && 0 != strcmp(ldap_result_matcheddn, "NULL"))
- slapi_ch_free((void**)&ldap_result_matcheddn);
- idl_free(children);
- slapi_sdn_done(&dn_newdn);
- slapi_sdn_done(&dn_newrdn);
- slapi_sdn_done(&dn_parentdn);
- modify_term(&parent_modify_context,be);
- modify_term(&newparent_modify_context,be);
- if (free_modrdn_existing_entry) {
- done_with_pblock_entry(pb,SLAPI_MODRDN_EXISTING_ENTRY);
- } else { /* owned by original_entry */
- slapi_pblock_set(pb, SLAPI_MODRDN_EXISTING_ENTRY, NULL);
- }
- done_with_pblock_entry(pb,SLAPI_MODRDN_PARENT_ENTRY);
- done_with_pblock_entry(pb,SLAPI_MODRDN_NEWPARENT_ENTRY);
- done_with_pblock_entry(pb,SLAPI_MODRDN_TARGET_ENTRY);
- slapi_ch_free_string(&original_newrdn);
- slapi_sdn_free(&orig_dn_newsuperiordn);
- backentry_free(&original_entry);
- backentry_free(&original_parent);
- backentry_free(&original_newparent);
- slapi_entry_free(original_targetentry);
- slapi_ch_free((void**)&errbuf);
- if (retval == 0 && opcsn != NULL && !is_fixup_operation)
- {
- slapi_pblock_set(pb, SLAPI_URP_NAMING_COLLISION_DN,
- slapi_ch_strdup(slapi_sdn_get_dn(sdn)));
- }
- if (pb->pb_conn)
- {
- slapi_log_error (SLAPI_LOG_TRACE, "ldbm_back_modrdn", "leave conn=%" NSPRIu64 " op=%d\n", pb->pb_conn->c_connid, operation->o_opid);
- }
- return retval;
- }
- /*
- * Work out what the new DN of the entry will be.
- */
- static const char *
- moddn_get_newdn(Slapi_PBlock *pb, Slapi_DN *dn_olddn, Slapi_DN *dn_newrdn, Slapi_DN *dn_newsuperiordn)
- {
- char *newdn;
- const char *newrdn= slapi_sdn_get_dn(dn_newrdn);
- const char *newsuperiordn= slapi_sdn_get_dn(dn_newsuperiordn);
-
- if( newsuperiordn!=NULL)
- {
- /* construct the new dn */
- if(slapi_dn_isroot(newsuperiordn))
- {
- newdn= slapi_ch_strdup(newrdn);
- }
- else
- {
- newdn= slapi_dn_plus_rdn(newsuperiordn, newrdn); /* JCM - Use Slapi_RDN */
- }
- }
- else
- {
- /* construct the new dn */
- char *pdn;
- const char *dn= slapi_sdn_get_dn(dn_olddn);
- pdn = slapi_dn_beparent( pb, dn );
- if ( pdn != NULL )
- {
- newdn= slapi_dn_plus_rdn(pdn, newrdn); /* JCM - Use Slapi_RDN */
- }
- else
- {
- newdn= slapi_ch_strdup(newrdn);
- }
- slapi_ch_free( (void**)&pdn );
- }
- return newdn;
- }
- /*
- * Return the entries to the cache.
- */
- static void
- moddn_unlock_and_return_entry(
- backend *be,
- struct backentry **targetentry)
- {
- ldbm_instance *inst = (ldbm_instance *) be->be_instance_info;
- /* Something bad happened so we should give back all the entries */
- if ( *targetentry!=NULL ) {
- cache_unlock_entry(&inst->inst_cache, *targetentry);
- CACHE_RETURN( &inst->inst_cache, targetentry );
- *targetentry= NULL;
- }
- }
- /*
- * JCM - There was a problem with multi-valued RDNs where
- * JCM - there was an intersection of the two sets RDN Components
- * JCM - and the deleteoldrdn flag was set. A value was deleted
- * JCM - but not re-added because the value is found to already
- * JCM - exist.
- *
- * This function returns 1 if it is necessary to add an RDN value
- * to the entry. This is necessary if either:
- * 1 the attribute or the value is not present in the entry, or
- * 2 the attribute is present, deleteoldrdn is set, and the RDN value
- * is in the deleted list.
- *
- * For example, suppose you rename cn=a to cn=a+sn=b. The cn=a value
- * is removed from the entry and then readded.
- */
- static int
- moddn_rdn_add_needed (
- struct backentry *ec,
- char *type,
- struct berval *bvp,
- int deleteoldrdn,
- Slapi_Mods *smods_wsi
- )
- {
- Slapi_Attr *attr;
- LDAPMod *mod;
- if (slapi_entry_attr_find(ec->ep_entry, type, &attr) != 0 ||
- slapi_attr_value_find( attr, bvp ) != 0 )
- {
- return 1;
- }
-
- if (deleteoldrdn == 0) return 0;
-
- /* in a multi-valued RDN, the RDN value might have been already
- * put on the smods_wsi list to be deleted, yet might still be
- * in the target RDN.
- */
-
- for (mod = slapi_mods_get_first_mod(smods_wsi);
- mod != NULL;
- mod = slapi_mods_get_next_mod(smods_wsi)) {
- if (SLAPI_IS_MOD_DELETE(mod->mod_op) &&
- (strcasecmp(mod->mod_type, type) == 0) &&
- (mod->mod_bvalues != NULL) &&
- (slapi_attr_value_cmp(attr, *mod->mod_bvalues, bvp) == 0)) {
- return 1;
- }
- }
-
- return 0;
- }
- /*
- * Build the list of modifications to apply to the Existing Entry
- * With State Information:
- * - delete old rdn values from the entry if deleteoldrdn is set
- * - add new rdn values to the entry
- * Without State Information
- * - No changes
- */
- static int
- moddn_newrdn_mods(Slapi_PBlock *pb, const char *olddn, struct backentry *ec, Slapi_Mods *smods_wsi, int is_repl_op)
- {
- char **rdns = NULL;
- char **dns = NULL;
- int deleteoldrdn;
- char *type = NULL;
- char *dn = NULL;
- char *newrdn = NULL;
- int i;
- struct berval *bvps[2];
- struct berval bv;
-
- bvps[0] = &bv;
- bvps[1] = NULL;
-
- /* slapi_pblock_get( pb, SLAPI_MODRDN_TARGET, &dn ); */
- slapi_pblock_get( pb, SLAPI_MODRDN_NEWRDN, &newrdn );
- slapi_pblock_get( pb, SLAPI_MODRDN_DELOLDRDN, &deleteoldrdn );
-
- /*
- * This loop removes the old RDN of the existing entry.
- */
- if (deleteoldrdn) {
- int baddn = 0; /* set to true if could not parse dn */
- int badrdn = 0; /* set to true if could not parse rdn */
- dn = slapi_ch_strdup(olddn);
- dns = slapi_ldap_explode_dn( dn, 0 );
- if ( dns != NULL )
- {
- rdns = slapi_ldap_explode_rdn( dns[0], 0 );
- if ( rdns != NULL )
- {
- for ( i = 0; rdns[i] != NULL; i++ )
- {
- /* delete from entry attributes */
- if ( deleteoldrdn && slapi_rdn2typeval( rdns[i], &type, &bv ) == 0 )
- {
- /* check if user is allowed to modify the specified attribute */
- /*
- * It would be better to do this check in the front end
- * end inside op_shared_rename(), but unfortunately we
- * don't have access to the target entry there.
- */
- if (!op_shared_is_allowed_attr (type, is_repl_op))
- {
- slapi_ldap_value_free( rdns );
- slapi_ldap_value_free( dns );
- slapi_ch_free_string(&dn);
- return LDAP_UNWILLING_TO_PERFORM;
- }
- if (strcasecmp (type, SLAPI_ATTR_UNIQUEID) != 0)
- slapi_mods_add_modbvps( smods_wsi, LDAP_MOD_DELETE, type, bvps );
- }
- }
- slapi_ldap_value_free( rdns );
- }
- else
- {
- badrdn = 1;
- }
- slapi_ldap_value_free( dns );
- }
- else
- {
- baddn = 1;
- }
- slapi_ch_free_string(&dn);
-
- if ( baddn || badrdn )
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "moddn_newrdn_mods failed: olddn=%s baddn=%d badrdn=%d\n",
- olddn, baddn, badrdn);
- return LDAP_OPERATIONS_ERROR;
- }
- }
- /*
- * add new RDN values to the entry (non-normalized)
- */
- rdns = slapi_ldap_explode_rdn( newrdn, 0 );
- if ( rdns != NULL )
- {
- for ( i = 0; rdns[i] != NULL; i++ )
- {
- if ( slapi_rdn2typeval( rdns[i], &type, &bv ) != 0) {
- continue;
- }
-
- /* add to entry if it's not already there or if was
- * already deleted
- */
- if (moddn_rdn_add_needed(ec, type, &bv,
- deleteoldrdn,
- smods_wsi) == 1) {
- slapi_mods_add_modbvps( smods_wsi, LDAP_MOD_ADD, type, bvps );
- }
- }
- slapi_ldap_value_free( rdns );
- }
- else
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "moddn_newrdn_mods failed: could not parse new rdn %s\n",
- newrdn, 0, 0);
- return LDAP_OPERATIONS_ERROR;
- }
-
- return LDAP_SUCCESS;
- }
- static void
- mods_remove_nsuniqueid(Slapi_Mods *smods)
- {
- int i;
- LDAPMod **mods = slapi_mods_get_ldapmods_byref(smods);
- for ( i = 0; mods[i] != NULL; i++ ) {
- if (!strcasecmp(mods[i]->mod_type, SLAPI_ATTR_UNIQUEID)) {
- mods[i]->mod_op = LDAP_MOD_IGNORE;
- }
- }
- }
- /*
- * Update the indexes to reflect the DN change made.
- * e is the entry before, ec the entry after.
- * mods contains the list of attribute change made.
- */
- static int
- modrdn_rename_entry_update_indexes(back_txn *ptxn, Slapi_PBlock *pb, struct ldbminfo *li, struct backentry *e, struct backentry **ec, Slapi_Mods *smods1, Slapi_Mods *smods2, Slapi_Mods *smods3, int *e_in_cache, int *ec_in_cache)
- {
- backend *be;
- ldbm_instance *inst;
- int retval= 0;
- char *msg;
- Slapi_Operation *operation;
- int is_ruv = 0; /* True if the current entry is RUV */
- int orig_ec_in_cache = 0;
- slapi_pblock_get( pb, SLAPI_BACKEND, &be );
- slapi_pblock_get( pb, SLAPI_OPERATION, &operation );
- is_ruv = operation_is_flag_set(operation, OP_FLAG_REPL_RUV);
- inst = (ldbm_instance *) be->be_instance_info;
- orig_ec_in_cache = *ec_in_cache;
- /*
- * Update the ID to Entry index.
- * Note that id2entry_add replaces the entry, so the Entry ID stays the same.
- */
- retval = id2entry_add( be, *ec, ptxn );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes: id2entry_add deadlock\n" );
- goto error_return;
- }
- if (retval != 0)
- {
- LDAPDebug( LDAP_DEBUG_ANY, "modrdn_rename_entry_update_indexes: id2entry_add failed, err=%d %s\n", retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- goto error_return;
- }
- *ec_in_cache = 1; /* id2entry_add adds to cache if not already in */
- if(smods1!=NULL && slapi_mods_get_num_mods(smods1)>0)
- {
- /*
- * update the indexes: lastmod, rdn, etc.
- */
- retval = index_add_mods( be, slapi_mods_get_ldapmods_byref(smods1), e, *ec, ptxn );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes: index_add_mods1 deadlock\n" );
- goto error_return;
- }
- if (retval != 0)
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "index_add_mods 1 failed, err=%d %s\n", retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- goto error_return;
- }
- }
- if(smods2!=NULL && slapi_mods_get_num_mods(smods2)>0)
- {
- /*
- * smods2 contains the state generated mods. One of them might be the removal of a "nsuniqueid" rdn component
- * previously gnerated through a conflict resolution. We need to make sure we don't remove the index for "nsuniqueid"
- * so let's get it out from the mods before calling index_add_mods...
- */
- mods_remove_nsuniqueid(smods2);
- /*
- * update the indexes: lastmod, rdn, etc.
- */
- retval = index_add_mods( be, slapi_mods_get_ldapmods_byref(smods2), e, *ec, ptxn );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes: index_add_mods2 deadlock\n" );
- goto error_return;
- }
- if (retval != 0)
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "index_add_mods 2 failed, err=%d %s\n", retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- goto error_return;
- }
- }
- if(smods3!=NULL && slapi_mods_get_num_mods(smods3)>0)
- {
- /*
- * update the indexes: lastmod, rdn, etc.
- */
- retval = index_add_mods( be, slapi_mods_get_ldapmods_byref(smods3), e, *ec, ptxn );
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Retry txn */
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes: index_add_mods3 deadlock\n" );
- goto error_return;
- }
- if (retval != 0)
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "index_add_mods 3 failed, err=%d %s\n", retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- goto error_return;
- }
- }
- /*
- * Remove the old entry from the Virtual List View indexes.
- * Add the new entry to the Virtual List View indexes.
- * If ruv, we don't have to update vlv.
- */
- if (!is_ruv)
- {
- retval= vlv_update_all_indexes(ptxn, be, pb, e, *ec);
- if (DB_LOCK_DEADLOCK == retval)
- {
- /* Abort and re-try */
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes: vlv_update_all_indexes deadlock\n" );
- goto error_return;
- }
- if (retval != 0)
- {
- LDAPDebug( LDAP_DEBUG_TRACE, "vlv_update_all_indexes failed, err=%d %s\n", retval, (msg = dblayer_strerror( retval )) ? msg : "", 0 );
- goto error_return;
- }
- }
- if (cache_replace( &inst->inst_cache, e, *ec ) != 0 ) {
- LDAPDebug0Args( LDAP_DEBUG_BACKLDBM, "modrdn_rename_entry_update_indexes cache_replace failed\n");
- retval= -1;
- goto error_return;
- } else {
- *e_in_cache = 0; /* e un-cached */
- }
- if (orig_ec_in_cache) {
- /* ec was already added to the cache via cache_add_tentative (to reserve its spot in the cache)
- and/or id2entry_add - so it already had one refcount - cache_replace adds another refcount -
- drop the extra ref added by cache_replace */
- CACHE_RETURN( &inst->inst_cache, ec );
- }
- error_return:
- return retval;
- }
- static int
- moddn_rename_child_entry(
- back_txn *ptxn,
- Slapi_PBlock *pb,
- struct ldbminfo *li,
- struct backentry *e,
- struct backentry **ec,
- int parentdncomps,
- char **newsuperiordns,
- int newsuperiordncomps,
- CSN *opcsn)
- {
- /*
- * Construct the new DN for the entry by taking the old DN
- * excluding the old parent entry DN, and adding the new
- * superior entry DN.
- *
- * slapi_ldap_explode_dn is probably a bit slow, but it knows about
- * DN escaping which is pretty complicated, and we wouldn't
- * want to reimplement that here.
- *
- * JCM - This was written before Slapi_RDN... so this could be made much neater.
- */
- int retval = 0;
- char *olddn;
- char *newdn;
- char **olddns;
- int olddncomps= 0;
- int need= 1; /* For the '\0' */
- int i;
- int e_in_cache = 1;
- int ec_in_cache = 0;
- olddn = slapi_entry_get_dn((*ec)->ep_entry);
- if (NULL == olddn) {
- return retval;
- }
- olddns = slapi_ldap_explode_dn( olddn, 0 );
- if (NULL == olddns) {
- return retval;
- }
- for(;olddns[olddncomps]!=NULL;olddncomps++);
- for(i=0;i<olddncomps-parentdncomps;i++)
- {
- need+= strlen(olddns[i]) + 2; /* For the ", " */
- }
- for(i=0;i<newsuperiordncomps;i++)
- {
- need+= strlen(newsuperiordns[i]) + 2; /* For the ", " */
- }
- need--; /* We don't have a comma on the end of the last component */
- newdn= slapi_ch_malloc(need);
- newdn[0]= '\0';
- for(i=0;i<olddncomps-parentdncomps;i++)
- {
- strcat(newdn,olddns[i]);
- strcat(newdn,", ");
- }
- for(i=0;i<newsuperiordncomps;i++)
- {
- strcat(newdn,newsuperiordns[i]);
- if(i<newsuperiordncomps-1)
- {
- /* We don't have a comma on the end of the last component */
- strcat(newdn,", ");
- }
- }
- slapi_ldap_value_free( olddns );
- slapi_entry_set_dn( (*ec)->ep_entry, newdn );
- /* add the entrydn operational attributes */
- add_update_entrydn_operational_attributes (*ec);
- /*
- * Update the DN CSN of the entry.
- */
- {
- entry_add_dncsn(e->ep_entry, opcsn);
- entry_add_rdn_csn(e->ep_entry, opcsn);
- entry_set_maxcsn(e->ep_entry, opcsn);
- }
- {
- Slapi_Mods smods;
- Slapi_Mods *smodsp = NULL;
- memset(&smods, 0, sizeof(smods));
- slapi_mods_init(&smods, 2);
- slapi_mods_add( &smods, LDAP_MOD_DELETE, LDBM_ENTRYDN_STR,
- strlen( backentry_get_ndn(e) ), backentry_get_ndn(e) );
- slapi_mods_add( &smods, LDAP_MOD_REPLACE, LDBM_ENTRYDN_STR,
- strlen( backentry_get_ndn(*ec) ), backentry_get_ndn(*ec) );
- smodsp = &smods;
- /*
- * Update all the indexes.
- */
- retval = modrdn_rename_entry_update_indexes(ptxn, pb, li, e, ec,
- smodsp, NULL, NULL,
- &e_in_cache, &ec_in_cache);
- /* JCMREPL - Should the children get updated modifiersname and lastmodifiedtime? */
- slapi_mods_done(&smods);
- }
- return retval;
- }
- /*
- * Rename all the children of an entry who's name has changed.
- * Called if "subtree-rename: off"
- */
- static int
- moddn_rename_children(
- back_txn *ptxn,
- Slapi_PBlock *pb,
- backend *be,
- IDList *children,
- Slapi_DN *dn_parentdn,
- Slapi_DN *dn_newsuperiordn,
- struct backentry *child_entries[])
- {
- /* Iterate over the children list renaming every child */
- struct ldbminfo *li = (struct ldbminfo *) be->be_database->plg_private;
- Slapi_Operation *operation;
- CSN *opcsn;
- int retval= -1, i;
- char **newsuperiordns = NULL;
- int newsuperiordncomps= 0;
- int parentdncomps= 0;
- NIDS nids = children ? children->b_nids : 0;
- struct backentry **child_entry_copies = NULL;
- ldbm_instance *inst = (ldbm_instance *)be->be_instance_info;
- /*
- * Break down the parent entry dn into its components.
- */
- {
- char **parentdns = slapi_ldap_explode_dn( slapi_sdn_get_dn(dn_parentdn), 0 );
- if (parentdns)
- {
- for(;parentdns[parentdncomps]!=NULL;parentdncomps++);
- slapi_ldap_value_free( parentdns );
- }
- else
- {
- return retval;
- }
- }
- /*
- * Break down the new superior entry dn into its components.
- */
- newsuperiordns = slapi_ldap_explode_dn( slapi_sdn_get_dn(dn_newsuperiordn), 0 );
- if (newsuperiordns)
- {
- for(;newsuperiordns[newsuperiordncomps]!=NULL;newsuperiordncomps++);
- }
- else
- {
- return retval;
- }
- /* probably, only if "subtree-rename is off */
- child_entry_copies =
- (struct backentry**)slapi_ch_calloc(sizeof(struct backentry*), nids+1);
- for (i = 0; i <= nids; i++)
- {
- child_entry_copies[i] = backentry_dup(child_entries[i]);
- }
- /*
- * Iterate over the child entries renaming them.
- */
- slapi_pblock_get( pb, SLAPI_OPERATION, &operation );
- opcsn = operation_get_csn (operation);
- for (i=0,retval=0; retval == 0 && child_entries[i] && child_entry_copies[i]; i++) {
- retval = moddn_rename_child_entry(ptxn, pb, li, child_entries[i],
- &child_entry_copies[i], parentdncomps,
- newsuperiordns, newsuperiordncomps,
- opcsn );
- }
- if (0 == retval) /* success */
- {
- CACHE_REMOVE( &inst->inst_cache, child_entry_copies[i] );
- CACHE_RETURN( &inst->inst_cache, &(child_entry_copies[i]) );
- }
- else /* failure */
- {
- while (child_entries[i] != NULL)
- {
- backentry_free(&(child_entry_copies[i]));
- i++;
- }
- }
- slapi_ldap_value_free( newsuperiordns );
- slapi_ch_free((void**)&child_entry_copies);
- return retval;
- }
- /*
- * Get an IDList of all the children of an entry.
- */
- static IDList *
- moddn_get_children(back_txn *ptxn,
- Slapi_PBlock *pb,
- backend *be,
- struct backentry *parententry,
- Slapi_DN *dn_parentdn,
- struct backentry ***child_entries,
- struct backdn ***child_dns)
- {
- ldbm_instance *inst = (ldbm_instance *) be->be_instance_info;
- int err= 0;
- IDList *candidates;
- IDList *result_idl = NULL;
- char filterstr[20];
- Slapi_Filter *filter;
- NIDS nids;
- int entrynum = 0;
- int dnnum = 0;
- ID id;
- idl_iterator sr_current; /* the current position in the search results */
- struct backentry *e= NULL;
- struct backdn *dn = NULL;
- if (child_entries)
- {
- *child_entries = NULL;
- }
- if (child_dns)
- {
- *child_dns = NULL;
- }
- if (entryrdn_get_switch())
- {
- err = entryrdn_get_subordinates(be,
- slapi_entry_get_sdn_const(parententry->ep_entry),
- parententry->ep_id, &candidates, ptxn);
- if (err) {
- LDAPDebug1Arg( LDAP_DEBUG_ANY, "moddn_get_children: "
- "entryrdn_get_subordinates returned %d\n", err);
- goto bail;
- }
- }
- else
- {
- /* Fetch a candidate list of all the entries below the entry
- * being moved */
- strcpy( filterstr, "objectclass=*" );
- filter = slapi_str2filter( filterstr );
- candidates= subtree_candidates(pb, be, slapi_sdn_get_ndn(dn_parentdn),
- parententry, filter, 1 /* ManageDSAIT */,
- NULL /* allids_before_scopingp */, &err);
- slapi_filter_free(filter,1);
- }
-
- if (candidates!=NULL)
- {
- sr_current = idl_iterator_init(candidates);
- result_idl= idl_alloc(candidates->b_nids);
- do
- {
- id = idl_iterator_dereference_increment(&sr_current, candidates);
- if ( id!=NOID )
- {
- int err= 0;
- e = id2entry( be, id, ptxn, &err );
- if (e!=NULL)
- {
- /* The subtree search will have included the parent
- * entry in the result set */
- if (e!=parententry)
- {
- /* Check that the candidate entry is really
- * below the base. */
- if(slapi_dn_issuffix( backentry_get_ndn(e),
- slapi_sdn_get_ndn(dn_parentdn)))
- {
- /*
- * The given ID list is not sorted.
- * We have to call idl_insert instead of idl_append.
- */
- idl_insert(&result_idl,id);
- }
- }
- CACHE_RETURN(&inst->inst_cache, &e);
- }
- }
- } while (id!=NOID);
- idl_free(candidates);
- }
-
- nids = result_idl ? result_idl->b_nids : 0;
- if (child_entries) {
- *child_entries= (struct backentry**)slapi_ch_calloc(sizeof(struct backentry*),nids+1);
- }
- if (child_dns)
- {
- *child_dns = (struct backdn **)slapi_ch_calloc(sizeof(struct backdn *),nids+1);
- }
-
- sr_current = idl_iterator_init(result_idl);
- do {
- id = idl_iterator_dereference_increment(&sr_current, result_idl);
- if ( id!=NOID ) {
- if (child_entries) {
- e = cache_find_id( &inst->inst_cache, id );
- if ( e != NULL ) {
- cache_lock_entry(&inst->inst_cache, e);
- (*child_entries)[entrynum] = e;
- entrynum++;
- }
- }
- if (entryrdn_get_switch() && child_dns)
- {
- dn = dncache_find_id( &inst->inst_dncache, id );
- if ( dn != NULL ) {
- (*child_dns)[dnnum] = dn;
- dnnum++;
- }
- }
- }
- } while (id!=NOID);
- bail:
- return result_idl;
- }
|