Moving NSCP Directory Server from DirectoryBranch to TRUNK, initial drop. (foxworth)ldapserver7x

1 files changed, 618 insertions, 0 deletions

diff --git a/ldap/servers/plugins/replication/repl5_agmtlist.c b/ldap/servers/plugins/replication/repl5_agmtlist.c
new file mode 100644
index 00000000..5c7213a6
--- /dev/null
+++ b/ldap/servers/plugins/replication/repl5_agmtlist.c
@@ -0,0 +1,618 @@
+/** BEGIN COPYRIGHT BLOCK
+ * Copyright 2001 Sun Microsystems, Inc.
+ * Portions copyright 1999, 2001-2003 Netscape Communications Corporation.
+ * All rights reserved.
+ * END COPYRIGHT BLOCK **/
+/* repl5_agmtlist.c */
+/*
+
+ Replication agreements are held in object set (objset.c).
+
+*/
+
+#include "repl5.h"
+
+#define AGMT_CONFIG_BASE "cn=mapping tree, cn=config"
+#define CONFIG_FILTER "(objectclass=nsds5replicationagreement)"
+
+PRCallOnceType once = {0};
+static Objset *agmt_set = NULL; /* The set of replication agreements */
+
+typedef struct agmt_wrapper {
+	Repl_Agmt *agmt;
+	void *handle;
+} agmt_wrapper;
+
+
+
+/*
+ * Find the replication agreement whose entry DN matches the given DN.
+ * Object is returned referenced, so be sure to release it when
+ * finished.
+ */
+Repl_Agmt *
+agmtlist_get_by_agmt_name(const Slapi_DN *agmt_name)
+{
+	Repl_Agmt *ra;
+	Object *ro;
+
+	for (ro = objset_first_obj(agmt_set); NULL != ro;
+		ro = objset_next_obj(agmt_set, ro))
+	{
+		ra = (Repl_Agmt *)object_get_data(ro);
+		if (agmt_matches_name(ra, agmt_name))
+		{
+			break;
+		}
+	}
+	return ra;
+}
+
+
+static int
+agmt_ptr_cmp(Object *ro, const void *arg)
+{
+	Repl_Agmt *ra;
+	Repl_Agmt *provided_ra = (Repl_Agmt *)arg;
+
+	ra = object_get_data(ro);
+
+    if (ra == provided_ra)
+        return 0;
+    else
+        return 1;
+}
+
+
+
+static int
+agmt_dn_cmp(Object *ro, const void *arg)
+{
+	Repl_Agmt *ra;
+	Slapi_DN *sdn = (Slapi_DN *)arg;
+
+	ra = object_get_data(ro);
+	return(slapi_sdn_compare(sdn, agmt_get_dn_byref(ra)));
+}
+
+void
+agmtlist_release_agmt(Repl_Agmt *ra)
+{
+	Object *ro;
+
+	PR_ASSERT(NULL != agmt_set);
+	PR_ASSERT(NULL != ra);
+
+	ro = objset_find(agmt_set, agmt_ptr_cmp, (const void *)ra);
+	if (NULL != ro)
+	{
+		/*
+		 * Release twice - once for the reference we got when finding
+		 * it, and once for the reference we got when we called
+		 * agmtlist_get_*().
+		 */
+		object_release(ro);
+		object_release(ro);
+	}
+}
+
+
+/*
+ * Note: when we add the new object, we have a reference to it. We hold
+ * on to this reference until the agreement is deleted (or until the
+ * server is shut down).
+ */
+static int
+add_new_agreement(Slapi_Entry *e)
+{
+    int rc = 0;
+    Repl_Agmt *ra = agmt_new_from_entry(e);
+    Slapi_DN *replarea_sdn = NULL;
+    Replica *replica = NULL;
+    Object *repl_obj = NULL;
+    Object *ro = NULL;
+
+    if (ra == NULL) return 0;
+
+    ro = object_new((void *)ra, agmt_delete);
+    objset_add_obj(agmt_set, ro);
+    object_release(ro); /* Object now owned by objset */
+
+    /* get the replica for this agreement */
+    replarea_sdn = agmt_get_replarea(ra);
+    repl_obj = replica_get_replica_from_dn(replarea_sdn);
+    slapi_sdn_free(&replarea_sdn);
+    if (repl_obj) {
+        replica = (Replica*)object_get_data (repl_obj);
+    }
+
+    rc = replica_start_agreement(replica, ra);
+
+    if (repl_obj) object_release(repl_obj);
+
+    return rc;
+}
+
+static int
+agmtlist_add_callback(Slapi_PBlock *pb, Slapi_Entry *e, Slapi_Entry *entryAfter,
+	int *returncode, char *returntext, void *arg)
+{
+	int rc;
+	slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmt_add: begin\n");
+
+	rc = add_new_agreement(e);
+	if (0 != rc) {
+		char *dn;
+		slapi_pblock_get(pb, SLAPI_TARGET_DN, &dn);
+		slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "agmtlist_add_callback: "
+			"Can't start agreement \"%s\"\n", dn);
+		*returncode = LDAP_UNWILLING_TO_PERFORM;
+		return SLAPI_DSE_CALLBACK_ERROR;
+	}
+	*returncode = LDAP_SUCCESS;
+	return SLAPI_DSE_CALLBACK_OK;
+}
+
+static int
+agmtlist_modify_callback(Slapi_PBlock *pb, Slapi_Entry *entryBefore, Slapi_Entry *e,
+	int *returncode, char *returntext, void *arg)
+{
+	int i;
+    char *dn;
+	Slapi_DN *sdn = NULL;
+	int start_initialize = 0, stop_initialize = 0, cancel_initialize = 0;
+    int update_the_schedule = 0;	/* do we need to update the repl sched? */
+	Repl_Agmt *agmt = NULL;
+	LDAPMod **mods;
+    char buff [BUFSIZ];
+    char *errortext = returntext ? returntext : buff;
+    int rc = SLAPI_DSE_CALLBACK_OK;
+    Slapi_Operation *op;
+    void *identity;
+
+    *returncode = LDAP_SUCCESS;
+
+     /* just let internal operations originated from replication plugin to go through */
+    slapi_pblock_get (pb, SLAPI_OPERATION, &op);
+    slapi_pblock_get (pb, SLAPI_PLUGIN_IDENTITY, &identity);                
+
+    if (operation_is_flag_set(op, OP_FLAG_INTERNAL) &&
+        (identity == repl_get_plugin_identity (PLUGIN_MULTIMASTER_REPLICATION)))
+    {
+        goto done;
+    }
+
+    slapi_pblock_get(pb, SLAPI_TARGET_DN, &dn);
+	sdn= slapi_sdn_new_dn_byref(dn);
+	agmt = agmtlist_get_by_agmt_name(sdn);
+	if (NULL == agmt)
+	{
+		slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "agmtlist_modify_callback: received "
+			"a modification for unknown replication agreement \"%s\"\n", dn);
+		goto done;
+	}
+
+	slapi_pblock_get(pb, SLAPI_MODIFY_MODS, &mods);
+	for (i = 0; NULL != mods && NULL != mods[i]; i++)
+	{
+		if (slapi_attr_types_equivalent(mods[i]->mod_type, type_nsds5ReplicaInitialize))
+		{
+            /* we don't allow delete attribute operations unless it was issued by
+               the replication plugin - handled above */
+            if (mods[i]->mod_op & LDAP_MOD_DELETE)
+            {                
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "deletion of %s attribute is not allowed\n", type_nsds5ReplicaInitialize);	
+                *returncode = LDAP_UNWILLING_TO_PERFORM;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+                break;
+            }
+            else
+            {
+                char *val;
+
+                if (mods[i]->mod_bvalues && mods[i]->mod_bvalues[0])
+                    val = slapi_berval_get_string_copy (mods[i]->mod_bvalues[0]);
+                else
+                {
+                    slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "no value provided for %s attribute\n", type_nsds5ReplicaInitialize);
+                    *returncode = LDAP_UNWILLING_TO_PERFORM;
+                    rc = SLAPI_DSE_CALLBACK_ERROR;
+                    break;   
+                }
+
+			    /* Start replica initialization */
+                if (val == NULL)
+                {
+                    sprintf (errortext, "No value supplied for attr (%s)", mods[i]->mod_type);
+                    slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: %s\n",
+                                    errortext);	  
+                    *returncode = LDAP_UNWILLING_TO_PERFORM;
+                    rc = SLAPI_DSE_CALLBACK_ERROR;
+                    break;
+                }
+            
+                if (strcasecmp (val, "start") == 0)
+                {                        
+			        start_initialize = 1;
+                }
+                else if (strcasecmp (val, "stop") == 0)
+                {
+                    stop_initialize = 1;
+                }
+                else if (strcasecmp (val, "cancel") == 0)
+                {
+                    cancel_initialize = 1;
+                }
+                else
+                {
+                    sprintf (errortext, "Invalid value (%s) value supplied for attr (%s)", 
+                             val, mods[i]->mod_type);
+                    slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: %s\n",
+                                    errortext);	
+                }
+            
+                slapi_ch_free ((void**)&val);
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaUpdateSchedule))
+		{
+			/*
+			 * Request to update the replication schedule.  Set a flag so
+			 * we know to update the schedule later.
+			 */
+			update_the_schedule = 1;
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaCredentials))
+		{
+			/* New replica credentials */
+			if (agmt_set_credentials_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update credentials for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaTimeout))
+		{
+			/* New replica timeout */
+			if (agmt_set_timeout_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update timeout for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaBusyWaitTime))
+		{
+			/* New replica busywaittime */
+			if (agmt_set_busywaittime_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update busy wait time for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaSessionPauseTime))
+		{
+			/* New replica pausetime */
+			if (agmt_set_pausetime_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update session pause time for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaBindDN))
+		{
+			/* New replica Bind DN */
+			if (agmt_set_binddn_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update bind DN for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5TransportInfo))
+		{
+			/* New Transport info */
+			if (agmt_set_transportinfo_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update transport info for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+					type_nsds5ReplicaBindMethod))
+		{
+			/* New replica bind method */
+			if (agmt_set_bind_method_from_entry(agmt, e) != 0)
+            {
+                slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                                "failed to update bind method for agreement %s\n",
+                                agmt_get_long_name(agmt));	
+                *returncode = LDAP_OPERATIONS_ERROR;
+                rc = SLAPI_DSE_CALLBACK_ERROR;
+            }
+		}
+		else if (slapi_attr_types_equivalent(mods[i]->mod_type,
+											 "nsds5debugreplicatimeout"))
+		{
+			char *val = slapi_entry_attr_get_charptr(e, "nsds5debugreplicatimeout");
+			repl5_set_debug_timeout(val);
+			slapi_ch_free_string(&val);
+		}
+        else if (strcasecmp (mods[i]->mod_type, "modifytimestamp") == 0 ||
+                 strcasecmp (mods[i]->mod_type, "modifiersname") == 0 ||
+                 strcasecmp (mods[i]->mod_type, "description") == 0)
+        {
+            /* ignore modifier's name and timestamp attributes and the description. */
+            continue;
+        }
+        else
+        {
+            slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                            "modification of %s attribute is not allowed\n", mods[i]->mod_type);
+            *returncode = LDAP_UNWILLING_TO_PERFORM;
+            rc = SLAPI_DSE_CALLBACK_ERROR;
+            break;
+        }
+	}
+
+	if (stop_initialize)
+	{
+        agmt_stop (agmt);
+    }
+    else if (start_initialize)
+    {
+	if (agmt_initialize_replica(agmt) != 0) {
+		/* The suffix is disabled */
+		agmt_set_last_init_status(agmt, 0, NSDS50_REPL_DISABLED, NULL);
+	}
+    }
+    else if (cancel_initialize)
+    {
+		agmt_replica_init_done(agmt);
+	}
+
+	if (update_the_schedule) 
+    {
+		if (agmt_set_schedule_from_entry(agmt, e) != 0)
+        {
+            slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_modify_callback: " 
+                            "failed to update replication schedule for agreement %s\n",
+                            agmt_get_long_name(agmt));	
+            *returncode = LDAP_OPERATIONS_ERROR;
+            rc = SLAPI_DSE_CALLBACK_ERROR;
+        }
+	}
+
+done:
+	if (NULL != agmt)
+	{
+		agmtlist_release_agmt(agmt);
+	}
+
+    if (sdn)
+	    slapi_sdn_free(&sdn);
+	return rc;
+}
+
+static int
+agmtlist_delete_callback(Slapi_PBlock *pb, Slapi_Entry *e, Slapi_Entry *entryAfter,
+	int *returncode, char *returntext, void *arg)
+{
+	Repl_Agmt *ra;
+	Object *ro;
+
+	slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "agmt_delete: begin\n");
+	ro = objset_find(agmt_set, agmt_dn_cmp, (const void *)slapi_entry_get_sdn_const(e));
+	ra = (NULL == ro) ? NULL : (Repl_Agmt *)object_get_data(ro);
+	if (NULL == ra)
+	{
+		slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "agmtlist_delete: "
+			"Tried to delete replication agreement \"%s\", but no such "
+			"agreement was configured.\n", slapi_sdn_get_dn(slapi_entry_get_sdn_const(e)));
+	}
+	else
+	{
+		agmt_stop(ra);
+		object_release(ro); /* Release ref acquired in objset_find */
+		objset_remove_obj(agmt_set, ro); /* Releases a reference (should be final reference */
+	}
+	*returncode = LDAP_SUCCESS;
+	return SLAPI_DSE_CALLBACK_OK;
+}
+
+static int
+agmtlist_rename_callback(Slapi_PBlock *pb, Slapi_Entry *entryBefore, Slapi_Entry *e,
+	int *returncode, char *returntext, void *arg)
+{
+	slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "agmt_rename: begin\n");
+
+	*returncode = LDAP_SUCCESS;
+	return SLAPI_DSE_CALLBACK_OK;
+}
+
+
+static int
+handle_agmt_search(Slapi_Entry *e, void *callback_data)
+{
+	int *agmtcount = (int *)callback_data;
+	int rc;
+
+	slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name,
+		"Found replication agreement named \"%s\".\n",
+		slapi_sdn_get_dn(slapi_entry_get_sdn(e)));
+	rc = add_new_agreement(e);
+	if (0 == rc)
+	{
+		(*agmtcount)++;
+	}
+	else
+	{
+		slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "The replication "
+			"agreement named \"%s\" could not be correctly parsed. No "
+			"replication will occur with this replica.\n",
+			slapi_sdn_get_dn(slapi_entry_get_sdn(e)));
+	}
+
+	return rc;
+}
+
+
+static void
+agmtlist_objset_destructor(void **o)
+{
+	/* XXXggood Nothing to do, I think. */
+}
+	
+
+int
+agmtlist_config_init()
+{
+	Slapi_PBlock *pb;
+	int agmtcount = 0;
+
+	agmt_set = objset_new(agmtlist_objset_destructor);
+
+	/* Register callbacks so we're informed about updates */
+	slapi_config_register_callback(SLAPI_OPERATION_ADD, DSE_FLAG_PREOP, AGMT_CONFIG_BASE,
+		LDAP_SCOPE_SUBTREE, CONFIG_FILTER, agmtlist_add_callback, NULL);
+	slapi_config_register_callback(SLAPI_OPERATION_MODIFY, DSE_FLAG_PREOP, AGMT_CONFIG_BASE,
+		LDAP_SCOPE_SUBTREE, CONFIG_FILTER, agmtlist_modify_callback, NULL);
+	slapi_config_register_callback(SLAPI_OPERATION_DELETE, DSE_FLAG_PREOP, AGMT_CONFIG_BASE,
+		LDAP_SCOPE_SUBTREE, CONFIG_FILTER, agmtlist_delete_callback, NULL);
+	slapi_config_register_callback(SLAPI_OPERATION_MODRDN, DSE_FLAG_PREOP, AGMT_CONFIG_BASE,
+		LDAP_SCOPE_SUBTREE, CONFIG_FILTER, agmtlist_rename_callback, NULL);
+
+	/* Search the DIT and find all the replication agreements */
+	pb = slapi_pblock_new();
+	slapi_search_internal_set_pb(pb, AGMT_CONFIG_BASE, LDAP_SCOPE_SUBTREE,
+		CONFIG_FILTER, NULL /* attrs */, 0 /* attrsonly */,
+		NULL, /* controls */ NULL /* uniqueid */,
+		repl_get_plugin_identity(PLUGIN_MULTIMASTER_REPLICATION), 0 /* actions */);
+	slapi_search_internal_callback_pb(pb,
+		(void *)&agmtcount /* callback data */,
+		NULL /* result_callback */,
+		handle_agmt_search /* search entry cb */,
+		NULL /* referral callback */);
+	slapi_pblock_destroy(pb);
+
+	slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name, "agmtlist_config_init: found %d replication agreements in DIT\n", agmtcount);
+
+	return 0;
+}
+
+
+
+void
+agmtlist_shutdown()
+{
+	Repl_Agmt *ra;
+	Object *ro;
+	Object *next_ro;
+
+	ro = objset_first_obj(agmt_set);
+	while (NULL != ro)
+	{
+		next_ro = objset_next_obj(agmt_set, ro);
+		ra = (Repl_Agmt *)object_get_data(ro);
+		agmt_stop(ra);
+        agmt_update_consumer_ruv (ra);
+		objset_remove_obj(agmt_set, ro);
+		ro = next_ro;
+	}
+	objset_delete(&agmt_set);
+	agmt_set = NULL;
+}
+
+
+
+/*
+ * Notify each replication agreement about an update.
+ */
+void
+agmtlist_notify_all(Slapi_PBlock *pb)
+{
+	Repl_Agmt *ra;
+	Object *ro;
+
+	if (NULL != agmt_set)
+	{
+		ro = objset_first_obj(agmt_set);
+		while (NULL != ro)
+		{
+			ra = (Repl_Agmt *)object_get_data(ro);
+			agmt_notify_change(ra, pb);
+			ro = objset_next_obj(agmt_set, ro);
+		}
+	}
+}
+
+Object* agmtlist_get_first_agreement_for_replica (Replica *r)
+{
+    return agmtlist_get_next_agreement_for_replica (r, NULL)   ;
+}
+
+Object* agmtlist_get_next_agreement_for_replica (Replica *r, Object *prev)
+{
+    const Slapi_DN *replica_root;
+    Slapi_DN *agmt_root;
+    Object *obj;
+    Repl_Agmt *agmt;
+
+    if (r == NULL)
+    {
+        /* ONREPL - log error */
+        return NULL;
+    }
+
+    replica_root = replica_get_root(r);  
+
+    if (prev)
+        obj = objset_next_obj(agmt_set, prev);   
+    else
+        obj = objset_first_obj(agmt_set);
+        
+    while (obj)
+    {
+        agmt = (Repl_Agmt*)object_get_data (obj);
+        PR_ASSERT (agmt);
+
+        agmt_root = agmt_get_replarea(agmt);
+        PR_ASSERT (agmt_root);
+
+        if (slapi_sdn_compare (replica_root, agmt_root) == 0)
+        {
+            slapi_sdn_free (&agmt_root);
+            return obj;
+        }
+
+        slapi_sdn_free (&agmt_root);
+        obj = objset_next_obj(agmt_set, obj);
+    }
+
+    return NULL;
+}