X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fback-bdb%2Fsearch.c;h=34197d090b9f921cd8b33dfae5cb49bbc909fe27;hb=0006ec0a46790567d3d49fcafce5ffaae08cdbf4;hp=4b0a7ef670d2b93cf5f2be4821824c93b4f08d00;hpb=61a15be30a64e79667f96c0998f5f507254fd751;p=openldap diff --git a/servers/slapd/back-bdb/search.c b/servers/slapd/back-bdb/search.c index 4b0a7ef670..34197d090b 100644 --- a/servers/slapd/back-bdb/search.c +++ b/servers/slapd/back-bdb/search.c @@ -1,7 +1,7 @@ /* search.c - search operation */ /* $OpenLDAP$ */ /* - * Copyright 1998-2000 The OpenLDAP Foundation, All Rights Reserved. + * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved. * COPYING RESTRICTIONS APPLY, see COPYRIGHT file */ @@ -11,143 +11,249 @@ #include #include "back-bdb.h" +#include "idl.h" +#include "external.h" static int base_candidate( - Backend *be, + BackendDB *be, Entry *e, ID *ids ); -int search_candidates(); - -static ID idl_first( ID *ids, ID *cursor ); -static ID idl_next( ID *ids, ID *cursor ); +static int search_candidates( + BackendDB *be, + Operation *op, + Entry *e, + Filter *filter, + int scope, + int deref, + ID *ids ); int bdb_search( - Backend *be, - Connection *conn, - Operation *op, - const char *base, - const char *nbase, - int scope, - int deref, - int slimit, - int tlimit, - Filter *filter, - const char *filterstr, - char **attrs, - int attrsonly ) + BackendDB *be, + Connection *conn, + Operation *op, + struct berval *base, + struct berval *nbase, + int scope, + int deref, + int slimit, + int tlimit, + Filter *filter, + struct berval *filterstr, + AttributeName *attrs, + int attrsonly ) { - int abandon; struct bdb_info *bdb = (struct bdb_info *) be->be_private; - int rc, err; + int abandon; + int rc; const char *text = NULL; time_t stoptime; - ID candidates[BDB_IDL_SIZE]; ID id, cursor; + ID candidates[BDB_IDL_UM_SIZE]; Entry *e = NULL; - struct berval **v2refs = NULL; + BerVarray v2refs = NULL; Entry *matched = NULL; - char *realbase = NULL; + struct berval realbase = { 0, NULL }; int nentries = 0; - int manageDSAit = get_manageDSAit( op ); + int manageDSAit; + + struct slap_limits_set *limit = NULL; + int isroot = 0; + + Debug( LDAP_DEBUG_TRACE, "=> bdb_back_search\n", + 0, 0, 0); - Debug(LDAP_DEBUG_TRACE, "=> ldbm_back_search\n", 0, 0, 0); + manageDSAit = get_manageDSAit( op ); - /* obtain entry */ - rc = dn2entry_r( be, NULL, nbase, &e, &matched ); + if ( nbase->bv_len == 0 ) { + /* DIT root special case */ + e = (Entry *) &slap_entry_root; + rc = 0; + } else +#ifdef BDB_ALIASES + /* get entry with reader lock */ + if ( deref & LDAP_DEREF_FINDING ) { + e = deref_dn_r( be, nbase-, &err, &matched, &text ); + + } else +#endif + { + rc = bdb_dn2entry_r( be, NULL, nbase, &e, &matched, 0 ); + } switch(rc) { case DB_NOTFOUND: case 0: break; default: + if (e != NULL) { + bdb_cache_return_entry_w(&bdb->bi_cache, e); + } + if (matched != NULL) { + bdb_cache_return_entry_r(&bdb->bi_cache, matched); + } send_ldap_result( conn, op, rc=LDAP_OTHER, - NULL, "internal error", NULL, NULL ); + NULL, "internal error", NULL, NULL ); return rc; } if ( e == NULL ) { - char *matched_dn = NULL; - struct berval **refs = NULL; + struct berval matched_dn = { 0, NULL }; + BerVarray refs = NULL; if ( matched != NULL ) { - matched_dn = ch_strdup( matched->e_dn ); + BerVarray erefs; - refs = is_entry_referral( matched ) + ber_dupbv( &matched_dn, &matched->e_name ); + + erefs = is_entry_referral( matched ) ? get_entry_referrals( be, conn, op, matched ) : NULL; - } else { - refs = default_referral; - } + bdb_cache_return_entry_r (&bdb->bi_cache, matched); + matched = NULL; - send_ldap_result( conn, op, err, - matched_dn, text, refs, NULL ); + if( erefs ) { + refs = referral_rewrite( erefs, &matched_dn, + base, scope ); + ber_bvarray_free( erefs ); + } - if( matched != NULL ) { - ber_bvecfree( refs ); - free( matched_dn ); - bdb_entry_return( be, matched ); + } else { + refs = referral_rewrite( default_referral, + NULL, base, scope ); } - return 1; + send_ldap_result( conn, op, rc=LDAP_REFERRAL , + matched_dn.bv_val, text, refs, NULL ); + + if ( refs ) ber_bvarray_free( refs ); + if ( matched_dn.bv_val ) ber_memfree( matched_dn.bv_val ); + return rc; } - if (!manageDSAit && is_entry_referral( e ) ) { + if (!manageDSAit && e != &slap_entry_root && is_entry_referral( e ) ) { /* entry is a referral, don't allow add */ - char *matched_dn = ch_strdup( e->e_dn ); - struct berval **refs = get_entry_referrals( be, - conn, op, e ); - - bdb_entry_return( be, e ); + struct berval matched_dn; + BerVarray erefs, refs; + + ber_dupbv( &matched_dn, &e->e_name ); + erefs = get_entry_referrals( be, conn, op, e ); + refs = NULL; + + bdb_cache_return_entry_r( &bdb->bi_cache, e ); + e = NULL; + + if( erefs ) { + refs = referral_rewrite( erefs, &matched_dn, + base, scope ); + ber_bvarray_free( erefs ); + } Debug( LDAP_DEBUG_TRACE, "bdb_search: entry is referral\n", 0, 0, 0 ); send_ldap_result( conn, op, LDAP_REFERRAL, - matched_dn, NULL, refs, NULL ); - - ber_bvecfree( refs ); - free( matched_dn ); + matched_dn.bv_val, + refs ? NULL : "bad referral object", + refs, NULL ); + ber_bvarray_free( refs ); + ber_memfree( matched_dn.bv_val ); return 1; } - if ( is_entry_alias( e ) ) { - /* don't deref */ - deref = LDAP_DEREF_NEVER; - } - - if ( tlimit == 0 && be_isroot( be, op->o_ndn ) ) { - tlimit = -1; /* allow root to set no limit */ + /* if not root, get appropriate limits */ + if ( be_isroot( be, &op->o_ndn ) ) { + isroot = 1; } else { - tlimit = (tlimit > be->be_timelimit || tlimit < 1) ? - be->be_timelimit : tlimit; - stoptime = op->o_time + tlimit; + ( void ) get_limits( be, &op->o_ndn, &limit ); } - if ( slimit == 0 && be_isroot( be, op->o_ndn ) ) { - slimit = -1; /* allow root to set no limit */ + /* The time/size limits come first because they require very little + * effort, so there's no chance the candidates are selected and then + * the request is not honored only because of time/size constraints */ + + /* if no time limit requested, use soft limit (unless root!) */ + if ( isroot ) { + if ( tlimit == 0 ) { + tlimit = -1; /* allow root to set no limit */ + } + + if ( slimit == 0 ) { + slimit = -1; + } + } else { - slimit = (slimit > be->be_sizelimit || slimit < 1) ? - be->be_sizelimit : slimit; + /* if no limit is required, use soft limit */ + if ( tlimit <= 0 ) { + tlimit = limit->lms_t_soft; + + /* if requested limit higher than hard limit, abort */ + } else if ( tlimit > limit->lms_t_hard ) { + /* no hard limit means use soft instead */ + if ( limit->lms_t_hard == 0 ) { + tlimit = limit->lms_t_soft; + + /* positive hard limit means abort */ + } else if ( limit->lms_t_hard > 0 ) { + send_search_result( conn, op, + LDAP_UNWILLING_TO_PERFORM, + NULL, NULL, NULL, NULL, 0 ); + rc = 0; + goto done; + } + + /* negative hard limit means no limit */ + } + + /* if no limit is required, use soft limit */ + if ( slimit <= 0 ) { + slimit = limit->lms_s_soft; + + /* if requested limit higher than hard limit, abort */ + } else if ( slimit > limit->lms_s_hard ) { + /* no hard limit means use soft instead */ + if ( limit->lms_s_hard == 0 ) { + slimit = limit->lms_s_soft; + + /* positive hard limit means abort */ + } else if ( limit->lms_s_hard > 0 ) { + send_search_result( conn, op, + LDAP_UNWILLING_TO_PERFORM, + NULL, NULL, NULL, NULL, 0 ); + rc = 0; + goto done; + } + + /* negative hard limit means no limit */ + } } + /* compute it anyway; root does not use it */ + stoptime = op->o_time + tlimit; + + /* select candidates */ if ( scope == LDAP_SCOPE_BASE ) { rc = base_candidate( be, e, candidates ); } else { - rc = search_candidates( be, e, filter, - scope, deref, manageDSAit, candidates ); + BDB_IDL_ALL( bdb, candidates ); + rc = search_candidates( be, op, e, filter, + scope, deref, candidates ); } /* need normalized dn below */ - realbase = ch_strdup( e->e_ndn ); + ber_dupbv( &realbase, &e->e_nname ); - /* start cursor at base entry's id */ - cursor = e->e_id; + /* start cursor at base entry's id + * FIXME: hack to make "" base work */ + cursor = e->e_id == NOID ? 1 : e->e_id; - bdb_entry_return( be, e ); + if ( e != &slap_entry_root ) { + bdb_cache_return_entry_r(&bdb->bi_cache, e); + } + e = NULL; if ( candidates[0] == 0 ) { Debug( LDAP_DEBUG_TRACE, "bdb_search: no candidates\n", @@ -161,9 +267,20 @@ bdb_search( goto done; } - for ( id = idl_first( candidates, &cursor ); + /* if not root and candidates exceed to-be-checked entries, abort */ + if ( !isroot && limit->lms_s_unchecked != -1 ) { + if ( BDB_IDL_N(candidates) > (unsigned) limit->lms_s_unchecked ) { + send_search_result( conn, op, + LDAP_UNWILLING_TO_PERFORM, + NULL, NULL, NULL, NULL, 0 ); + rc = 1; + goto done; + } + } + + for ( id = bdb_idl_first( candidates, &cursor ); id != NOID; - id = idl_next( candidates, &cursor ) ) + id = bdb_idl_next( candidates, &cursor ) ) { int scopeok = 0; @@ -179,23 +296,47 @@ bdb_search( /* check time limit */ if ( tlimit != -1 && slap_get_time() > stoptime ) { - send_search_result( conn, op, LDAP_TIMELIMIT_EXCEEDED, + send_search_result( conn, op, rc = LDAP_TIMELIMIT_EXCEEDED, NULL, NULL, v2refs, NULL, nentries ); - rc = 0; goto done; } /* get the entry with reader lock */ - rc = bdb_id2entry( be, NULL, id, &e ); + rc = bdb_id2entry_r( be, NULL, id, &e ); if ( e == NULL ) { - Debug( LDAP_DEBUG_TRACE, - "bdb_search: candidate %ld not found\n", - id, 0, 0 ); + if( !BDB_IDL_IS_RANGE(candidates) ) { + /* only complain for non-range IDLs */ + Debug( LDAP_DEBUG_TRACE, + "bdb_search: candidate %ld not found\n", + (long) id, 0, 0 ); + } + + goto loop_continue; + } + +#ifdef BDB_SUBENTRIES + if ( is_entry_subentry( e ) ) { + if( scope != LDAP_SCOPE_BASE ) { + if(!get_subentries_visibility( op )) { + /* only subentries are visible */ + goto loop_continue; + } + } else if ( get_subentries( op ) && + !get_subentries_visibility( op )) + { + /* only subentries are visible */ + goto loop_continue; + } + + } else if ( get_subentries_visibility( op )) { + /* only subentries are visible */ goto loop_continue; } +#endif +#ifdef BDB_ALIASES if ( deref & LDAP_DEREF_SEARCHING && is_entry_alias( e ) ) { Entry *matched; int err; @@ -215,16 +356,14 @@ bdb_search( /* need to skip alias which deref into scope */ if( scope & LDAP_SCOPE_ONELEVEL ) { - char *pdn = dn_parent( NULL, e->e_ndn ); - if ( pdn != NULL ) { - if( strcmp( pdn, realbase ) ) { - free( pdn ); - goto loop_continue; - } - free(pdn); + struct berval pdn; + + dnParent( &e->e_nname, &pdn ): + if ( ber_bvcmp( pdn, &realbase ) ) { + goto loop_continue; } - } else if ( dn_issuffix( e->e_ndn, realbase ) ) { + } else if ( dnIsSuffix( &e->e_nname, &realbase ) ) { /* alias is within scope */ Debug( LDAP_DEBUG_TRACE, "bdb_search: \"%s\" in subtree\n", @@ -234,6 +373,7 @@ bdb_search( scopeok = 1; } +#endif /* * if it's a referral, add it to the list of referrals. only do @@ -243,38 +383,38 @@ bdb_search( if ( !manageDSAit && scope != LDAP_SCOPE_BASE && is_entry_referral( e ) ) { - struct berval **refs = get_entry_referrals( + BerVarray erefs = get_entry_referrals( be, conn, op, e ); + BerVarray refs = referral_rewrite( erefs, + &e->e_name, NULL, + scope == LDAP_SCOPE_SUBTREE + ? LDAP_SCOPE_SUBTREE + : LDAP_SCOPE_BASE ); send_search_reference( be, conn, op, - e, refs, scope, NULL, &v2refs ); + e, refs, NULL, &v2refs ); - ber_bvecfree( refs ); + ber_bvarray_free( refs ); goto loop_continue; } /* if it matches the filter and scope, send it */ - if ( test_filter( be, conn, op, e, filter ) == LDAP_COMPARE_TRUE ) { - char *dn; + rc = test_filter( be, conn, op, e, filter ); + if ( rc == LDAP_COMPARE_TRUE ) { + struct berval dn; /* check scope */ if ( !scopeok && scope == LDAP_SCOPE_ONELEVEL ) { - if ( (dn = dn_parent( be, e->e_ndn )) != NULL ) { - (void) dn_normalize( dn ); - scopeok = (dn == realbase) - ? 1 - : (strcmp( dn, realbase ) ? 0 : 1 ); - free( dn ); - + if ( be_issuffix( be, &e->e_nname ) ) { + scopeok = (realbase.bv_len == 0); } else { - scopeok = (realbase == NULL || *realbase == '\0'); + dnParent( &e->e_nname, &dn ); + scopeok = dn_match( &dn, &realbase ); } } else if ( !scopeok && scope == LDAP_SCOPE_SUBTREE ) { - dn = ch_strdup( e->e_ndn ); - scopeok = dn_issuffix( dn, realbase ); - free( dn ); + scopeok = dnIsSuffix( &e->e_nname, &realbase ); } else { scopeok = 1; @@ -283,17 +423,23 @@ bdb_search( if ( scopeok ) { /* check size limit */ if ( --slimit == -1 ) { - bdb_entry_return( be, e ); + bdb_cache_return_entry_r (&bdb->bi_cache, e); + e = NULL; send_search_result( conn, op, - LDAP_SIZELIMIT_EXCEEDED, NULL, NULL, + rc = LDAP_SIZELIMIT_EXCEEDED, NULL, NULL, v2refs, NULL, nentries ); - rc = 0; goto done; } if (e) { - int result = send_search_entry( be, conn, op, - e, attrs, attrsonly, NULL); + int result; + + if( op->o_noop ) { + result = 0; + } else { + result = send_search_entry( be, conn, op, + e, attrs, attrsonly, NULL); + } switch (result) { case 0: /* entry sent ok */ @@ -302,26 +448,28 @@ bdb_search( case 1: /* entry not sent */ break; case -1: /* connection closed */ - bdb_entry_return( be, e ); - rc = 0; + bdb_cache_return_entry_r(&bdb->bi_cache, e); + e = NULL; + rc = LDAP_OTHER; goto done; } } } else { Debug( LDAP_DEBUG_TRACE, "bdb_search: %ld scope not okay\n", - id, 0, 0 ); + (long) id, 0, 0 ); } } else { Debug( LDAP_DEBUG_TRACE, "bdb_search: %ld does match filter\n", - id, 0, 0 ); + (long) id, 0, 0 ); } loop_continue: if( e != NULL ) { /* free reader lock */ - bdb_entry_return( be, e ); + bdb_cache_return_entry_r ( &bdb->bi_cache, e ); + e = NULL; } ldap_pvt_thread_yield(); @@ -333,19 +481,24 @@ loop_continue: rc = 0; done: - ber_bvecfree( v2refs ); - if( realbase ) free( realbase ); + if( e != NULL ) { + /* free reader lock */ + bdb_cache_return_entry_r ( &bdb->bi_cache, e ); + } + + if( v2refs ) ber_bvarray_free( v2refs ); + if( realbase.bv_val ) ch_free( realbase.bv_val ); return rc; } static int base_candidate( - Backend *be, + BackendDB *be, Entry *e, ID *ids ) { - Debug(LDAP_DEBUG_TRACE, "base_candidates: base: \"%s\" (0x08lx)\n", + Debug(LDAP_DEBUG_ARGS, "base_candidates: base: \"%s\" (0x%08lx)\n", e->e_dn, (long) e->e_id, 0); ids[0] = 1; @@ -353,42 +506,132 @@ static int base_candidate( return 0; } -static ID idl_first( ID *ids, ID *cursor ) +/* Is "objectClass=xx" mentioned anywhere in this filter? Presence + * doesn't count, we're looking for explicit values. + */ +static int oc_filter( + Filter *f +) { - ID pos; + int rc = 0; - if ( ids[0] == 0 ) { - *cursor = NOID; - return NOID; - } - - if ( BDB_IS_ALLIDS( ids ) ) { - return *cursor; - } + switch(f->f_choice) { + case LDAP_FILTER_EQUALITY: + case LDAP_FILTER_APPROX: + if (f->f_av_desc == slap_schema.si_ad_objectClass) + rc = 1; + break; - pos = bdb_idl_search( ids, *cursor ); + case LDAP_FILTER_SUBSTRINGS: + if (f->f_sub_desc == slap_schema.si_ad_objectClass) + rc = 1; + break; - if( pos > ids[0] ) { - return NOID; + case LDAP_FILTER_AND: + case LDAP_FILTER_OR: + for (f=f->f_and; f; f=f->f_next) + if ((rc = oc_filter(f))) + break; + break; + default: + break; } - - *cursor = pos; - return ids[pos]; + return rc; } -static ID idl_next( ID *ids, ID *cursor ) +static int search_candidates( + BackendDB *be, + Operation *op, + Entry *e, + Filter *filter, + int scope, + int deref, + ID *ids ) { - if ( BDB_IS_ALLIDS( ids ) ) { - if( ++(*cursor) < ids[1] ) { - return *cursor; + int rc; + Filter f, scopef, rf, xf; + ID tmp[BDB_IDL_UM_SIZE]; + AttributeAssertion aa_ref; +#ifdef BDB_SUBENTRIES + Filter sf; + AttributeAssertion aa_subentry; +#endif +#ifdef BDB_ALIASES + Filter af; + AttributeAssertion aa_alias; +#endif + struct bdb_info *bdb = (struct bdb_info *) be->be_private; + + /* + * This routine takes as input a filter (user-filter) + * and rewrites it as follows: + * (&(scope=DN)[(objectClass=subentry)] + * (|[(objectClass=referral)(objectClass=alias)](user-filter)) + */ + + Debug(LDAP_DEBUG_TRACE, + "search_candidates: base=\"%s\" (0x%08lx) scope=%d\n", + e->e_dn, (long) e->e_id, scope ); + + xf.f_or = filter; + xf.f_choice = LDAP_FILTER_OR; + xf.f_next = NULL; + + /* If the user's filter doesn't mention objectClass, or if + * it just uses objectClass=*, these clauses are redundant. + */ + if (oc_filter(filter) && !get_subentries_visibility(op) ) { + if( !get_manageDSAit(op) ) { /* match referrals */ + struct berval bv_ref = { sizeof("REFERRAL")-1, "REFERRAL" }; + rf.f_choice = LDAP_FILTER_EQUALITY; + rf.f_ava = &aa_ref; + rf.f_av_desc = slap_schema.si_ad_objectClass; + rf.f_av_value = bv_ref; + rf.f_next = xf.f_or; + xf.f_or = &rf; + } + +#ifdef BDB_ALIASES + if( deref & LDAP_DEREF_SEARCHING ) { /* match aliases */ + struct berval bv_alias = { sizeof("ALIAS")-1, "ALIAS" }; + af.f_choice = LDAP_FILTER_EQUALITY; + af.f_ava = &aa_alias; + af.f_av_desc = slap_schema.si_ad_objectClass; + af.f_av_value = bv_alias; + af.f_next = xf.f_or; + xf.f_or = ⁡ } - return NOID; +#endif } - if ( *cursor < ids[0] ) { - return ids[(*cursor)++]; + f.f_next = NULL; + f.f_choice = LDAP_FILTER_AND; + f.f_and = &scopef; + scopef.f_choice = scope == LDAP_SCOPE_SUBTREE + ? SLAPD_FILTER_DN_SUBTREE + : SLAPD_FILTER_DN_ONE; + scopef.f_dn = &e->e_nname; + scopef.f_next = xf.f_or == filter ? filter : &xf ; + +#ifdef BDB_SUBENTRIES + if( get_subentries_visibility( op ) ) { + struct berval bv_subentry = { sizeof("SUBENTRY")-1, "SUBENTRY" }; + sf.f_choice = LDAP_FILTER_EQUALITY; + sf.f_ava = &aa_subentry; + sf.f_av_desc = slap_schema.si_ad_objectClass; + sf.f_av_value = bv_subentry; + sf.f_next = scopef.f_next; + scopef.f_next = &sf; } +#endif - return NOID; -} + rc = bdb_filter_candidates( be, &f, ids, tmp ); + + Debug(LDAP_DEBUG_TRACE, + "bdb_search_candidates: id=%ld first=%ld last=%ld\n", + (long) ids[0], + (long) BDB_IDL_FIRST(ids), + (long) BDB_IDL_LAST(ids) ); + return rc; +}