]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/backend.c
Add trickle-sync for quick mode
[openldap] / servers / slapd / backend.c
index 3233f65e8fe44a12493a5c08a3ae6b1c38efca6f..b5d005b18083668258b35d1ea15066bc60df4089 100644 (file)
@@ -2,7 +2,7 @@
 /* $OpenLDAP$ */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *
- * Copyright 1998-2006 The OpenLDAP Foundation.
+ * Copyright 1998-2007 The OpenLDAP Foundation.
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -418,11 +418,11 @@ backend_stopdown_one( BackendDB *bd )
 void backend_destroy_one( BackendDB *bd, int dynamic )
 {
        if ( dynamic ) {
-               LDAP_STAILQ_REMOVE(&backendDB, bd, slap_backend_db, be_next );
+               LDAP_STAILQ_REMOVE(&backendDB, bd, BackendDB, be_next );
        }
 
        if ( bd->be_syncinfo ) {
-               syncinfo_free( bd->be_syncinfo );
+               syncinfo_free( bd->be_syncinfo, 1 );
        }
 
        backend_stopdown_one( bd );
@@ -440,16 +440,6 @@ void backend_destroy_one( BackendDB *bd, int dynamic )
        }
        acl_destroy( bd->be_acl, frontendDB->be_acl );
        limits_destroy( bd->be_limits );
-       if ( bd->be_replogfile ) {
-               ch_free( bd->be_replogfile );
-       }
-       if ( bd->be_replica_argsfile ) {
-               ch_free( bd->be_replica_argsfile );
-       }
-       if ( bd->be_replica_pidfile ) {
-               ch_free( bd->be_replica_pidfile );
-       }
-       destroy_replica_info( bd );
        if ( !BER_BVISNULL( &bd->be_update_ndn ) ) {
                ch_free( bd->be_update_ndn.bv_val );
        }
@@ -500,17 +490,6 @@ int backend_destroy(void)
                        free( bd->be_rootpw.bv_val );
                }
                acl_destroy( bd->be_acl, frontendDB->be_acl );
-
-               if ( bd->be_replogfile != NULL ) {
-                       free( bd->be_replogfile );
-               }
-               if ( bd->be_replica_argsfile ) {
-                       ch_free( bd->be_replica_argsfile );
-               }
-               if ( bd->be_replica_pidfile ) {
-                       ch_free( bd->be_replica_pidfile );
-               }
-               assert( bd->be_replica == NULL );
        }
 
        return 0;
@@ -560,7 +539,7 @@ backend_db_move(
        int idx
 )
 {
-       LDAP_STAILQ_REMOVE(&backendDB, be, slap_backend_db, be_next);
+       LDAP_STAILQ_REMOVE(&backendDB, be, BackendDB, be_next);
        backend_db_insert(be, idx);
 }
 
@@ -614,7 +593,7 @@ backend_db_init(
                fprintf( stderr, "database init failed (%s)\n", type );
                /* If we created and linked this be, remove it and free it */
                if ( !b0 ) {
-                       LDAP_STAILQ_REMOVE(&backendDB, be, slap_backend_db, be_next);
+                       LDAP_STAILQ_REMOVE(&backendDB, be, BackendDB, be_next);
                        ch_free( be );
                        be = NULL;
                        nbackends--;
@@ -1321,124 +1300,159 @@ fe_acl_group(
        if ( target && dn_match( &target->e_nname, gr_ndn ) ) {
                e = target;
                rc = 0;
+
        } else {
                op->o_private = NULL;
                rc = be_entry_get_rw( op, gr_ndn, group_oc, group_at, 0, &e );
                e_priv = op->o_private;
                op->o_private = o_priv;
        }
+
        if ( e ) {
                a = attr_find( e->e_attrs, group_at );
                if ( a ) {
-                       /* If the attribute is a subtype of labeledURI, treat this as
-                        * a dynamic group ala groupOfURLs
+                       /* If the attribute is a subtype of labeledURI,
+                        * treat this as a dynamic group ala groupOfURLs
                         */
-                       if (is_at_subtype( group_at->ad_type,
+                       if ( is_at_subtype( group_at->ad_type,
                                slap_schema.si_ad_labeledURI->ad_type ) )
                        {
                                int i;
                                LDAPURLDesc *ludp;
                                struct berval bv, nbase;
                                Filter *filter;
-                               Entry *user;
+                               Entry *user = NULL;
                                void *user_priv = NULL;
                                Backend *b2 = op->o_bd;
 
                                if ( target && dn_match( &target->e_nname, op_ndn ) ) {
                                        user = target;
-                               } else {
-                                       op->o_bd = select_backend( op_ndn, 0, 0 );
-                                       op->o_private = NULL;
-                                       rc = be_entry_get_rw(op, op_ndn, NULL, NULL, 0, &user );
-                                       user_priv = op->o_private;
-                                       op->o_private = o_priv;
                                }
                                
-                               if ( rc == 0 ) {
-                                       rc = LDAP_COMPARE_FALSE;
-                                       for ( i = 0; !BER_BVISNULL( &a->a_vals[i] ); i++ ) {
-                                               if ( ldap_url_parse( a->a_vals[i].bv_val, &ludp ) !=
-                                                       LDAP_URL_SUCCESS )
-                                               {
-                                                       continue;
+                               rc = LDAP_COMPARE_FALSE;
+                               for ( i = 0; !BER_BVISNULL( &a->a_vals[i] ); i++ ) {
+                                       if ( ldap_url_parse( a->a_vals[i].bv_val, &ludp ) !=
+                                               LDAP_URL_SUCCESS )
+                                       {
+                                               continue;
+                                       }
+
+                                       BER_BVZERO( &nbase );
+
+                                       /* host, attrs and extensions parts must be empty */
+                                       if ( ( ludp->lud_host && *ludp->lud_host )
+                                               || ludp->lud_attrs
+                                               || ludp->lud_exts )
+                                       {
+                                               goto loopit;
+                                       }
+
+                                       ber_str2bv( ludp->lud_dn, 0, 0, &bv );
+                                       if ( dnNormalize( 0, NULL, NULL, &bv, &nbase,
+                                               op->o_tmpmemctx ) != LDAP_SUCCESS )
+                                       {
+                                               goto loopit;
+                                       }
+
+                                       switch ( ludp->lud_scope ) {
+                                       case LDAP_SCOPE_BASE:
+                                               if ( !dn_match( &nbase, op_ndn ) ) {
+                                                       goto loopit;
                                                }
-                                               BER_BVZERO( &nbase );
-                                               /* host part must be empty */
-                                               /* attrs and extensions parts must be empty */
-                                               if ( ( ludp->lud_host && *ludp->lud_host ) ||
-                                                       ludp->lud_attrs || ludp->lud_exts )
-                                               {
+                                               break;
+                                       case LDAP_SCOPE_ONELEVEL:
+                                               dnParent( op_ndn, &bv );
+                                               if ( !dn_match( &nbase, &bv ) ) {
                                                        goto loopit;
                                                }
-                                               ber_str2bv( ludp->lud_dn, 0, 0, &bv );
-                                               if ( dnNormalize( 0, NULL, NULL, &bv, &nbase,
-                                                       op->o_tmpmemctx ) != LDAP_SUCCESS )
+                                               break;
+                                       case LDAP_SCOPE_SUBTREE:
+                                               if ( !dnIsSuffix( op_ndn, &nbase ) ) {
+                                                       goto loopit;
+                                               }
+                                               break;
+                                       case LDAP_SCOPE_SUBORDINATE:
+                                               if ( dn_match( &nbase, op_ndn ) ||
+                                                       !dnIsSuffix( op_ndn, &nbase ) )
                                                {
                                                        goto loopit;
                                                }
-                                               switch ( ludp->lud_scope ) {
-                                               case LDAP_SCOPE_BASE:
-                                                       if ( !dn_match( &nbase, op_ndn ) ) {
-                                                               goto loopit;
-                                                       }
-                                                       break;
-                                               case LDAP_SCOPE_ONELEVEL:
-                                                       dnParent( op_ndn, &bv );
-                                                       if ( !dn_match( &nbase, &bv ) ) {
-                                                               goto loopit;
-                                                       }
-                                                       break;
-                                               case LDAP_SCOPE_SUBTREE:
-                                                       if ( !dnIsSuffix( op_ndn, &nbase ) ) {
-                                                               goto loopit;
-                                                       }
-                                                       break;
-                                               case LDAP_SCOPE_SUBORDINATE:
-                                                       if ( dn_match( &nbase, op_ndn ) ||
-                                                               !dnIsSuffix( op_ndn, &nbase ) )
-                                                       {
+                                       }
+
+                                       /* NOTE: this could be NULL
+                                        * if no filter is provided,
+                                        * or if filter parsing fails.
+                                        * In the latter case,
+                                        * we should give up. */
+                                       if ( ludp->lud_filter != NULL && ludp->lud_filter != '\0') {
+                                               filter = str2filter_x( op, ludp->lud_filter );
+                                               if ( filter == NULL ) {
+                                                       /* give up... */
+                                                       rc = LDAP_OTHER;
+                                                       goto loopit;
+                                               }
+
+                                               /* only get user if required
+                                                * and not available yet */
+                                               if ( user == NULL ) {   
+                                                       int rc2;
+
+                                                       op->o_bd = select_backend( op_ndn, 0, 0 );
+                                                       op->o_private = NULL;
+                                                       rc2 = be_entry_get_rw( op, op_ndn, NULL, NULL, 0, &user );
+                                                       user_priv = op->o_private;
+                                                       op->o_private = o_priv;
+                                                       if ( rc2 != 0 ) {
+                                                               /* give up... */
+                                                               rc = LDAP_OTHER;
                                                                goto loopit;
                                                        }
                                                }
-                                               filter = str2filter_x( op, ludp->lud_filter );
-                                               if ( filter ) {
-                                                       if ( test_filter( NULL, user, filter ) ==
-                                                               LDAP_COMPARE_TRUE )
-                                                       {
-                                                               rc = 0;
-                                                       }
-                                                       filter_free_x( op, filter );
+
+                                               if ( test_filter( NULL, user, filter ) ==
+                                                       LDAP_COMPARE_TRUE )
+                                               {
+                                                       rc = 0;
                                                }
+                                               filter_free_x( op, filter );
+                                       }
 loopit:
-                                               ldap_free_urldesc( ludp );
-                                               if ( !BER_BVISNULL( &nbase ) ) {
-                                                       op->o_tmpfree( nbase.bv_val, op->o_tmpmemctx );
-                                               }
-                                               if ( rc == 0 ) break;
+                                       ldap_free_urldesc( ludp );
+                                       if ( !BER_BVISNULL( &nbase ) ) {
+                                               op->o_tmpfree( nbase.bv_val, op->o_tmpmemctx );
                                        }
-                                       if ( user != target ) {
-                                               op->o_private = user_priv;
-                                               be_entry_release_r( op, user );
-                                               op->o_private = o_priv;
+                                       if ( rc != LDAP_COMPARE_FALSE ) {
+                                               break;
                                        }
                                }
+
+                               if ( user != NULL && user != target ) {
+                                       op->o_private = user_priv;
+                                       be_entry_release_r( op, user );
+                                       op->o_private = o_priv;
+                               }
                                op->o_bd = b2;
+
                        } else {
                                rc = value_find_ex( group_at,
-                               SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH |
-                               SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH,
-                               a->a_nvals, op_ndn, op->o_tmpmemctx );
-                               if ( rc == LDAP_NO_SUCH_ATTRIBUTE )
+                                       SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH |
+                                       SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH,
+                                       a->a_nvals, op_ndn, op->o_tmpmemctx );
+                               if ( rc == LDAP_NO_SUCH_ATTRIBUTE ) {
                                        rc = LDAP_COMPARE_FALSE;
+                               }
                        }
+
                } else {
                        rc = LDAP_NO_SUCH_ATTRIBUTE;
                }
+
                if ( e != target ) {
                        op->o_private = e_priv;
                        be_entry_release_r( op, e );
                        op->o_private = o_priv;
                }
+
        } else {
                rc = LDAP_NO_SUCH_OBJECT;
        }
@@ -1455,6 +1469,7 @@ loopit:
                g->ga_next = op->o_groups;
                op->o_groups = g;
        }
+
 done:
        op->o_bd = be;
        return rc;