From abd1c1d0e098dfd071ab12dad075870d88495783 Mon Sep 17 00:00:00 2001

From: Mark Reynolds <mreynolds@redhat.com>

Date: Thu, 22 Dec 2016 14:38:27 -0500

Subject: [PATCH] Ticket 48964 - cleanallruv changelog purging removes wrong

 rid

Bug Description:  A regression from the previous patch uses the local replica

                  object to locate the correct changelog file, but the rid to

                  be clean is not the same rid from the replica object.  So the

                  local replica object's rid is used accidentally to purge the

                  change log.

Fix Description:  Instead if passing the replica object to the changelog purging

                  code, create a new purge_data struct to hold all the neccessary

                  data to purge the correct changelog file and the cleaned rid.

https://fedorahosted.org/389/ticket/48964

Reviewed by: nhosoi(Thanks!)

(cherry picked from commit a38d76d27970b5b6facf2ffbd1bce9d6979e6297)

(cherry picked from commit 4053587d5dfb9c4b4e5cd966cabb1adc624511d6)

---

 ldap/servers/plugins/replication/cl5_api.c         | 54 +++++++++++++---------

 ldap/servers/plugins/replication/cl5_api.h         |  2 +-

 ldap/servers/plugins/replication/repl5.h           |  8 ++++

 .../plugins/replication/repl5_replica_config.c     | 12 ++++-

 4 files changed, 50 insertions(+), 26 deletions(-)

diff --git a/ldap/servers/plugins/replication/cl5_api.c b/ldap/servers/plugins/replication/cl5_api.c

index f8b2cea..66c2677 100644

--- a/ldap/servers/plugins/replication/cl5_api.c

+++ b/ldap/servers/plugins/replication/cl5_api.c

@@ -3500,12 +3500,12 @@ static void _cl5DoTrimming ()

  * changelog for the backend that is being cleaned, and purge all the records

  * with the cleaned rid.

  */

-static void _cl5DoPurging (Replica *replica)

+static void _cl5DoPurging (cleanruv_purge_data *purge_data)

 {

-	ReplicaId rid = replica_get_rid(replica);

-	const Slapi_DN *sdn = replica_get_root(replica);

-	const char *replName = replica_get_name(replica);

-	char *replGen = replica_get_generation(replica);

+	ReplicaId rid = purge_data->cleaned_rid;

+	const Slapi_DN *suffix_sdn = purge_data->suffix_sdn;

+	const char *replName = purge_data->replName;

+	char *replGen = purge_data->replGen;

 	char *fileName;

 	Object *obj;

@@ -3517,18 +3517,15 @@ static void _cl5DoPurging (Replica *replica)

 		_cl5PurgeRID (obj, rid);

 		object_release (obj);

 		slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,

-			"Purged rid (%d) from suffix (%s)\n",

-			rid, slapi_sdn_get_dn(sdn));

+			"_cl5DoPurging - Purged rid (%d) from suffix (%s)\n",

+			rid, slapi_sdn_get_dn(suffix_sdn));

 	} else {

 		slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,

-			"Purge rid (%d) failed to find changelog file (%s) for suffix (%s)\n",

-			rid, fileName, slapi_sdn_get_dn(sdn));

+			"_cl5DoPurging - Purge rid (%d) failed to find changelog file (%s) for suffix (%s)\n",

+			rid, fileName, slapi_sdn_get_dn(suffix_sdn));

 	}

 	PR_Unlock (s_cl5Desc.dbTrim.lock);

-	slapi_ch_free_string(&replGen);

-	slapi_ch_free_string(&fileName);

-

 	return;

 }

@@ -6983,19 +6980,27 @@ cl5CleanRUV(ReplicaId rid){

     slapi_rwlock_unlock (s_cl5Desc.stLock);

 }

+static void free_purge_data(cleanruv_purge_data *purge_data)

+{

+    slapi_ch_free_string(&purge_data->replGen);

+    slapi_ch_free_string(&purge_data->replName);

+    slapi_ch_free((void **)&purge_data);

+}

+

 /*

  * Create a thread to purge a changelog of cleaned RIDs

  */

-void trigger_cl_purging(Replica *replica){

+void trigger_cl_purging(cleanruv_purge_data *purge_data){

     PRThread *trim_tid = NULL;

     trim_tid = PR_CreateThread(PR_USER_THREAD, (VFP)(void*)trigger_cl_purging_thread,

-                   (void *)replica, PR_PRIORITY_NORMAL, PR_GLOBAL_THREAD,

+                   (void *)purge_data, PR_PRIORITY_NORMAL, PR_GLOBAL_THREAD,

                    PR_UNJOINABLE_THREAD, DEFAULT_THREAD_STACKSIZE);

     if (NULL == trim_tid){

         slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,

-            "trigger_cl_purging: failed to create trimming "

+            "trigger_cl_purging: failed to create cl trimming "

             "thread; NSPR error - %d\n", PR_GetError ());

+        free_purge_data(purge_data);

     } else {

         /* need a little time for the thread to get started */

         DS_Sleep(PR_SecondsToInterval(1));

@@ -7007,13 +7012,12 @@ void trigger_cl_purging(Replica *replica){

  */

 void

 trigger_cl_purging_thread(void *arg){

-    Replica *replica = (Replica *)arg;

+    cleanruv_purge_data *purge_data = (cleanruv_purge_data *)arg;

     /* Make sure we have a change log, and we aren't closing it */

-    if (replica == NULL ||

-        s_cl5Desc.dbState == CL5_STATE_CLOSED ||

+    if (s_cl5Desc.dbState == CL5_STATE_CLOSED ||

         s_cl5Desc.dbState == CL5_STATE_CLOSING) {

-        return;

+        goto free_and_return;

     }

     /* Bump the changelog thread count */

@@ -7021,13 +7025,17 @@ trigger_cl_purging_thread(void *arg){

         slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,

             "trigger_cl_purging: Abort - failed to increment thread count "

             "NSPR error - %d\n", PR_GetError ());

-        return;

+        goto free_and_return;

     }

     /* Purge the changelog */

-    _cl5DoPurging(replica);

+    _cl5DoPurging(purge_data);

     _cl5RemoveThread();

+

     slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,

-        "trigger_cl_purging: purged changelog for (%s) rid (%d)\n",

-        slapi_sdn_get_dn(replica_get_root(replica)), replica_get_rid(replica));

+        "trigger_cl_purging_thread - purged changelog for (%s) rid (%d)\n",

+        slapi_sdn_get_dn(purge_data->suffix_sdn), purge_data->cleaned_rid);

+

+free_and_return:

+    free_purge_data(purge_data);

 }

diff --git a/ldap/servers/plugins/replication/cl5_api.h b/ldap/servers/plugins/replication/cl5_api.h

index 1a1c2f5..e33601d 100644

--- a/ldap/servers/plugins/replication/cl5_api.h

+++ b/ldap/servers/plugins/replication/cl5_api.h

@@ -467,6 +467,6 @@ int cl5WriteRUV();

 int cl5DeleteRUV();

 void cl5CleanRUV(ReplicaId rid);

 void cl5NotifyCleanup(int rid);

-void trigger_cl_purging(Replica *replica);

+void trigger_cl_purging(cleanruv_purge_data *purge_data);

 #endif

diff --git a/ldap/servers/plugins/replication/repl5.h b/ldap/servers/plugins/replication/repl5.h

index 6582876..4ab2355 100644

--- a/ldap/servers/plugins/replication/repl5.h

+++ b/ldap/servers/plugins/replication/repl5.h

@@ -704,6 +704,14 @@ typedef struct _cleanruv_data

 	char *force;

 } cleanruv_data;

+typedef struct _cleanruv_purge_data

+{

+	int cleaned_rid;

+	const Slapi_DN *suffix_sdn;

+	char *replName;

+	char *replGen;

+} cleanruv_purge_data;

+

 /* replutil.c */

 LDAPControl* create_managedsait_control ();

 LDAPControl* create_backend_control(Slapi_DN *sdn);

diff --git a/ldap/servers/plugins/replication/repl5_replica_config.c b/ldap/servers/plugins/replication/repl5_replica_config.c

index 59e5298..d78d982 100644

--- a/ldap/servers/plugins/replication/repl5_replica_config.c

+++ b/ldap/servers/plugins/replication/repl5_replica_config.c

@@ -1434,6 +1434,7 @@ replica_execute_cleanruv_task (Object *r, ReplicaId rid, char *returntext /* not

 	Object *RUVObj;

 	RUV *local_ruv = NULL;

 	Replica *replica = (Replica*)object_get_data (r);

+	cleanruv_purge_data *purge_data;

 	int rc = 0;

 	PR_ASSERT (replica);

@@ -1465,9 +1466,16 @@ replica_execute_cleanruv_task (Object *r, ReplicaId rid, char *returntext /* not

 	cl5CleanRUV(rid);

 	/*

-	 * Now purge the changelog

+	 * Now purge the changelog.  The purging thread will free the purge_data

 	 */

-	trigger_cl_purging(replica);

+	if (replica){

+		purge_data = (cleanruv_purge_data*)slapi_ch_calloc(1, sizeof(cleanruv_purge_data));

+		purge_data->cleaned_rid = rid;

+		purge_data->suffix_sdn = replica_get_root(replica);

+		purge_data->replName = (char *)replica_get_name(replica);

+		purge_data->replGen = replica_get_generation(replica);

+		trigger_cl_purging(purge_data);

+	}

 	if (rc != RUV_SUCCESS){

 		slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name, "cleanruv_task: task failed(%d)\n",rc);

-- 

2.7.4