From: Howard Chu Date: Mon, 9 May 2005 10:33:43 +0000 (+0000) Subject: More fixes for overlay support. Converted pcache to config table. X-Git-Tag: OPENLDAP_AC_BP~683 X-Git-Url: https://git.sur5r.net/?a=commitdiff_plain;h=1d283c21548c01f676054cab93d0d864f20891cb;p=openldap More fixes for overlay support. Converted pcache to config table. --- diff --git a/servers/slapd/backover.c b/servers/slapd/backover.c index bda4c6cb03..599899ff85 100644 --- a/servers/slapd/backover.c +++ b/servers/slapd/backover.c @@ -72,7 +72,7 @@ over_db_config( slap_overinfo *oi = be->bd_info->bi_private; slap_overinst *on = oi->oi_list; BackendInfo *bi_orig = be->bd_info; - ConfigArgs ca; + ConfigArgs ca = {0}; ConfigTable *ct; int rc = 0; diff --git a/servers/slapd/bconfig.c b/servers/slapd/bconfig.c index b2dc01de7e..1bd6e75ad6 100644 --- a/servers/slapd/bconfig.c +++ b/servers/slapd/bconfig.c @@ -1497,6 +1497,7 @@ config_timelimit(ConfigArgs *c) { static int config_overlay(ConfigArgs *c) { + slap_overinfo *oi; if (c->op == SLAP_CONFIG_EMIT) { return 1; } else if ( c->op == LDAP_MOD_DELETE ) { @@ -1513,6 +1514,8 @@ config_overlay(ConfigArgs *c) { } else if(overlay_config(c->be, c->argv[1])) { return(1); } + oi = (slap_overinfo *)c->be->bd_info; + c->bi = &oi->oi_list->on_bi; return(0); } @@ -3810,6 +3813,20 @@ config_back_db_open( BackendDB *be ) parent = e; ceparent = ce; + /* Create includeFile nodes */ + if ( cfb->cb_config->c_kids ) { + c.depth = 0; + c.private = cfb->cb_config->c_kids; + config_build_includes( &c, ceparent, op, &rs ); + } + +#ifdef SLAPD_MODULES + /* Create Module nodes... */ + if ( modpaths.mp_loads ) { + config_build_modules( &c, ceparent, op, &rs ); + } +#endif + /* Create schema nodes... cn=schema will contain the hardcoded core * schema, read-only. Child objects will contain runtime loaded schema * files. @@ -3817,23 +3834,15 @@ config_back_db_open( BackendDB *be ) rdn = schema_rdn; c.private = NULL; e = config_build_entry( op, &rs, ceparent, &c, &rdn, &CFOC_SCHEMA, NULL ); + ce = e->e_private; - /* Create includeFile nodes and schema nodes for included schema... */ + /* Create schema nodes for included schema... */ if ( cfb->cb_config->c_kids ) { c.depth = 0; c.private = cfb->cb_config->c_kids; config_build_schema_inc( &c, ce, op, &rs ); - c.private = cfb->cb_config->c_kids; - config_build_includes( &c, ceparent, op, &rs ); } -#ifdef SLAPD_MODULES - /* Create Module nodes... */ - if ( modpaths.mp_loads ) { - config_build_modules( &c, ceparent, op, &rs ); - } -#endif - /* Create backend nodes. Skip if they don't provide a cf_table. * There usually aren't any of these. */ @@ -3874,6 +3883,8 @@ config_back_db_open( BackendDB *be ) e = config_build_entry( op, &rs, ceparent, &c, &rdn, &CFOC_DATABASE, be->be_cf_ocs ); ce = e->e_private; + if ( be->be_cf_ocs && be->be_cf_ocs->co_cfadd ) + be->be_cf_ocs->co_cfadd( op, &rs, e, &c ); /* Iterate through overlays */ if ( oi ) { slap_overinst *on; @@ -3888,6 +3899,8 @@ config_back_db_open( BackendDB *be ) c.bi = &on->on_bi; oe = config_build_entry( op, &rs, ce, &c, &rdn, &CFOC_OVERLAY, c.bi->bi_cf_ocs ); + if ( c.bi->bi_cf_ocs && c.bi->bi_cf_ocs->co_cfadd ) + c.bi->bi_cf_ocs->co_cfadd( op, &rs, oe, &c ); } } } diff --git a/servers/slapd/config.c b/servers/slapd/config.c index 14d684d605..851fdae3b9 100644 --- a/servers/slapd/config.c +++ b/servers/slapd/config.c @@ -598,7 +598,7 @@ read_config_file(const char *fname, int depth, ConfigArgs *cf, ConfigTable *cft) goto leave; } - } else if ( c->bi ) { + } else if ( c->bi && !c->be ) { rc = SLAP_CONF_UNKNOWN; if ( c->bi->bi_cf_ocs ) { ct = config_find_keyword( c->bi->bi_cf_ocs->co_table, c ); diff --git a/servers/slapd/overlays/pcache.c b/servers/slapd/overlays/pcache.c index 8b9a479632..b6f433b5cc 100644 --- a/servers/slapd/overlays/pcache.c +++ b/servers/slapd/overlays/pcache.c @@ -32,6 +32,8 @@ #include "lutil.h" #include "ldap_rq.h" +#include "config.h" + /* query cache structs */ /* query */ @@ -1484,68 +1486,292 @@ consistency_check( #define MAX_ATTR_SETS 500 -static void find_supersets( struct attr_set* attr_sets, int numsets ); -static int compare_sets( struct attr_set* setA, int, int ); + +/* + * compares two sets of attributes (indices i and j) + * returns 0: if neither set is contained in the other set + * 1: if set i is contained in set j + * 2: if set j is contained in set i + * 3: the sets are equivalent + */ static int -proxy_cache_config( - BackendDB *be, - const char *fname, - int lineno, - int argc, - char **argv -) +compare_sets(struct attr_set* set, int i, int j) { - slap_overinst *on = (slap_overinst *)be->bd_info; + int k,l,numI,numJ; + int common=0; + int result=0; + + if (( set[i].attrs == NULL ) && ( set[j].attrs == NULL )) + return 3; + + if ( set[i].attrs == NULL ) + return 2; + + if ( set[j].attrs == NULL ) + return 1; + + numI = set[i].count; + numJ = set[j].count; + + for ( l=0; l < numI; l++ ) { + for ( k = 0; k < numJ; k++ ) { + if ( strcmp( set[i].attrs[l].an_name.bv_val, + set[j].attrs[k].an_name.bv_val ) == 0 ) + common++; + } + } + + if ( common == numI ) + result = 1; + + if ( common == numJ ) + result += 2; + + return result; +} + +static void +find_supersets ( struct attr_set* attr_sets, int numsets ) +{ + int num[MAX_ATTR_SETS]; + int i, j, res; + int* id_array; + for ( i = 0; i < MAX_ATTR_SETS; i++ ) + num[i] = 0; + + for ( i = 0; i < numsets; i++ ) { + attr_sets[i].ID_array = (int*) ch_malloc( sizeof( int ) ); + attr_sets[i].ID_array[0] = -1; + } + + for ( i = 0; i < numsets; i++ ) { + for ( j=i+1; j < numsets; j++ ) { + res = compare_sets( attr_sets, i, j ); + switch ( res ) { + case 0: + break; + case 3: + case 1: + id_array = attr_sets[i].ID_array; + attr_sets[i].ID_array = (int *) ch_realloc( id_array, + ( num[i] + 2 ) * sizeof( int )); + attr_sets[i].ID_array[num[i]] = j; + attr_sets[i].ID_array[num[i]+1] = -1; + num[i]++; + if (res == 1) + break; + case 2: + id_array = attr_sets[j].ID_array; + attr_sets[j].ID_array = (int *) ch_realloc( id_array, + ( num[j] + 2 ) * sizeof( int )); + attr_sets[j].ID_array[num[j]] = i; + attr_sets[j].ID_array[num[j]+1] = -1; + num[j]++; + break; + } + } + } +} + +enum { + PC_MAIN = 1, + PC_ATTR, + PC_TEMP, + PC_RESP +}; + +static ConfigDriver pc_cf_gen; +static ConfigLDAPadd pc_ldadd; +static ConfigCfAdd pc_cfadd; + +static ConfigTable pccfg[] = { + { "proxycache", "backend> " + " ce_type != Cft_Overlay || !p->ce_bi || + p->ce_bi->bi_cf_ocs != pcocs ) + return LDAP_CONSTRAINT_VIOLATION; + + on = (slap_overinst *)p->ce_bi; + cm = on->on_bi.bi_private; + ca->be = &cm->db; + return LDAP_SUCCESS; +} + +static int +pc_cfadd( Operation *op, SlapReply *rs, Entry *p, ConfigArgs *ca ) +{ + CfEntryInfo *pe = p->e_private; + slap_overinst *on = (slap_overinst *)pe->ce_bi; + cache_manager *cm = on->on_bi.bi_private; + struct berval bv; + + /* FIXME: should not hardcode "olcDatabase" here */ + bv.bv_len = sprintf( ca->msg, "olcDatabase=%s", cm->db.bd_info->bi_type ); + bv.bv_val = ca->msg; + ca->be = &cm->db; + config_build_entry( op, rs, pe, ca, &bv, cm->db.bd_info->bi_cf_ocs, + &pcocs[1] ); + + return 0; +} + +static int +pc_cf_gen( ConfigArgs *c ) +{ + slap_overinst *on = (slap_overinst *)c->bi; cache_manager* cm = on->on_bi.bi_private; query_manager* qm = cm->qm; QueryTemplate* temp; AttributeName* attr_name; AttributeName* attrarray; const char* text=NULL; - char *argv0 = NULL; - - int index, i; - int num; - int rc = 0; - - if ( strncasecmp( argv[0], "proxycache-", STRLENOF( "proxycache-" ) ) == 0 ) { - argv0 = argv[0] + STRLENOF( "proxycache-" ); - } else { - argv0 = argv[0]; + int i, num, rc = 0; + char *ptr; + + if ( c->op == SLAP_CONFIG_EMIT ) { + struct berval bv; + switch( c->type ) { + case PC_MAIN: + bv.bv_len = sprintf( c->msg, "%s %d %d %d %d", + cm->db.bd_info->bi_type, cm->max_entries, cm->numattrsets, + cm->num_entries_limit, cm->cc_period ); + bv.bv_val = c->msg; + value_add_one( &c->rvalue_vals, &bv ); + break; + case PC_ATTR: + for (i=0; inumattrsets; i++) { + if ( !qm->attr_sets[i].count ) continue; + + bv.bv_len = sprintf( c->msg, "%d", i ); + + /* count the attr length */ + for ( attr_name = qm->attr_sets[i].attrs; + attr_name->an_name.bv_val; attr_name++ ) + bv.bv_len += attr_name->an_name.bv_len + 1; + + bv.bv_val = ch_malloc( bv.bv_len+1 ); + ptr = lutil_strcopy( bv.bv_val, c->msg ); + for ( attr_name = qm->attr_sets[i].attrs; + attr_name->an_name.bv_val; attr_name++ ) { + *ptr++ = ' '; + ptr = lutil_strcopy( ptr, attr_name->an_name.bv_val ); + } + ber_bvarray_add( &c->rvalue_vals, &bv ); + } + if ( !c->rvalue_vals ) + rc = 1; + break; + case PC_TEMP: + for (i=0; inumtemplates; i++) { + bv.bv_len = sprintf( c->msg, " %d %d", + qm->templates[i].attr_set_index, + qm->templates[i].ttl ); + bv.bv_len += qm->templates[i].querystr.bv_len + 2; + bv.bv_val = ch_malloc( bv.bv_len+1 ); + ptr = bv.bv_val; + *ptr++ = '"'; + ptr = lutil_strcopy( ptr, qm->templates[i].querystr.bv_val ); + *ptr++ = '"'; + strcpy( ptr, c->msg ); + ber_bvarray_add( &c->rvalue_vals, &bv ); + } + if ( !c->rvalue_vals ) + rc = 1; + break; + case PC_RESP: + if ( cm->response_cb == PCACHE_RESPONSE_CB_HEAD ) { + bv.bv_val = "head"; + bv.bv_len = STRLENOF("head"); + } else { + bv.bv_val = "tail"; + bv.bv_len = STRLENOF("tail"); + } + value_add_one( &c->rvalue_vals, &bv ); + break; + } + return rc; + } else if ( c->op == LDAP_MOD_DELETE ) { + return 1; /* FIXME */ +#if 0 + switch( c->type ) { + case PC_ATTR: + case PC_TEMP: + } + return rc; +#endif } - if ( strcasecmp( argv0, "proxycache" ) == 0 ) { - if ( argc < 6 ) { - fprintf( stderr, "%s: line %d: missing arguments in \"proxycache" - " " - "\"\n", fname, lineno ); + switch( c->type ) { + case PC_MAIN: + cm->numattrsets = atoi( c->argv[3] ); + if ( cm->numattrsets > MAX_ATTR_SETS ) { + sprintf( c->msg, "numattrsets must be <= %d", MAX_ATTR_SETS ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); return( 1 ); } - - cm->db.bd_info = backend_info( argv[1] ); + cm->db.bd_info = backend_info( c->argv[1] ); if ( !cm->db.bd_info ) { - fprintf( stderr, "%s: line %d: backend %s unknown\n", - fname, lineno, argv[1] ); + sprintf( c->msg, "unknown backend type" ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); + return( 1 ); + } + if ( cm->db.bd_info->bi_db_init( &cm->db ) ) { + sprintf( c->msg, "backend %s init failed", c->argv[1] ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); return( 1 ); } - if ( cm->db.bd_info->bi_db_init( &cm->db ) ) return( 1 ); /* This type is in use, needs to be opened */ cm->db.bd_info->bi_nDB++; - cm->max_entries = atoi( argv[2] ); + cm->max_entries = atoi( c->argv[2] ); - cm->numattrsets = atoi( argv[3] ); - if ( cm->numattrsets > MAX_ATTR_SETS ) { - fprintf( stderr, "%s: line %d: numattrsets must be <= %d\n", - fname, lineno, MAX_ATTR_SETS ); - return( 1 ); - } - - cm->num_entries_limit = atoi( argv[4] ); - cm->cc_period = atoi( argv[5] ); - Debug( LDAP_DEBUG_ANY, + cm->num_entries_limit = atoi( c->argv[4] ); + cm->cc_period = atoi( c->argv[5] ); + Debug( LDAP_DEBUG_TRACE, "Total # of attribute sets to be cached = %d\n", cm->numattrsets, 0, 0 ); qm->attr_sets = ( struct attr_set * )ch_malloc( cm->numattrsets * @@ -1553,50 +1779,41 @@ proxy_cache_config( for ( i = 0; i < cm->numattrsets; i++ ) { qm->attr_sets[i].attrs = NULL; } - - } else if ( strcasecmp( argv0, "proxyattrset" ) == 0 ) { - if ( argc < 3 ) { - fprintf( stderr, "%s: line %d: missing arguments in \"proxyattrset " - " \"\n", fname, lineno ); - return( 1 ); - } - Debug( LDAP_DEBUG_ANY, "Attribute Set # %d\n", - atoi( argv[1] ), 0, 0 ); - if (atoi(argv[1]) >= cm->numattrsets) { - fprintf( stderr, "%s; line %d index out of bounds \n", - fname, lineno ); + break; + case PC_ATTR: + num = atoi( c->argv[1] ); + if (num >= cm->numattrsets) { + sprintf( c->msg, "attrset index out of bounds" ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); return 1; } - index = atoi( argv[1] ); - if ( argv[2] && strcmp( argv[2], "*" ) ) { - qm->attr_sets[index].count = argc - 2; - qm->attr_sets[index].attrs = (AttributeName*)ch_malloc( - (argc-1) * sizeof( AttributeName )); - attr_name = qm->attr_sets[index].attrs; - for ( i = 2; i < argc; i++ ) { - Debug( LDAP_DEBUG_ANY, "\t %s\n", - argv[i], 0, 0 ); - ber_str2bv( argv[i], 0, 1, - &attr_name->an_name); + if ( c->argv[2] && strcmp( c->argv[2], "*" ) ) { + qm->attr_sets[num].count = c->argc - 2; + qm->attr_sets[num].attrs = (AttributeName*)ch_malloc( + (c->argc-1) * sizeof( AttributeName )); + attr_name = qm->attr_sets[num].attrs; + for ( i = 2; i < c->argc; i++ ) { + ber_str2bv( c->argv[i], 0, 1, &attr_name->an_name); attr_name->an_desc = NULL; - slap_bv2ad( &attr_name->an_name, - &attr_name->an_desc, &text ); + if ( slap_bv2ad( &attr_name->an_name, + &attr_name->an_desc, &text )) { + strcpy( c->msg, text ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); + ch_free( qm->attr_sets[num].attrs ); + qm->attr_sets[num].attrs = NULL; + qm->attr_sets[num].count = 0; + return 1; + } attr_name++; attr_name->an_name.bv_val = NULL; attr_name->an_name.bv_len = 0; } } - } else if ( strcasecmp( argv0, "proxytemplate" ) == 0 ) { - if ( argc != 4 ) { - fprintf( stderr, "%s: line %d: missing argument(s) in " - "\"proxytemplate \" line\n", - fname, lineno ); - return( 1 ); - } - if (( i = atoi( argv[2] )) >= cm->numattrsets ) { - Debug( LDAP_DEBUG_ANY, - "%s: line %d, template index invalid\n", - fname, lineno, 0 ); + break; + case PC_TEMP: + if (( i = atoi( c->argv[2] )) >= cm->numattrsets ) { + sprintf( c->msg, "template index invalid" ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); return 1; } num = cm->numtemplates; @@ -1607,63 +1824,60 @@ proxy_cache_config( temp = qm->templates + num; ldap_pvt_thread_rdwr_init( &temp->t_rwlock ); temp->query = temp->query_last = NULL; - temp->ttl = atoi( argv[3] ); + temp->ttl = atoi( c->argv[3] ); temp->no_of_queries = 0; - if ( argv[1] == NULL ) { - Debug( LDAP_DEBUG_ANY, - "Templates string not specified " - "for template %d\n", num, 0, 0 ); - return 1; - } - ber_str2bv( argv[1], 0, 1, &temp->querystr ); - Debug( LDAP_DEBUG_ANY, "Template:\n", 0, 0, 0 ); - Debug( LDAP_DEBUG_ANY, " query template: %s\n", + + ber_str2bv( c->argv[1], 0, 1, &temp->querystr ); + Debug( LDAP_DEBUG_TRACE, "Template:\n", 0, 0, 0 ); + Debug( LDAP_DEBUG_TRACE, " query template: %s\n", temp->querystr.bv_val, 0, 0 ); temp->attr_set_index = i; - Debug( LDAP_DEBUG_ANY, " attributes: \n", 0, 0, 0 ); + Debug( LDAP_DEBUG_TRACE, " attributes: \n", 0, 0, 0 ); if ( ( attrarray = qm->attr_sets[i].attrs ) != NULL ) { for ( i=0; attrarray[i].an_name.bv_val; i++ ) - Debug( LDAP_DEBUG_ANY, "\t%s\n", + Debug( LDAP_DEBUG_TRACE, "\t%s\n", attrarray[i].an_name.bv_val, 0, 0 ); } temp++; temp->querystr.bv_val = NULL; cm->numtemplates++; - - } else if ( strcasecmp( argv0, "response-callback" ) == 0 ) { - /* set to "tail" to put the response callback - * at the end of the callback list; this is required - * in case other overlays are present, so that the - * final entry is cached. */ - - if ( argc < 2 ) { - Debug( LDAP_DEBUG_ANY, - "missing specifier for \"response-callback {head(default)|tail}\" " - "callback position\n", 0, 0, 0 ); - return 1; - } - - if ( strcasecmp( argv[1], "head" ) == 0 ) { + break; + case PC_RESP: + if ( strcasecmp( c->argv[1], "head" ) == 0 ) { cm->response_cb = PCACHE_RESPONSE_CB_HEAD; - } else if ( strcasecmp( argv[1], "tail" ) == 0 ) { + } else if ( strcasecmp( c->argv[1], "tail" ) == 0 ) { cm->response_cb = PCACHE_RESPONSE_CB_TAIL; } else { - Debug( LDAP_DEBUG_ANY, - "unknown specifier %s for \"response-callback {head(default)|tail}\" " - "callback position\n", argv[1], 0, 0 ); + sprintf( c->msg, "unknown specifier" ); + Debug( LDAP_DEBUG_ANY, "%s: %s\n", c->log, c->msg, 0 ); return 1; } + break; } - /* anything else */ - else { - rc = cm->db.bd_info->bi_db_config( &cm->db, fname, lineno, argc, argv ); - } - return rc; } +static int +proxy_cache_config( + BackendDB *be, + const char *fname, + int lineno, + int argc, + char **argv +) +{ + slap_overinst *on = (slap_overinst *)be->bd_info; + cache_manager* cm = on->on_bi.bi_private; + + /* Something for the cache database? */ + if ( cm->db.bd_info && cm->db.bd_info->bi_db_config ) + return cm->db.bd_info->bi_db_config( &cm->db, fname, lineno, + argc, argv ); + return SLAP_CONF_UNKNOWN; +} + static int proxy_cache_init( BackendDB *be @@ -1722,9 +1936,9 @@ proxy_cache_open( /* consistency check (add more...) */ for ( i = 0; i < cm->numattrsets; i++ ) { if ( cm->qm->attr_sets[i].attrs == NULL ) { - fprintf( stderr, "proxy_cache_open(): " + Debug( LDAP_DEBUG_ANY, "proxy_cache_open(): " "attr set %d (of %d) missing\n", - i, cm->numattrsets ); + i, cm->numattrsets, 0 ); return 1; } } @@ -1749,12 +1963,12 @@ proxy_cache_open( if ( BER_BVISNULL( &cm->db.be_rootndn ) || BER_BVISEMPTY( &cm->db.be_rootndn ) ) { - fprintf( stderr, "proxy_cache_open(): " + Debug( LDAP_DEBUG_ANY, "proxy_cache_open(): " "underlying database of type \"%s\"\n" " serving naming context \"%s\"\n" " has no \"rootdn\", required by \"proxycache\".\n", on->on_info->oi_orig->bi_type, - cm->db.be_suffix[0].bv_val ); + cm->db.be_suffix[0].bv_val, 0 ); return 1; } } @@ -1825,93 +2039,6 @@ proxy_cache_destroy( return rc; } -static void -find_supersets ( struct attr_set* attr_sets, int numsets ) -{ - int num[MAX_ATTR_SETS]; - int i, j, res; - int* id_array; - for ( i = 0; i < MAX_ATTR_SETS; i++ ) - num[i] = 0; - - for ( i = 0; i < numsets; i++ ) { - attr_sets[i].ID_array = (int*) ch_malloc( sizeof( int ) ); - attr_sets[i].ID_array[0] = -1; - } - - for ( i = 0; i < numsets; i++ ) { - for ( j=i+1; j < numsets; j++ ) { - res = compare_sets( attr_sets, i, j ); - switch ( res ) { - case 0: - break; - case 3: - case 1: - id_array = attr_sets[i].ID_array; - attr_sets[i].ID_array = (int *) ch_realloc( id_array, - ( num[i] + 2 ) * sizeof( int )); - attr_sets[i].ID_array[num[i]] = j; - attr_sets[i].ID_array[num[i]+1] = -1; - num[i]++; - if (res == 1) - break; - case 2: - id_array = attr_sets[j].ID_array; - attr_sets[j].ID_array = (int *) ch_realloc( id_array, - ( num[j] + 2 ) * sizeof( int )); - attr_sets[j].ID_array[num[j]] = i; - attr_sets[j].ID_array[num[j]+1] = -1; - num[j]++; - break; - } - } - } -} - -/* - * compares two sets of attributes (indices i and j) - * returns 0: if neither set is contained in the other set - * 1: if set i is contained in set j - * 2: if set j is contained in set i - * 3: the sets are equivalent - */ - -static int -compare_sets(struct attr_set* set, int i, int j) -{ - int k,l,numI,numJ; - int common=0; - int result=0; - - if (( set[i].attrs == NULL ) && ( set[j].attrs == NULL )) - return 3; - - if ( set[i].attrs == NULL ) - return 2; - - if ( set[j].attrs == NULL ) - return 1; - - numI = set[i].count; - numJ = set[j].count; - - for ( l=0; l < numI; l++ ) { - for ( k = 0; k < numJ; k++ ) { - if ( strcmp( set[i].attrs[l].an_name.bv_val, - set[j].attrs[k].an_name.bv_val ) == 0 ) - common++; - } - } - - if ( common == numI ) - result = 1; - - if ( common == numJ ) - result += 2; - - return result; -} - static slap_overinst proxy_cache; int pcache_init() @@ -1923,8 +2050,9 @@ int pcache_init() at = ldap_str2attributetype( queryid_schema, &code, &err, LDAP_SCHEMA_ALLOW_ALL ); if ( !at ) { - fprintf( stderr, "AttributeType Load failed %s %s\n", - ldap_scherr2str(code), err ); + Debug( LDAP_DEBUG_ANY, + "pcache_init: ldap_str2attributetype failed %s %s\n", + ldap_scherr2str(code), err, 0 ); return code; } code = at_add( at, 0, NULL, &err ); @@ -1933,8 +2061,9 @@ int pcache_init() } ldap_memfree( at ); if ( code ) { - fprintf( stderr, "AttributeType Load failed %s %s\n", - scherr2str(code), err ); + Debug( LDAP_DEBUG_ANY, + "pcache_init: at_add failed %s %s\n", + scherr2str(code), err, 0 ); return code; } @@ -1946,6 +2075,11 @@ int pcache_init() proxy_cache.on_bi.bi_db_destroy = proxy_cache_destroy; proxy_cache.on_bi.bi_op_search = proxy_cache_search; + proxy_cache.on_bi.bi_cf_ocs = pcocs; + + code = config_register_schema( pccfg, pcocs ); + if ( code ) return code; + return overlay_register( &proxy_cache ); }