X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fsets.c;h=82c1831c4a645347a9e54ba4489143d81906b973;hb=b60644a07fc620d8e1f367e828355e6babc8d44f;hp=128000cdb11cd4126bb03f28a8c65b017a6e0a5e;hpb=2f6f6f6a0758a57d5ab5e76e7f6ecfc3fc0ee09d;p=openldap diff --git a/servers/slapd/sets.c b/servers/slapd/sets.c index 128000cdb1..82c1831c4a 100644 --- a/servers/slapd/sets.c +++ b/servers/slapd/sets.c @@ -1,7 +1,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 2000-2004 The OpenLDAP Foundation. + * Copyright 2000-2006 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -31,129 +31,288 @@ slap_set_size( BerVarray set ) i = 0; if ( set != NULL ) { - while ( !BER_BVISNULL( &set[i] ) ) { + while ( !BER_BVISNULL( &set[ i ] ) ) { i++; } } return i; } +static int +slap_set_isempty( BerVarray set ) +{ + if ( set == NULL ) { + return 1; + } + + if ( !BER_BVISNULL( &set[ 0 ] ) ) { + return 0; + } + + return 1; +} + static void -slap_set_dispose( SetCookie *cp, BerVarray set ) +slap_set_dispose( SetCookie *cp, BerVarray set, unsigned flags ) { - ber_bvarray_free_x(set, cp->op->o_tmpmemctx); + if ( flags & SLAP_SET_REFVAL ) { + if ( ! ( flags & SLAP_SET_REFARR ) ) { + cp->set_op->o_tmpfree( set, cp->set_op->o_tmpmemctx ); + } + + } else { + ber_bvarray_free_x( set, cp->set_op->o_tmpmemctx ); + } +} + +static BerVarray +set_dup( SetCookie *cp, BerVarray set, unsigned flags ) +{ + BerVarray newset = NULL; + + if ( set == NULL ) { + return NULL; + } + + if ( flags & SLAP_SET_REFARR ) { + int i; + + for ( i = 0; !BER_BVISNULL( &set[ i ] ); i++ ) + ; + newset = cp->set_op->o_tmpcalloc( i + 1, + sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + if ( newset == NULL ) { + return NULL; + } + + if ( flags & SLAP_SET_REFVAL ) { + for ( i = 0; !BER_BVISNULL( &set[ i ] ); i++ ) { + ber_dupbv_x( &newset[ i ], &set[ i ], + cp->set_op->o_tmpmemctx ); + } + + } else { + AC_MEMCPY( newset, set, ( i + 1 ) * sizeof( struct berval ) ); + } + + } else { + newset = set; + } + + return newset; } BerVarray -slap_set_join (SetCookie *cp, BerVarray lset, int op, BerVarray rset) +slap_set_join( + SetCookie *cp, + BerVarray lset, + unsigned op_flags, + BerVarray rset ) { - BerVarray set; - long i, j, last; + BerVarray set; + long i, j, last; + unsigned op = ( op_flags & SLAP_SET_OPMASK ); set = NULL; - if (op == '|') { - if (lset == NULL || lset->bv_val == NULL) { - if (rset == NULL) { - if (lset == NULL) - return(cp->op->o_tmpcalloc(1, sizeof(struct berval), - cp->op->o_tmpmemctx)); - return(lset); + switch ( op ) { + case '|': /* union */ + if ( lset == NULL || BER_BVISNULL( lset ) ) { + if ( rset == NULL ) { + if ( lset == NULL ) { + set = cp->set_op->o_tmpcalloc( 1, + sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + BER_BVZERO( set ); + return set; + } + return set_dup( cp, lset, SLAP_SET_LREF2REF( op_flags ) ); } - slap_set_dispose(cp, lset); - return(rset); + slap_set_dispose( cp, lset, SLAP_SET_LREF2REF( op_flags ) ); + return set_dup( cp, rset, SLAP_SET_RREF2REF( op_flags ) ); } - if (rset == NULL || rset->bv_val == NULL) { - slap_set_dispose(cp, rset); - return(lset); + if ( rset == NULL || BER_BVISNULL( rset ) ) { + slap_set_dispose( cp, rset, SLAP_SET_RREF2REF( op_flags ) ); + return set_dup( cp, lset, SLAP_SET_LREF2REF( op_flags ) ); } - i = slap_set_size(lset) + slap_set_size(rset) + 1; - set = cp->op->o_tmpcalloc(i, sizeof(struct berval), cp->op->o_tmpmemctx); - if (set != NULL) { + i = slap_set_size( lset ) + slap_set_size( rset ) + 1; + set = cp->set_op->o_tmpcalloc( i, sizeof( struct berval ), cp->set_op->o_tmpmemctx ); + if ( set != NULL ) { /* set_chase() depends on this routine to * keep the first elements of the result * set the same (and in the same order) * as the left-set. */ - for (i = 0; lset[i].bv_val; i++) - set[i] = lset[i]; - cp->op->o_tmpfree(lset, cp->op->o_tmpmemctx); - for (i = 0; rset[i].bv_val; i++) { - for (j = 0; set[j].bv_val; j++) { - if ( dn_match( &rset[i], &set[j] ) ) + for ( i = 0; !BER_BVISNULL( &lset[ i ] ); i++ ) { + if ( op_flags & SLAP_SET_LREFVAL ) { + ber_dupbv_x( &set[ i ], &lset[ i ], cp->set_op->o_tmpmemctx ); + + } else { + set[ i ] = lset[ i ]; + } + } + + last = i; + + for ( i = 0; !BER_BVISNULL( &rset[ i ] ); i++ ) { + int exists = 0; + + for ( j = 0; !BER_BVISNULL( &set[ j ] ); j++ ) { + if ( bvmatch( &rset[ i ], &set[ j ] ) ) { - cp->op->o_tmpfree(rset[i].bv_val, cp->op->o_tmpmemctx); - rset[i].bv_val = NULL; + if ( !( op_flags & SLAP_SET_RREFVAL ) ) { + cp->set_op->o_tmpfree( rset[ i ].bv_val, cp->set_op->o_tmpmemctx ); + BER_BVZERO( &rset[ i ] ); + } + exists = 1; break; } } - if (rset[i].bv_val) - set[j] = rset[i]; + + if ( !exists ) { + if ( op_flags & SLAP_SET_RREFVAL ) { + ber_dupbv_x( &set[ last ], &rset[ i ], cp->set_op->o_tmpmemctx ); + + } else { + set[ last ] = rset[ i ]; + } + last++; + } } - cp->op->o_tmpfree(rset, cp->op->o_tmpmemctx); + BER_BVZERO( &set[ last ] ); } - return(set); - } + break; + + case '&': /* intersection */ + if ( lset == NULL || BER_BVISNULL( lset ) + || rset == NULL || BER_BVISNULL( rset ) ) + { + set = cp->set_op->o_tmpcalloc( 1, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + BER_BVZERO( set ); - if (op == '&') { - if (lset == NULL || lset->bv_val == NULL || rset == NULL || rset->bv_val == NULL) { - set = cp->op->o_tmpcalloc(1, sizeof(struct berval), cp->op->o_tmpmemctx); } else { - set = lset; + set = set_dup( cp, lset, SLAP_SET_LREF2REF( op_flags ) ); + if ( set == NULL ) { + break; + } lset = NULL; - last = slap_set_size(set) - 1; - for (i = 0; set[i].bv_val; i++) { - for (j = 0; rset[j].bv_val; j++) { - if ( dn_match( &set[i], &rset[j] ) ) { + last = slap_set_size( set ) - 1; + for ( i = 0; !BER_BVISNULL( &set[ i ] ); i++ ) { + for ( j = 0; !BER_BVISNULL( &rset[ j ] ); j++ ) { + if ( bvmatch( &set[ i ], &rset[ j ] ) ) { break; } } - if (rset[j].bv_val == NULL) { - cp->op->o_tmpfree(set[i].bv_val, cp->op->o_tmpmemctx); - set[i] = set[last]; - set[last].bv_val = NULL; + + if ( BER_BVISNULL( &rset[ j ] ) ) { + cp->set_op->o_tmpfree( set[ i ].bv_val, cp->set_op->o_tmpmemctx ); + set[ i ] = set[ last ]; + BER_BVZERO( &set[ last ] ); last--; i--; } } } + break; + + case '+': /* string concatenation */ + i = slap_set_size( rset ); + j = slap_set_size( lset ); + + set = cp->set_op->o_tmpcalloc( i * j + 1, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + if ( set == NULL ) { + break; + } + + for ( last = 0, i = 0; !BER_BVISNULL( &lset[ i ] ); i++ ) { + for ( j = 0; !BER_BVISNULL( &rset[ j ] ); j++ ) { + struct berval bv; + long k; + + bv.bv_len = lset[ i ].bv_len + rset[ j ].bv_len; + bv.bv_val = cp->set_op->o_tmpalloc( bv.bv_len + 1, + cp->set_op->o_tmpmemctx ); + if ( bv.bv_val == NULL ) { + slap_set_dispose( cp, set, 0 ); + set = NULL; + goto done; + } + AC_MEMCPY( bv.bv_val, lset[ i ].bv_val, lset[ i ].bv_len ); + AC_MEMCPY( &bv.bv_val[ lset[ i ].bv_len ], rset[ j ].bv_val, rset[ j ].bv_len ); + bv.bv_val[ bv.bv_len ] = '\0'; + + for ( k = 0; k < last; k++ ) { + if ( bvmatch( &set[ k ], &bv ) ) { + cp->set_op->o_tmpfree( bv.bv_val, cp->set_op->o_tmpmemctx ); + break; + } + } + + if ( k == last ) { + set[ last++ ] = bv; + } + } + } + BER_BVZERO( &set[ last ] ); + break; + + default: + break; } - slap_set_dispose(cp, lset); - slap_set_dispose(cp, rset); - return(set); +done:; + if ( !( op_flags & SLAP_SET_LREFARR ) && lset != NULL ) { + if ( !( op_flags & SLAP_SET_LREFVAL )) + cp->set_op->o_tmpfree( lset->bv_val, cp->set_op->o_tmpmemctx ); + cp->set_op->o_tmpfree( lset, cp->set_op->o_tmpmemctx ); + } + + if ( !( op_flags & SLAP_SET_RREFARR ) && rset != NULL ) { + if ( !( op_flags & SLAP_SET_RREFVAL )) + cp->set_op->o_tmpfree( rset->bv_val, cp->set_op->o_tmpmemctx ); + cp->set_op->o_tmpfree( rset, cp->set_op->o_tmpmemctx ); + } + + return set; } static BerVarray set_chase( SLAP_SET_GATHER gatherer, SetCookie *cp, BerVarray set, AttributeDescription *desc, int closure ) { - BerVarray vals, nset; - int i; + BerVarray vals, nset; + int i; - if (set == NULL) - return cp->op->o_tmpcalloc( 1, sizeof(struct berval), - cp->op->o_tmpmemctx ); + if ( set == NULL ) { + set = cp->set_op->o_tmpcalloc( 1, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + BER_BVZERO( set ); + return set; + } - if ( BER_BVISNULL( set ) ) + if ( BER_BVISNULL( set ) ) { return set; + } - nset = cp->op->o_tmpcalloc( 1, sizeof(struct berval), cp->op->o_tmpmemctx ); + nset = cp->set_op->o_tmpcalloc( 1, sizeof( struct berval ), cp->set_op->o_tmpmemctx ); if ( nset == NULL ) { - slap_set_dispose( cp, set ); + slap_set_dispose( cp, set, 0 ); return NULL; } - for ( i = 0; !BER_BVISNULL( &set[i] ); i++ ) { - vals = (gatherer)( cp, &set[i], desc ); + for ( i = 0; !BER_BVISNULL( &set[ i ] ); i++ ) { + vals = gatherer( cp, &set[ i ], desc ); if ( vals != NULL ) { nset = slap_set_join( cp, nset, '|', vals ); } } - slap_set_dispose( cp, set ); + slap_set_dispose( cp, set, 0 ); if ( closure ) { - for ( i = 0; !BER_BVISNULL( &nset[i] ); i++ ) { - vals = (gatherer)( cp, &nset[i], desc ); + for ( i = 0; !BER_BVISNULL( &nset[ i ] ); i++ ) { + vals = gatherer( cp, &nset[ i ], desc ); if ( vals != NULL ) { nset = slap_set_join( cp, nset, '|', vals ); if ( nset == NULL ) { @@ -171,155 +330,189 @@ slap_set_filter( SLAP_SET_GATHER gatherer, SetCookie *cp, struct berval *fbv, struct berval *user, struct berval *target, BerVarray *results ) { +#define STACK_SIZE 64 #define IS_SET(x) ( (unsigned long)(x) >= 256 ) #define IS_OP(x) ( (unsigned long)(x) < 256 ) -#define SF_ERROR(x) do { rc = -1; goto _error; } while (0) -#define SF_TOP() ( (BerVarray)( (stp < 0) ? 0 : stack[stp] ) ) -#define SF_POP() ( (BerVarray)( (stp < 0) ? 0 : stack[stp--] ) ) +#define SF_ERROR(x) do { rc = -1; goto _error; } while ( 0 ) +#define SF_TOP() ( (BerVarray)( ( stp < 0 ) ? 0 : stack[ stp ] ) ) +#define SF_POP() ( (BerVarray)( ( stp < 0 ) ? 0 : stack[ stp-- ] ) ) #define SF_PUSH(x) do { \ - if (stp >= 63) SF_ERROR(overflow); \ - stack[++stp] = (BerVarray)(long)(x); \ - } while (0) + if ( stp >= ( STACK_SIZE - 1 ) ) SF_ERROR( overflow ); \ + stack[ ++stp ] = (BerVarray)(long)(x); \ + } while ( 0 ) - BerVarray set, lset; - BerVarray stack[64] = { 0 }; - int len, op, rc, stp; - char c, *filter = fbv->bv_val; + BerVarray set, lset; + BerVarray stack[ STACK_SIZE ] = { 0 }; + int len, rc, stp; + unsigned long op; + char c, *filter = fbv->bv_val; - if (results) + if ( results ) { *results = NULL; + } stp = -1; - while ((c = *filter++)) { + while ( ( c = *filter++ ) ) { set = NULL; - switch (c) { + switch ( c ) { case ' ': case '\t': case '\x0A': case '\x0D': break; - case '(': - if (IS_SET(SF_TOP())) - SF_ERROR(syntax); - SF_PUSH(c); + case '(' /* ) */ : + if ( IS_SET( SF_TOP() ) ) { + SF_ERROR( syntax ); + } + SF_PUSH( c ); break; - case ')': + case /* ( */ ')': set = SF_POP(); - if (IS_OP(set)) - SF_ERROR(syntax); - if (SF_TOP() == (void *)'(') { + if ( IS_OP( set ) ) { + SF_ERROR( syntax ); + } + if ( SF_TOP() == (void *)'(' /* ) */ ) { SF_POP(); - SF_PUSH(set); + SF_PUSH( set ); set = NULL; - } else if (IS_OP(SF_TOP())) { - op = (long)SF_POP(); + + } else if ( IS_OP( SF_TOP() ) ) { + op = (unsigned long)SF_POP(); lset = SF_POP(); SF_POP(); - set = slap_set_join(cp, lset, op, set); - if (set == NULL) - SF_ERROR(memory); - SF_PUSH(set); + set = slap_set_join( cp, lset, op, set ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + SF_PUSH( set ); set = NULL; + } else { - SF_ERROR(syntax); + SF_ERROR( syntax ); } break; - case '&': - case '|': + case '|': /* union */ + case '&': /* intersection */ + case '+': /* string concatenation */ set = SF_POP(); - if (IS_OP(set)) - SF_ERROR(syntax); - if (SF_TOP() == 0 || SF_TOP() == (void *)'(') { - SF_PUSH(set); + if ( IS_OP( set ) ) { + SF_ERROR( syntax ); + } + if ( SF_TOP() == 0 || SF_TOP() == (void *)'(' /* ) */ ) { + SF_PUSH( set ); set = NULL; - } else if (IS_OP(SF_TOP())) { - op = (long)SF_POP(); + + } else if ( IS_OP( SF_TOP() ) ) { + op = (unsigned long)SF_POP(); lset = SF_POP(); - set = slap_set_join(cp, lset, op, set); - if (set == NULL) - SF_ERROR(memory); - SF_PUSH(set); + set = slap_set_join( cp, lset, op, set ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + SF_PUSH( set ); set = NULL; + } else { - SF_ERROR(syntax); + SF_ERROR( syntax ); } - SF_PUSH(c); + SF_PUSH( c ); break; - case '[': - if ((SF_TOP() == (void *)'/') || IS_SET(SF_TOP())) - SF_ERROR(syntax); - for ( len = 0; (c = *filter++) && (c != ']'); len++ ) + case '[' /* ] */: + if ( ( SF_TOP() == (void *)'/' ) || IS_SET( SF_TOP() ) ) { + SF_ERROR( syntax ); + } + for ( len = 0; ( c = *filter++ ) && ( c != /* [ */ ']' ); len++ ) ; - if (c == 0) - SF_ERROR(syntax); + if ( c == 0 ) { + SF_ERROR( syntax ); + } - set = cp->op->o_tmpcalloc(2, sizeof(struct berval), cp->op->o_tmpmemctx); - if (set == NULL) - SF_ERROR(memory); - set->bv_val = cp->op->o_tmpcalloc(len + 1, sizeof(char), cp->op->o_tmpmemctx); - if (set->bv_val == NULL) - SF_ERROR(memory); - AC_MEMCPY(set->bv_val, &filter[-len - 1], len); + set = cp->set_op->o_tmpcalloc( 2, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + set->bv_val = cp->set_op->o_tmpcalloc( len + 1, sizeof( char ), + cp->set_op->o_tmpmemctx ); + if ( BER_BVISNULL( set ) ) { + SF_ERROR( memory ); + } + AC_MEMCPY( set->bv_val, &filter[ - len - 1 ], len ); set->bv_len = len; - SF_PUSH(set); + SF_PUSH( set ); set = NULL; break; case '-': c = *filter++; - if (c != '>') - SF_ERROR(syntax); + if ( c != '>' ) { + SF_ERROR( syntax ); + } /* fall through to next case */ case '/': - if (IS_OP(SF_TOP())) - SF_ERROR(syntax); - SF_PUSH('/'); + if ( IS_OP( SF_TOP() ) ) { + SF_ERROR( syntax ); + } + SF_PUSH( '/' ); break; default: - if ((c != '_') - && (c < 'A' || c > 'Z') - && (c < 'a' || c > 'z')) + if ( ( c != '_' ) + && ( c < 'A' || c > 'Z' ) + && ( c < 'a' || c > 'z' ) ) { - SF_ERROR(syntax); + SF_ERROR( syntax ); } filter--; - for ( len = 1; - (c = filter[len]) - && ((c >= '0' && c <= '9') - || (c >= 'A' && c <= 'Z') - || (c >= 'a' && c <= 'z')); - len++) - { } - if (len == 4 - && memcmp("this", filter, len) == 0) + for ( len = 1; + ( c = filter[ len ] ) + && ( ( c >= '0' && c <= '9' ) + || ( c >= 'A' && c <= 'Z' ) + || ( c >= 'a' && c <= 'z' ) ); + len++ ) + /* count */ ; + if ( len == 4 + && memcmp( "this", filter, len ) == 0 ) { - if ((SF_TOP() == (void *)'/') || IS_SET(SF_TOP())) - SF_ERROR(syntax); - set = cp->op->o_tmpcalloc(2, sizeof(struct berval), cp->op->o_tmpmemctx); - if (set == NULL) - SF_ERROR(memory); - ber_dupbv_x( set, target, cp->op->o_tmpmemctx ); - if (set->bv_val == NULL) - SF_ERROR(memory); - } else if (len == 4 - && memcmp("user", filter, len) == 0) + if ( ( SF_TOP() == (void *)'/' ) || IS_SET( SF_TOP() ) ) { + SF_ERROR( syntax ); + } + set = cp->set_op->o_tmpcalloc( 2, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + ber_dupbv_x( set, target, cp->set_op->o_tmpmemctx ); + if ( BER_BVISNULL( set ) ) { + SF_ERROR( memory ); + } + BER_BVZERO( &set[ 1 ] ); + + } else if ( len == 4 + && memcmp( "user", filter, len ) == 0 ) { - if ((SF_TOP() == (void *)'/') || IS_SET(SF_TOP())) - SF_ERROR(syntax); - set = cp->op->o_tmpcalloc(2, sizeof(struct berval), cp->op->o_tmpmemctx); - if (set == NULL) - SF_ERROR(memory); - ber_dupbv_x( set, user, cp->op->o_tmpmemctx ); - if (set->bv_val == NULL) - SF_ERROR(memory); - } else if (SF_TOP() != (void *)'/') { - SF_ERROR(syntax); + if ( ( SF_TOP() == (void *)'/' ) || IS_SET( SF_TOP() ) ) { + SF_ERROR( syntax ); + } + set = cp->set_op->o_tmpcalloc( 2, sizeof( struct berval ), + cp->set_op->o_tmpmemctx ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + ber_dupbv_x( set, user, cp->set_op->o_tmpmemctx ); + if ( BER_BVISNULL( set ) ) { + SF_ERROR( memory ); + } + BER_BVZERO( &set[ 1 ] ); + + } else if ( SF_TOP() != (void *)'/' ) { + SF_ERROR( syntax ); + } else { struct berval fb2; AttributeDescription *ad = NULL; @@ -330,50 +523,62 @@ slap_set_filter( SLAP_SET_GATHER gatherer, fb2.bv_len = len; if ( slap_bv2ad( &fb2, &ad, &text ) != LDAP_SUCCESS ) { - SF_ERROR(syntax); + SF_ERROR( syntax ); } + + /* NOTE: ad must have distinguishedName syntax + * or expand in an LDAP URI if c == '*' + */ set = set_chase( gatherer, cp, SF_POP(), ad, c == '*' ); - if (set == NULL) - SF_ERROR(memory); - if (c == '*') + if ( set == NULL ) { + SF_ERROR( memory ); + } + if ( c == '*' ) { len++; + } } filter += len; - SF_PUSH(set); + SF_PUSH( set ); set = NULL; break; } } set = SF_POP(); - if (IS_OP(set)) - SF_ERROR(syntax); - if (SF_TOP() == 0) { + if ( IS_OP( set ) ) { + SF_ERROR( syntax ); + } + if ( SF_TOP() == 0 ) { + /* FIXME: ok ? */ ; - } else if (IS_OP(SF_TOP())) { - op = (long)SF_POP(); + } else if ( IS_OP( SF_TOP() ) ) { + op = (unsigned long)SF_POP(); lset = SF_POP(); - set = slap_set_join(cp, lset, op, set); - if (set == NULL) - SF_ERROR(memory); + set = slap_set_join( cp, lset, op, set ); + if ( set == NULL ) { + SF_ERROR( memory ); + } + } else { - SF_ERROR(syntax); + SF_ERROR( syntax ); } - rc = slap_set_size(set) > 0 ? 1 : 0; - if (results) { + rc = slap_set_isempty( set ) ? 0 : 1; + if ( results ) { *results = set; set = NULL; } _error: - if (IS_SET(set)) - slap_set_dispose(cp, set); - while ((set = SF_POP())) { - if (IS_SET(set)) - slap_set_dispose(cp, set); + if ( IS_SET( set ) ) { + slap_set_dispose( cp, set, 0 ); + } + while ( ( set = SF_POP() ) ) { + if ( IS_SET( set ) ) { + slap_set_dispose( cp, set, 0 ); + } } - return(rc); + return rc; }