X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fextended.c;h=bc34f65f60df30ea70ba6c2c8aca70a192c362be;hb=c6b5abbfd20567116846ebc38f0005c429284c98;hp=52eb15a7a7ac6cf3dd78faf2b7603b4e7dd1fca5;hpb=951b275ed6e967b80f72da71c5fb4c8c825851e6;p=openldap diff --git a/servers/slapd/extended.c b/servers/slapd/extended.c index 52eb15a7a7..bc34f65f60 100644 --- a/servers/slapd/extended.c +++ b/servers/slapd/extended.c @@ -1,26 +1,30 @@ /* $OpenLDAP$ */ -/* - * Copyright 1999 The OpenLDAP Foundation. +/* This work is part of OpenLDAP Software . + * + * Copyright 1999-2012 The OpenLDAP Foundation. * All rights reserved. * - * Redistribution and use in source and binary forms are permitted only - * as authorized by the OpenLDAP Public License. A copy of this - * license is available at http://www.OpenLDAP.org/license.html or - * in file LICENSE in the top-level directory of the distribution. + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in the file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * . */ /* * LDAPv3 Extended Operation Request * ExtendedRequest ::= [APPLICATION 23] SEQUENCE { - * requestName [0] LDAPOID, - * requestValue [1] OCTET STRING OPTIONAL + * requestName [0] LDAPOID, + * requestValue [1] OCTET STRING OPTIONAL * } * * LDAPv3 Extended Operation Response * ExtendedResponse ::= [APPLICATION 24] SEQUENCE { * COMPONENTS OF LDAPResult, - * responseName [10] LDAPOID OPTIONAL, - * response [11] OCTET STRING OPTIONAL + * responseName [10] LDAPOID OPTIONAL, + * response [11] OCTET STRING OPTIONAL * } * */ @@ -28,268 +32,427 @@ #include "portable.h" #include + #include +#include #include "slap.h" +#include "lber_pvt.h" -#ifdef SLAPD_EXTERNAL_EXTENSIONS +static struct extop_list { + struct extop_list *next; + struct berval oid; + slap_mask_t flags; + SLAP_EXTOP_MAIN_FN *ext_main; +} *supp_ext_list = NULL; -typedef struct extensions_cookie_t { - Connection *conn; - Operation *op; -} extensions_cookie_t; +static SLAP_EXTOP_MAIN_FN whoami_extop; -#define MAX_OID_LENGTH 128 +/* This list of built-in extops is for extops that are not part + * of backends or in external modules. Essentially, this is + * just a way to get built-in extops onto the extop list without + * having a separate init routine for each built-in extop. + */ +static struct { + const struct berval *oid; + slap_mask_t flags; + SLAP_EXTOP_MAIN_FN *ext_main; +} builtin_extops[] = { +#ifdef LDAP_X_TXN + { &slap_EXOP_TXN_START, 0, txn_start_extop }, + { &slap_EXOP_TXN_END, 0, txn_end_extop }, +#endif + { &slap_EXOP_CANCEL, 0, cancel_extop }, + { &slap_EXOP_WHOAMI, 0, whoami_extop }, + { &slap_EXOP_MODIFY_PASSWD, SLAP_EXOP_WRITES, passwd_extop }, + { NULL, 0, NULL } +}; -typedef struct extensions_list_t { - struct extensions_list_t *next; - char *oid; - int (*ext_main)(int (*)(), void *, char *reqoid, struct berval *reqdata, char **rspoid, struct berval *rspdata, char **text); -} extensions_list_t; -extensions_list_t *supp_ext_list = NULL; +static struct extop_list *find_extop( + struct extop_list *list, struct berval *oid ); -#define MAX_SUPP_EXT_TRACKED 64 -int supp_ext_count = 0; -char *supportedExtensions[MAX_SUPP_EXT_TRACKED] = { NULL }; +struct berval * +get_supported_extop (int index) +{ + struct extop_list *ext; -extensions_list_t *find_extension (extensions_list_t *list, char *oid); -int extensions_callback (extensions_cookie_t *cookie, int msg, int arg, void *argp); -#else + /* linear scan is slow, but this way doesn't force a + * big change on root_dse.c, where this routine is used. + */ + for (ext = supp_ext_list; ext != NULL && --index >= 0; ext = ext->next) { + ; /* empty */ + } -char *supportedExtensions[] = { - NULL -}; -#endif + if (ext == NULL) return NULL; + + return &ext->oid; +} + + +int exop_root_dse_info( Entry *e ) +{ + AttributeDescription *ad_supportedExtension + = slap_schema.si_ad_supportedExtension; + struct berval vals[2]; + struct extop_list *ext; + + vals[1].bv_val = NULL; + vals[1].bv_len = 0; + + for (ext = supp_ext_list; ext != NULL; ext = ext->next) { + if( ext->flags & SLAP_EXOP_HIDE ) continue; + + vals[0] = ext->oid; + if( attr_merge( e, ad_supportedExtension, vals, NULL ) ) { + return LDAP_OTHER; + } + } + + return LDAP_SUCCESS; +} int do_extended( - Connection *conn, - Operation *op + Operation *op, + SlapReply *rs ) { - int rc = LDAP_SUCCESS; - char* reqoid ; - struct berval reqdata; - ber_tag_t tag; + struct berval reqdata = {0, NULL}; ber_len_t len; -#ifdef SLAPD_EXTERNAL_EXTENSIONS - extensions_list_t *ext; - char *rspoid, *text; - struct berval rspdata; - extensions_cookie_t cookie; -#endif - - Debug( LDAP_DEBUG_TRACE, "do_extended\n", 0, 0, 0 ); - reqoid = NULL; - reqdata.bv_val = NULL; + Debug( LDAP_DEBUG_TRACE, "%s do_extended\n", + op->o_log_prefix, 0, 0 ); if( op->o_protocol < LDAP_VERSION3 ) { - Debug( LDAP_DEBUG_ANY, "do_extended: protocol version (%d) too low\n", - op->o_protocol, 0 ,0 ); - send_ldap_disconnect( conn, op, - LDAP_PROTOCOL_ERROR, "requires LDAPv3" ); - rc = -1; + Debug( LDAP_DEBUG_ANY, "%s do_extended: protocol version (%d) too low\n", + op->o_log_prefix, op->o_protocol, 0 ); + send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "requires LDAPv3" ); + rs->sr_err = SLAPD_DISCONNECT; goto done; } - if ( ber_scanf( op->o_ber, "{a" /*}*/, &reqoid ) == LBER_ERROR ) { - Debug( LDAP_DEBUG_ANY, "do_extended: ber_scanf failed\n", 0, 0 ,0 ); - send_ldap_disconnect( conn, op, - LDAP_PROTOCOL_ERROR, "decoding error" ); - rc = -1; - goto done; - } - -#ifdef SLAPD_EXTERNAL_EXTENSIONS - if( !(ext = find_extension(supp_ext_list, reqoid)) ) -#else - if( !charray_inlist( supportedExtensions, reqoid ) ) -#endif - { - Debug( LDAP_DEBUG_ANY, "do_extended: unsupported operation \"%s\"\n", - reqoid, 0 ,0 ); - send_ldap_result( conn, op, rc = LDAP_PROTOCOL_ERROR, - NULL, "unsuppored extended operation", NULL, NULL ); + if ( ber_scanf( op->o_ber, "{m" /*}*/, &op->ore_reqoid ) == LBER_ERROR ) { + Debug( LDAP_DEBUG_ANY, "%s do_extended: ber_scanf failed\n", + op->o_log_prefix, 0, 0 ); + send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" ); + rs->sr_err = SLAPD_DISCONNECT; goto done; } - tag = ber_peek_tag( op->o_ber, &len ); - if( ber_peek_tag( op->o_ber, &len ) == LDAP_TAG_EXOP_REQ_VALUE ) { - if( ber_scanf( op->o_ber, "o", &reqdata ) == LBER_ERROR ) { - Debug( LDAP_DEBUG_ANY, "do_extended: ber_scanf failed\n", 0, 0 ,0 ); - send_ldap_disconnect( conn, op, - LDAP_PROTOCOL_ERROR, "decoding error" ); - rc = -1; + if( ber_scanf( op->o_ber, "m", &reqdata ) == LBER_ERROR ) { + Debug( LDAP_DEBUG_ANY, "%s do_extended: ber_scanf failed\n", + op->o_log_prefix, 0, 0 ); + send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" ); + rs->sr_err = SLAPD_DISCONNECT; goto done; } } - if( (rc = get_ctrls( conn, op, 1 )) != LDAP_SUCCESS ) { - Debug( LDAP_DEBUG_ANY, "do_extended: get_ctrls failed\n", 0, 0 ,0 ); - return rc; + if( get_ctrls( op, rs, 1 ) != LDAP_SUCCESS ) { + Debug( LDAP_DEBUG_ANY, "%s do_extended: get_ctrls failed\n", + op->o_log_prefix, 0, 0 ); + return rs->sr_err; } - Debug( LDAP_DEBUG_ARGS, "do_extended: oid \"%s\"\n", reqoid, 0 ,0 ); + Statslog( LDAP_DEBUG_STATS, "%s EXT oid=%s\n", + op->o_log_prefix, op->ore_reqoid.bv_val, 0, 0, 0 ); -#ifdef SLAPD_EXTERNAL_EXTENSIONS - cookie.conn = conn; - cookie.op = op; - rspoid = NULL; - rspdata.bv_len = 0; - rspdata.bv_val = NULL; - text = NULL; - rc = (ext->ext_main)(extensions_callback, &cookie, reqoid, &reqdata, &rspoid, &rspdata, &text); - - send_ldap_extended(conn, op, rc, NULL, text, rspoid, rspdata.bv_val ? &rspdata : NULL); + /* check for controls inappropriate for all extended operations */ + if( get_manageDSAit( op ) == SLAP_CONTROL_CRITICAL ) { + send_ldap_error( op, rs, + LDAP_UNAVAILABLE_CRITICAL_EXTENSION, + "manageDSAit control inappropriate" ); + goto done; + } - if (rspoid != NULL) - free(rspoid); - if ( rspdata.bv_val != NULL ) - free(rspdata.bv_val); - if ( text != NULL ) - free(text); + /* FIXME: temporary? */ + if ( reqdata.bv_val ) { + op->ore_reqdata = &reqdata; + } -#else - send_ldap_result( conn, op, rc = LDAP_PROTOCOL_ERROR, - NULL, "unsupported extended operation", NULL, NULL ); + op->o_bd = frontendDB; + rs->sr_err = frontendDB->be_extended( op, rs ); -#endif + /* clean up in case some overlay set them? */ + if ( !BER_BVISNULL( &op->o_req_ndn ) ) { + if ( !BER_BVISNULL( &op->o_req_dn ) + && op->o_req_ndn.bv_val != op->o_req_dn.bv_val ) + { + op->o_tmpfree( op->o_req_dn.bv_val, op->o_tmpmemctx ); + } + op->o_tmpfree( op->o_req_ndn.bv_val, op->o_tmpmemctx ); + BER_BVZERO( &op->o_req_dn ); + BER_BVZERO( &op->o_req_ndn ); + } done: - if ( reqoid != NULL ) { - free( reqoid ); + return rs->sr_err; +} + +int +fe_extended( Operation *op, SlapReply *rs ) +{ + struct extop_list *ext = NULL; + struct berval reqdata = BER_BVNULL; + + if (op->ore_reqdata) { + reqdata = *op->ore_reqdata; } - if ( reqdata.bv_val != NULL ) { - free( reqdata.bv_val ); + + ext = find_extop(supp_ext_list, &op->ore_reqoid ); + if ( ext == NULL ) { + Debug( LDAP_DEBUG_ANY, "%s do_extended: unsupported operation \"%s\"\n", + op->o_log_prefix, op->ore_reqoid.bv_val, 0 ); + send_ldap_error( op, rs, LDAP_PROTOCOL_ERROR, + "unsupported extended operation" ); + goto done; } - return rc; -} + op->ore_flags = ext->flags; -#ifdef SLAPD_EXTERNAL_EXTENSIONS + Debug( LDAP_DEBUG_ARGS, "do_extended: oid=%s\n", + op->ore_reqoid.bv_val, 0 ,0 ); + + { /* start of OpenLDAP extended operation */ + BackendDB *bd = op->o_bd; + + rs->sr_err = (ext->ext_main)( op, rs ); + + if( rs->sr_err != SLAPD_ABANDON ) { + if ( rs->sr_err == LDAP_REFERRAL && rs->sr_ref == NULL ) { + rs->sr_ref = referral_rewrite( default_referral, + NULL, NULL, LDAP_SCOPE_DEFAULT ); + if ( !rs->sr_ref ) rs->sr_ref = default_referral; + if ( !rs->sr_ref ) { + rs->sr_err = LDAP_UNWILLING_TO_PERFORM; + rs->sr_text = "referral missing"; + } + } + + if ( op->o_bd == NULL ) + op->o_bd = bd; + send_ldap_extended( op, rs ); + + if ( rs->sr_ref != default_referral ) { + ber_bvarray_free( rs->sr_ref ); + rs->sr_ref = NULL; + } + } + + if ( rs->sr_rspoid != NULL ) { + free( (char *)rs->sr_rspoid ); + rs->sr_rspoid = NULL; + } + + if ( rs->sr_rspdata != NULL ) { + ber_bvfree( rs->sr_rspdata ); + rs->sr_rspdata = NULL; + } + } /* end of OpenLDAP extended operation */ + +done:; + return rs->sr_err; +} int -load_extension ( - const void *module, - const char *file_name -) +load_extop2( + const struct berval *ext_oid, + slap_mask_t ext_flags, + SLAP_EXTOP_MAIN_FN *ext_main, + unsigned flags ) { - extensions_list_t *ext; - int (*ext_getoid)(int index, char *oid, int blen); - int rc; - - ext = ch_calloc(1, sizeof(extensions_list_t)); - if (ext == NULL) - return(-1); - - ext->oid = ch_malloc(MAX_OID_LENGTH); - if (ext->oid == NULL) { - free(ext); - return(-1); + struct berval oidm = BER_BVNULL; + struct extop_list *ext; + int insertme = 0; + + if ( !ext_main ) { + return -1; } - ext->ext_main = module_resolve(module, "ext_main"); - if (ext->ext_main == NULL) { - free(ext->oid); - free(ext); - return(-1); + if ( ext_oid == NULL || BER_BVISNULL( ext_oid ) || + BER_BVISEMPTY( ext_oid ) ) + { + return -1; } - ext_getoid = module_resolve(module, "ext_getoid"); - if (ext_getoid == NULL) { - free(ext->oid); - free(ext); - return(-1); + if ( numericoidValidate( NULL, (struct berval *)ext_oid ) != + LDAP_SUCCESS ) + { + oidm.bv_val = oidm_find( ext_oid->bv_val ); + if ( oidm.bv_val == NULL ) { + return -1; + } + oidm.bv_len = strlen( oidm.bv_val ); + ext_oid = &oidm; } - rc = (ext_getoid)(0, ext->oid, MAX_OID_LENGTH); - if (rc != 0) { - free(ext->oid); - free(ext); - return(rc); + + for ( ext = supp_ext_list; ext; ext = ext->next ) { + if ( bvmatch( ext_oid, &ext->oid ) ) { + if ( flags == 1 ) { + break; + } + return -1; + } } - if (*ext->oid == 0) { - free(ext->oid); - free(ext); - return(-1); + + if ( flags == 0 || ext == NULL ) { + ext = ch_calloc( 1, sizeof(struct extop_list) + ext_oid->bv_len + 1 ); + if ( ext == NULL ) { + return(-1); + } + + ext->oid.bv_val = (char *)(ext + 1); + AC_MEMCPY( ext->oid.bv_val, ext_oid->bv_val, ext_oid->bv_len ); + ext->oid.bv_len = ext_oid->bv_len; + ext->oid.bv_val[ext->oid.bv_len] = '\0'; + + insertme = 1; } - /* supportedExtensions must be maintained for the root DSE. - * Unfortunately, this global var is declared extern char *[], - * which means it cannot grow dynamically. So, for now it is - * a char *[n], and only (n-1) oids are tracked. In the off - * chance that this is too few, the extensions will still be - * loaded, but not reported in root DSE info. To increase - * the maximum, change MAX_SUPP_EXT_TRACKED and recompile or - * fix root_dse.c to use something other than a static array. - */ - if (supp_ext_count < (MAX_SUPP_EXT_TRACKED - 1)) { - supportedExtensions[supp_ext_count++] = ch_strdup(ext->oid); - supportedExtensions[supp_ext_count] = NULL; + ext->flags = ext_flags; + ext->ext_main = ext_main; + + if ( insertme ) { + ext->next = supp_ext_list; + supp_ext_list = ext; } - ext->next = supp_ext_list; - supp_ext_list = ext; return(0); } -extensions_list_t * -find_extension (extensions_list_t *list, char *oid) +int +unload_extop( + const struct berval *ext_oid, + SLAP_EXTOP_MAIN_FN *ext_main, + unsigned flags ) { - extensions_list_t *ext; + struct berval oidm = BER_BVNULL; + struct extop_list *ext, **extp; + + /* oid must be given */ + if ( ext_oid == NULL || BER_BVISNULL( ext_oid ) || + BER_BVISEMPTY( ext_oid ) ) + { + return -1; + } + + /* if it's not an oid, check if it's a macto */ + if ( numericoidValidate( NULL, (struct berval *)ext_oid ) != + LDAP_SUCCESS ) + { + oidm.bv_val = oidm_find( ext_oid->bv_val ); + if ( oidm.bv_val == NULL ) { + return -1; + } + oidm.bv_len = strlen( oidm.bv_val ); + ext_oid = &oidm; + } + + /* lookup the oid */ + for ( extp = &supp_ext_list; *extp; extp = &(*extp)->next ) { + if ( bvmatch( ext_oid, &(*extp)->oid ) ) { + /* if ext_main is given, only remove if it matches */ + if ( ext_main != NULL && (*extp)->ext_main != ext_main ) { + return -1; + } + break; + } + } + + if ( *extp == NULL ) { + return -1; + } + + ext = *extp; + *extp = (*extp)->next; + + ch_free( ext ); + + return 0; +} + +int +extops_init (void) +{ + int i; + + for ( i = 0; builtin_extops[i].oid != NULL; i++ ) { + load_extop( (struct berval *)builtin_extops[i].oid, + builtin_extops[i].flags, + builtin_extops[i].ext_main ); + } + + return(0); +} + +int +extops_kill (void) +{ + struct extop_list *ext; + + /* we allocated the memory, so we have to free it, too. */ + while ((ext = supp_ext_list) != NULL) { + supp_ext_list = ext->next; + ch_free(ext); + } + return(0); +} + +static struct extop_list * +find_extop( struct extop_list *list, struct berval *oid ) +{ + struct extop_list *ext; for (ext = list; ext; ext = ext->next) { - if (strcmp(ext->oid, oid) == 0) + if (bvmatch(&ext->oid, oid)) return(ext); } return(NULL); } -int -extensions_callback (extensions_cookie_t *cookie, int msg, int arg, void *argp) + +const struct berval slap_EXOP_WHOAMI = BER_BVC(LDAP_EXOP_WHO_AM_I); + +static int +whoami_extop ( + Operation *op, + SlapReply *rs ) { - if (cookie == NULL) - return(-1); - - if (argp == NULL) - return(-1); - - switch (msg) { - case 0: /* SLAPD_EXT_GETVERSION */ - *(int *)argp = 1; - return(0); - - case 1: /* SLAPD_EXT_GETPROTO */ - *(int *)argp = cookie->op->o_protocol; - return(0); - - case 2: /* SLAPD_EXT_GETAUTH */ - *(int *)argp = cookie->op->o_authtype; - return(0); - - case 3: /* SLAPD_EXT_GETDN */ - *(char **)argp = cookie->op->o_dn; - return(0); - - case 4: /* SLAPD_EXT_GETCLIENT */ - if (cookie->conn->c_peer_domain != NULL && *cookie->conn->c_peer_domain != 0) { - *(char **)argp = cookie->conn->c_peer_domain; - return(0); - } - if (cookie->conn->c_peer_name != NULL && *cookie->conn->c_peer_name != 0) { - *(char **)argp = cookie->conn->c_peer_name; - return(0); - } - break; - - default: - break; + struct berval *bv; + + if ( op->ore_reqdata != NULL ) { + /* no request data should be provided */ + rs->sr_text = "no request data expected"; + return LDAP_PROTOCOL_ERROR; } - return(-1); -} -#endif + Statslog( LDAP_DEBUG_STATS, "%s WHOAMI\n", + op->o_log_prefix, 0, 0, 0, 0 ); + + op->o_bd = op->o_conn->c_authz_backend; + if( backend_check_restrictions( op, rs, + (struct berval *)&slap_EXOP_WHOAMI ) != LDAP_SUCCESS ) + { + return rs->sr_err; + } + bv = (struct berval *) ch_malloc( sizeof(struct berval) ); + if( op->o_dn.bv_len ) { + bv->bv_len = op->o_dn.bv_len + STRLENOF( "dn:" ); + bv->bv_val = ch_malloc( bv->bv_len + 1 ); + AC_MEMCPY( bv->bv_val, "dn:", STRLENOF( "dn:" ) ); + AC_MEMCPY( &bv->bv_val[STRLENOF( "dn:" )], op->o_dn.bv_val, + op->o_dn.bv_len ); + bv->bv_val[bv->bv_len] = '\0'; + + } else { + bv->bv_len = 0; + bv->bv_val = NULL; + } + + rs->sr_rspdata = bv; + return LDAP_SUCCESS; +}