]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/overlays/translucent.c
ITS#6103: rev 1.331 followup for LDAP_CONNECTIONLESS
[openldap] / servers / slapd / overlays / translucent.c
index 555284ec8ba7f1e57751430b7b37698838dc9143..92d9a211517b2f9d65ac73a18a5624b37edee06c 100644 (file)
@@ -2,7 +2,7 @@
 /* $OpenLDAP$ */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *
- * Copyright 2004-2008 The OpenLDAP Foundation.
+ * Copyright 2004-2009 The OpenLDAP Foundation.
  * Portions Copyright 2005 Symas Corporation.
  * All rights reserved.
  *
@@ -41,6 +41,8 @@ typedef struct translucent_info {
        int strict;
        int no_glue;
        int defer_db_open;
+       int bind_local;
+       int pwmod_local;
 } translucent_info;
 
 static ConfigLDAPadd translucent_ldadd;
@@ -67,25 +69,29 @@ static ConfigTable translucentcfg[] = {
          "DESC 'Disable automatic glue records for ADD and MODRDN' "
          "SYNTAX OMsBoolean SINGLE-VALUE )", NULL, NULL },
        { "translucent_local", "attr[,attr...]", 1, 2, 0,
-         ARG_STRING|ARG_MAGIC|TRANS_LOCAL,
+         ARG_MAGIC|TRANS_LOCAL,
          translucent_cf_gen,
          "( OLcfgOvAt:14.3 NAME 'olcTranslucentLocal' "
          "DESC 'Attributes to use in local search filter' "
          "SYNTAX OMsDirectoryString )", NULL, NULL },
        { "translucent_remote", "attr[,attr...]", 1, 2, 0,
-         ARG_STRING|ARG_MAGIC|TRANS_REMOTE,
+         ARG_MAGIC|TRANS_REMOTE,
          translucent_cf_gen,
          "( OLcfgOvAt:14.4 NAME 'olcTranslucentRemote' "
          "DESC 'Attributes to use in remote search filter' "
          "SYNTAX OMsDirectoryString )", NULL, NULL },
-       { NULL, NULL, 0, 0, 0, ARG_IGNORED }
-};
-
-static ConfigTable transdummy[] = {
-       { "", "", 0, 0, 0, ARG_IGNORED,
-               NULL, "( OLcfgGlAt:13 NAME 'olcDatabase' "
-                       "DESC 'The backend type for a database instance' "
-                       "SUP olcBackend SINGLE-VALUE X-ORDERED 'SIBLINGS' )", NULL, NULL },
+       { "translucent_bind_local", "on|off", 1, 2, 0,
+         ARG_ON_OFF|ARG_OFFSET,
+         (void *)offsetof(translucent_info, bind_local),
+         "( OLcfgOvAt:14.5 NAME 'olcTranslucentBindLocal' "
+         "DESC 'Enable local bind' "
+         "SYNTAX OMsBoolean SINGLE-VALUE)", NULL, NULL },
+       { "translucent_pwmod_local", "on|off", 1, 2, 0,
+         ARG_ON_OFF|ARG_OFFSET,
+         (void *)offsetof(translucent_info, pwmod_local),
+         "( OLcfgOvAt:14.6 NAME 'olcTranslucentPwModLocal' "
+         "DESC 'Enable local RFC 3062 Password Modify extended operation' "
+         "SYNTAX OMsBoolean SINGLE-VALUE)", NULL, NULL },
        { NULL, NULL, 0, 0, 0, ARG_IGNORED }
 };
 
@@ -95,12 +101,13 @@ static ConfigOCs translucentocs[] = {
          "DESC 'Translucent configuration' "
          "SUP olcOverlayConfig "
          "MAY ( olcTranslucentStrict $ olcTranslucentNoGlue $"
-         " olcTranslucentLocal $ olcTranslucentRemote ) )",
+         " olcTranslucentLocal $ olcTranslucentRemote $"
+         " olcTranslucentBindLocal $ olcTranslucentPwModLocal ) )",
          Cft_Overlay, translucentcfg, NULL, translucent_cfadd },
        { "( OLcfgOvOc:14.2 "
          "NAME 'olcTranslucentDatabase' "
          "DESC 'Translucent target database configuration' "
-         "AUXILIARY )", Cft_Misc, transdummy, translucent_ldadd },
+         "AUXILIARY )", Cft_Misc, olcDatabaseDummy, translucent_ldadd },
        { NULL, 0, NULL }
 };
 /* for translucent_init() */
@@ -152,7 +159,7 @@ translucent_cfadd( Operation *op, SlapReply *rs, Entry *e, ConfigArgs *ca )
        /* FIXME: should not hardcode "olcDatabase" here */
        bv.bv_len = snprintf( ca->cr_msg, sizeof( ca->cr_msg ),
                "olcDatabase=%s", ov->db.bd_info->bi_type );
-       if ( bv.bv_len < 0 || bv.bv_len >= sizeof( ca->cr_msg ) ) {
+       if ( bv.bv_len >= sizeof( ca->cr_msg ) ) {
                return -1;
        }
        bv.bv_val = ca->cr_msg;
@@ -425,6 +432,7 @@ static int translucent_modify(Operation *op, SlapReply *rs) {
 
        db = op->o_bd;
        op->o_bd = &ov->db;
+       ov->db.be_acl = op->o_bd->be_acl;
        rc = ov->db.bd_info->bi_entry_get_rw(op, &op->o_req_ndn, NULL, NULL, 0, &re);
        if(rc != LDAP_SUCCESS || re == NULL ) {
                send_ldap_error((op), rs, LDAP_NO_SUCH_OBJECT,
@@ -622,12 +630,136 @@ static int translucent_compare(Operation *op, SlapReply *rs) {
 */
        db = op->o_bd;
        op->o_bd = &ov->db;
+       ov->db.be_acl = op->o_bd->be_acl;
        rc = ov->db.bd_info->bi_op_compare(op, rs);
        op->o_bd = db;
 
        return(rc);
 }
 
+static int translucent_pwmod(Operation *op, SlapReply *rs) {
+       SlapReply nrs = { REP_RESULT };
+       Operation nop;
+
+       slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
+       translucent_info *ov = on->on_bi.bi_private;
+       const struct berval bv_exop_pwmod = BER_BVC(LDAP_EXOP_MODIFY_PASSWD);
+       Entry *e = NULL, *re = NULL;
+       BackendDB *db;
+       int rc = 0;
+       slap_callback cb = { 0 };
+
+       if (!ov->pwmod_local) {
+               rs->sr_err = LDAP_CONSTRAINT_VIOLATION,
+               rs->sr_text = "attempt to modify password in local database";
+               return rs->sr_err;
+       }
+
+/*
+** fetch entry from the captive backend;
+** if it did not exist, fail;
+** release it, if captive backend supports this;
+**
+*/
+       db = op->o_bd;
+       op->o_bd = &ov->db;
+       ov->db.be_acl = op->o_bd->be_acl;
+       rc = ov->db.bd_info->bi_entry_get_rw(op, &op->o_req_ndn, NULL, NULL, 0, &re);
+       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);
+       }
+       op->o_bd = db;
+/*
+** fetch entry from local backend;
+** if it exists:
+**     return CONTINUE;
+*/
+
+       op->o_bd->bd_info = (BackendInfo *) on->on_info;
+       rc = be_entry_get_rw(op, &op->o_req_ndn, NULL, NULL, 0, &e);
+       op->o_bd->bd_info = (BackendInfo *) on;
+
+       if(e && rc == LDAP_SUCCESS) {
+               if(re) {
+                       if(ov->db.bd_info->bi_entry_release_rw) {
+                               op->o_bd = &ov->db;
+                               ov->db.bd_info->bi_entry_release_rw(op, re, 0);
+                               op->o_bd = db;
+                       } else {
+                               entry_free(re);
+                       }
+               }
+               op->o_bd->bd_info = (BackendInfo *) on->on_info;
+               be_entry_release_r(op, e);
+               op->o_bd->bd_info = (BackendInfo *) on;
+               return SLAP_CB_CONTINUE;
+       }
+
+       /* don't leak remote entry copy */
+       if(re) {
+               if(ov->db.bd_info->bi_entry_release_rw) {
+                       op->o_bd = &ov->db;
+                       ov->db.bd_info->bi_entry_release_rw(op, re, 0);
+                       op->o_bd = db;
+               } else {
+                       entry_free(re);
+               }
+       }
+/*
+** glue_parent() for this Entry;
+** call bi_op_add() in local backend;
+**
+*/
+       e = entry_alloc();
+       ber_dupbv( &e->e_name, &op->o_req_dn );
+       ber_dupbv( &e->e_nname, &op->o_req_ndn );
+       e->e_attrs = NULL;
+
+       nop = *op;
+       nop.o_tag = LDAP_REQ_ADD;
+       cb.sc_response = slap_null_cb;
+       nop.oq_add.rs_e = e;
+
+       glue_parent(&nop);
+
+       nop.o_callback = &cb;
+       rc = on->on_info->oi_orig->bi_op_add(&nop, &nrs);
+       if ( nop.ora_e == e ) {
+               entry_free( e );
+       }
+
+       if ( rc == LDAP_SUCCESS ) {
+               return SLAP_CB_CONTINUE;
+       }
+
+       return rc;
+}
+
+static int translucent_exop(Operation *op, SlapReply *rs) {
+       SlapReply nrs = { REP_RESULT };
+
+       slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
+       translucent_info *ov = on->on_bi.bi_private;
+       const struct berval bv_exop_pwmod = BER_BVC(LDAP_EXOP_MODIFY_PASSWD);
+
+       Debug(LDAP_DEBUG_TRACE, "==> translucent_exop: %s\n",
+               op->o_req_dn.bv_val, 0, 0);
+
+       if(ov->defer_db_open) {
+               send_ldap_error(op, rs, LDAP_UNAVAILABLE,
+                       "remote DB not available");
+               return(rs->sr_err);
+       }
+
+       if ( bvmatch( &bv_exop_pwmod, &op->ore_reqoid ) ) {
+               return translucent_pwmod( op, rs );
+       }
+
+       return SLAP_CB_CONTINUE;
+}
+
 /*
 ** translucent_search_cb()
 **     merge local data with remote data
@@ -692,7 +824,7 @@ static int translucent_search_cb(Operation *op, SlapReply *rs) {
                        if ( re ) {
                                if ( rs->sr_flags & REP_ENTRY_MUSTRELEASE ) {
                                        rs->sr_flags ^= REP_ENTRY_MUSTRELEASE;
-                                       be_entry_release_r( op, rs->sr_entry );
+                                       overlay_entry_release_ov( op, rs->sr_entry, 0, on );
                                }
                                if ( rs->sr_flags & REP_ENTRY_MUSTBEFREED ) {
                                        rs->sr_flags ^= REP_ENTRY_MUSTBEFREED;
@@ -726,7 +858,7 @@ static int translucent_search_cb(Operation *op, SlapReply *rs) {
                        re = entry_dup( rs->sr_entry );
                        if ( rs->sr_flags & REP_ENTRY_MUSTRELEASE ) {
                                rs->sr_flags ^= REP_ENTRY_MUSTRELEASE;
-                               be_entry_release_r( op, rs->sr_entry );
+                               overlay_entry_release_ov( op, rs->sr_entry, 0, on );
                        }
                        if ( rs->sr_flags & REP_ENTRY_MUSTBEFREED ) {
                                rs->sr_flags ^= REP_ENTRY_MUSTBEFREED;
@@ -769,7 +901,7 @@ static int translucent_search_cb(Operation *op, SlapReply *rs) {
                if ( tc->step & LCL_SIDE ) {
                        if ( rs->sr_flags & REP_ENTRY_MUSTRELEASE ) {
                                rs->sr_flags ^= REP_ENTRY_MUSTRELEASE;
-                               be_entry_release_r( op, rs->sr_entry );
+                               overlay_entry_release_ov( op, rs->sr_entry, 0, on );
                        }
                        if ( rs->sr_flags & REP_ENTRY_MUSTBEFREED ) {
                                rs->sr_flags ^= REP_ENTRY_MUSTBEFREED;
@@ -967,6 +1099,7 @@ static int translucent_search(Operation *op, SlapReply *rs) {
        cb.sc_private = &tc;
        cb.sc_next = op->o_callback;
 
+       ov->db.be_acl = op->o_bd->be_acl;
        tc.db = op->o_bd;
        tc.on = on;
        tc.orig = op->ors_filter;
@@ -1044,6 +1177,7 @@ static int translucent_bind(Operation *op, SlapReply *rs) {
        slap_overinst *on = (slap_overinst *) op->o_bd->bd_info;
        translucent_info *ov = on->on_bi.bi_private;
        BackendDB *db;
+       slap_callback sc = { 0 }, *save_cb;
        int rc;
 
        Debug(LDAP_DEBUG_TRACE, "translucent_bind: <%s> method %d\n",
@@ -1054,10 +1188,26 @@ static int translucent_bind(Operation *op, SlapReply *rs) {
                        "remote DB not available");
                return(rs->sr_err);
        }
+
+       if (ov->bind_local) {
+               sc.sc_response = slap_null_cb;
+               save_cb = op->o_callback;
+               op->o_callback = &sc;
+       }
+
        db = op->o_bd;
        op->o_bd = &ov->db;
+       ov->db.be_acl = op->o_bd->be_acl;
        rc = ov->db.bd_info->bi_op_bind(op, rs);
        op->o_bd = db;
+
+       if (ov->bind_local) {
+               op->o_callback = save_cb;
+               if (rc != LDAP_SUCCESS) {
+                       rc = SLAP_CB_CONTINUE;
+               }
+       }
+
        return rc;
 }
 
@@ -1123,7 +1273,6 @@ static int translucent_db_init(BackendDB *be, ConfigReply *cr) {
        on->on_bi.bi_private = ov;
        ov->db = *be;
        ov->db.be_private = NULL;
-       ov->db.be_pcl_mutexp = &ov->db.be_pcl_mutex;
        ov->defer_db_open = 1;
 
        if ( !backend_db_init( "ldap", &ov->db, -1, NULL )) {
@@ -1246,6 +1395,7 @@ int translucent_initialize() {
        translucent.on_bi.bi_op_search  = translucent_search;
        translucent.on_bi.bi_op_compare = translucent_compare;
        translucent.on_bi.bi_connection_destroy = translucent_connection_destroy;
+       translucent.on_bi.bi_extended   = translucent_exop;
 
        translucent.on_bi.bi_cf_ocs = translucentocs;
        rc = config_register_schema ( translucentcfg, translucentocs );