]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/back-ldap/add.c
Merge remote branch 'origin/mdb.master'
[openldap] / servers / slapd / back-ldap / add.c
index f6fa13cae653144905d5e91e573b12da3966d745..827dd42522340162dff777416715e3a5ae40e8e8 100644 (file)
@@ -1,38 +1,24 @@
 /* add.c - ldap backend add function */
 /* $OpenLDAP$ */
-/*
- * Copyright 1998-2003 The OpenLDAP Foundation, All Rights Reserved.
- * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
- */
-/* This is an altered version */
-/*
- * Copyright 1999, Howard Chu, All rights reserved. <hyc@highlandsun.com>
- * 
- * Permission is granted to anyone to use this software for any purpose
- * on any computer system, and to alter it and redistribute it, subject
- * to the following restrictions:
- * 
- * 1. The author is not responsible for the consequences of use of this
- *    software, no matter how awful, even if they arise from flaws in it.
- * 
- * 2. The origin of this software must not be misrepresented, either by
- *    explicit claim or by omission.  Since few users ever read sources,
- *    credits should appear in the documentation.
- * 
- * 3. Altered versions must be plainly marked as such, and must not be
- *    misrepresented as being the original software.  Since few users
- *    ever read sources, credits should appear in the documentation.
- * 
- * 4. This notice may not be removed or altered.
- *
+/* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *
+ * Copyright 1999-2011 The OpenLDAP Foundation.
+ * Portions Copyright 2000-2003 Pierangelo Masarati.
+ * Portions Copyright 1999-2003 Howard Chu.
+ * All rights reserved.
  *
- * Copyright 2000, Pierangelo Masarati, All rights reserved. <ando@sys-net.it>
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted only as authorized by the OpenLDAP
+ * Public License.
  *
- * This software is being modified by Pierangelo Masarati.
- * The previously reported conditions apply to the modified code as well.
- * Changes in the original code are highlighted where required.
- * Credits for the original code go to the author, Howard Chu.
+ * 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 the Howard Chu for inclusion
+ * in OpenLDAP Software and subsequently enhanced by Pierangelo
+ * Masarati.
  */
 
 #include "portable.h"
 
 int
 ldap_back_add(
-    Operation  *op,
-    SlapReply  *rs )
+       Operation       *op,
+       SlapReply       *rs )
 {
-       struct ldapinfo *li = (struct ldapinfo *) op->o_bd->be_private;
-       struct ldapconn *lc;
-       int i, j;
-       Attribute *a;
-       LDAPMod **attrs;
-       struct berval mapped;
-       struct berval mdn = { 0, NULL };
-       ber_int_t msgid;
-
-#ifdef NEW_LOGGING
-       LDAP_LOG( BACK_LDAP, ENTRY, "ldap_back_add: %s\n", op->o_req_dn.bv_val, 0, 0 );
-#else /* !NEW_LOGGING */
-       Debug(LDAP_DEBUG_ARGS, "==> ldap_back_add: %s\n", op->o_req_dn.bv_val, 0, 0);
-#endif /* !NEW_LOGGING */
+       ldapinfo_t              *li = (ldapinfo_t *)op->o_bd->be_private;
+
+       ldapconn_t              *lc = NULL;
+       int                     i = 0,
+                               j = 0;
+       Attribute               *a;
+       LDAPMod                 **attrs = NULL,
+                               *attrs2 = NULL;
+       ber_int_t               msgid;
+       int                     isupdate;
+       ldap_back_send_t        retrying = LDAP_BACK_RETRYING;
+       LDAPControl             **ctrls = NULL;
+
+       rs->sr_err = LDAP_SUCCESS;
        
-       lc = ldap_back_getconn(op, rs);
-       if ( !lc || !ldap_back_dobind( lc, op, rs ) ) {
-               return( -1 );
-       }
+       Debug( LDAP_DEBUG_ARGS, "==> ldap_back_add(\"%s\")\n",
+                       op->o_req_dn.bv_val, 0, 0 );
 
-       /*
-        * Rewrite the add dn, if needed
-        */
-#ifdef ENABLE_REWRITE
-       switch (rewrite_session( li->rwinfo, "addDn", op->o_req_dn.bv_val, op->o_conn, 
-                               &mdn.bv_val )) {
-       case REWRITE_REGEXEC_OK:
-               if ( mdn.bv_val != NULL && mdn.bv_val[ 0 ] != '\0' ) {
-                       mdn.bv_len = strlen( mdn.bv_val );
-               } else {
-                       mdn = op->o_req_dn;
-               }
-#ifdef NEW_LOGGING
-               LDAP_LOG( BACK_LDAP, DETAIL1, 
-                       "[rw] addDn: \"%s\" -> \"%s\"\n", op->o_req_dn.bv_val, mdn.bv_val, 0 );         
-#else /* !NEW_LOGGING */
-               Debug( LDAP_DEBUG_ARGS, "rw> addDn: \"%s\" -> \"%s\"\n%s", 
-                               op->o_req_dn.bv_val, mdn.bv_val, "" );
-#endif /* !NEW_LOGGING */
-               break;
-               
-       case REWRITE_REGEXEC_UNWILLING:
-               send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
-                               "Operation not allowed" );
-               return( -1 );
-               
-       case REWRITE_REGEXEC_ERR:
-               send_ldap_error( op, rs, LDAP_OTHER,
-                               "Rewrite error" );
-               return( -1 );
+       if ( !ldap_back_dobind( &lc, op, rs, LDAP_BACK_SENDERR ) ) {
+               lc = NULL;
+               goto cleanup;
        }
-#else /* !ENABLE_REWRITE */
-       ldap_back_dn_massage( li, &op->o_req_dn, &mdn, 0, 1 );
-#endif /* !ENABLE_REWRITE */
 
        /* Count number of attributes in entry */
-       for (i = 1, a = op->oq_add.rs_e->e_attrs; a; i++, a = a->a_next)
-               ;
+       for ( i = 1, a = op->oq_add.rs_e->e_attrs; a; i++, a = a->a_next )
+               /* just count attrs */ ;
        
        /* Create array of LDAPMods for ldap_add() */
-       attrs = (LDAPMod **)ch_malloc(sizeof(LDAPMod *)*i);
-
-       for (i=0, a=op->oq_add.rs_e->e_attrs; a; a=a->a_next) {
-               /*
-                * lastmod should always be <off>, so that
-                * creation/modification operational attrs
-                * of the target directory are used, if available
-                */
-#if 0
-               if ( !strcasecmp( a->a_desc->ad_cname.bv_val,
-                       slap_schema.si_ad_creatorsName->ad_cname.bv_val )
-                       || !strcasecmp( a->a_desc->ad_cname.bv_val,
-                       slap_schema.si_ad_createTimestamp->ad_cname.bv_val )
-                       || !strcasecmp( a->a_desc->ad_cname.bv_val,
-                       slap_schema.si_ad_modifiersName->ad_cname.bv_val )
-                       || !strcasecmp( a->a_desc->ad_cname.bv_val,
-                       slap_schema.si_ad_modifyTimestamp->ad_cname.bv_val )
-               ) {
-                       continue;
-               }
-#endif
-               
-               if ( a->a_desc->ad_type->sat_no_user_mod  ) {
+       attrs = (LDAPMod **)ch_malloc( sizeof( LDAPMod * )*i 
+                       + sizeof( LDAPMod )*( i - 1 ) );
+       attrs2 = ( LDAPMod * )&attrs[ i ];
+
+       isupdate = be_shadow_update( op );
+       for ( i = 0, a = op->oq_add.rs_e->e_attrs; a; a = a->a_next ) {
+               if ( !isupdate && !get_relax( op ) && a->a_desc->ad_type->sat_no_user_mod  )
+               {
                        continue;
                }
 
-               ldap_back_map(&li->at_map, &a->a_desc->ad_cname, &mapped,
-                               BACKLDAP_MAP);
-               if (mapped.bv_val == NULL || mapped.bv_val[0] == '\0') {
-                       continue;
-               }
+               attrs[ i ] = &attrs2[ i ];
+               attrs[ i ]->mod_op = LDAP_MOD_BVALUES;
+               attrs[ i ]->mod_type = a->a_desc->ad_cname.bv_val;
 
-               attrs[i] = (LDAPMod *)ch_malloc(sizeof(LDAPMod));
-               if (attrs[i] == NULL) {
-                       continue;
+               for ( j = 0; a->a_vals[ j ].bv_val; j++ )
+                       /* just count vals */ ;
+               attrs[i]->mod_vals.modv_bvals = 
+                       ch_malloc( ( j + 1 )*sizeof( struct berval * ) );
+               for ( j = 0; a->a_vals[ j ].bv_val; j++ ) {
+                       attrs[ i ]->mod_vals.modv_bvals[ j ] = &a->a_vals[ j ];
                }
-
-               attrs[i]->mod_op = LDAP_MOD_BVALUES;
-               attrs[i]->mod_type = mapped.bv_val;
-
-#ifdef ENABLE_REWRITE
-               /*
-                * FIXME: dn-valued attrs should be rewritten
-                * to allow their use in ACLs at back-ldap level.
-                */
-               if ( strcmp( a->a_desc->ad_type->sat_syntax->ssyn_oid,
-                                       SLAPD_DN_SYNTAX ) == 0 ) {
-                       /*
-                        * FIXME: rewrite could fail; in this case
-                        * the operation should give up, right?
-                        */
-                       (void)ldap_dnattr_rewrite( li->rwinfo, a->a_vals, op->o_conn );
-               }
-#endif /* ENABLE_REWRITE */
-
-               for (j=0; a->a_vals[j].bv_val; j++);
-               attrs[i]->mod_vals.modv_bvals = ch_malloc((j+1)*sizeof(struct berval *));
-               for (j=0; a->a_vals[j].bv_val; j++)
-                       attrs[i]->mod_vals.modv_bvals[j] = &a->a_vals[j];
-               attrs[i]->mod_vals.modv_bvals[j] = NULL;
+               attrs[ i ]->mod_vals.modv_bvals[ j ] = NULL;
                i++;
        }
-       attrs[i] = NULL;
-
-       j = ldap_add_ext(lc->ld, mdn.bv_val, attrs, op->o_ctrls, NULL, &msgid);
-       for (--i; i>= 0; --i) {
-               ch_free(attrs[i]->mod_vals.modv_bvals);
-               ch_free(attrs[i]);
+       attrs[ i ] = NULL;
+
+retry:
+       ctrls = op->o_ctrls;
+       rs->sr_err = ldap_back_controls_add( op, rs, lc, &ctrls );
+       if ( rs->sr_err != LDAP_SUCCESS ) {
+               send_ldap_result( op, rs );
+               goto cleanup;
        }
-       ch_free(attrs);
-       if ( mdn.bv_val != op->o_req_dn.bv_val ) {
-               free( mdn.bv_val );
+
+       rs->sr_err = ldap_add_ext( lc->lc_ld, op->o_req_dn.bv_val, attrs,
+                       ctrls, NULL, &msgid );
+       rs->sr_err = ldap_back_op_result( lc, op, rs, msgid,
+               li->li_timeout[ SLAP_OP_ADD ],
+               ( LDAP_BACK_SENDRESULT | retrying ) );
+       if ( rs->sr_err == LDAP_UNAVAILABLE && retrying ) {
+               retrying &= ~LDAP_BACK_RETRYING;
+               if ( ldap_back_retry( &lc, op, rs, LDAP_BACK_SENDERR ) ) {
+                       /* if the identity changed, there might be need to re-authz */
+                       (void)ldap_back_controls_free( op, rs, &ctrls );
+                       goto retry;
+               }
        }
-       
-       return( ldap_back_op_result( lc, op, rs, msgid, j, 1 ) );
-}
 
-#ifdef ENABLE_REWRITE
-int
-ldap_dnattr_rewrite(
-               struct rewrite_info     *rwinfo,
-               BerVarray                       a_vals,
-               void                    *cookie
-)
-{
-       char *mattr;
-       
-       for ( ; a_vals->bv_val != NULL; a_vals++ ) {
-               switch ( rewrite_session( rwinfo, "bindDn", a_vals->bv_val,
-                                       cookie, &mattr )) {
-               case REWRITE_REGEXEC_OK:
-                       if ( mattr == NULL ) {
-                               /* no substitution */
-                               continue;
-                       }
-#ifdef NEW_LOGGING
-                       LDAP_LOG( BACK_LDAP, DETAIL1, 
-                               "[rw] bindDn (in add of dn-valued"
-                               " attr): \"%s\" -> \"%s\"\n", a_vals->bv_val, mattr, 0 );
-#else /* !NEW_LOGGING */
-                       Debug( LDAP_DEBUG_ARGS,
-                                       "rw> bindDn (in add of dn-valued attr):"
-                                       " \"%s\" -> \"%s\"\n%s",
-                                       a_vals->bv_val, mattr, "" );
-#endif /* !NEW_LOGGING */
-
-                       /*
-                        * FIXME: replacing server-allocated memory 
-                        * (ch_malloc) with librewrite allocated memory
-                        * (malloc)
-                        */
-                       ch_free( a_vals->bv_val );
-                       a_vals->bv_val = mattr;
-                       a_vals->bv_len = strlen( mattr );
-                       
-                       break;
-                       
-               case REWRITE_REGEXEC_UNWILLING:
-                       
-               case REWRITE_REGEXEC_ERR:
-                       /*
-                        * FIXME: better give up,
-                        * skip the attribute
-                        * or leave it untouched?
-                        */
-                       break;
+cleanup:
+       (void)ldap_back_controls_free( op, rs, &ctrls );
+
+       if ( attrs ) {
+               for ( --i; i >= 0; --i ) {
+                       ch_free( attrs[ i ]->mod_vals.modv_bvals );
                }
+               ch_free( attrs );
        }
-       
-       return 0;
+
+       if ( lc ) {
+               ldap_back_release_conn( li, lc );
+       }
+
+       Debug( LDAP_DEBUG_ARGS, "<== ldap_back_add(\"%s\"): %d\n",
+                       op->o_req_dn.bv_val, rs->sr_err, 0 );
+
+       return rs->sr_err;
 }
-#endif /* ENABLE_REWRITE */