X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fbackglue.c;h=0686adae32108a7b782d8b4a11cff08eaf6bbe56;hb=329bd66d6ab650e052929af9ccc35bb7416bd87d;hp=b2665549b07810dccf4057f2985b9b8d419a6c56;hpb=b623e4495b0d119cc81f56a66c0da499ccb89a03;p=openldap diff --git a/servers/slapd/backglue.c b/servers/slapd/backglue.c index b2665549b0..0686adae32 100644 --- a/servers/slapd/backglue.c +++ b/servers/slapd/backglue.c @@ -1,8 +1,17 @@ /* backglue.c - backend glue routines */ /* $OpenLDAP$ */ -/* - * Copyright 2001-2002 The OpenLDAP Foundation, All Rights Reserved. - * COPYING RESTRICTIONS APPLY, see COPYRIGHT file +/* This work is part of OpenLDAP Software . + * + * Copyright 2001-2003 The OpenLDAP Foundation. + * All rights reserved. + * + * 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 + * . */ /* @@ -29,6 +38,7 @@ #include +#include #include #define SLAPD_TOOLS @@ -40,7 +50,8 @@ typedef struct gluenode { } gluenode; typedef struct glueinfo { - BackendDB *be; + BackendInfo bi; + BackendDB bd; int nodes; gluenode n[1]; } glueinfo; @@ -48,6 +59,8 @@ typedef struct glueinfo { static int glueMode; static BackendDB *glueBack; +static slap_response glue_back_response; + /* Just like select_backend, but only for our backends */ static BackendDB * glue_back_select ( @@ -55,7 +68,7 @@ glue_back_select ( const char *dn ) { - glueinfo *gi = (glueinfo *) be->be_private; + glueinfo *gi = (glueinfo *) be->bd_info; struct berval bv; int i; @@ -114,7 +127,7 @@ glue_back_db_open ( BackendDB *be ) { - glueinfo *gi = (glueinfo *)be->be_private; + glueinfo *gi = (glueinfo *) be->bd_info; static int glueOpened = 0; int rc = 0; @@ -122,10 +135,10 @@ glue_back_db_open ( glueOpened = 1; - gi->be->be_acl = be->be_acl; + gi->bd.be_acl = be->be_acl; - if (gi->be->bd_info->bi_db_open) - rc = gi->be->bd_info->bi_db_open(gi->be); + if (gi->bd.bd_info->bi_db_open) + rc = gi->bd.bd_info->bi_db_open(&gi->bd); return rc; } @@ -135,7 +148,7 @@ glue_back_db_close ( BackendDB *be ) { - glueinfo *gi = (glueinfo *)be->be_private; + glueinfo *gi = (glueinfo *) be->bd_info; static int glueClosed = 0; if (glueClosed) return 0; @@ -143,8 +156,8 @@ glue_back_db_close ( glueClosed = 1; /* Close the master */ - if (gi->be->bd_info->bi_db_close) - gi->be->bd_info->bi_db_close( gi->be ); + if (gi->bd.bd_info->bi_db_close) + gi->bd.bd_info->bi_db_close( &gi->bd ); return 0; } @@ -154,179 +167,133 @@ glue_back_db_destroy ( BackendDB *be ) { - glueinfo *gi = (glueinfo *)be->be_private; + glueinfo *gi = (glueinfo *) be->bd_info; - if (gi->be->bd_info->bi_db_destroy) - gi->be->bd_info->bi_db_destroy( gi->be ); - free (gi->be); + if (gi->bd.bd_info->bi_db_destroy) + gi->bd.bd_info->bi_db_destroy( &gi->bd ); free (gi); return 0; } typedef struct glue_state { int err; - int nentries; + int is_slimit; + int slimit; int matchlen; char *matched; int nrefs; BerVarray refs; - slap_callback *prevcb; } glue_state; -static void -glue_back_response ( - Connection *conn, - Operation *op, - ber_tag_t tag, - ber_int_t msgid, - ber_int_t err, - const char *matched, - const char *text, - BerVarray ref, - const char *resoid, - struct berval *resdata, - struct berval *sasldata, - LDAPControl **ctrls -) +static int +glue_back_response ( Operation *op, SlapReply *rs ) { glue_state *gs = op->o_callback->sc_private; - if (err == LDAP_SUCCESS || gs->err != LDAP_SUCCESS) - gs->err = err; - if (gs->err == LDAP_SUCCESS && gs->matched) { - free (gs->matched); - gs->matchlen = 0; - } - if (gs->err != LDAP_SUCCESS && matched) { - int len; - len = strlen (matched); - if (len > gs->matchlen) { - if (gs->matched) - free (gs->matched); - gs->matched = ch_strdup (matched); - gs->matchlen = len; + switch(rs->sr_type) { + case REP_SEARCH: + if ( gs->is_slimit && rs->sr_nentries >= gs->slimit ) { + gs->err = LDAP_SIZELIMIT_EXCEEDED; + return -1; } - } - if (ref) { - int i, j, k; - BerVarray new; - - for (i=0; ref[i].bv_val; i++); - - j = gs->nrefs; - if (!j) { - new = ch_malloc ((i+1)*sizeof(struct berval)); - } else { - new = ch_realloc(gs->refs, - (j+i+1)*sizeof(struct berval)); + /* fallthru */ + case REP_SEARCHREF: + return SLAP_CB_CONTINUE; + + default: + if ( gs->is_slimit && rs->sr_err == LDAP_SIZELIMIT_EXCEEDED + && rs->sr_nentries >= gs->slimit ) { + gs->err = LDAP_SIZELIMIT_EXCEEDED; + return -1; } - for (k=0; ksr_err == LDAP_SUCCESS || gs->err != LDAP_SUCCESS) { + gs->err = rs->sr_err; } - new[j].bv_val = NULL; - gs->nrefs = j; - gs->refs = new; - } -} - -static void -glue_back_sresult ( - Connection *c, - Operation *op, - ber_int_t err, - const char *matched, - const char *text, - BerVarray refs, - LDAPControl **ctrls, - int nentries -) -{ - glue_state *gs = op->o_callback->sc_private; - - gs->nentries += nentries; - glue_back_response (c, op, 0, 0, err, matched, text, refs, - NULL, NULL, NULL, ctrls); -} + if (gs->err == LDAP_SUCCESS && gs->matched) { + ch_free (gs->matched); + gs->matched = NULL; + gs->matchlen = 0; + } + if (gs->err != LDAP_SUCCESS && rs->sr_matched) { + int len; + len = strlen (rs->sr_matched); + if (len > gs->matchlen) { + if (gs->matched) + ch_free (gs->matched); + gs->matched = ch_strdup (rs->sr_matched); + gs->matchlen = len; + } + } + if (rs->sr_ref) { + int i, j, k; + BerVarray new; -static int -glue_back_sendentry ( - BackendDB *be, - Connection *c, - Operation *op, - Entry *e, - AttributeName *an, - int ao, - LDAPControl **ctrls -) -{ - slap_callback *tmp = op->o_callback; - glue_state *gs = tmp->sc_private; - int rc; + for (i=0; rs->sr_ref[i].bv_val; i++); - op->o_callback = gs->prevcb; - if (op->o_callback && op->o_callback->sc_sendentry) { - rc = op->o_callback->sc_sendentry(be, c, op, e, an, ao, ctrls); - } else { - rc = send_search_entry(be, c, op, e, an, ao, ctrls); + j = gs->nrefs; + if (!j) { + new = ch_malloc ((i+1)*sizeof(struct berval)); + } else { + new = ch_realloc(gs->refs, + (j+i+1)*sizeof(struct berval)); + } + for (k=0; ksr_ref[k] ); + } + new[j].bv_val = NULL; + gs->nrefs = j; + gs->refs = new; + } } - op->o_callback = tmp; - return rc; + return 0; } static int -glue_back_search ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - int scope, - int deref, - int slimit, - int tlimit, - Filter *filter, - struct berval *filterstr, - AttributeName *attrs, - int attrsonly -) +glue_back_search ( Operation *op, SlapReply *rs ) { - glueinfo *gi = (glueinfo *)b0->be_private; - BackendDB *be; - int i, rc = 0, t2limit = 0, s2limit = 0; + BackendDB *b0 = op->o_bd; + glueinfo *gi = (glueinfo *) b0->bd_info; + int i; long stoptime = 0; - glue_state gs = {0}; - slap_callback cb; + glue_state gs = {0, 0, 0, 0, NULL, 0, NULL}; + slap_callback cb = { NULL, glue_back_response, NULL, NULL }; + int scope0, slimit0, tlimit0; + struct berval dn, ndn; + + gs.is_slimit = ( op->ors_slimit > 0 ); - cb.sc_response = glue_back_response; - cb.sc_sresult = glue_back_sresult; - cb.sc_sendentry = glue_back_sendentry; cb.sc_private = &gs; - gs.prevcb = op->o_callback; + cb.sc_next = op->o_callback; - if (tlimit) { - stoptime = slap_get_time () + tlimit; + if (op->ors_tlimit) { + stoptime = slap_get_time () + op->ors_tlimit; } - switch (scope) { + switch (op->ors_scope) { case LDAP_SCOPE_BASE: - be = glue_back_select (b0, ndn->bv_val); + op->o_bd = glue_back_select (b0, op->o_req_ndn.bv_val); - if (be && be->be_search) { - rc = be->be_search (be, conn, op, dn, ndn, scope, - deref, slimit, tlimit, filter, filterstr, - attrs, attrsonly); + if (op->o_bd && op->o_bd->be_search) { + rs->sr_err = op->o_bd->be_search( op, rs ); } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, - "No search target found", NULL, NULL); + send_ldap_error(op, rs, LDAP_UNWILLING_TO_PERFORM, + "No search target found"); } - return rc; + return rs->sr_err; case LDAP_SCOPE_ONELEVEL: case LDAP_SCOPE_SUBTREE: + case LDAP_SCOPE_SUBORDINATE: /* FIXME */ op->o_callback = &cb; - rc = gs.err = LDAP_UNWILLING_TO_PERFORM; + rs->sr_err = gs.err = LDAP_UNWILLING_TO_PERFORM; + scope0 = op->ors_scope; + if ( gs.is_slimit ) { + slimit0 = gs.slimit = op->ors_slimit; + } + tlimit0 = op->ors_tlimit; + dn = op->o_req_dn; + ndn = op->o_req_ndn; /* * Execute in reverse order, most general first @@ -334,322 +301,89 @@ glue_back_search ( for (i = gi->nodes-1; i >= 0; i--) { if (!gi->n[i].be || !gi->n[i].be->be_search) continue; - if (tlimit) { - t2limit = stoptime - slap_get_time (); - if (t2limit <= 0) { - rc = gs.err = LDAP_TIMELIMIT_EXCEEDED; + if (tlimit0) { + op->ors_tlimit = stoptime - slap_get_time (); + if (op->ors_tlimit <= 0) { + rs->sr_err = gs.err = LDAP_TIMELIMIT_EXCEEDED; break; } } - if (slimit) { - s2limit = slimit - gs.nentries; - if (s2limit <= 0) { - rc = gs.err = LDAP_SIZELIMIT_EXCEEDED; + if ( gs.is_slimit ) { + op->ors_slimit = slimit0 - rs->sr_nentries; + if (op->ors_slimit < 0) { + rs->sr_err = gs.err = LDAP_SIZELIMIT_EXCEEDED; break; } } - rc = 0; + rs->sr_err = 0; /* * check for abandon */ if (op->o_abandon) { goto done; } - be = gi->n[i].be; - if (scope == LDAP_SCOPE_ONELEVEL && - dn_match(&gi->n[i].pdn, ndn)) { - rc = be->be_search (be, conn, op, - &be->be_suffix[0], &be->be_nsuffix[0], - LDAP_SCOPE_BASE, deref, - s2limit, t2limit, filter, filterstr, - attrs, attrsonly); - - } else if (scope == LDAP_SCOPE_SUBTREE && - dnIsSuffix(&be->be_nsuffix[0], ndn)) { - rc = be->be_search (be, conn, op, - &be->be_suffix[0], &be->be_nsuffix[0], - scope, deref, - s2limit, t2limit, filter, filterstr, - attrs, attrsonly); - - } else if (dnIsSuffix(ndn, &be->be_nsuffix[0])) { - rc = be->be_search (be, conn, op, dn, ndn, - scope, deref, - s2limit, t2limit, filter, filterstr, - attrs, attrsonly); + op->o_bd = gi->n[i].be; + if (scope0 == LDAP_SCOPE_ONELEVEL && + dn_match(&gi->n[i].pdn, &ndn)) + { + op->ors_scope = LDAP_SCOPE_BASE; + op->o_req_dn = op->o_bd->be_suffix[0]; + op->o_req_ndn = op->o_bd->be_nsuffix[0]; + rs->sr_err = op->o_bd->be_search(op, rs); + + } else if (scope0 == LDAP_SCOPE_SUBTREE && + dnIsSuffix(&op->o_bd->be_nsuffix[0], &ndn)) + { + op->o_req_dn = op->o_bd->be_suffix[0]; + op->o_req_ndn = op->o_bd->be_nsuffix[0]; + rs->sr_err = op->o_bd->be_search( op, rs ); + + } else if (dnIsSuffix(&ndn, &op->o_bd->be_nsuffix[0])) { + rs->sr_err = op->o_bd->be_search( op, rs ); + } + + switch ( gs.err ) { + + /* + * Add errors that should result in dropping + * the search + */ + case LDAP_SIZELIMIT_EXCEEDED: + case LDAP_TIMELIMIT_EXCEEDED: + case LDAP_ADMINLIMIT_EXCEEDED: + goto end_of_loop; + + default: + break; } } +end_of_loop:; + op->ors_scope = scope0; + if ( gs.is_slimit ) { + op->ors_slimit = slimit0; + } + op->ors_tlimit = tlimit0; + op->o_req_dn = dn; + op->o_req_ndn = ndn; + break; } - op->o_callback = gs.prevcb; + op->o_callback = cb.sc_next; + rs->sr_err = gs.err; + rs->sr_matched = gs.matched; + rs->sr_ref = gs.refs; - send_search_result (conn, op, gs.err, gs.matched, NULL, - gs.refs, NULL, gs.nentries); + send_ldap_result( op, rs ); done: + op->o_bd = b0; if (gs.matched) free (gs.matched); if (gs.refs) ber_bvarray_free(gs.refs); - return rc; -} - -static int -glue_back_bind ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - int method, - struct berval *cred, - struct berval *edn -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_bind) { - rc = be->be_bind (be, conn, op, dn, ndn, method, cred, edn); - - if( rc == LDAP_SUCCESS ) { - ldap_pvt_thread_mutex_lock( &conn->c_mutex ); - if( conn->c_authz_backend == NULL ) { - conn->c_authz_backend = be; - } - ldap_pvt_thread_mutex_unlock( &conn->c_mutex ); - } - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, "No bind target found", - NULL, NULL); - } - return rc; -} - -static int -glue_back_compare ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - AttributeAssertion *ava -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_compare) { - rc = be->be_compare (be, conn, op, dn, ndn, ava); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, "No compare target found", - NULL, NULL); - } - return rc; -} - -static int -glue_back_modify ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - Modifications *mod -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_modify) { - rc = be->be_modify (be, conn, op, dn, ndn, mod); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, - "No modify target found", NULL, NULL); - } - return rc; -} - -static int -glue_back_modrdn ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - struct berval *newrdn, - struct berval *nnewrdn, - int del, - struct berval *newsup, - struct berval *nnewsup -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_modrdn) { - rc = be->be_modrdn (be, conn, op, dn, ndn, - newrdn, nnewrdn, del, newsup, nnewsup ); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, - "No modrdn target found", NULL, NULL); - } - return rc; -} - -static int -glue_back_add ( - BackendDB *b0, - Connection *conn, - Operation *op, - Entry *e -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, e->e_ndn); - - if (be && be->be_add) { - rc = be->be_add (be, conn, op, e); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, "No add target found", - NULL, NULL); - } - return rc; -} - -static int -glue_back_delete ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_delete) { - rc = be->be_delete (be, conn, op, dn, ndn); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - send_ldap_result (conn, op, rc, NULL, "No delete target found", - NULL, NULL); - } - return rc; -} - -static int -glue_back_release_rw ( - BackendDB *b0, - Connection *conn, - Operation *op, - Entry *e, - int rw -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, e->e_ndn); - - if (be && be->be_release) { - rc = be->be_release (be, conn, op, e, rw); - } else { - entry_free (e); - rc = 0; - } - return rc; -} - -static int -glue_back_group ( - BackendDB *b0, - Connection *conn, - Operation *op, - Entry *target, - struct berval *ndn, - struct berval *ondn, - ObjectClass *oc, - AttributeDescription * ad -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_group) { - rc = be->be_group (be, conn, op, target, ndn, ondn, oc, ad); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - } - return rc; -} - -static int -glue_back_attribute ( - BackendDB *b0, - Connection *conn, - Operation *op, - Entry *target, - struct berval *ndn, - AttributeDescription *ad, - BerVarray *vals -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_attribute) { - rc = be->be_attribute (be, conn, op, target, ndn, ad, vals); - } else { - rc = LDAP_UNWILLING_TO_PERFORM; - } - return rc; + return rs->sr_err; } -static int -glue_back_referrals ( - BackendDB *b0, - Connection *conn, - Operation *op, - struct berval *dn, - struct berval *ndn, - const char **text -) -{ - BackendDB *be; - int rc; - - be = glue_back_select (b0, ndn->bv_val); - - if (be && be->be_chk_referrals) { - rc = be->be_chk_referrals (be, conn, op, dn, ndn, text); - } else { - rc = LDAP_SUCCESS;; - } - return rc; -} static int glue_tool_entry_open ( @@ -687,7 +421,7 @@ glue_tool_entry_first ( BackendDB *b0 ) { - glueinfo *gi = (glueinfo *) b0->be_private; + glueinfo *gi = (glueinfo *) b0->bd_info; int i; /* If we're starting from scratch, start at the most general */ @@ -712,7 +446,7 @@ glue_tool_entry_next ( BackendDB *b0 ) { - glueinfo *gi = (glueinfo *) b0->be_private; + glueinfo *gi = (glueinfo *) b0->bd_info; int i; ID rc; @@ -800,7 +534,7 @@ glue_tool_sync ( BackendDB *b0 ) { - glueinfo *gi = (glueinfo *) b0->be_private; + glueinfo *gi = (glueinfo *) b0->bd_info; int i; /* just sync everyone */ @@ -823,7 +557,7 @@ glue_sub_init( ) * backends and connect them to their superior. */ for (i = nBackendDB - 1, b1=&backendDB[i]; cont && i>=0; b1--,i--) { - if (b1->be_flags & SLAP_BFLAG_GLUE_SUBORDINATE) { + if (SLAP_GLUE_SUBORDINATE ( b1 ) ) { /* The last database cannot be a subordinate of noone */ if (i == nBackendDB - 1) { b1->be_flags ^= SLAP_BFLAG_GLUE_SUBORDINATE; @@ -832,11 +566,11 @@ glue_sub_init( ) } gi = NULL; for (j = i-1, be=&backendDB[j]; j>=0; be--,j--) { - if (!(be->be_flags & SLAP_BFLAG_GLUE_SUBORDINATE)) { + if ( ! SLAP_GLUE_SUBORDINATE( be ) ) { continue; } /* We will only link it once */ - if (be->be_flags & SLAP_BFLAG_GLUE_LINKED) { + if ( SLAP_GLUE_LINKED( be ) ) { continue; } if (!dnIsSuffix(&be->be_nsuffix[0], &b1->be_nsuffix[0])) { @@ -854,30 +588,17 @@ glue_sub_init( ) */ b1->be_flags |= SLAP_BFLAG_GLUE_INSTANCE; gi = (glueinfo *)ch_malloc(sizeof(glueinfo)); - gi->be = (BackendDB *)ch_malloc( - sizeof(BackendDB) + sizeof(BackendInfo)); - bi = (BackendInfo *)(gi->be+1); - *gi->be = *b1; gi->nodes = 0; - *bi = *b1->bd_info; + gi->bd = *b1; + gi->bi = *b1->bd_info; + bi = (BackendInfo *)gi; bi->bi_open = glue_back_open; bi->bi_close = glue_back_close; bi->bi_db_open = glue_back_db_open; bi->bi_db_close = glue_back_db_close; bi->bi_db_destroy = glue_back_db_destroy; - bi->bi_op_bind = glue_back_bind; bi->bi_op_search = glue_back_search; - bi->bi_op_compare = glue_back_compare; - bi->bi_op_modify = glue_back_modify; - bi->bi_op_modrdn = glue_back_modrdn; - bi->bi_op_add = glue_back_add; - bi->bi_op_delete = glue_back_delete; - - bi->bi_entry_release_rw = glue_back_release_rw; - bi->bi_acl_group = glue_back_group; - bi->bi_acl_attribute = glue_back_attribute; - bi->bi_chk_referrals = glue_back_referrals; /* * hooks for slap tools @@ -890,6 +611,10 @@ glue_sub_init( ) bi->bi_tool_entry_put = glue_tool_entry_put; bi->bi_tool_entry_reindex = glue_tool_entry_reindex; bi->bi_tool_sync = glue_tool_sync; + /* FIXME : will support later */ + bi->bi_tool_dn2id_get = 0; + bi->bi_tool_id2entry_get = 0; + bi->bi_tool_entry_modify = 0; } else { gi = (glueinfo *)ch_realloc(gi, sizeof(glueinfo) + @@ -903,11 +628,10 @@ glue_sub_init( ) /* One more node for the master */ gi = (glueinfo *)ch_realloc(gi, sizeof(glueinfo) + gi->nodes * sizeof(gluenode)); - gi->n[gi->nodes].be = gi->be; + gi->n[gi->nodes].be = &gi->bd; dnParent( &b1->be_nsuffix[0], &gi->n[gi->nodes].pdn ); gi->nodes++; - b1->be_private = gi; - b1->bd_info = bi; + b1->bd_info = (BackendInfo *)gi; } } /* If there are any unresolved subordinates left, something is wrong */