X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fbackend.c;h=1b26ee117f3b41e94f8b01992fc0835398df8a3d;hb=0445405299ebc97d0f11585031fb1abef031caf9;hp=396beff3f1ea237bace7ed76e18776f60c438d61;hpb=bc1186bfb1c37f60632f42b0f120a8846595b5ee;p=openldap diff --git a/servers/slapd/backend.c b/servers/slapd/backend.c index 396beff3f1..1b26ee117f 100644 --- a/servers/slapd/backend.c +++ b/servers/slapd/backend.c @@ -1,5 +1,6 @@ +/* $OpenLDAP$ */ /* - * Copyright 1998-1999 The OpenLDAP Foundation, All Rights Reserved. + * Copyright 1998-2000 The OpenLDAP Foundation, All Rights Reserved. * COPYING RESTRICTIONS APPLY, see COPYRIGHT file */ /* backend.c - routines for dealing with back-end databases */ @@ -17,16 +18,20 @@ #include "slap.h" #include "lutil.h" -#include "ldap_defaults.h" - +#ifdef SLAPD_BDB +#include "back-bdb/external.h" +#endif +#ifdef SLAPD_DNSSRV +#include "back-dnssrv/external.h" +#endif #ifdef SLAPD_LDAP #include "back-ldap/external.h" #endif #ifdef SLAPD_LDBM #include "back-ldbm/external.h" #endif -#ifdef SLAPD_BDB2 -#include "back-bdb2/external.h" +#ifdef SLAPD_META +#include "back-meta/external.h" #endif #ifdef SLAPD_PASSWD #include "back-passwd/external.h" @@ -40,16 +45,28 @@ #ifdef SLAPD_TCL #include "back-tcl/external.h" #endif +#ifdef SLAPD_SQL +#include "back-sql/external.h" +#endif +#ifdef SLAPD_PRIVATE +#include "private/external.h" +#endif static BackendInfo binfo[] = { +#if defined(SLAPD_BDB) && !defined(SLAPD_BDB_DYNAMIC) + {"bdb", bdb_initialize}, +#endif +#if defined(SLAPD_DNSSRV) && !defined(SLAPD_DNSSRV_DYNAMIC) + {"dnssrv", dnssrv_back_initialize}, +#endif #if defined(SLAPD_LDAP) && !defined(SLAPD_LDAP_DYNAMIC) {"ldap", ldap_back_initialize}, #endif #if defined(SLAPD_LDBM) && !defined(SLAPD_LDBM_DYNAMIC) {"ldbm", ldbm_back_initialize}, #endif -#if defined(SLAPD_BDB2) && !defined(SLAPD_BDB2_DYNAMIC) - {"bdb2", bdb2_back_initialize}, +#if defined(SLAPD_META) && !defined(SLAPD_META_DYNAMIC) + {"meta", meta_back_initialize}, #endif #if defined(SLAPD_PASSWD) && !defined(SLAPD_PASSWD_DYNAMIC) {"passwd", passwd_back_initialize}, @@ -60,8 +77,15 @@ static BackendInfo binfo[] = { #if defined(SLAPD_SHELL) && !defined(SLAPD_SHELL_DYNAMIC) {"shell", shell_back_initialize}, #endif -#if defined(SLAPD_TCL) && !defined(SLAPD_LDAP_TCL) +#if defined(SLAPD_TCL) && !defined(SLAPD_TCL_DYNAMIC) {"tcl", tcl_back_initialize}, +#endif +#if defined(SLAPD_SQL) && !defined(SLAPD_SQL_DYNAMIC) + {"sql", sql_back_initialize}, +#endif + /* for any private backend */ +#if defined(SLAPD_PRIVATE) && !defined(SLAPD_PRIVATE_DYNAMIC) + {"private", private_back_initialize}, #endif {NULL} }; @@ -78,8 +102,13 @@ int backend_init(void) if((nBackendInfo != 0) || (backendInfo != NULL)) { /* already initialized */ +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_ERR, + "backend_init: backend already initialized\n" )); +#else Debug( LDAP_DEBUG_ANY, "backend_init: already initialized.\n", 0, 0, 0 ); +#endif return -1; } @@ -90,10 +119,15 @@ int backend_init(void) rc = binfo[nBackendInfo].bi_init( &binfo[nBackendInfo] ); if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_INFO, + "backend_init: initialized for type \"%s\"\n", + binfo[nBackendInfo].bi_type )); +#else Debug( LDAP_DEBUG_ANY, "backend_init: initialized for type \"%s\"\n", binfo[nBackendInfo].bi_type, 0, 0 ); - +#endif /* destroy those we've already inited */ for( nBackendInfo--; nBackendInfo >= 0 ; @@ -116,9 +150,15 @@ int backend_init(void) #ifdef SLAPD_MODULES return 0; #else - Debug( LDAP_DEBUG_ANY, + +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_ERR, + "backend_init: failed\n" )); +#else + Debug( LDAP_DEBUG_ANY, "backend_init: failed\n", 0, 0, 0 ); +#endif return rc; #endif /* SLAPD_MODULES */ @@ -129,9 +169,15 @@ int backend_add(BackendInfo *aBackendInfo) int rc = 0; if ((rc = aBackendInfo->bi_init(aBackendInfo)) != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_ERR, + "backend_add: initialization for type \"%s\" failed\n", + aBackendInfo->bi_type )); +#else Debug( LDAP_DEBUG_ANY, "backend_add: initialization for type \"%s\" failed\n", aBackendInfo->bi_type, 0, 0 ); +#endif return rc; } @@ -142,13 +188,13 @@ int backend_add(BackendInfo *aBackendInfo) /* if backendInfo == binfo no deallocation of old backendInfo */ if (backendInfo == binfo) { newBackendInfo = ch_calloc(nBackendInfo + 1, sizeof(BackendInfo)); - memcpy(newBackendInfo, backendInfo, sizeof(BackendInfo) * + AC_MEMCPY(newBackendInfo, backendInfo, sizeof(BackendInfo) * nBackendInfo); } else { newBackendInfo = ch_realloc(backendInfo, sizeof(BackendInfo) * (nBackendInfo + 1)); } - memcpy(&newBackendInfo[nBackendInfo], aBackendInfo, + AC_MEMCPY(&newBackendInfo[nBackendInfo], aBackendInfo, sizeof(BackendInfo)); backendInfo = newBackendInfo; nBackendInfo++; @@ -164,26 +210,44 @@ int backend_startup(Backend *be) if( ! ( nBackendDB > 0 ) ) { /* no databases */ +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_INFO, + "backend_startup: %d databases to startup. \n", + nBackendDB )); +#else Debug( LDAP_DEBUG_ANY, "backend_startup: %d databases to startup.\n", nBackendDB, 0, 0 ); +#endif return 1; } if(be != NULL) { /* startup a specific backend database */ +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_DETAIL1, + "backend_startup: starting \"%s\"\n", + be->be_suffix[0] )); +#else Debug( LDAP_DEBUG_TRACE, - "backend_startup: starting database\n", - 0, 0, 0 ); + "backend_startup: starting \"%s\"\n", + be->be_suffix[0], 0, 0 ); +#endif if ( be->bd_info->bi_open ) { rc = be->bd_info->bi_open( be->bd_info ); } if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_CRIT, + "backend_startup: bi_open failed!\n" )); +#else Debug( LDAP_DEBUG_ANY, "backend_startup: bi_open failed!\n", 0, 0, 0 ); +#endif + return rc; } @@ -192,9 +256,14 @@ int backend_startup(Backend *be) } if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_CRIT, + "backend_startup: bi_db_open failed!\n" )); +#else Debug( LDAP_DEBUG_ANY, "backend_startup: bi_db_open failed!\n", 0, 0, 0 ); +#endif return rc; } @@ -214,24 +283,37 @@ int backend_startup(Backend *be) } if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_CRIT, + "backend_startup: bi_open %d failed!\n", i )); +#else Debug( LDAP_DEBUG_ANY, "backend_startup: bi_open %d failed!\n", i, 0, 0 ); +#endif return rc; } } /* open each backend database */ for( i = 0; i < nBackendDB; i++ ) { + /* append global access controls */ + acl_append( &backendDB[i].be_acl, global_acl ); + if ( backendDB[i].bd_info->bi_db_open ) { rc = backendDB[i].bd_info->bi_db_open( &backendDB[i] ); } if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_CRIT, + "backend_startup: bi_db_open %d failed!\n", i )); +#else Debug( LDAP_DEBUG_ANY, "backend_startup: bi_db_open %d failed!\n", i, 0, 0 ); +#endif return rc; } } @@ -277,17 +359,21 @@ int backend_shutdown( Backend *be ) /* close each backend database */ for( i = 0; i < nBackendDB; i++ ) { - BackendInfo *bi; - if ( backendDB[i].bd_info->bi_db_close ) { backendDB[i].bd_info->bi_db_close( &backendDB[i] ); } if(rc != 0) { +#ifdef NEW_LOGGING + LDAP_LOG(( "backend", LDAP_LEVEL_NOTICE, + "backend_shutdown: bi_close %s failed!\n", + backendDB[i].be_type )); +#else Debug( LDAP_DEBUG_ANY, "backend_close: bi_close %s failed!\n", - bi->bi_type, 0, 0 ); + backendDB[i].be_type, 0, 0 ); +#endif } } @@ -379,13 +465,14 @@ backend_db_init( be->bd_info = bi; be->be_sizelimit = defsize; be->be_timelimit = deftime; + be->be_dfltaccess = global_default_access; + + be->be_restrictops = global_restrictops; + be->be_requires = global_requires; /* assign a default depth limit for alias deref */ be->be_max_deref_depth = SLAPD_DEFAULT_MAXDEREFDEPTH; - be->be_realm = global_realm != NULL - ? ch_strdup( global_realm ) : NULL; - if(bi->bi_db_init) { rc = bi->bi_db_init( be ); } @@ -413,9 +500,12 @@ be_db_close( void ) } Backend * -select_backend( const char * dn ) +select_backend( + const char * dn, + int manageDSAit ) { int i, j, len, dnlen; + Backend *be = NULL; dnlen = strlen( dn ); for ( i = 0; i < nbackends; i++ ) { @@ -425,31 +515,33 @@ select_backend( const char * dn ) len = strlen( backends[i].be_nsuffix[j] ); if ( len > dnlen ) { + /* suffix is longer than DN */ continue; } - if ( strcmp( backends[i].be_nsuffix[j], - dn + (dnlen - len) ) == 0 ) { - return( &backends[i] ); + + if ( (len < dnlen) && !(DN_SEPARATOR( dn[(dnlen-len)-1] )) ) { + /* make sure we have a separator */ + continue; } - } - } + -#ifdef LDAP_ALLOW_NULL_SEARCH_BASE - /* Add greg@greg.rim.or.jp - * It's quick hack for cheap client - * Some browser offer a NULL base at ldap_search - * - * Should only be used as a last resort. -Kdz - */ - if(dnlen == 0) { - Debug( LDAP_DEBUG_TRACE, - "select_backend: use default backend\n", 0, 0, 0 ); - return( &backends[0] ); + if ( strcmp( backends[i].be_nsuffix[j], &dn[dnlen-len] ) == 0 ) { + if( be == NULL ) { + be = &backends[i]; + + if( manageDSAit && len == dnlen ) { + continue; + } + } else { + be = &backends[i]; + } + return be; + } + } } -#endif /* LDAP_ALLOW_NULL_SEARCH_BASE */ - return( NULL ); + return be; } int @@ -474,7 +566,11 @@ be_isroot( Backend *be, const char *ndn ) { int rc; - if ( ndn == NULL || be->be_root_ndn == NULL ) { + if ( ndn == NULL || *ndn == '\0' ) { + return( 0 ); + } + + if ( be->be_root_ndn == NULL || *be->be_root_ndn == '\0' ) { return( 0 ); } @@ -494,33 +590,51 @@ be_root_dn( Backend *be ) } int -be_isroot_pw( Backend *be, const char *ndn, struct berval *cred ) +be_isroot_pw( Backend *be, + Connection *conn, + const char *ndn, + struct berval *cred ) { int result; if ( ! be_isroot( be, ndn ) ) { - return( 0 ); + return 0; } -#ifdef SLAPD_CRYPT - ldap_pvt_thread_mutex_lock( &crypt_mutex ); + if( be->be_root_pw.bv_len == 0 ) { + return 0; + } + +#if defined( SLAPD_CRYPT ) || defined( SLAPD_SPASSWD ) + ldap_pvt_thread_mutex_lock( &passwd_mutex ); +#ifdef SLAPD_SPASSWD + lutil_passwd_sasl_conn = conn->c_sasl_context; +#endif #endif - result = lutil_passwd( cred->bv_val, be->be_root_pw, NULL ); + result = lutil_passwd( &be->be_root_pw, cred, NULL ); -#ifdef SLAPD_CRYPT - ldap_pvt_thread_mutex_unlock( &crypt_mutex ); +#if defined( SLAPD_CRYPT ) || defined( SLAPD_SPASSWD ) +#ifdef SLAPD_SPASSWD + lutil_passwd_sasl_conn = NULL; +#endif + ldap_pvt_thread_mutex_unlock( &passwd_mutex ); #endif return result == 0; } int -be_entry_release_rw( Backend *be, Entry *e, int rw ) +be_entry_release_rw( + BackendDB *be, + Connection *conn, + Operation *op, + Entry *e, + int rw ) { if ( be->be_release ) { /* free and release entry from backend */ - return be->be_release( be, e, rw ); + return be->be_release( be, conn, op, e, rw ); } else { /* free entry */ entry_free( e ); @@ -577,38 +691,330 @@ backend_connection_destroy( return 0; } +static int +backend_check_controls( + Backend *be, + Connection *conn, + Operation *op, + const char **text ) +{ + LDAPControl **ctrls; + ctrls = op->o_ctrls; + if( ctrls == NULL ) { + return LDAP_SUCCESS; + } + + for( ; *ctrls != NULL ; ctrls++ ) { + if( (*ctrls)->ldctl_iscritical && + !charray_inlist( be->be_controls, (*ctrls)->ldctl_oid ) ) + { + *text = "control unavailable in NamingContext"; + return LDAP_UNAVAILABLE_CRITICAL_EXTENSION; + } + } + + return LDAP_SUCCESS; +} + +int +backend_check_restrictions( + Backend *be, + Connection *conn, + Operation *op, + const void *opdata, + const char **text ) +{ + int rc; + slap_mask_t restrictops; + slap_mask_t requires; + slap_mask_t opflag; + slap_ssf_set_t *ssf; + int updateop = 0; + + if( be ) { + rc = backend_check_controls( be, conn, op, text ); + + if( rc != LDAP_SUCCESS ) { + return rc; + } + + restrictops = be->be_restrictops; + requires = be->be_requires; + ssf = &be->be_ssf_set; + + } else { + restrictops = global_restrictops; + requires = global_requires; + ssf = &global_ssf_set; + } + + switch( op->o_tag ) { + case LDAP_REQ_ADD: + opflag = SLAP_RESTRICT_OP_ADD; + updateop++; + break; + case LDAP_REQ_BIND: + opflag = SLAP_RESTRICT_OP_BIND; + break; + case LDAP_REQ_COMPARE: + opflag = SLAP_RESTRICT_OP_COMPARE; + break; + case LDAP_REQ_DELETE: + updateop++; + opflag = SLAP_RESTRICT_OP_DELETE; + break; + case LDAP_REQ_EXTENDED: + opflag = SLAP_RESTRICT_OP_EXTENDED; + break; + case LDAP_REQ_MODIFY: + updateop++; + opflag = SLAP_RESTRICT_OP_MODIFY; + break; + case LDAP_REQ_RENAME: + updateop++; + opflag = SLAP_RESTRICT_OP_RENAME; + break; + case LDAP_REQ_SEARCH: + opflag = SLAP_RESTRICT_OP_SEARCH; + break; + case LDAP_REQ_UNBIND: + opflag = 0; + break; + default: + *text = "restrict operations internal error"; + return LDAP_OTHER; + } + + if ( op->o_tag != LDAP_REQ_EXTENDED + || strcmp( (const char *) opdata, LDAP_EXOP_START_TLS ) ) + { + /* these checks don't apply to StartTLS */ + + if( op->o_tag == LDAP_REQ_EXTENDED ) { + /* threat other extended operations as update ops */ + updateop++; + } + + if( op->o_transport_ssf < ssf->sss_transport ) { + *text = "transport confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_tls_ssf < ssf->sss_tls ) { + *text = "TLS confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_tag != LDAP_REQ_BIND || opdata == NULL ) { + /* these checks don't apply to SASL bind */ + + if( op->o_sasl_ssf < ssf->sss_sasl ) { + *text = "SASL confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_ssf < ssf->sss_ssf ) { + *text = "confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + } + + if( updateop ) { + if( op->o_transport_ssf < ssf->sss_update_transport ) { + *text = "transport update confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_tls_ssf < ssf->sss_update_tls ) { + *text = "TLS update confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_sasl_ssf < ssf->sss_update_sasl ) { + *text = "SASL update confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_ssf < ssf->sss_update_ssf ) { + *text = "update confidentiality required"; + return LDAP_CONFIDENTIALITY_REQUIRED; + } + + if( op->o_ndn == NULL ) { + *text = "modifications require authentication"; + return LDAP_OPERATIONS_ERROR; + } + } + } + + if ( op->o_tag != LDAP_REQ_BIND && ( op->o_tag != LDAP_REQ_EXTENDED || + strcmp( (const char *) opdata, LDAP_EXOP_START_TLS ) ) ) + { + /* these checks don't apply to Bind or StartTLS */ + + if( requires & SLAP_REQUIRE_STRONG ) { + /* should check mechanism */ + if( op->o_authmech == NULL || + op->o_dn == NULL || *op->o_dn == '\0' ) + { + *text = "strong authentication required"; + return LDAP_STRONG_AUTH_REQUIRED; + } + } + + if( requires & SLAP_REQUIRE_SASL ) { + if( op->o_authmech == NULL || + op->o_dn == NULL || *op->o_dn == '\0' ) + { + *text = "SASL authentication required"; + return LDAP_STRONG_AUTH_REQUIRED; + } + } + + if( requires & SLAP_REQUIRE_AUTHC ) { + if( op->o_dn == NULL || *op->o_dn == '\0' ) { + *text = "authentication required"; + return LDAP_UNWILLING_TO_PERFORM; + } + } + + if( requires & SLAP_REQUIRE_BIND ) { + int version; + ldap_pvt_thread_mutex_lock( &conn->c_mutex ); + version = conn->c_protocol; + ldap_pvt_thread_mutex_unlock( &conn->c_mutex ); + + if( !version ) { + /* no bind has occurred */ + *text = "BIND required"; + return LDAP_OPERATIONS_ERROR; + } + } + + if( requires & SLAP_REQUIRE_LDAP_V3 ) { + if( op->o_protocol < LDAP_VERSION3 ) { + /* no bind has occurred */ + *text = "operation restricted to LDAPv3 clients"; + return LDAP_OPERATIONS_ERROR; + } + } + } + + if( restrictops & opflag ) { + if( restrictops == SLAP_RESTRICT_OP_READS ) { + *text = "read operations restricted"; + } else { + *text = "operation restricted"; + } + return LDAP_UNWILLING_TO_PERFORM; + } + + return LDAP_SUCCESS; +} + +int backend_check_referrals( + Backend *be, + Connection *conn, + Operation *op, + const char *dn, + const char *ndn ) +{ + int rc = LDAP_SUCCESS; + + if( be->be_chk_referrals ) { + const char *text; + + rc = be->be_chk_referrals( be, + conn, op, dn, ndn, &text ); + + if( rc != LDAP_SUCCESS && rc != LDAP_REFERRAL ) { + send_ldap_result( conn, op, rc, + NULL, text, NULL, NULL ); + } + } + + return rc; +} + int backend_group( Backend *be, + Connection *conn, + Operation *op, Entry *target, const char *gr_ndn, const char *op_ndn, - const char *objectclassValue, - const char *groupattrName + ObjectClass *group_oc, + AttributeDescription *group_at ) { - if (be->be_group) - return( be->be_group(be, target, gr_ndn, op_ndn, - objectclassValue, groupattrName) ); - else - return(1); + if( strcmp( target->e_ndn, gr_ndn ) != 0 ) { + /* we won't attempt to send it to a different backend */ + + be = select_backend(gr_ndn, 0); + + if (be == NULL) { + return LDAP_NO_SUCH_OBJECT; + } + } + + if( be->be_group ) { + return be->be_group( be, conn, op, + target, gr_ndn, op_ndn, + group_oc, group_at ); + } + + return LDAP_UNWILLING_TO_PERFORM; } -#ifdef SLAPD_SCHEMA_DN -Attribute *backend_subschemasubentry( Backend *be ) +int +backend_attribute( + Backend *be, + Connection *conn, + Operation *op, + Entry *target, + const char *e_ndn, + AttributeDescription *entry_at, + struct berval ***vals +) { - /* should be backend specific */ - static struct berval ss_val = { - sizeof(SLAPD_SCHEMA_DN)-1, - SLAPD_SCHEMA_DN }; - static struct berval *ss_vals[2] = { &ss_val, NULL }; - static Attribute ss_attr = { - "subschemasubentry", - ss_vals, - SYNTAX_DN | SYNTAX_CIS, - NULL - }; - - return &ss_attr; + if( target == NULL || strcmp( target->e_ndn, e_ndn ) != 0 ) { + /* we won't attempt to send it to a different backend */ + + be = select_backend(e_ndn, 0); + + if (be == NULL) { + return LDAP_NO_SUCH_OBJECT; + } + } + + if( be->be_attribute ) { + return be->be_attribute( be, conn, op, target, e_ndn, + entry_at, vals ); + } + + return LDAP_UNWILLING_TO_PERFORM; } + +Attribute *backend_operational( + Backend *be, + Connection *conn, + Operation *op, + Entry *e ) +{ + Attribute *a = NULL; + +#ifdef SLAPD_SCHEMA_DN + a = ch_malloc( sizeof( Attribute ) ); + a->a_desc = ad_dup( slap_schema.si_ad_subschemaSubentry ); + + /* Should be backend specific */ + a->a_vals = ch_malloc( 2 * sizeof( struct berval * ) ); + a->a_vals[0] = ber_bvstrdup( SLAPD_SCHEMA_DN ); + a->a_vals[1] = NULL; + + a->a_next = NULL; #endif + + return a; +}