]> git.sur5r.net Git - openldap/blob - servers/slapd/back-bdb/delete.c
misc updates
[openldap] / servers / slapd / back-bdb / delete.c
1 /* delete.c - bdb backend delete routine */
2 /* $OpenLDAP$ */
3 /*
4  * Copyright 1998-2003 The OpenLDAP Foundation, All Rights Reserved.
5  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
6  */
7
8 #include "portable.h"
9
10 #include <stdio.h>
11 #include <ac/string.h>
12
13 #include "back-bdb.h"
14 #include "external.h"
15
16 int
17 bdb_delete( Operation *op, SlapReply *rs )
18 {
19         struct bdb_info *bdb = (struct bdb_info *) op->o_bd->be_private;
20         Entry   *matched = NULL;
21         struct berval   pdn = {0, NULL};
22         Entry   *e = NULL;
23         Entry   *p = NULL;
24         EntryInfo       *ei = NULL, *eip = NULL;
25         int             manageDSAit = get_manageDSAit( op );
26         AttributeDescription *children = slap_schema.si_ad_children;
27         AttributeDescription *entry = slap_schema.si_ad_entry;
28         DB_TXN          *ltid = NULL, *lt2;
29         struct bdb_op_info opinfo;
30
31         u_int32_t       locker = 0;
32         DB_LOCK         lock, plock;
33
34         int             noop = 0;
35
36         int             num_retries = 0;
37
38         Operation* ps_list;
39         int     rc;
40         EntryInfo   *suffix_ei;
41         Entry       *ctxcsn_e;
42         int         ctxcsn_added = 0;
43
44         LDAPControl *ctrls[SLAP_MAX_RESPONSE_CONTROLS];
45         int num_ctrls = 0;
46
47 #ifdef NEW_LOGGING
48         LDAP_LOG ( OPERATION, ARGS,  "==> bdb_delete: %s\n", op->o_req_dn.bv_val, 0, 0 );
49 #else
50         Debug( LDAP_DEBUG_ARGS, "==> bdb_delete: %s\n",
51                 op->o_req_dn.bv_val, 0, 0 );
52 #endif
53
54         if( 0 ) {
55 retry:  /* transaction retry */
56                 if( e != NULL ) {
57                         bdb_unlocked_cache_return_entry_w(&bdb->bi_cache, e);
58                         e = NULL;
59                 }
60 #ifdef NEW_LOGGING
61                 LDAP_LOG ( OPERATION, DETAIL1, 
62                         "==> bdb_delete: retrying...\n", 0, 0, 0 );
63 #else
64                 Debug( LDAP_DEBUG_TRACE, "==> bdb_delete: retrying...\n",
65                         0, 0, 0 );
66 #endif
67                 rs->sr_err = TXN_ABORT( ltid );
68                 ltid = NULL;
69                 op->o_private = NULL;
70                 op->o_do_not_cache = opinfo.boi_acl_cache;
71                 if( rs->sr_err != 0 ) {
72                         rs->sr_err = LDAP_OTHER;
73                         rs->sr_text = "internal error";
74                         goto return_results;
75                 }
76                 ldap_pvt_thread_yield();
77                 bdb_trans_backoff( ++num_retries );
78         }
79
80         /* begin transaction */
81         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, NULL, &ltid, 
82                 bdb->bi_db_opflags );
83         rs->sr_text = NULL;
84         if( rs->sr_err != 0 ) {
85 #ifdef NEW_LOGGING
86                 LDAP_LOG ( OPERATION, ERR, 
87                         "==> bdb_delete: txn_begin failed: %s (%d)\n",
88                         db_strerror(rs->sr_err), rs->sr_err, 0 );
89 #else
90                 Debug( LDAP_DEBUG_TRACE,
91                         "bdb_delete: txn_begin failed: %s (%d)\n",
92                         db_strerror(rs->sr_err), rs->sr_err, 0 );
93 #endif
94                 rs->sr_err = LDAP_OTHER;
95                 rs->sr_text = "internal error";
96                 goto return_results;
97         }
98
99         locker = TXN_ID ( ltid );
100
101         opinfo.boi_bdb = op->o_bd;
102         opinfo.boi_txn = ltid;
103         opinfo.boi_locker = locker;
104         opinfo.boi_err = 0;
105         opinfo.boi_acl_cache = op->o_do_not_cache;
106         op->o_private = &opinfo;
107
108         if ( !be_issuffix( op->o_bd, &op->o_req_ndn ) ) {
109                 dnParent( &op->o_req_ndn, &pdn );
110         }
111
112         /* get entry */
113         rs->sr_err = bdb_dn2entry( op, ltid, &op->o_req_ndn, &ei, 1,
114                 locker, &lock );
115
116         switch( rs->sr_err ) {
117         case 0:
118         case DB_NOTFOUND:
119                 break;
120         case DB_LOCK_DEADLOCK:
121         case DB_LOCK_NOTGRANTED:
122                 goto retry;
123         case LDAP_BUSY:
124                 rs->sr_text = "ldap server busy";
125                 goto return_results;
126         default:
127                 rs->sr_err = LDAP_OTHER;
128                 rs->sr_text = "internal error";
129                 goto return_results;
130         }
131
132         if ( rs->sr_err == 0 ) {
133                 e = ei->bei_e;
134                 eip = ei->bei_parent;
135                 bdb_cache_find_id( op, ltid, eip->bei_id, &eip,
136                         0, locker, &plock );
137         } else {
138                 matched = ei->bei_e;
139         }
140         if ( eip ) {
141                 p = eip->bei_e;
142         }
143
144         if ( pdn.bv_len != 0 ) {
145                 if( p == NULL || !bvmatch( &pdn, &p->e_nname )) {
146 #ifdef NEW_LOGGING
147                         LDAP_LOG ( OPERATION, DETAIL1, 
148                                 "<=- bdb_delete: parent does not exist\n", 0, 0, 0 );
149 #else
150                         Debug( LDAP_DEBUG_TRACE,
151                                 "<=- bdb_delete: parent does not exist\n",
152                                 0, 0, 0);
153 #endif
154                         rs->sr_err = LDAP_OTHER;
155                         rs->sr_text = "could not locate parent of entry";
156                         goto return_results;
157                 }
158
159                 /* check parent for "children" acl */
160                 rs->sr_err = access_allowed( op, p,
161                         children, NULL, ACL_WRITE, NULL );
162
163                 bdb_unlocked_cache_return_entry_r(&bdb->bi_cache, p);
164                 p = NULL;
165
166                 if ( !rs->sr_err  ) {
167                         switch( opinfo.boi_err ) {
168                         case DB_LOCK_DEADLOCK:
169                         case DB_LOCK_NOTGRANTED:
170                                 goto retry;
171                         }
172
173 #ifdef NEW_LOGGING
174                         LDAP_LOG ( OPERATION, DETAIL1, 
175                                 "<=- bdb_delete: no write access to parent\n", 0, 0, 0 );
176 #else
177                         Debug( LDAP_DEBUG_TRACE,
178                                 "<=- bdb_delete: no write access to parent\n",
179                                 0, 0, 0 );
180 #endif
181                         rs->sr_err = LDAP_INSUFFICIENT_ACCESS;
182                         rs->sr_text = "no write access to parent";
183                         goto return_results;
184                 }
185
186         } else {
187                 /* no parent, must be root to delete */
188                 if( ! be_isroot( op->o_bd, &op->o_ndn ) ) {
189                         if ( be_issuffix( op->o_bd, (struct berval *)&slap_empty_bv )
190                                 || be_isupdate( op->o_bd, &op->o_ndn ) ) {
191                                 p = (Entry *)&slap_entry_root;
192
193                                 /* check parent for "children" acl */
194                                 rs->sr_err = access_allowed( op, p,
195                                         children, NULL, ACL_WRITE, NULL );
196
197                                 p = NULL;
198
199                                 if ( !rs->sr_err  ) {
200                                         switch( opinfo.boi_err ) {
201                                         case DB_LOCK_DEADLOCK:
202                                         case DB_LOCK_NOTGRANTED:
203                                                 goto retry;
204                                         }
205
206 #ifdef NEW_LOGGING
207                                         LDAP_LOG ( OPERATION, DETAIL1, 
208                                                 "<=- bdb_delete: no access to parent\n", 0, 0, 0 );
209 #else
210                                         Debug( LDAP_DEBUG_TRACE,
211                                                 "<=- bdb_delete: no access "
212                                                 "to parent\n", 0, 0, 0 );
213 #endif
214                                         rs->sr_err = LDAP_INSUFFICIENT_ACCESS;
215                                         rs->sr_text = "no write access to parent";
216                                         goto return_results;
217                                 }
218
219                         } else {
220 #ifdef NEW_LOGGING
221                                 LDAP_LOG ( OPERATION, DETAIL1, 
222                                         "<=- bdb_delete: no parent and not root\n", 0, 0, 0 );
223 #else
224                                 Debug( LDAP_DEBUG_TRACE,
225                                         "<=- bdb_delete: no parent "
226                                         "and not root\n", 0, 0, 0);
227 #endif
228                                 rs->sr_err = LDAP_INSUFFICIENT_ACCESS;
229                                 goto return_results;
230                         }
231                 }
232         }
233
234         /* FIXME : dn2entry() should return non-glue entry */
235         if ( e == NULL || ( !manageDSAit && is_entry_glue( e ))) {
236 #ifdef NEW_LOGGING
237                 LDAP_LOG ( OPERATION, ARGS, 
238                         "<=- bdb_delete: no such object %s\n", op->o_req_dn.bv_val, 0, 0);
239 #else
240                 Debug( LDAP_DEBUG_ARGS,
241                         "<=- bdb_delete: no such object %s\n",
242                         op->o_req_dn.bv_val, 0, 0);
243 #endif
244
245                 if ( matched != NULL ) {
246                         rs->sr_matched = ch_strdup( matched->e_dn );
247                         rs->sr_ref = is_entry_referral( matched )
248                                 ? get_entry_referrals( op, matched )
249                                 : NULL;
250                         bdb_unlocked_cache_return_entry_r(&bdb->bi_cache, matched);
251                         matched = NULL;
252
253                 } else {
254                         BerVarray deref = NULL;
255                         if ( !LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) {
256                                 syncinfo_t *si;
257                                 LDAP_STAILQ_FOREACH( si, &op->o_bd->be_syncinfo, si_next ) {
258                                         struct berval tmpbv;
259                                         ber_dupbv( &tmpbv, &si->si_provideruri_bv[0] );
260                                         ber_bvarray_add( &deref, &tmpbv );
261                                 }
262                         } else {
263                                 deref = default_referral;
264                         }
265                         rs->sr_ref = referral_rewrite( deref, NULL, &op->o_req_dn,
266                                 LDAP_SCOPE_DEFAULT );
267                 }
268
269                 rs->sr_err = LDAP_REFERRAL;
270                 send_ldap_result( op, rs );
271
272                 if ( rs->sr_ref != default_referral ) {
273                         ber_bvarray_free( rs->sr_ref );
274                 }
275                 free( (char *)rs->sr_matched );
276                 rs->sr_ref = NULL;
277                 rs->sr_matched = NULL;
278
279                 rs->sr_err = -1;
280                 goto done;
281         }
282
283         if ( get_assert( op ) &&
284                 ( test_filter( op, e, get_assertion( op )) != LDAP_COMPARE_TRUE ))
285         {
286                 rs->sr_err = LDAP_ASSERTION_FAILED;
287                 goto return_results;
288         }
289
290         rs->sr_err = access_allowed( op, e,
291                 entry, NULL, ACL_WRITE, NULL );
292
293         if ( !rs->sr_err  ) {
294                 switch( opinfo.boi_err ) {
295                 case DB_LOCK_DEADLOCK:
296                 case DB_LOCK_NOTGRANTED:
297                         goto retry;
298                 }
299
300 #ifdef NEW_LOGGING
301                 LDAP_LOG ( OPERATION, DETAIL1, 
302                         "<=- bdb_delete: no write access to entry\n", 0, 0, 0 );
303 #else
304                 Debug( LDAP_DEBUG_TRACE,
305                         "<=- bdb_delete: no write access to entry\n",
306                         0, 0, 0 );
307 #endif
308                 rs->sr_err = LDAP_INSUFFICIENT_ACCESS;
309                 rs->sr_text = "no write access to entry";
310                 goto return_results;
311         }
312
313         if ( !manageDSAit && is_entry_referral( e ) ) {
314                 /* entry is a referral, don't allow delete */
315                 rs->sr_ref = get_entry_referrals( op, e );
316
317 #ifdef NEW_LOGGING
318                 LDAP_LOG ( OPERATION, DETAIL1, 
319                         "<=- bdb_delete: entry is referral\n", 0, 0, 0 );
320 #else
321                 Debug( LDAP_DEBUG_TRACE,
322                         "bdb_delete: entry is referral\n", 0, 0, 0 );
323 #endif
324
325                 rs->sr_err = LDAP_REFERRAL;
326                 rs->sr_matched = e->e_name.bv_val;
327                 send_ldap_result( op, rs );
328
329                 ber_bvarray_free( rs->sr_ref );
330                 rs->sr_ref = NULL;
331                 rs->sr_matched = NULL;
332
333                 rs->sr_err = 1;
334                 goto done;
335         }
336
337         /* pre-read */
338         if( op->o_preread ) {
339                 if( slap_read_controls( op, rs, e,
340                         &slap_pre_read_bv, &ctrls[num_ctrls] ) )
341                 {
342 #ifdef NEW_LOGGING
343                         LDAP_LOG ( OPERATION, DETAIL1, 
344                                 "<=- bdb_delete: pre-read failed!\n", 0, 0, 0 );
345 #else
346                         Debug( LDAP_DEBUG_TRACE,
347                                 "<=- bdb_delete: pre-read failed!\n", 0, 0, 0 );
348 #endif
349                         goto return_results;
350                 }
351                 ctrls[++num_ctrls] = NULL;
352         }
353
354         /* nested transaction */
355         rs->sr_err = TXN_BEGIN( bdb->bi_dbenv, ltid, &lt2, 
356                 bdb->bi_db_opflags );
357         rs->sr_text = NULL;
358         if( rs->sr_err != 0 ) {
359 #ifdef NEW_LOGGING
360                 LDAP_LOG ( OPERATION, ERR, 
361                         "bdb_delete: txn_begin(2) failed: %s (%d)\n", db_strerror(rs->sr_err), rs->sr_err, 0 );
362 #else
363                 Debug( LDAP_DEBUG_TRACE,
364                         "bdb_delete: txn_begin(2) failed: %s (%d)\n",
365                         db_strerror(rs->sr_err), rs->sr_err, 0 );
366 #endif
367                 rs->sr_err = LDAP_OTHER;
368                 rs->sr_text = "internal error";
369                 goto return_results;
370         }
371
372         /* Can't do it if we have kids */
373         rs->sr_err = bdb_cache_children( op, lt2, e );
374         if( rs->sr_err != DB_NOTFOUND ) {
375                 switch( rs->sr_err ) {
376                 case DB_LOCK_DEADLOCK:
377                 case DB_LOCK_NOTGRANTED:
378                         goto retry;
379                 case 0:
380 #ifdef NEW_LOGGING
381                         LDAP_LOG ( OPERATION, DETAIL1, 
382                                 "<=- bdb_delete: non-leaf %s\n", op->o_req_dn.bv_val, 0, 0 );
383 #else
384                         Debug(LDAP_DEBUG_ARGS,
385                                 "<=- bdb_delete: non-leaf %s\n",
386                                 op->o_req_dn.bv_val, 0, 0);
387 #endif
388                         rs->sr_err = LDAP_NOT_ALLOWED_ON_NONLEAF;
389                         rs->sr_text = "subtree delete not supported";
390                         break;
391                 default:
392 #ifdef NEW_LOGGING
393                         LDAP_LOG ( OPERATION, ERR, 
394                                 "<=- bdb_delete: has_children failed %s (%d)\n",
395                                 db_strerror(rs->sr_err), rs->sr_err, 0 );
396 #else
397                         Debug(LDAP_DEBUG_ARGS,
398                                 "<=- bdb_delete: has_children failed: %s (%d)\n",
399                                 db_strerror(rs->sr_err), rs->sr_err, 0 );
400 #endif
401                         rs->sr_err = LDAP_OTHER;
402                         rs->sr_text = "internal error";
403                 }
404                 goto return_results;
405         }
406
407         /* delete from dn2id */
408         rs->sr_err = bdb_dn2id_delete( op, lt2, eip, e );
409         if ( rs->sr_err != 0 ) {
410 #ifdef NEW_LOGGING
411                 LDAP_LOG ( OPERATION, ERR, 
412                         "<=- bdb_delete: dn2id failed: %s (%d)\n",
413                         db_strerror(rs->sr_err), rs->sr_err, 0 );
414 #else
415                 Debug(LDAP_DEBUG_TRACE,
416                         "<=- bdb_delete: dn2id failed: %s (%d)\n",
417                         db_strerror(rs->sr_err), rs->sr_err, 0 );
418 #endif
419                 switch( rs->sr_err ) {
420                 case DB_LOCK_DEADLOCK:
421                 case DB_LOCK_NOTGRANTED:
422                         goto retry;
423                 }
424                 rs->sr_text = "DN index delete failed";
425                 rs->sr_err = LDAP_OTHER;
426                 goto return_results;
427         }
428
429         /* delete from id2entry */
430         rs->sr_err = bdb_id2entry_delete( op->o_bd, lt2, e );
431         if ( rs->sr_err != 0 ) {
432 #ifdef NEW_LOGGING
433                 LDAP_LOG ( OPERATION, ERR, 
434                         "<=- bdb_delete: id2entry failed: %s (%d)\n", 
435                         db_strerror(rs->sr_err), rs->sr_err, 0 );
436 #else
437                 Debug(LDAP_DEBUG_TRACE,
438                         "<=- bdb_delete: id2entry failed: %s (%d)\n",
439                         db_strerror(rs->sr_err), rs->sr_err, 0 );
440 #endif
441                 switch( rs->sr_err ) {
442                 case DB_LOCK_DEADLOCK:
443                 case DB_LOCK_NOTGRANTED:
444                         goto retry;
445                 }
446                 rs->sr_text = "entry delete failed";
447                 rs->sr_err = LDAP_OTHER;
448                 goto return_results;
449         }
450
451         /* delete indices for old attributes */
452         rs->sr_err = bdb_index_entry_del( op, lt2, e );
453         if ( rs->sr_err != LDAP_SUCCESS ) {
454 #ifdef NEW_LOGGING
455                 LDAP_LOG ( OPERATION, ERR, 
456                         "<=- bdb_delete: index failed: %s (%d)\n", 
457                         db_strerror(rs->sr_err), rs->sr_err, 0 );
458 #else
459                 Debug( LDAP_DEBUG_TRACE,
460                         "<=- bdb_delete: index failed: %s (%d)\n", 
461                         db_strerror(rs->sr_err), rs->sr_err, 0 );
462 #endif
463                 switch( rs->sr_err ) {
464                 case DB_LOCK_DEADLOCK:
465                 case DB_LOCK_NOTGRANTED:
466                         goto retry;
467                 }
468                 rs->sr_text = "entry index delete failed";
469                 rs->sr_err = LDAP_OTHER;
470                 goto return_results;
471         }
472         if ( TXN_COMMIT( lt2, 0 ) != 0 ) {
473                 rs->sr_err = LDAP_OTHER;
474                 rs->sr_text = "txn_commit(2) failed";
475                 goto return_results;
476         }
477
478 #if 0   /* Do we want to reclaim deleted IDs? */
479         ldap_pvt_thread_mutex_lock( &bdb->bi_lastid_mutex );
480         if ( e->e_id == bdb->bi_lastid ) {
481                 bdb_last_id( op->o_bd, ltid );
482         }
483         ldap_pvt_thread_mutex_unlock( &bdb->bi_lastid_mutex );
484 #endif
485
486         if ( LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) {
487                 rc = bdb_csn_commit( op, rs, ltid, ei, &suffix_ei,
488                         &ctxcsn_e, &ctxcsn_added, locker );
489                 switch ( rc ) {
490                 case BDB_CSN_ABORT :
491                         goto return_results;
492                 case BDB_CSN_RETRY :
493                         goto retry;
494                 }
495         }
496
497         if( op->o_noop ) {
498                 if ( ( rs->sr_err = TXN_ABORT( ltid ) ) != 0 ) {
499                         rs->sr_text = "txn_abort (no-op) failed";
500                 } else {
501                         noop = 1;
502                         rs->sr_err = LDAP_SUCCESS;
503                 }
504         } else {
505                 bdb_cache_delete( &bdb->bi_cache, e, bdb->bi_dbenv,
506                         locker, &lock );
507
508                 if ( LDAP_STAILQ_EMPTY( &op->o_bd->be_syncinfo )) {
509                         if ( ctxcsn_added ) {
510                                 bdb_cache_add( bdb, suffix_ei,
511                                         ctxcsn_e, (struct berval *)&slap_ldapsync_cn_bv, locker );
512                         }
513                 }
514
515                 rs->sr_err = TXN_COMMIT( ltid, 0 );
516         }
517         ltid = NULL;
518         op->o_private = NULL;
519
520         if( rs->sr_err != 0 ) {
521 #ifdef NEW_LOGGING
522                 LDAP_LOG ( OPERATION, ERR, 
523                         "bdb_delete: txn_%s failed: %s (%d)\n",
524                         op->o_noop ? "abort (no-op)" : "commit", db_strerror(rs->sr_err), rs->sr_err );
525 #else
526                 Debug( LDAP_DEBUG_TRACE,
527                         "bdb_delete: txn_%s failed: %s (%d)\n",
528                         op->o_noop ? "abort (no-op)" : "commit",
529                         db_strerror(rs->sr_err), rs->sr_err );
530 #endif
531                 rs->sr_err = LDAP_OTHER;
532                 rs->sr_text = "commit failed";
533
534                 goto return_results;
535         }
536
537 #ifdef NEW_LOGGING
538         LDAP_LOG ( OPERATION, RESULTS, 
539                 "bdb_delete: deleted%s id=%08lx db=\"%s\"\n",
540                 op->o_noop ? " (no-op)" : "", e->e_id, e->e_dn );
541 #else
542         Debug( LDAP_DEBUG_TRACE,
543                 "bdb_delete: deleted%s id=%08lx dn=\"%s\"\n",
544                 op->o_noop ? " (no-op)" : "",
545                 e->e_id, e->e_dn );
546 #endif
547         rs->sr_err = LDAP_SUCCESS;
548         rs->sr_text = NULL;
549         if( num_ctrls ) rs->sr_ctrls = ctrls;
550
551 return_results:
552         send_ldap_result( op, rs );
553
554         if ( rs->sr_err == LDAP_SUCCESS && !noop && !op->o_no_psearch ) {
555                 LDAP_LIST_FOREACH( ps_list, &bdb->bi_psearch_list, o_ps_link ) {
556                         bdb_psearch( op, rs, ps_list, e, LDAP_PSEARCH_BY_DELETE );
557                 }
558         }
559
560         if(rs->sr_err == LDAP_SUCCESS && bdb->bi_txn_cp ) {
561                 ldap_pvt_thread_yield();
562                 TXN_CHECKPOINT( bdb->bi_dbenv,
563                         bdb->bi_txn_cp_kbyte, bdb->bi_txn_cp_min, 0 );
564         }
565
566 done:
567         /* free entry */
568         if( e != NULL ) {
569                 if ( rs->sr_err == LDAP_SUCCESS ) {
570                         /* Free the EntryInfo and the Entry */
571                         bdb_cache_delete_cleanup( &bdb->bi_cache, e );
572                 } else {
573                         bdb_unlocked_cache_return_entry_w(&bdb->bi_cache, e);
574                 }
575         }
576
577         if( ltid != NULL ) {
578                 TXN_ABORT( ltid );
579                 op->o_private = NULL;
580         }
581
582         return ( ( rs->sr_err == LDAP_SUCCESS ) ? noop : rs->sr_err );
583 }