X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=servers%2Fslapd%2Fattr.c;h=9f90dd58b33055f7026b68a4418f09b6f166d4a2;hb=b74b7c232d9d02e9c20d7144c6cbe17f93cf0d5b;hp=5cf97ec67e6d00f63af0ef264ac3918605a57e53;hpb=43f0177a08d32c10c60d3aee57b9aa94f8ec2936;p=openldap diff --git a/servers/slapd/attr.c b/servers/slapd/attr.c index 5cf97ec67e..9f90dd58b3 100644 --- a/servers/slapd/attr.c +++ b/servers/slapd/attr.c @@ -2,7 +2,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 1998-2006 The OpenLDAP Foundation. + * Copyright 1998-2009 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -124,7 +124,7 @@ attrs_alloc( int num ) void -attr_free( Attribute *a ) +attr_clean( Attribute *a ) { if ( a->a_nvals && a->a_nvals != a->a_vals && !( a->a_flags & SLAP_ATTR_DONT_FREE_VALS )) { @@ -146,7 +146,20 @@ attr_free( Attribute *a ) ber_bvarray_free( a->a_vals ); } } - memset( a, 0, sizeof( Attribute )); + a->a_desc = NULL; + a->a_vals = NULL; + a->a_nvals = NULL; +#ifdef LDAP_COMP_MATCH + a->a_comp_data = NULL; +#endif + a->a_flags = 0; + a->a_numvals = 0; +} + +void +attr_free( Attribute *a ) +{ + attr_clean( a ); ldap_pvt_thread_mutex_lock( &attr_mutex ); a->a_next = attr_list; attr_list = a; @@ -173,27 +186,38 @@ comp_tree_free( Attribute *a ) void attrs_free( Attribute *a ) { - Attribute *next; - - for( ; a != NULL ; a = next ) { - next = a->a_next; - attr_free( a ); + if ( a ) { + Attribute *b = (Attribute *)0xBAD, *tail, *next; + + /* save tail */ + tail = a; + do { + next = a->a_next; + attr_clean( a ); + a->a_next = b; + b = a; + a = next; + } while ( next ); + + ldap_pvt_thread_mutex_lock( &attr_mutex ); + /* replace NULL with current attr list and let attr list + * start from last attribute returned to list */ + tail->a_next = attr_list; + attr_list = b; + ldap_pvt_thread_mutex_unlock( &attr_mutex ); } } - static void attr_dup2( Attribute *tmp, Attribute *a ) { + tmp->a_flags = a->a_flags & SLAP_ATTR_PERSISTENT_FLAGS; if ( a->a_vals != NULL ) { - int i; + unsigned i, j; - for ( i = 0; !BER_BVISNULL( &a->a_vals[i] ); i++ ) { - /* EMPTY */ ; - } - - tmp->a_vals = ch_malloc( (i + 1) * sizeof(struct berval) ); - for ( i = 0; !BER_BVISNULL( &a->a_vals[i] ); i++ ) { + tmp->a_numvals = a->a_numvals; + tmp->a_vals = ch_malloc( (tmp->a_numvals + 1) * sizeof(struct berval) ); + for ( i = 0; i < tmp->a_numvals; i++ ) { ber_dupbv( &tmp->a_vals[i], &a->a_vals[i] ); if ( BER_BVISNULL( &tmp->a_vals[i] ) ) break; /* FIXME: error? */ @@ -204,9 +228,8 @@ attr_dup2( Attribute *tmp, Attribute *a ) assert( a->a_nvals != NULL ); if ( a->a_nvals != a->a_vals ) { - int j; - tmp->a_nvals = ch_malloc( (i + 1) * sizeof(struct berval) ); + tmp->a_nvals = ch_malloc( (tmp->a_numvals + 1) * sizeof(struct berval) ); for ( j = 0; !BER_BVISNULL( &a->a_nvals[j] ); j++ ) { assert( j < i ); ber_dupbv( &tmp->a_nvals[j], &a->a_nvals[j] ); @@ -258,6 +281,161 @@ attrs_dup( Attribute *a ) return anew; } +int +attr_valfind( + Attribute *a, + unsigned flags, + struct berval *val, + unsigned *slot, + void *ctx ) +{ + struct berval nval = BER_BVNULL, *cval; + MatchingRule *mr; + const char *text; + int match = -1, rc; + unsigned i; + + if ( flags & SLAP_MR_ORDERING ) + mr = a->a_desc->ad_type->sat_ordering; + else + mr = a->a_desc->ad_type->sat_equality; + + if( !SLAP_IS_MR_ASSERTED_VALUE_NORMALIZED_MATCH( flags ) && + mr->smr_normalize ) + { + rc = (mr->smr_normalize)( + flags & (SLAP_MR_TYPE_MASK|SLAP_MR_SUBTYPE_MASK|SLAP_MR_VALUE_OF_SYNTAX), + a->a_desc->ad_type->sat_syntax, + mr, val, &nval, ctx ); + + if( rc != LDAP_SUCCESS ) { + return LDAP_INVALID_SYNTAX; + } + cval = &nval; + } else { + cval = val; + } + + if ( a->a_flags & SLAP_ATTR_SORTED_VALS ) { + /* Binary search */ + unsigned base = 0, n = a->a_numvals; + + while ( 0 < n ) { + unsigned pivot = n >> 1; + i = base + pivot; + rc = value_match( &match, a->a_desc, mr, flags, + &a->a_nvals[i], cval, &text ); + if ( rc == LDAP_SUCCESS && match == 0 ) + break; + if ( match < 0 ) { + base = i+1; + n -= pivot+1; + } else { + n = pivot; + } + } + if ( match < 0 ) + i++; + } else { + /* Linear search */ + for ( i = 0; i < a->a_numvals; i++ ) { + const char *text; + + rc = ordered_value_match( &match, a->a_desc, mr, flags, + &a->a_nvals[i], cval, &text ); + if ( rc == LDAP_SUCCESS && match == 0 ) + break; + } + } + if ( slot ) + *slot = i; + if ( match ) + rc = LDAP_NO_SUCH_ATTRIBUTE; + if ( nval.bv_val ) + slap_sl_free( nval.bv_val, ctx ); + + return rc; +} + +int +attr_valadd( + Attribute *a, + BerVarray vals, + BerVarray nvals, + int nn ) +{ + int i; + BerVarray v2; + + v2 = (BerVarray) SLAP_REALLOC( (char *) a->a_vals, + (a->a_numvals + nn + 1) * sizeof(struct berval) ); + if( v2 == NULL ) { + Debug(LDAP_DEBUG_TRACE, + "attr_valadd: SLAP_REALLOC failed.\n", 0, 0, 0 ); + return LBER_ERROR_MEMORY; + } + a->a_vals = v2; + if ( nvals ) { + v2 = (BerVarray) SLAP_REALLOC( (char *) a->a_nvals, + (a->a_numvals + nn + 1) * sizeof(struct berval) ); + if( v2 == NULL ) { + Debug(LDAP_DEBUG_TRACE, + "attr_valadd: SLAP_REALLOC failed.\n", 0, 0, 0 ); + return LBER_ERROR_MEMORY; + } + a->a_nvals = v2; + } else { + a->a_nvals = a->a_vals; + } + + /* If sorted and old vals exist, must insert */ + if (( a->a_flags & SLAP_ATTR_SORTED_VALS ) && a->a_numvals ) { + unsigned slot; + int j, rc; + v2 = nvals ? nvals : vals; + for ( i = 0; i < nn; i++ ) { + rc = attr_valfind( a, SLAP_MR_EQUALITY | SLAP_MR_VALUE_OF_ASSERTION_SYNTAX | + SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH | SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH, + &v2[i], &slot, NULL ); + if ( rc != LDAP_NO_SUCH_ATTRIBUTE ) { + /* should never happen */ + if ( rc == LDAP_SUCCESS ) + rc = LDAP_TYPE_OR_VALUE_EXISTS; + return rc; + } + for ( j = a->a_numvals; j >= (int)slot; j-- ) { + a->a_vals[j+1] = a->a_vals[j]; + if ( nvals ) + a->a_nvals[j+1] = a->a_nvals[j]; + } + ber_dupbv( &a->a_nvals[slot], &v2[i] ); + if ( nvals ) + ber_dupbv( &a->a_vals[slot], &vals[i] ); + a->a_numvals++; + } + BER_BVZERO( &a->a_vals[a->a_numvals] ); + if ( a->a_vals != a->a_nvals ) + BER_BVZERO( &a->a_nvals[a->a_numvals] ); + } else { + v2 = &a->a_vals[a->a_numvals]; + for ( i = 0 ; i < nn; i++ ) { + ber_dupbv( &v2[i], &vals[i] ); + if ( BER_BVISNULL( &v2[i] ) ) break; + } + BER_BVZERO( &v2[i] ); + + if ( nvals ) { + v2 = &a->a_nvals[a->a_numvals]; + for ( i = 0 ; i < nn; i++ ) { + ber_dupbv( &v2[i], &nvals[i] ); + if ( BER_BVISNULL( &v2[i] ) ) break; + } + BER_BVZERO( &v2[i] ); + } + a->a_numvals += i; + } + return 0; +} /* * attr_merge - merge the given type and value with the list of @@ -277,7 +455,7 @@ attr_merge( BerVarray vals, BerVarray nvals ) { - int rc; + int i = 0; Attribute **a; @@ -300,18 +478,10 @@ attr_merge( || ( (*a)->a_nvals != (*a)->a_vals ) ) ) ); } - rc = value_add( &(*a)->a_vals, vals ); - - if ( rc == LDAP_SUCCESS ) { - if ( nvals ) { - rc = value_add( &(*a)->a_nvals, nvals ); - /* FIXME: what if rc != LDAP_SUCCESS ? */ - } else { - (*a)->a_nvals = (*a)->a_vals; - } + if ( vals != NULL ) { + for ( ; !BER_BVISNULL( &vals[i] ); i++ ) ; } - - return rc; + return attr_valadd( *a, vals, nvals, i ); } /* @@ -355,7 +525,6 @@ attr_normalize( *nvalsp = nvals; } -error_return:; if ( rc != LDAP_SUCCESS && nvals != NULL ) { ber_bvarray_free_x( nvals, memctx ); } @@ -391,7 +560,6 @@ attr_merge_one( struct berval *val, struct berval *nval ) { - int rc; Attribute **a; for ( a = &e->e_attrs; *a != NULL; a = &(*a)->a_next ) { @@ -404,17 +572,7 @@ attr_merge_one( *a = attr_alloc( desc ); } - rc = value_add_one( &(*a)->a_vals, val ); - - if ( rc == LDAP_SUCCESS ) { - if ( nval ) { - rc = value_add_one( &(*a)->a_nvals, nval ); - /* FIXME: what if rc != LDAP_SUCCESS ? */ - } else { - (*a)->a_nvals = (*a)->a_vals; - } - } - return rc; + return attr_valadd( *a, val, nval, 1 ); } /*