]> git.sur5r.net Git - openldap/blob - servers/slapd/back-bdb/modify.c
Silence warnings in prev commit
[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, text, textbuf, textlen );
200         if ( rc != LDAP_SUCCESS || op->o_noop ) {
201                 attrs_free( e->e_attrs );
202                 /* clear the indexing flags */
203                 for ( ap = save_attrs; ap != NULL; ap = ap->a_next ) {
204                         ap->a_flags = 0;
205                 }
206                 e->e_attrs = save_attrs;
207
208                 if ( rc != LDAP_SUCCESS ) {
209                         Debug( LDAP_DEBUG_ANY,
210                                 "entry failed schema check: %s\n",
211                                 *text, 0, 0 );
212                 }
213
214                 /* if NOOP then silently revert to saved attrs */
215                 return rc;
216         }
217
218         /* update the indices of the modified attributes */
219
220         /* start with deleting the old index entries */
221         for ( ap = save_attrs; ap != NULL; ap = ap->a_next ) {
222                 if ( ap->a_flags & SLAP_ATTR_IXDEL ) {
223                         rc = bdb_index_values( op, tid, ap->a_desc,
224                                 ap->a_nvals,
225                                 e->e_id, SLAP_INDEX_DELETE_OP );
226                         if ( rc != LDAP_SUCCESS ) {
227                                 attrs_free( e->e_attrs );
228                                 e->e_attrs = save_attrs;
229                                 Debug( LDAP_DEBUG_ANY,
230                                        "Attribute index delete failure",
231                                        0, 0, 0 );
232                                 return rc;
233                         }
234                         ap->a_flags &= ~SLAP_ATTR_IXDEL;
235                 }
236         }
237
238         /* add the new index entries */
239         for ( ap = e->e_attrs; ap != NULL; ap = ap->a_next ) {
240                 if (ap->a_flags & SLAP_ATTR_IXADD) {
241                         rc = bdb_index_values( op, tid, ap->a_desc,
242                                 ap->a_nvals,
243                                 e->e_id, SLAP_INDEX_ADD_OP );
244                         if ( rc != LDAP_SUCCESS ) {
245                                 attrs_free( e->e_attrs );
246                                 e->e_attrs = save_attrs;
247                                 Debug( LDAP_DEBUG_ANY,
248                                        "Attribute index add failure",
249                                        0, 0, 0 );
250                                 return rc;
251                         }
252                         ap->a_flags &= ~SLAP_ATTR_IXADD;
253                 }
254         }
255
256         return rc;
257 }
258
259
260 int
261 bdb_modify( Operation *op, SlapReply *rs )
262 {
263         struct bdb_info *bdb = (struct bdb_info *) op->o_bd->be_private;
264         Entry           *e = NULL;
265         EntryInfo       *ei = NULL;
266         int             manageDSAit = get_manageDSAit( op );
267         char textbuf[SLAP_TEXT_BUFLEN];
268         size_t textlen = sizeof textbuf;
269         DB_TXN  *ltid = NULL, *lt2;
270         struct bdb_op_info opinfo = {0};
271         Entry           dummy = {0};
272         int                     fakeroot = 0;
273
274         u_int32_t       locker = 0;
275         DB_LOCK         lock;
276
277         int             num_retries = 0;
278
279         LDAPControl **preread_ctrl = NULL;
280         LDAPControl **postread_ctrl = NULL;
281         LDAPControl *ctrls[SLAP_MAX_RESPONSE_CONTROLS];
282         int num_ctrls = 0;
283
284         int rc;
285
286         Debug( LDAP_DEBUG_ARGS, LDAP_XSTRING(bdb_modify) ": %s\n",
287                 op->o_req_dn.bv_val, 0, 0 );
288
289         ctrls[num_ctrls] = NULL;
290
291         if( 0 ) {
292 retry:  /* transaction retry */
293                 if ( dummy.e_attrs ) {
294                         attrs_free( dummy.e_attrs );
295                         dummy.e_attrs = NULL;
296                 }
297                 if( e != NULL ) {
298                         bdb_unlocked_cache_return_entry_w(&bdb->bi_cache, e);
299                         e = NULL;
300                 }
301                 Debug(LDAP_DEBUG_TRACE,
302                         LDAP_XSTRING(bdb_modify) ": retrying...\n", 0, 0, 0);
303
304                 rs->sr_err = TXN_ABORT( ltid );
305                 ltid = NULL;
306                 op->o_private = NULL;
307                 op->o_do_not_cache = opinfo.boi_acl_cache;
308                 if( rs->sr_err != 0 ) {
309                         rs->sr_err = LDAP_OTHER;
310                         rs->sr_text = "internal error";
311                         goto return_results;
312                 }
313                 ldap_pvt_thread_yield();
314                 bdb_trans_backoff( ++num_retries );
315         }
316
317         /* begin transaction */
318         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, NULL, &ltid, 
319                 bdb->bi_db_opflags );
320         rs->sr_text = NULL;
321         if( rs->sr_err != 0 ) {
322                 Debug( LDAP_DEBUG_TRACE,
323                         LDAP_XSTRING(bdb_modify) ": txn_begin failed: "
324                         "%s (%d)\n", db_strerror(rs->sr_err), rs->sr_err, 0 );
325                 rs->sr_err = LDAP_OTHER;
326                 rs->sr_text = "internal error";
327                 goto return_results;
328         }
329
330         locker = TXN_ID ( ltid );
331
332         opinfo.boi_bdb = op->o_bd;
333         opinfo.boi_txn = ltid;
334         opinfo.boi_locker = locker;
335         opinfo.boi_err = 0;
336         opinfo.boi_acl_cache = op->o_do_not_cache;
337         op->o_private = &opinfo;
338
339         /* get entry or ancestor */
340         rs->sr_err = bdb_dn2entry( op, ltid, &op->o_req_ndn, &ei, 1,
341                 locker, &lock );
342
343         e = ei->bei_e;
344
345         if ( rs->sr_err != 0 ) {
346                 Debug( LDAP_DEBUG_TRACE,
347                         LDAP_XSTRING(bdb_modify) ": dn2entry failed (%d)\n",
348                         rs->sr_err, 0, 0 );
349                 switch( rs->sr_err ) {
350                 case DB_LOCK_DEADLOCK:
351                 case DB_LOCK_NOTGRANTED:
352                         goto retry;
353                 case DB_NOTFOUND:
354                         if ( BER_BVISEMPTY( &op->o_req_ndn )) {
355                                 struct berval ocbva[] = {
356                                         BER_BVC("locality"),
357                                         BER_BVC("syncProviderSubentry"),
358                                         BER_BVNULL
359                                 };
360                                 e = ch_calloc( 1, sizeof(Entry));
361                                 e->e_name.bv_val = ch_strdup( "" );
362                                 ber_dupbv( &e->e_nname, &e->e_name );
363                                 attr_merge( e, slap_schema.si_ad_objectClass, ocbva, NULL );
364                                 attr_merge_one( e, slap_schema.si_ad_structuralObjectClass,
365                                         &ocbva[0], NULL );
366                                 e->e_private = ei;
367                                 fakeroot = 1;
368                                 rs->sr_err = 0;
369                         }
370                         break;
371                 case LDAP_BUSY:
372                         rs->sr_text = "ldap server busy";
373                         goto return_results;
374                 default:
375                         rs->sr_err = LDAP_OTHER;
376                         rs->sr_text = "internal error";
377                         goto return_results;
378                 }
379         }
380
381         /* acquire and lock entry */
382         /* FIXME: dn2entry() should return non-glue entry */
383         if (( rs->sr_err == DB_NOTFOUND ) ||
384                 ( !manageDSAit && e && is_entry_glue( e )))
385         {
386                 if ( e != NULL ) {
387                         rs->sr_matched = ch_strdup( e->e_dn );
388                         rs->sr_ref = is_entry_referral( e )
389                                 ? get_entry_referrals( op, e )
390                                 : NULL;
391                         bdb_unlocked_cache_return_entry_r (&bdb->bi_cache, e);
392                         e = NULL;
393
394                 } else {
395                         rs->sr_ref = referral_rewrite( default_referral, NULL,
396                                 &op->o_req_dn, LDAP_SCOPE_DEFAULT );
397                 }
398
399                 rs->sr_err = LDAP_REFERRAL;
400                 send_ldap_result( op, rs );
401
402                 if ( rs->sr_ref != default_referral ) {
403                         ber_bvarray_free( rs->sr_ref );
404                 }
405                 free( (char *)rs->sr_matched );
406                 rs->sr_ref = NULL;
407                 rs->sr_matched = NULL;
408
409                 goto done;
410         }
411
412         if ( !manageDSAit && is_entry_referral( e ) ) {
413                 /* entry is a referral, don't allow modify */
414                 rs->sr_ref = get_entry_referrals( op, e );
415
416                 Debug( LDAP_DEBUG_TRACE,
417                         LDAP_XSTRING(bdb_modify) ": entry is referral\n",
418                         0, 0, 0 );
419
420                 rs->sr_err = LDAP_REFERRAL;
421                 rs->sr_matched = e->e_name.bv_val;
422                 send_ldap_result( op, rs );
423
424                 ber_bvarray_free( rs->sr_ref );
425                 rs->sr_ref = NULL;
426                 rs->sr_matched = NULL;
427                 goto done;
428         }
429
430         if ( get_assert( op ) &&
431                 ( test_filter( op, e, get_assertion( op )) != LDAP_COMPARE_TRUE ))
432         {
433                 rs->sr_err = LDAP_ASSERTION_FAILED;
434                 goto return_results;
435         }
436
437         if( op->o_preread ) {
438                 if( preread_ctrl == NULL ) {
439                         preread_ctrl = &ctrls[num_ctrls++];
440                         ctrls[num_ctrls] = NULL;
441                 }
442                 if ( slap_read_controls( op, rs, e,
443                         &slap_pre_read_bv, preread_ctrl ) )
444                 {
445                         Debug( LDAP_DEBUG_TRACE,
446                                 "<=- " LDAP_XSTRING(bdb_modify) ": pre-read failed!\n",
447                                 0, 0, 0 );
448                         goto return_results;
449                 }
450         }
451
452         /* nested transaction */
453         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, ltid, &lt2, bdb->bi_db_opflags );
454         rs->sr_text = NULL;
455         if( rs->sr_err != 0 ) {
456                 Debug( LDAP_DEBUG_TRACE,
457                         LDAP_XSTRING(bdb_modify) ": txn_begin(2) failed: " "%s (%d)\n",
458                         db_strerror(rs->sr_err), rs->sr_err, 0 );
459                 rs->sr_err = LDAP_OTHER;
460                 rs->sr_text = "internal error";
461                 goto return_results;
462         }
463         /* Modify the entry */
464         dummy = *e;
465         rs->sr_err = bdb_modify_internal( op, lt2, op->oq_modify.rs_modlist,
466                 &dummy, &rs->sr_text, textbuf, textlen );
467
468         if( rs->sr_err != LDAP_SUCCESS ) {
469                 Debug( LDAP_DEBUG_TRACE,
470                         LDAP_XSTRING(bdb_modify) ": modify failed (%d)\n",
471                         rs->sr_err, 0, 0 );
472                 if ( (rs->sr_err == LDAP_INSUFFICIENT_ACCESS) && opinfo.boi_err ) {
473                         rs->sr_err = opinfo.boi_err;
474                 }
475                 /* Only free attrs if they were dup'd.  */
476                 if ( dummy.e_attrs == e->e_attrs ) dummy.e_attrs = NULL;
477                 switch( rs->sr_err ) {
478                 case DB_LOCK_DEADLOCK:
479                 case DB_LOCK_NOTGRANTED:
480                         goto retry;
481                 }
482                 goto return_results;
483         }
484
485         /* change the entry itself */
486         rs->sr_err = bdb_id2entry_update( op->o_bd, lt2, &dummy );
487         if ( rs->sr_err != 0 ) {
488                 Debug( LDAP_DEBUG_TRACE,
489                         LDAP_XSTRING(bdb_modify) ": id2entry update failed " "(%d)\n",
490                         rs->sr_err, 0, 0 );
491                 switch( rs->sr_err ) {
492                 case DB_LOCK_DEADLOCK:
493                 case DB_LOCK_NOTGRANTED:
494                         goto retry;
495                 }
496                 rs->sr_text = "entry update failed";
497                 goto return_results;
498         }
499
500         if ( TXN_COMMIT( lt2, 0 ) != 0 ) {
501                 rs->sr_err = LDAP_OTHER;
502                 rs->sr_text = "txn_commit(2) failed";
503                 goto return_results;
504         }
505
506         if( op->o_postread ) {
507                 if( postread_ctrl == NULL ) {
508                         postread_ctrl = &ctrls[num_ctrls++];
509                         ctrls[num_ctrls] = NULL;
510                 }
511                 if( slap_read_controls( op, rs, &dummy,
512                         &slap_post_read_bv, postread_ctrl ) )
513                 {
514                         Debug( LDAP_DEBUG_TRACE,
515                                 "<=- " LDAP_XSTRING(bdb_modify)
516                                 ": post-read failed!\n", 0, 0, 0 );
517                         goto return_results;
518                 }
519         }
520
521         if( op->o_noop ) {
522                 if ( ( rs->sr_err = TXN_ABORT( ltid ) ) != 0 ) {
523                         rs->sr_text = "txn_abort (no-op) failed";
524                 } else {
525                         rs->sr_err = LDAP_NO_OPERATION;
526                         goto return_results;
527                 }
528         } else {
529                 /* may have changed in bdb_modify_internal() */
530                 e->e_ocflags = dummy.e_ocflags;
531                 if ( fakeroot ) {
532                         e->e_private = NULL;
533                         entry_free( e );
534                 } else {
535                         rc = bdb_cache_modify( e, dummy.e_attrs, bdb->bi_dbenv, locker, &lock );
536                         switch( rc ) {
537                         case DB_LOCK_DEADLOCK:
538                         case DB_LOCK_NOTGRANTED:
539                                 goto retry;
540                         }
541                 }
542                 dummy.e_attrs = NULL;
543
544                 rs->sr_err = TXN_COMMIT( ltid, 0 );
545         }
546         ltid = NULL;
547         op->o_private = NULL;
548
549         if( rs->sr_err != 0 ) {
550                 Debug( LDAP_DEBUG_TRACE,
551                         LDAP_XSTRING(bdb_modify) ": txn_%s failed: %s (%d)\n",
552                         op->o_noop ? "abort (no-op)" : "commit",
553                         db_strerror(rs->sr_err), rs->sr_err );
554                 rs->sr_err = LDAP_OTHER;
555                 rs->sr_text = "commit failed";
556
557                 goto return_results;
558         }
559
560         Debug( LDAP_DEBUG_TRACE,
561                 LDAP_XSTRING(bdb_modify) ": updated%s id=%08lx dn=\"%s\"\n",
562                 op->o_noop ? " (no-op)" : "",
563                 dummy.e_id, op->o_req_dn.bv_val );
564
565         rs->sr_err = LDAP_SUCCESS;
566         rs->sr_text = NULL;
567         if( num_ctrls ) rs->sr_ctrls = ctrls;
568
569 return_results:
570         if( dummy.e_attrs ) {
571                 attrs_free( dummy.e_attrs );
572         }
573         send_ldap_result( op, rs );
574
575         if( rs->sr_err == LDAP_SUCCESS && bdb->bi_txn_cp ) {
576                 ldap_pvt_thread_yield();
577                 TXN_CHECKPOINT( bdb->bi_dbenv,
578                         bdb->bi_txn_cp_kbyte, bdb->bi_txn_cp_min, 0 );
579         }
580
581 done:
582         if( ltid != NULL ) {
583                 TXN_ABORT( ltid );
584                 op->o_private = NULL;
585         }
586
587         if( e != NULL ) {
588                 bdb_unlocked_cache_return_entry_w (&bdb->bi_cache, e);
589         }
590
591         if( preread_ctrl != NULL ) {
592                 slap_sl_free( (*preread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx );
593                 slap_sl_free( *preread_ctrl, op->o_tmpmemctx );
594         }
595         if( postread_ctrl != NULL ) {
596                 slap_sl_free( (*postread_ctrl)->ldctl_value.bv_val, op->o_tmpmemctx );
597                 slap_sl_free( *postread_ctrl, op->o_tmpmemctx );
598         }
599         return rs->sr_err;
600 }