-/* Copyright 2004, Symas Corporation.
- * All Rights Reserved.
+/* translucent.c - translucent proxy module */
+/* $OpenLDAP$ */
+/* This work is part of OpenLDAP Software <http://www.openldap.org/>.
+ *
+ * Copyright 2004-2006 The OpenLDAP Foundation.
+ * Portions Copyright 2005 Symas Corporation.
+ * 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
+ * <http://www.OpenLDAP.org/license.html>.
+ */
+/* ACKNOWLEDGEMENTS:
+ * This work was initially developed by Symas Corp. for inclusion in
+ * OpenLDAP Software. This work was sponsored by Hewlett-Packard.
*/
#include "portable.h"
#include <ac/socket.h>
#include "slap.h"
+#include "lutil.h"
/* config block */
void glue_parent(Operation *op) {
Operation nop = *op;
slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
- struct berval dn = { 0, NULL };
- char *odn = op->o_req_ndn.bv_val;
+ struct berval ndn = BER_BVNULL;
Attribute *a;
Entry *e;
- int idn, ldn;
+ struct berval pdn;
- /* tis more work to use strchr() for a berval... */
- for(idn = 0; odn[idn] && odn[idn] != ','; idn++);
- if(!idn || !odn[idn]) return; /* because you never know */
- idn++;
- ldn = dn.bv_len = op->o_req_ndn.bv_len - idn;
- dn.bv_val = ch_malloc(ldn + 1);
- strcpy(dn.bv_val, odn + idn);
+ dnParent( &op->o_req_ndn, &pdn );
+ ber_dupbv_x( &ndn, &pdn, op->o_tmpmemctx );
- Debug(LDAP_DEBUG_TRACE, "=> glue_parent: fabricating glue for <%s>\n", dn.bv_val, 0, 0);
+ Debug(LDAP_DEBUG_TRACE, "=> glue_parent: fabricating glue for <%s>\n", ndn.bv_val, 0, 0);
e = ch_calloc(1, sizeof(Entry));
e->e_id = NOID;
- ber_dupbv(&e->e_name, &dn);
- ber_dupbv(&e->e_nname, &dn);
+ ber_dupbv(&e->e_name, &ndn);
+ ber_dupbv(&e->e_nname, &ndn);
a = ch_calloc(1, sizeof(Attribute));
a->a_desc = slap_schema.si_ad_objectClass;
a->a_next = e->e_attrs;
e->e_attrs = a;
- nop.o_req_dn = dn;
- nop.o_req_ndn = dn;
+ nop.o_req_dn = ndn;
+ nop.o_req_ndn = ndn;
nop.ora_e = e;
nop.o_bd->bd_info = (BackendInfo *) on->on_info->oi_orig;
syncrepl_add_glue(&nop, e);
+
+ op->o_tmpfree( ndn.bv_val, op->o_tmpmemctx );
+
return;
}
*/
void free_attr_chain(Attribute *a) {
Attribute *ax;
- for(ax = NULL; a; a = a->a_next) {
- if(ax) ch_free(ax);
- ax = a;
+ for(; a; a = ax) {
+ ax = a->a_next;
+ ch_free(a);
}
return;
}
return(SLAP_CB_CONTINUE);
}
+static int
+translucent_tag_cb( Operation *op, SlapReply *rs )
+{
+ op->o_tag = (ber_tag_t)op->o_callback->sc_private;
+ rs->sr_tag = slap_req2res( op->o_tag );
+
+ return SLAP_CB_CONTINUE;
+}
+
/*
** translucent_modify()
** modify in local backend if exists in both;
slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
overlay_stack *ov = on->on_bi.bi_private;
- translucent_configuration *cf = ov->config;
void *private = op->o_bd->be_private;
- Entry ne, *e, *re = NULL;
+ Entry ne, *e = NULL, *re = NULL;
Attribute *a, *ax;
Modifications *m, *mm;
int del, rc, erc = 0;
+ slap_callback cb = { 0 };
Debug(LDAP_DEBUG_TRACE, "==> translucent_modify: %s\n",
op->o_req_dn.bv_val, 0, 0);
op->o_bd->be_private = private;
/* if(ov->config->no_add && (!re || rc != LDAP_SUCCESS)) */
- if(!re || rc != LDAP_SUCCESS) {
+ if(rc != LDAP_SUCCESS || re == NULL ) {
send_ldap_error(op, rs, LDAP_NO_SUCH_OBJECT,
"attempt to modify nonexistent local record");
return(rs->sr_err);
mm = m;
m = m->sml_next;
mm->sml_next = NULL; /* hack */
- slap_mods_free(mm);
+ slap_mods_free(mm, 1);
if(m) continue;
}
m->sml_op = LDAP_MOD_ADD;
}
}
+ /* don't leak remote entry copy */
+ if(re) {
+ op->o_bd->be_private = ov->private;
+ if(ov->info->bi_entry_release_rw)
+ ov->info->bi_entry_release_rw(op, re, 0);
+ else
+ entry_free(re);
+ op->o_bd->be_private = private;
+ }
/*
** foreach Modification:
** if MOD_ADD or MOD_REPLACE, add Attribute;
op->o_bd->bd_info = (BackendInfo *) on;
glue_parent(&nop);
+ cb.sc_response = translucent_tag_cb;
+ cb.sc_private = (void *)LDAP_REQ_MODIFY;
+ cb.sc_next = nop.o_callback;
+ nop.o_callback = &cb;
rc = on->on_info->oi_orig->bi_op_add(&nop, &nrs);
free_attr_chain(a);
slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
overlay_stack *ov = on->on_bi.bi_private;
void *private = op->o_bd->be_private;
- translucent_configuration *cf = ov->config;
AttributeAssertion *ava = op->orc_ava;
- Attribute *a, *an, *ra, *as = NULL;
- Entry *e, *ee, *re;
+ Entry *e;
int rc;
Debug(LDAP_DEBUG_TRACE, "==> translucent_compare: <%s> %s:%s\n",
slap_overinst *on;
Entry *e, *re = NULL;
Attribute *a, *ax, *an, *as = NULL;
- BerVarray b, bx;
void *private;
- int i, rc, size;
+ int rc;
if(!op || !rs || rs->sr_type != REP_SEARCH || !rs->sr_entry)
return(SLAP_CB_CONTINUE);
slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
slap_callback cb = { NULL, NULL, NULL, NULL };
overlay_stack *ov = on->on_bi.bi_private;
- translucent_configuration *cf = ov->config;
void *private = op->o_bd->be_private;
int rc;
}
/*
-** translucent_config()
+** translucent_db_config()
** pass config directives to captive backend;
** parse unrecognized directives ourselves;
**
*/
-static int translucent_config(
+static int translucent_db_config(
BackendDB *be,
const char *fname,
int lineno,
slap_overinst *on = (slap_overinst *) be->bd_info;
overlay_stack *ov = on->on_bi.bi_private;
void *private = be->be_private;
+ void *be_cf_ocs = be->be_cf_ocs;
int rc;
/* "this should never happen" */
}
be->be_private = ov->private;
+ be->be_cf_ocs = ov->info->bi_cf_ocs;
rc = ov->info->bi_db_config ? ov->info->bi_db_config(be, fname, lineno, argc, argv) : 0;
be->be_private = private;
+ be->be_cf_ocs = be_cf_ocs;
/* pass okay or error up, SLAP_CONF_UNKNOWN might be ours */
if(rc == 0 || rc == 1) return(rc);
ov->config->debug = 0xFFFF;
rc = 0;
} else if(argc == 2) {
- ov->config->debug = atoi(argv[1]);
+ if ( lutil_atoi( &ov->config->debug, argv[1]) != 0 ) {
+ fprintf(stderr, "%s: line %d: unable to parse debug \"%s\"\n",
+ fname, lineno, argv[1]);
+ return 1;
+ }
rc = 0;
} else {
fprintf(stderr, "%s: line %d: too many arguments (%d) to debug\n",
}
/*
-** translucent_open()
+** translucent_db_open()
** if the captive backend has an open() method, call it;
**
*/
-static int translucent_open(BackendDB *be) {
+static int translucent_db_open(BackendDB *be) {
slap_overinst *on = (slap_overinst *) be->bd_info;
overlay_stack *ov = on->on_bi.bi_private;
void *private = be->be_private;
}
/*
-** translucent_close()
+** translucent_db_close()
** if the captive backend has a close() method, call it;
** free any config data;
**
*/
-static int translucent_close(BackendDB *be) {
+static int translucent_db_close(BackendDB *be) {
slap_overinst *on = (slap_overinst *) be->bd_info;
overlay_stack *ov = on->on_bi.bi_private;
- translucent_configuration *cf = ov->config;
- void *private = be->be_private;
- int rc;
+ int rc = 0;
+
+ if ( ov ) {
+ void *private = be->be_private;
+
+ be->be_private = ov->private;
+ rc = (ov->info && ov->info->bi_db_close) ? ov->info->bi_db_close(be) : 0;
+ be->be_private = private;
+ if(ov->config) ch_free(ov->config);
+ ov->config = NULL;
+ }
+
+ return(rc);
+}
+
+/*
+** translucent_db_destroy()
+** if the captive backend has a db_destroy() method, call it
+**
+*/
+
+static int translucent_db_destroy(BackendDB *be) {
+ slap_overinst *on = (slap_overinst *) be->bd_info;
+ overlay_stack *ov = on->on_bi.bi_private;
+ int rc = 0;
+
+ if ( ov ) {
+ void *private = be->be_private;
+
+ be->be_private = ov->private;
+ rc = (ov->info && ov->info->bi_db_destroy) ? ov->info->bi_db_destroy(be) : 0;
+ be->be_private = private;
+ ch_free(ov);
+ on->on_bi.bi_private = NULL;
+ }
- be->be_private = ov->private;
- rc = (ov->info && ov->info->bi_db_close) ? ov->info->bi_db_close(be) : 0;
- be->be_private = private;
- if(ov->config) ch_free(ov->config);
- ch_free(ov);
return(rc);
}
/*
-** translucent_init()
+** translucent_initialize()
** initialize the slap_overinst with our entry points;
**
*/
-int translucent_init() {
+int translucent_initialize() {
translucent.on_bi.bi_type = "translucent";
translucent.on_bi.bi_db_init = translucent_db_init;
- translucent.on_bi.bi_db_config = translucent_config;
- translucent.on_bi.bi_db_open = translucent_open;
- translucent.on_bi.bi_db_close = translucent_close;
+ translucent.on_bi.bi_db_config = translucent_db_config;
+ translucent.on_bi.bi_db_open = translucent_db_open;
+ translucent.on_bi.bi_db_close = translucent_db_close;
+ translucent.on_bi.bi_db_destroy = translucent_db_destroy;
translucent.on_bi.bi_op_bind = translucent_bind;
translucent.on_bi.bi_op_add = translucent_add;
translucent.on_bi.bi_op_modify = translucent_modify;
#if SLAPD_OVER_TRANSLUCENT == SLAPD_MOD_DYNAMIC && defined(PIC)
int init_module(int argc, char *argv[]) {
- return translucent_init();
+ return translucent_initialize();
}
#endif
projects / openldap / blobdiff