]> git.sur5r.net Git - openldap/blob - servers/slapd/back-bdb/modify.c
Additional manageDIT changes.
[openldap] / servers / slapd / back-bdb / modify.c
1 /* modify.c - bdb backend modify routine */
2 /* $OpenLDAP$ */
3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
4  *
5  * Copyright 2000-2005 The OpenLDAP Foundation.
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted only as authorized by the OpenLDAP
10  * Public License.
11  *
12  * A copy of this license is available in the file LICENSE in the
13  * top-level directory of the distribution or, alternatively, at
14  * <http://www.OpenLDAP.org/license.html>.
15  */
16
17 #include "portable.h"
18
19 #include <stdio.h>
20 #include <ac/string.h>
21 #include <ac/time.h>
22
23 #include "back-bdb.h"
24
25 static struct berval scbva[] = {
26         BER_BVC("glue"),
27         BER_BVNULL
28 };
29
30 int bdb_modify_internal(
31         Operation *op,
32         DB_TXN *tid,
33         Modifications *modlist,
34         Entry *e,
35         const char **text,
36         char *textbuf,
37         size_t textlen )
38 {
39         int rc, err;
40         Modification    *mod;
41         Modifications   *ml;
42         Attribute       *save_attrs;
43         Attribute       *ap;
44         int                     glue_attr_delete = 0;
45
46         Debug( LDAP_DEBUG_TRACE, "bdb_modify_internal: 0x%08lx: %s\n",
47                 e->e_id, e->e_dn, 0);
48
49         if ( !acl_check_modlist( op, e, modlist )) {
50                 return LDAP_INSUFFICIENT_ACCESS;
51         }
52
53         /* save_attrs will be disposed of by bdb_cache_modify */
54         save_attrs = e->e_attrs;
55         e->e_attrs = attrs_dup( e->e_attrs );
56
57         for ( ml = modlist; ml != NULL; ml = ml->sml_next ) {
58                 int match;
59                 mod = &ml->sml_mod;
60                 switch( mod->sm_op ) {
61                 case LDAP_MOD_ADD:
62                 case LDAP_MOD_REPLACE:
63                         if ( mod->sm_desc == slap_schema.si_ad_structuralObjectClass ) {
64                                 value_match( &match, slap_schema.si_ad_structuralObjectClass,
65                                         slap_schema.si_ad_structuralObjectClass->
66                                                 ad_type->sat_equality,
67                                         SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX,
68                                         &mod->sm_values[0], &scbva[0], text );
69                                 if ( !match ) glue_attr_delete = 1;
70                         }
71                 }
72                 if ( glue_attr_delete )
73                         break;
74         }
75
76         if ( glue_attr_delete ) {
77                 Attribute       **app = &e->e_attrs;
78                 while ( *app != NULL ) {
79                         if ( !is_at_operational( (*app)->a_desc->ad_type )) {
80                                 Attribute *save = *app;
81                                 *app = (*app)->a_next;
82                                 attr_free( save );
83                                 continue;
84                         }
85                         app = &(*app)->a_next;
86                 }
87         }
88
89         for ( ml = modlist; ml != NULL; ml = ml->sml_next ) {
90                 mod = &ml->sml_mod;
91
92                 switch ( mod->sm_op ) {
93                 case LDAP_MOD_ADD:
94                         Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: add\n", 0, 0, 0);
95                         err = modify_add_values( e, mod, get_permissiveModify(op),
96                                 text, textbuf, textlen );
97                         if( err != LDAP_SUCCESS ) {
98                                 Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
99                                         err, *text, 0);
100                         }
101                         break;
102
103                 case LDAP_MOD_DELETE:
104                         if ( glue_attr_delete ) {
105                                 err = LDAP_SUCCESS;
106                                 break;
107                         }
108
109                         Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: delete\n", 0, 0, 0);
110                         err = modify_delete_values( e, mod, get_permissiveModify(op),
111                                 text, textbuf, textlen );
112                         assert( err != LDAP_TYPE_OR_VALUE_EXISTS );
113                         if( err != LDAP_SUCCESS ) {
114                                 Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
115                                         err, *text, 0);
116                         }
117                         break;
118
119                 case LDAP_MOD_REPLACE:
120                         Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: replace\n", 0, 0, 0);
121                         err = modify_replace_values( e, mod, get_permissiveModify(op),
122                                 text, textbuf, textlen );
123                         if( err != LDAP_SUCCESS ) {
124                                 Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
125                                         err, *text, 0);
126                         }
127                         break;
128
129                 case LDAP_MOD_INCREMENT:
130                         Debug(LDAP_DEBUG_ARGS,
131                                 "bdb_modify_internal: increment\n", 0, 0, 0);
132                         err = modify_increment_values( e, mod, get_permissiveModify(op),
133                                 text, textbuf, textlen );
134                         if( err != LDAP_SUCCESS ) {
135                                 Debug(LDAP_DEBUG_ARGS,
136                                         "bdb_modify_internal: %d %s\n",
137                                         err, *text, 0);
138                         }
139                         break;
140
141                 case SLAP_MOD_SOFTADD:
142                         Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: softadd\n", 0, 0, 0);
143                         /* Avoid problems in index_add_mods()
144                          * We need to add index if necessary.
145                          */
146                         mod->sm_op = LDAP_MOD_ADD;
147
148                         err = modify_add_values( e, mod, get_permissiveModify(op),
149                                 text, textbuf, textlen );
150
151                         mod->sm_op = SLAP_MOD_SOFTADD;
152
153                         if ( err == LDAP_TYPE_OR_VALUE_EXISTS ) {
154                                 err = LDAP_SUCCESS;
155                         }
156
157                         if( err != LDAP_SUCCESS ) {
158                                 Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
159                                         err, *text, 0);
160                         }
161                         break;
162
163                 default:
164                         Debug(LDAP_DEBUG_ANY, "bdb_modify_internal: invalid op %d\n",
165                                 mod->sm_op, 0, 0);
166                         *text = "Invalid modify operation";
167                         err = LDAP_OTHER;
168                         Debug(LDAP_DEBUG_ARGS, "bdb_modify_internal: %d %s\n",
169                                 err, *text, 0);
170                 }
171
172                 if ( err != LDAP_SUCCESS ) {
173                         attrs_free( e->e_attrs );
174                         e->e_attrs = save_attrs;
175                         /* unlock entry, delete from cache */
176                         return err; 
177                 }
178
179                 /* If objectClass was modified, reset the flags */
180                 if ( mod->sm_desc == slap_schema.si_ad_objectClass ) {
181                         e->e_ocflags = 0;
182                 }
183
184                 if ( glue_attr_delete ) e->e_ocflags = 0;
185
186                 /* check if modified attribute was indexed
187                  * but not in case of NOOP... */
188                 err = bdb_index_is_indexed( op->o_bd, mod->sm_desc );
189                 if ( err == LDAP_SUCCESS && !op->o_noop ) {
190                         ap = attr_find( save_attrs, mod->sm_desc );
191                         if ( ap ) ap->a_flags |= SLAP_ATTR_IXDEL;
192
193                         ap = attr_find( e->e_attrs, mod->sm_desc );
194                         if ( ap ) ap->a_flags |= SLAP_ATTR_IXADD;
195                 }
196         }
197
198         /* check that the entry still obeys the schema */
199         rc = entry_schema_check( op->o_bd, e, save_attrs, get_manageDIT(op),
200                 text, textbuf, textlen );
201         if ( rc != LDAP_SUCCESS || op->o_noop ) {
202                 attrs_free( e->e_attrs );
203                 /* clear the indexing flags */
204                 for ( ap = save_attrs; ap != NULL; ap = ap->a_next ) {
205                         ap->a_flags = 0;
206                 }
207                 e->e_attrs = save_attrs;
208
209                 if ( rc != LDAP_SUCCESS ) {
210                         Debug( LDAP_DEBUG_ANY,
211                                 "entry failed schema check: %s\n",
212                                 *text, 0, 0 );
213                 }
214
215                 /* if NOOP then silently revert to saved attrs */
216                 return rc;
217         }
218
219         /* update the indices of the modified attributes */
220
221         /* start with deleting the old index entries */
222         for ( ap = save_attrs; ap != NULL; ap = ap->a_next ) {
223                 if ( ap->a_flags & SLAP_ATTR_IXDEL ) {
224                         rc = bdb_index_values( op, tid, ap->a_desc,
225                                 ap->a_nvals,
226                                 e->e_id, SLAP_INDEX_DELETE_OP );
227                         if ( rc != LDAP_SUCCESS ) {
228                                 attrs_free( e->e_attrs );
229                                 e->e_attrs = save_attrs;
230                                 Debug( LDAP_DEBUG_ANY,
231                                        "Attribute index delete failure",
232                                        0, 0, 0 );
233                                 return rc;
234                         }
235                         ap->a_flags &= ~SLAP_ATTR_IXDEL;
236                 }
237         }
238
239         /* add the new index entries */
240         for ( ap = e->e_attrs; ap != NULL; ap = ap->a_next ) {
241                 if (ap->a_flags & SLAP_ATTR_IXADD) {
242                         rc = bdb_index_values( op, tid, ap->a_desc,
243                                 ap->a_nvals,
244                                 e->e_id, SLAP_INDEX_ADD_OP );
245                         if ( rc != LDAP_SUCCESS ) {
246                                 attrs_free( e->e_attrs );
247                                 e->e_attrs = save_attrs;
248                                 Debug( LDAP_DEBUG_ANY,
249                                        "Attribute index add failure",
250                                        0, 0, 0 );
251                                 return rc;
252                         }
253                         ap->a_flags &= ~SLAP_ATTR_IXADD;
254                 }
255         }
256
257         return rc;
258 }
259
260
261 int
262 bdb_modify( Operation *op, SlapReply *rs )
263 {
264         struct bdb_info *bdb = (struct bdb_info *) op->o_bd->be_private;
265         Entry           *e = NULL;
266         EntryInfo       *ei = NULL;
267         int             manageDSAit = get_manageDSAit( op );
268         char textbuf[SLAP_TEXT_BUFLEN];
269         size_t textlen = sizeof textbuf;
270         DB_TXN  *ltid = NULL, *lt2;
271         struct bdb_op_info opinfo = {0};
272         Entry           dummy = {0};
273         int                     fakeroot = 0;
274
275         u_int32_t       locker = 0;
276         DB_LOCK         lock;
277
278         int             num_retries = 0;
279
280         LDAPControl **preread_ctrl = NULL;
281         LDAPControl **postread_ctrl = NULL;
282         LDAPControl *ctrls[SLAP_MAX_RESPONSE_CONTROLS];
283         int num_ctrls = 0;
284
285         int rc;
286
287         Debug( LDAP_DEBUG_ARGS, LDAP_XSTRING(bdb_modify) ": %s\n",
288                 op->o_req_dn.bv_val, 0, 0 );
289
290         ctrls[num_ctrls] = NULL;
291
292         if( 0 ) {
293 retry:  /* transaction retry */
294                 if ( dummy.e_attrs ) {
295                         attrs_free( dummy.e_attrs );
296                         dummy.e_attrs = NULL;
297                 }
298                 if( e != NULL ) {
299                         bdb_unlocked_cache_return_entry_w(&bdb->bi_cache, e);
300                         e = NULL;
301                 }
302                 Debug(LDAP_DEBUG_TRACE,
303                         LDAP_XSTRING(bdb_modify) ": retrying...\n", 0, 0, 0);
304
305                 rs->sr_err = TXN_ABORT( ltid );
306                 ltid = NULL;
307                 op->o_private = NULL;
308                 op->o_do_not_cache = opinfo.boi_acl_cache;
309                 if( rs->sr_err != 0 ) {
310                         rs->sr_err = LDAP_OTHER;
311                         rs->sr_text = "internal error";
312                         goto return_results;
313                 }
314                 if ( op->o_abandon ) {
315                         rs->sr_err = SLAPD_ABANDON;
316                         goto return_results;
317                 }
318                 ldap_pvt_thread_yield();
319                 bdb_trans_backoff( ++num_retries );
320         }
321
322         /* begin transaction */
323         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, NULL, &ltid, 
324                 bdb->bi_db_opflags );
325         rs->sr_text = NULL;
326         if( rs->sr_err != 0 ) {
327                 Debug( LDAP_DEBUG_TRACE,
328                         LDAP_XSTRING(bdb_modify) ": txn_begin failed: "
329                         "%s (%d)\n", db_strerror(rs->sr_err), rs->sr_err, 0 );
330                 rs->sr_err = LDAP_OTHER;
331                 rs->sr_text = "internal error";
332                 goto return_results;
333         }
334
335         locker = TXN_ID ( ltid );
336
337         opinfo.boi_bdb = op->o_bd;
338         opinfo.boi_txn = ltid;
339         opinfo.boi_locker = locker;
340         opinfo.boi_err = 0;
341         opinfo.boi_acl_cache = op->o_do_not_cache;
342         op->o_private = &opinfo;
343
344         /* get entry or ancestor */
345         rs->sr_err = bdb_dn2entry( op, ltid, &op->o_req_ndn, &ei, 1,
346                 locker, &lock );
347
348         e = ei->bei_e;
349
350         if ( rs->sr_err != 0 ) {
351                 Debug( LDAP_DEBUG_TRACE,
352                         LDAP_XSTRING(bdb_modify) ": dn2entry failed (%d)\n",
353                         rs->sr_err, 0, 0 );
354                 switch( rs->sr_err ) {
355                 case DB_LOCK_DEADLOCK:
356                 case DB_LOCK_NOTGRANTED:
357                         goto retry;
358                 case DB_NOTFOUND:
359                         if ( BER_BVISEMPTY( &op->o_req_ndn )) {
360                                 struct berval gluebv = BER_BVC("glue");
361                                 e = ch_calloc( 1, sizeof(Entry));
362                                 e->e_name.bv_val = ch_strdup( "" );
363                                 ber_dupbv( &e->e_nname, &e->e_name );
364                                 attr_merge_one( e, slap_schema.si_ad_objectClass,
365                                         &gluebv, NULL );
366                                 attr_merge_one( e, slap_schema.si_ad_structuralObjectClass,
367                                         &gluebv, NULL );
368                                 e->e_private = ei;
369                                 fakeroot = 1;
370                                 rs->sr_err = 0;
371                         }
372                         break;
373                 case LDAP_BUSY:
374                         rs->sr_text = "ldap server busy";
375                         goto return_results;
376                 default:
377                         rs->sr_err = LDAP_OTHER;
378                         rs->sr_text = "internal error";
379                         goto return_results;
380                 }
381         }
382
383         /* acquire and lock entry */
384         /* FIXME: dn2entry() should return non-glue entry */
385         if (( rs->sr_err == DB_NOTFOUND ) ||
386                 ( !manageDSAit && e && is_entry_glue( e )))
387         {
388                 if ( e != NULL ) {
389                         rs->sr_matched = ch_strdup( e->e_dn );
390                         rs->sr_ref = is_entry_referral( e )
391                                 ? get_entry_referrals( op, e )
392                                 : NULL;
393                         bdb_unlocked_cache_return_entry_r (&bdb->bi_cache, e);
394                         e = NULL;
395
396                 } else {
397                         rs->sr_ref = referral_rewrite( default_referral, NULL,
398                                 &op->o_req_dn, LDAP_SCOPE_DEFAULT );
399                 }
400
401                 rs->sr_err = LDAP_REFERRAL;
402                 send_ldap_result( op, rs );
403
404                 if ( rs->sr_ref != default_referral ) {
405                         ber_bvarray_free( rs->sr_ref );
406                 }
407                 free( (char *)rs->sr_matched );
408                 rs->sr_ref = NULL;
409                 rs->sr_matched = NULL;
410
411                 goto done;
412         }
413
414         if ( !manageDSAit && is_entry_referral( e ) ) {
415                 /* entry is a referral, don't allow modify */
416                 rs->sr_ref = get_entry_referrals( op, e );
417
418                 Debug( LDAP_DEBUG_TRACE,
419                         LDAP_XSTRING(bdb_modify) ": entry is referral\n",
420                         0, 0, 0 );
421
422                 rs->sr_err = LDAP_REFERRAL;
423                 rs->sr_matched = e->e_name.bv_val;
424                 send_ldap_result( op, rs );
425
426                 ber_bvarray_free( rs->sr_ref );
427                 rs->sr_ref = NULL;
428                 rs->sr_matched = NULL;
429                 goto done;
430         }
431
432         if ( get_assert( op ) &&
433                 ( test_filter( op, e, get_assertion( op )) != LDAP_COMPARE_TRUE ))
434         {
435                 rs->sr_err = LDAP_ASSERTION_FAILED;
436                 goto return_results;
437         }
438
439         if( op->o_preread ) {
440                 if( preread_ctrl == NULL ) {
441                         preread_ctrl = &ctrls[num_ctrls++];
442                         ctrls[num_ctrls] = NULL;
443                 }
444                 if ( slap_read_controls( op, rs, e,
445                         &slap_pre_read_bv, preread_ctrl ) )
446                 {
447                         Debug( LDAP_DEBUG_TRACE,
448                                 "<=- " LDAP_XSTRING(bdb_modify) ": pre-read failed!\n",
449                                 0, 0, 0 );
450                         goto return_results;
451                 }
452         }
453
454         /* nested transaction */
455         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, ltid, &lt2, bdb->bi_db_opflags );
456         rs->sr_text = NULL;
457         if( rs->sr_err != 0 ) {
458                 Debug( LDAP_DEBUG_TRACE,
459                         LDAP_XSTRING(bdb_modify) ": txn_begin(2) failed: " "%s (%d)\n",
460                         db_strerror(rs->sr_err), rs->sr_err, 0 );
461                 rs->sr_err = LDAP_OTHER;
462                 rs->sr_text = "internal error";
463                 goto return_results;
464         }
465         /* Modify the entry */
466         dummy = *e;
467         rs->sr_err = bdb_modify_internal( op, lt2, op->oq_modify.rs_modlist,
468                 &dummy, &rs->sr_text, textbuf, textlen );
469
470         if( rs->sr_err != LDAP_SUCCESS ) {
471                 Debug( LDAP_DEBUG_TRACE,
472                         LDAP_XSTRING(bdb_modify) ": modify failed (%d)\n",
473                         rs->sr_err, 0, 0 );
474                 if ( (rs->sr_err == LDAP_INSUFFICIENT_ACCESS) && opinfo.boi_err ) {
475                         rs->sr_err = opinfo.boi_err;
476                 }
477                 /* Only free attrs if they were dup'd.  */
478                 if ( dummy.e_attrs == e->e_attrs ) dummy.e_attrs = NULL;
479                 switch( rs->sr_err ) {
480                 case DB_LOCK_DEADLOCK:
481                 case DB_LOCK_NOTGRANTED:
482                         goto retry;
483                 }
484                 goto return_results;
485         }
486
487         /* change the entry itself */
488         rs->sr_err = bdb_id2entry_update( op->o_bd, lt2, &dummy );
489         if ( rs->sr_err != 0 ) {
490                 Debug( LDAP_DEBUG_TRACE,
491                         LDAP_XSTRING(bdb_modify) ": id2entry update failed " "(%d)\n",
492                         rs->sr_err, 0, 0 );
493                 switch( rs->sr_err ) {
494                 case DB_LOCK_DEADLOCK:
495                 case DB_LOCK_NOTGRANTED:
496                         goto retry;
497                 }
498                 rs->sr_text = "entry update failed";
499                 goto return_results;
500         }
501
502         if ( TXN_COMMIT( lt2, 0 ) != 0 ) {
503                 rs->sr_err = LDAP_OTHER;
504                 rs->sr_text = "txn_commit(2) failed";
505                 goto return_results;
506         }
507
508         if( op->o_postread ) {
509                 if( postread_ctrl == NULL ) {
510                         postread_ctrl = &ctrls[num_ctrls++];
511                         ctrls[num_ctrls] = NULL;
512                 }
513                 if( slap_read_controls( op, rs, &dummy,
514                         &slap_post_read_bv, postread_ctrl ) )
515                 {
516                         Debug( LDAP_DEBUG_TRACE,
517                                 "<=- " LDAP_XSTRING(bdb_modify)
518                                 ": post-read failed!\n", 0, 0, 0 );
519                         goto return_results;
520                 }
521         }
522
523         if( op->o_noop ) {
524                 if ( ( rs->sr_err = TXN_ABORT( ltid ) ) != 0 ) {
525                         rs->sr_text = "txn_abort (no-op) failed";
526                 } else {
527                         rs->sr_err = LDAP_NO_OPERATION;
528                         goto return_results;
529                 }
530         } else {
531                 /* may have changed in bdb_modify_internal() */
532                 e->e_ocflags = dummy.e_ocflags;
533                 if ( fakeroot ) {
534                         e->e_private = NULL;
535                         entry_free( e );
536                 } else {
537                         rc = bdb_cache_modify( e, dummy.e_attrs, bdb->bi_dbenv, locker, &lock );
538                         switch( rc ) {
539                         case DB_LOCK_DEADLOCK:
540                         case DB_LOCK_NOTGRANTED:
541                                 goto retry;
542                         }
543                 }
544                 dummy.e_attrs = NULL;
545
546                 rs->sr_err = TXN_COMMIT( ltid, 0 );
547         }
548         ltid = NULL;
549         op->o_private = NULL;
550
551         if( rs->sr_err != 0 ) {
552                 Debug( LDAP_DEBUG_TRACE,
553                         LDAP_XSTRING(bdb_modify) ": txn_%s failed: %s (%d)\n",
554                         op->o_noop ? "abort (no-op)" : "commit",
555                         db_strerror(rs->sr_err), rs->sr_err );
556                 rs->sr_err = LDAP_OTHER;
557                 rs->sr_text = "commit failed";
558
559                 goto return_results;
560         }
561
562         Debug( LDAP_DEBUG_TRACE,
563                 LDAP_XSTRING(bdb_modify) ": updated%s id=%08lx dn=\"%s\"\n",
564                 op->o_noop ? " (no-op)" : "",
565                 dummy.e_id, op->o_req_dn.bv_val );
566
567         rs->sr_err = LDAP_SUCCESS;
568         rs->sr_text = NULL;
569         if( num_ctrls ) rs->sr_ctrls = ctrls;
570
571 return_results:
572         if( dummy.e_attrs ) {
573                 attrs_free( dummy.e_attrs );
574         }
575         send_ldap_result( op, rs );
576
577         if( rs->sr_err == LDAP_SUCCESS && bdb->bi_txn_cp ) {
578                 ldap_pvt_thread_yield();
579                 TXN_CHECKPOINT( bdb->bi_dbenv,
580                         bdb->bi_txn_cp_kbyte, bdb->bi_txn_cp_min, 0 );
581         }
582
583 done:
584         if( ltid != NULL ) {
585                 TXN_ABORT( ltid );
586                 op->o_private = NULL;
587         }
588
589         if( e != NULL ) {
590                 bdb_unlocked_cache_return_entry_w (&bdb->bi_cache, e);
591         }
592
593         if( preread_ctrl != NULL ) {
594                 slap_sl_free( (*preread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx );
595                 slap_sl_free( *preread_ctrl, op->o_tmpmemctx );
596         }
597         if( postread_ctrl != NULL ) {
598                 slap_sl_free( (*postread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx );
599                 slap_sl_free( *postread_ctrl, op->o_tmpmemctx );
600         }
601         return rs->sr_err;
602 }