X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fresult.c;h=bb27c760f3638cbc3cd7872e5db45e9fea6d416d;hb=d1824b14ae78b128fb9ff6cf73d2ec4a0e756a90;hp=5b085af13821e5338034bb4f16640e588f3d7789;hpb=ea83f6a66972de84aa3efe2cd53f50f69465588c;p=openldap diff --git a/servers/slapd/result.c b/servers/slapd/result.c index 5b085af138..bb27c760f3 100644 --- a/servers/slapd/result.c +++ b/servers/slapd/result.c @@ -2,7 +2,7 @@ /* $OpenLDAP$ */ /* This work is part of OpenLDAP Software . * - * Copyright 1998-2005 The OpenLDAP Foundation. + * Copyright 1998-2006 The OpenLDAP Foundation. * All rights reserved. * * Redistribution and use in source and binary forms, with or without @@ -36,7 +36,6 @@ #include #include "slap.h" -#include "lutil.h" const struct berval slap_dummy_bv = BER_BVNULL; @@ -83,11 +82,7 @@ static char *v2ref( BerVarray ref, const char *text ) } } - v2 = SLAP_MALLOC( len+i+sizeof("Referral:") ); - if( v2 == NULL ) { - Debug( LDAP_DEBUG_ANY, "v2ref: SLAP_MALLOC failed", 0, 0, 0 ); - return NULL; - } + v2 = ch_malloc( len+i+sizeof("Referral:") ); if( text != NULL ) { strcpy(v2, text); @@ -99,11 +94,7 @@ static char *v2ref( BerVarray ref, const char *text ) len += sizeof("Referral:"); for( i=0; ref[i].bv_val != NULL; i++ ) { - v2 = SLAP_REALLOC( v2, len + ref[i].bv_len + 1 ); - if( v2 == NULL ) { - Debug( LDAP_DEBUG_ANY, "v2ref: SLAP_MALLOC failed", 0, 0, 0 ); - return NULL; - } + v2 = ch_realloc( v2, len + ref[i].bv_len + 1 ); v2[len-1] = '\n'; AC_MEMCPY(&v2[len], ref[i].bv_val, ref[i].bv_len ); len += ref[i].bv_len; @@ -175,7 +166,7 @@ static long send_ldap_ber( return 0; } - if ( ber_flush( conn->c_sb, ber, 0 ) == 0 ) { + if ( ber_flush2( conn->c_sb, ber, LBER_FLUSH_FREE_NEVER ) == 0 ) { break; } @@ -187,7 +178,7 @@ static long send_ldap_ber( * it's a hard error and return. */ - Debug( LDAP_DEBUG_CONNS, "ber_flush failed errno=%d reason=\"%s\"\n", + Debug( LDAP_DEBUG_CONNS, "ber_flush2 failed errno=%d reason=\"%s\"\n", err, sock_errstr(err), 0 ); if ( err != EWOULDBLOCK && err != EAGAIN ) { @@ -286,6 +277,144 @@ send_ldap_controls( Operation *o, BerElement *ber, LDAPControl **c ) return rc; } +/* + * slap_response_play() + * + * plays the callback list; rationale: a callback can + * - remove itself from the list, by setting op->o_callback = NULL; + * malloc()'ed callbacks should free themselves from inside the + * sc_response() function. + * - replace itself with another (list of) callback(s), by setting + * op->o_callback = a new (list of) callback(s); in this case, it + * is the callback's responsibility to to append existing subsequent + * callbacks to the end of the list that is passed to the sc_response() + * function. + * - modify the list of subsequent callbacks by modifying the value + * of the sc_next field from inside the sc_response() function; this + * case does not require any handling from inside slap_response_play() + * + * To stop execution of the playlist, the sc_response() function must return + * a value different from SLAP_SC_CONTINUE. + * + * The same applies to slap_cleanup_play(); only, there is no means to stop + * execution of the playlist, since all cleanup functions must be called. + */ +static int +slap_response_play( + Operation *op, + SlapReply *rs ) +{ + int rc; + +#ifdef LDAP_DEVEL + slap_callback *sc = op->o_callback, **scp; + + rc = SLAP_CB_CONTINUE; + for ( scp = ≻ *scp; ) { + slap_callback *sc_next = (*scp)->sc_next, **sc_nextp = &(*scp)->sc_next; + + op->o_callback = *scp; + if ( op->o_callback->sc_response ) { + rc = op->o_callback->sc_response( op, rs ); + if ( op->o_callback == NULL ) { + /* the callback has been removed; + * repair the list */ + *scp = sc_next; + sc_nextp = scp; + + } else if ( op->o_callback != *scp ) { + /* a new callback has been inserted + * in place of the existing one; repair the list */ + *scp = op->o_callback; + sc_nextp = scp; + } + if ( rc != SLAP_CB_CONTINUE ) break; + } + scp = sc_nextp; + } + + op->o_callback = sc; +#else /* ! LDAP_DEVEL */ + slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; + + rc = SLAP_CB_CONTINUE; + for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { + sc_next = op->o_callback->sc_next; + if ( op->o_callback->sc_response ) { + slap_callback *sc2 = op->o_callback; + rc = op->o_callback->sc_response( op, rs ); + if ( op->o_callback != sc2 ) { + *sc_prev = op->o_callback; + } + if ( rc != SLAP_CB_CONTINUE || !op->o_callback ) break; + if ( op->o_callback != sc2 ) continue; + } + sc_prev = &op->o_callback->sc_next; + } + + op->o_callback = sc; +#endif /* ! LDAP_DEVEL */ + + return rc; +} + +static int +slap_cleanup_play( + Operation *op, + SlapReply *rs ) +{ +#ifdef LDAP_DEVEL + slap_callback *sc = op->o_callback, **scp; + + for ( scp = ≻ *scp; ) { + slap_callback *sc_next = (*scp)->sc_next, **sc_nextp = &(*scp)->sc_next; + + op->o_callback = *scp; + if ( op->o_callback->sc_cleanup ) { + (void)op->o_callback->sc_cleanup( op, rs ); + if ( op->o_callback == NULL ) { + /* the callback has been removed; + * repair the list */ + *scp = sc_next; + sc_nextp = scp; + + } else if ( op->o_callback != *scp ) { + /* a new callback has been inserted + * after the existing one; repair the list */ + /* a new callback has been inserted + * in place of the existing one; repair the list */ + *scp = op->o_callback; + sc_nextp = scp; + } + /* don't care about the result; do all cleanup */ + } + scp = sc_nextp; + } + + op->o_callback = sc; +#else /* ! LDAP_DEVEL */ + slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; + + for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { + sc_next = op->o_callback->sc_next; + if ( op->o_callback->sc_cleanup ) { + slap_callback *sc2 = op->o_callback; + (void)op->o_callback->sc_cleanup( op, rs ); + if ( op->o_callback != sc2 ) { + *sc_prev = op->o_callback; + } + if ( !op->o_callback ) break; + if ( op->o_callback != sc2 ) continue; + } + sc_prev = &op->o_callback->sc_next; + } + + op->o_callback = sc; +#endif /* ! LDAP_DEVEL */ + + return LDAP_SUCCESS; +} + static int send_ldap_response( Operation *op, @@ -296,29 +425,16 @@ send_ldap_response( int rc = LDAP_SUCCESS; long bytes; - if ( rs->sr_err == SLAPD_ABANDON ) { + if ( rs->sr_err == SLAPD_ABANDON || op->o_abandon ) { rc = SLAPD_ABANDON; goto clean2; } if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - rc = SLAP_CB_CONTINUE; - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_response ) { - rc = op->o_callback->sc_response( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( rc != SLAP_CB_CONTINUE || !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; + rc = slap_response_play( op, rs ); + if ( rc != SLAP_CB_CONTINUE ) { + goto clean2; } - - op->o_callback = sc; - if ( rc != SLAP_CB_CONTINUE ) goto clean2; } #ifdef LDAP_CONNECTIONLESS @@ -456,23 +572,9 @@ cleanup:; clean2:; if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_cleanup ) { - (void)op->o_callback->sc_cleanup( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; - } - op->o_callback = sc; + (void)slap_cleanup_play( op, rs ); } - if ( rs->sr_matched && rs->sr_flags & REP_MATCHED_MUSTBEFREED ) { free( (char *)rs->sr_matched ); rs->sr_matched = NULL; @@ -532,7 +634,7 @@ slap_send_ldap_result( Operation *op, SlapReply *rs ) rs->sr_type = REP_RESULT; /* Propagate Abandons so that cleanup callbacks can be processed */ - if ( rs->sr_err == SLAPD_ABANDON ) + if ( rs->sr_err == SLAPD_ABANDON || op->o_abandon ) goto abandon; assert( !LDAP_API_ERROR( rs->sr_err ) ); @@ -557,11 +659,8 @@ slap_send_ldap_result( Operation *op, SlapReply *rs ) assert( rs->sr_err != LDAP_PARTIAL_RESULTS ); if ( rs->sr_err == LDAP_REFERRAL ) { -#ifdef LDAP_CONTROL_X_DOMAIN_SCOPE - if( op->o_domain_scope ) { - rs->sr_ref = NULL; - } -#endif + if( op->o_domain_scope ) rs->sr_ref = NULL; + if( rs->sr_ref == NULL ) { rs->sr_err = LDAP_NO_SUCH_OBJECT; } else if ( op->o_protocol < LDAP_VERSION3 ) { @@ -665,10 +764,11 @@ slap_send_ldap_intermediate( Operation *op, SlapReply *rs ) /* * returns: * - * 0 entry sent - * 1 entry not sent (other) - * -1 entry not sent (connection closed) - * SLAPD_SEND_SIZELIMIT entry not sent (caller must send sizelimitExceeded) + * LDAP_SUCCESS entry sent + * LDAP_OTHER entry not sent (other) + * LDAP_INSUFFICIENT_ACCESS entry not sent (ACL) + * LDAP_UNAVAILABLE entry not sent (connection closed) + * LDAP_SIZELIMIT_EXCEEDED entry not sent (caller must send sizelimitExceeded) */ int @@ -677,7 +777,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) BerElementBuffer berbuf; BerElement *ber = (BerElement *) &berbuf; Attribute *a; - int i, j, rc=-1, bytes; + int i, j, rc = LDAP_UNAVAILABLE, bytes; char *edn; int userattrs; AccessControlState acl_state = ACL_STATE_INIT; @@ -689,7 +789,11 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) * e_flags: array of a_flags */ char **e_flags = NULL; - + + if ( op->ors_slimit >= 0 && rs->sr_nentries >= op->ors_slimit ) { + return LDAP_SIZELIMIT_EXCEEDED; + } + rs->sr_type = REP_SEARCH; /* eventually will loop through generated operational attribute types @@ -698,7 +802,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) /* NOTE: moved before overlays callback circling because * they may modify entry and other stuff in rs */ /* check for special all operational attributes ("+") type */ - /* FIXME: maybe we could se this flag at the operation level; + /* FIXME: maybe we could set this flag at the operation level; * however, in principle the caller of send_search_entry() may * change the attribute list at each call */ rs->sr_attr_flags = slap_attr_flags( rs->sr_attrs ); @@ -709,24 +813,10 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) } if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - rc = SLAP_CB_CONTINUE; - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next ) - { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_response ) { - rc = op->o_callback->sc_response( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( rc != SLAP_CB_CONTINUE || !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; + rc = slap_response_play( op, rs ); + if ( rc != SLAP_CB_CONTINUE ) { + goto error_return; } - - op->o_callback = sc; - if ( rc != SLAP_CB_CONTINUE ) goto error_return; } Debug( LDAP_DEBUG_TRACE, "=> send_search_entry: conn %lu dn=\"%s\"%s\n", @@ -740,7 +830,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) "send_search_entry: conn %lu access to entry (%s) not allowed\n", op->o_connid, rs->sr_entry->e_name.bv_val, 0 ); - rc = 1; + rc = LDAP_INSUFFICIENT_ACCESS; goto error_return; } @@ -786,6 +876,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding DN error" ); + rc = rs->sr_err; goto error_return; } @@ -833,6 +924,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "matched values filtering error" ); + rc = rs->sr_err; goto error_return; } } @@ -882,6 +974,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding description error"); + rc = rs->sr_err; goto error_return; } finish = 1; @@ -915,6 +1008,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding description error"); + rc = rs->sr_err; goto error_return; } } @@ -926,6 +1020,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding values error" ); + rc = rs->sr_err; goto error_return; } } @@ -938,6 +1033,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encode end error" ); + rc = rs->sr_err; goto error_return; } } @@ -991,6 +1087,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "matched values filtering error" ); + rc = rs->sr_err; goto error_return; } } @@ -1040,6 +1137,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding description error" ); + rc = rs->sr_err; goto error_return; } @@ -1068,6 +1166,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encoding values error" ); + rc = rs->sr_err; goto error_return; } } @@ -1080,6 +1179,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encode end error" ); + rc = rs->sr_err; goto error_return; } } @@ -1114,7 +1214,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) if ( op->o_res_ber == NULL ) ber_free_buf( ber ); send_ldap_error( op, rs, LDAP_OTHER, "encode entry end error" ); - rc = 1; + rc = rs->sr_err; goto error_return; } @@ -1125,15 +1225,6 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) } if ( op->o_res_ber == NULL ) { - if ( --op->ors_slimit == -1 ) { - rc = SLAPD_SEND_SIZELIMIT; - ber_free_buf( ber ); - /* putback, so dumb backends that don't - * check sizelimit won't at least return - * more than expected... */ - op->ors_slimit++; - goto error_return; - } bytes = send_ldap_ber( op->o_conn, ber ); ber_free_buf( ber ); @@ -1142,7 +1233,7 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) "send_search_entry: conn %lu ber write failed.\n", op->o_connid, 0, 0 ); - rc = -1; + rc = LDAP_UNAVAILABLE; goto error_return; } rs->sr_nentries++; @@ -1160,24 +1251,11 @@ slap_send_search_entry( Operation *op, SlapReply *rs ) Debug( LDAP_DEBUG_TRACE, "<= send_search_entry: conn %lu exit.\n", op->o_connid, 0, 0 ); - rc = 0; + rc = LDAP_SUCCESS; error_return:; if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_cleanup ) { - (void)op->o_callback->sc_cleanup( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; - } - op->o_callback = sc; + (void)slap_cleanup_play( op, rs ); } if ( e_flags ) { @@ -1221,23 +1299,10 @@ slap_send_search_reference( Operation *op, SlapReply *rs ) rs->sr_type = REP_SEARCHREF; if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - rc = SLAP_CB_CONTINUE; - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_response ) { - rc = op->o_callback->sc_response( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( rc != SLAP_CB_CONTINUE || !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; + rc = slap_response_play( op, rs ); + if ( rc != SLAP_CB_CONTINUE ) { + goto rel; } - - op->o_callback = sc; - if ( rc != SLAP_CB_CONTINUE ) goto rel; } Debug( LDAP_DEBUG_TRACE, @@ -1265,7 +1330,6 @@ slap_send_search_reference( Operation *op, SlapReply *rs ) goto rel; } -#ifdef LDAP_CONTROL_X_DOMAIN_SCOPE if( op->o_domain_scope ) { Debug( LDAP_DEBUG_ANY, "send_search_reference: domainScope control in (%s)\n", @@ -1273,7 +1337,6 @@ slap_send_search_reference( Operation *op, SlapReply *rs ) rc = 0; goto rel; } -#endif if( rs->sr_ref == NULL ) { Debug( LDAP_DEBUG_ANY, @@ -1365,20 +1428,7 @@ slap_send_search_reference( Operation *op, SlapReply *rs ) rel: if ( op->o_callback ) { - slap_callback *sc = op->o_callback, **sc_prev = &sc, *sc_next; - - for ( sc_next = op->o_callback; sc_next; op->o_callback = sc_next) { - sc_next = op->o_callback->sc_next; - if ( op->o_callback->sc_cleanup ) { - (void)op->o_callback->sc_cleanup( op, rs ); - if ( op->o_callback != *sc_prev ) { - *sc_prev = op->o_callback; - } - if ( rc != SLAP_CB_CONTINUE || !op->o_callback ) break; - } - sc_prev = &op->o_callback->sc_next; - } - op->o_callback = sc; + (void)slap_cleanup_play( op, rs ); } return rc; @@ -1416,9 +1466,43 @@ str2result( } if ( strncasecmp( s, "code", STRLENOF( "code" ) ) == 0 ) { - if ( c != NULL && lutil_atoi( code, c ) != 0 ) { - goto bailout; + char *next = NULL; + long retcode; + + if ( c == NULL ) { + Debug( LDAP_DEBUG_ANY, "str2result (%s) missing value\n", + s, 0, 0 ); + rc = -1; + continue; + } + + while ( isspace( (unsigned char) c[ 0 ] ) ) c++; + if ( c[ 0 ] == '\0' ) { + Debug( LDAP_DEBUG_ANY, "str2result (%s) missing or empty value\n", + s, 0, 0 ); + rc = -1; + continue; + } + + retcode = strtol( c, &next, 10 ); + if ( next == NULL || next == c ) { + Debug( LDAP_DEBUG_ANY, "str2result (%s) unable to parse value\n", + s, 0, 0 ); + rc = -1; + continue; + } + + while ( isspace( (unsigned char) next[ 0 ] ) ) next++; + if ( next[ 0 ] != '\0' ) { + Debug( LDAP_DEBUG_ANY, "str2result (%s) extra cruft after value\n", + s, 0, 0 ); + rc = -1; + continue; } + + /* FIXME: what if it's larger that max int? */ + *code = (int)retcode; + } else if ( strncasecmp( s, "matched", STRLENOF( "matched" ) ) == 0 ) { if ( c != NULL ) { *matched = c; @@ -1428,7 +1512,6 @@ str2result( *info = c; } } else { -bailout:; Debug( LDAP_DEBUG_ANY, "str2result (%s) unknown\n", s, 0, 0 ); @@ -1471,6 +1554,7 @@ int slap_read_controls( myop.o_bd = NULL; myop.o_res_ber = ber; myop.o_callback = NULL; + myop.ors_slimit = 1; rc = slap_send_search_entry( &myop, rs ); if( rc ) return rc;