Author: rmeggins
Update of /cvs/dirsec/ldapserver/ldap/servers/plugins/replication
In directory cvs1.fedora.phx.redhat.com:/tmp/cvs-serv6239/ldapserver/ldap/servers/plugins/replication
Modified Files:
cl5_api.c cl5_clcache.c cl5_clcache.h cl5_config.c
Log Message:
Resolves: bug 487425
Bug Description: slapd crashes after changelog is moved
Reviewed by: nkinder, nhosoi (Thanks!)
Fix Description: There are a number of real fixes, mixed in with many changes for debugging and instrumentation.
1) When the update thread gets the changelog iterator, it will use _cl5AddThread to increment the count of threads holding an open handle to the changelog. When it releases the iterator, or if there were some error acquiring the database handle, it will decrement the thread count. The way it used to work was that it would increment the thread count when retrieving the DB object, but then would immediately decrement it, meaning it had an open handle to the database, but there was no way for the changelog code to know that (except via the reference count on the DB object itself).
2) Changed the AddThread code to increment the thread count outside of the state lock - this better fits the semantics of the other uses of threadcount which are outside of the lock.
3) The changelog code that closes the databases was not closing things down in the correct order. The first thing it must do is wait for all threads with open database handles or otherwise accessing the database to terminate. Once that is done, it can call _cl5DBClose() to actually close all of the databases. Otherwise, a race condition could cause a database to be accessed after it has been closed.
4) Added clcache cleanup code, and made it possible to re-init the clcache. The clcache was not designed to be dynamically closed and opened.
clcache is init-ed in _cl5Open
clcache_init is re-entrant
Added more code to clean up the clcache
Delete the clcache in _cl5Delete
5) The clcache stores the current buffer in a thread private storage area. If the clcache has been re-initialized, this buffer is also invalid and the clcache code must get a new buffer.
Platforms tested: RHEL5
Flag Day: no
Doc impact: no
Index: cl5_api.c
===================================================================
RCS file: /cvs/dirsec/ldapserver/ldap/servers/plugins/replication/cl5_api.c,v
retrieving revision 1.26
retrieving revision 1.27
diff -u -r1.26 -r1.27
--- cl5_api.c 5 Dec 2008 22:41:51 -0000 1.26
+++ cl5_api.c 4 Mar 2009 18:58:05 -0000 1.27
@@ -527,7 +527,7 @@
/* already open - ignore */
if (s_cl5Desc.dbState == CL5_STATE_OPEN)
{
- slapi_log_error(SLAPI_LOG_PLUGIN, repl_plugin_name_cl,
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
"cl5Open: changelog already opened; request ignored\n");
rc = CL5_SUCCESS;
goto done;
@@ -920,6 +920,11 @@
object_release (file_obj);
}
+ else
+ {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "cl5GetUpperBoundRUV: "
+ "could not find DB object for replica\n");
+ }
object_release (r_obj);
@@ -1756,7 +1761,7 @@
if (replica == NULL || consumerRuv == NULL || iterator == NULL)
{
slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
- "cl5CreateReplayIterator: invalid parameter\n");
+ "cl5CreateReplayIteratorEx: invalid parameter\n");
return CL5_BAD_DATA;
}
@@ -1765,7 +1770,7 @@
if (s_cl5Desc.dbState == CL5_STATE_NONE)
{
slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
- "cl5CreateReplayIterator: changelog is not initialized\n");
+ "cl5CreateReplayIteratorEx: changelog is not initialized\n");
return CL5_BAD_STATE;
}
@@ -1787,8 +1792,17 @@
object_release (obj);
}
}
+ else
+ {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "cl5CreateReplayIteratorEx: could not find DB object for replica\n");
+ }
- _cl5RemoveThread ();
+ if (rc != CL5_SUCCESS)
+ {
+ /* release the thread */
+ _cl5RemoveThread ();
+ }
return rc;
}
@@ -1842,8 +1856,17 @@
object_release (obj);
}
}
+ else
+ {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "cl5CreateReplayIterator: could not find DB object for replica\n");
+ }
- _cl5RemoveThread ();
+ if (rc != CL5_SUCCESS)
+ {
+ /* release the thread */
+ _cl5RemoveThread ();
+ }
return rc;
@@ -1937,14 +1960,21 @@
clcache_return_buffer ( &(*iterator)->clcache );
- if ((*iterator)->fileObj)
+ if ((*iterator)->fileObj) {
object_release ((*iterator)->fileObj);
+ (*iterator)->fileObj = NULL;
+ }
/* release supplier's ruv */
- if ((*iterator)->supplierRuvObj)
+ if ((*iterator)->supplierRuvObj) {
object_release ((*iterator)->supplierRuvObj);
+ (*iterator)->supplierRuvObj = NULL;
+ }
slapi_ch_free ((void **)iterator);
+
+ /* this thread no longer holds a db reference, release it */
+ _cl5RemoveThread();
}
/* Name: cl5DeleteOnClose
@@ -2039,10 +2069,14 @@
PR_ASSERT (file);
count = file->entryCount;
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "cl5GetOperationCount: found DB object %p\n", obj);
object_release (obj);
}
else
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "cl5GetOperationCount: could not get DB object for replica\n");
count = 0;
}
}
@@ -2071,6 +2105,12 @@
_cl5SetDefaultDBConfig ();
}
+ /* init the clcache */
+ if (( clcache_init (&s_cl5Desc.dbEnv) != 0 )) {
+ rc = CL5_SYSTEM_ERROR;
+ goto done;
+ }
+
/* initialize trimming */
rc = _cl5TrimInit ();
if (rc != CL5_SUCCESS)
@@ -2404,6 +2444,7 @@
PRDirEntry *entry = NULL;
int rc;
Object *replica;
+ int count = 0;
/* create lock that guarantees that each file is only added once to the list */
s_cl5Desc.fileLock = PR_NewLock ();
@@ -2445,6 +2486,7 @@
}
object_release (replica);
+ count++;
}
else /* there is no matching replica for the file - remove */
{
@@ -2464,6 +2506,8 @@
}
}
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBOpen: "
+ "opened %d existing databases in %s\n", count, s_cl5Desc.dbDir);
PR_CloseDir(dir);
return CL5_SUCCESS;
@@ -2759,12 +2803,12 @@
return CL5_BAD_STATE;
}
+ PR_RWLock_Unlock (s_cl5Desc.stLock);
+
/* increment global thread count to make sure that changelog does not close while
backup is in progress */
PR_AtomicIncrement (&s_cl5Desc.threadCount);
- PR_RWLock_Unlock (s_cl5Desc.stLock);
-
return CL5_SUCCESS;
}
@@ -3157,6 +3201,7 @@
}
PR_AtomicDecrement (&s_cl5Desc.threadCount);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DeadlockMain: exiting\n");
return 0;
}
@@ -3237,6 +3282,7 @@
}
PR_AtomicDecrement (&s_cl5Desc.threadCount);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5CheckpointMain: exiting\n");
return 0;
}
@@ -3262,6 +3308,7 @@
}
PR_AtomicDecrement (&s_cl5Desc.threadCount);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5TrickleMain: exiting\n");
return 0;
}
@@ -3773,28 +3820,38 @@
if (s_cl5Desc.dbState != CL5_STATE_CLOSED) /* Don't try to close twice */
{
- /* close db files */
- _cl5DBClose ();
-
- /* stop global threads */
+ /* cl5Close() set the state flag to CL5_STATE_CLOSING, which should
+ trigger all of the db housekeeping threads to exit, and which will
+ eventually cause no new update threads to start - so we wait here
+ for those other threads to finish before we proceed */
interval = PR_MillisecondsToInterval(100);
while (s_cl5Desc.threadCount > 0)
{
- slapi_log_error( SLAPI_LOG_PLUGIN, repl_plugin_name_cl,
+ slapi_log_error( SLAPI_LOG_REPL, repl_plugin_name_cl,
"_cl5Close: waiting for threads to exit: %d thread(s) still active\n",
s_cl5Desc.threadCount);
DS_Sleep(interval);
}
+ /* There should now be no threads accessing any of the changelog databases -
+ it is safe to remove those databases */
+ _cl5DBClose ();
+
/* cleanup trimming */
_cl5TrimCleanup ();
- /* shutdown db environment */
+ /* There should be no more open databases after _cl5DBClose, so it is now
+ safe to close the dbEnv */
if (s_cl5Desc.dbEnv)
{
DB_ENV *dbEnv = s_cl5Desc.dbEnv;
- dbEnv->close(dbEnv, 0);
+ int rc = dbEnv->close(dbEnv, 0);
s_cl5Desc.dbEnv = NULL;
+ if (rc) {
+ slapi_log_error( SLAPI_LOG_FATAL, repl_plugin_name_cl,
+ "_cl5Close: error closing DB environment: %d (%s)\n",
+ rc, db_strerror(rc));
+ }
}
/* record successful close by writing guardian file;
@@ -3828,11 +3885,20 @@
{
if (NULL != s_cl5Desc.dbFiles)
{
- objset_delete (&s_cl5Desc.dbFiles);
+ Object *obj;
+ for (obj = objset_first_obj(s_cl5Desc.dbFiles); obj;
+ obj = objset_next_obj(s_cl5Desc.dbFiles, obj)) {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5DBClose: deleting DB object %p\n", obj);
+ }
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5DBClose: closing databases in %s\n", s_cl5Desc.dbDir);
+ objset_delete (&s_cl5Desc.dbFiles);
}
if (NULL != s_cl5Desc.fileLock)
{
PR_DestroyLock (s_cl5Desc.fileLock);
+ s_cl5Desc.fileLock = NULL;
}
}
@@ -3936,6 +4002,9 @@
"_cl5Delete: changelog dir (%s) is not empty - cannot remove\n",
clDir);
}
+
+ /* invalidate the clcache */
+ clcache_destroy();
return CL5_SUCCESS;
}
@@ -4142,6 +4211,7 @@
}
PR_AtomicDecrement (&s_cl5Desc.threadCount);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5TrimMain: exiting\n");
return 0;
}
@@ -4502,8 +4572,8 @@
else
{
slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,
- "_cl5WriteRUV: failed to write %s RUV for file %s; db error - %d\n",
- purge? "purge" : "upper bound", file->name, rc);
+ "_cl5WriteRUV: failed to write %s RUV for file %s; db error - %d (%s)\n",
+ purge? "purge" : "upper bound", file->name, rc, db_strerror(rc));
if (CL5_OS_ERR_IS_DISKFULL(rc))
{
@@ -5168,12 +5238,14 @@
PR_TRUE /* check for duplicates */);
if (rc != CL5_SUCCESS)
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5WriteOperation: failed to find or open DB object for replica %s\n", replName);
return rc;
}
}
else if (rc != CL5_SUCCESS)
{
- slapi_log_error(SLAPI_LOG_PLUGIN, repl_plugin_name_cl,
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
"_cl5WriteOperation: failed to get db file for target dn (%s)",
op->target_address.dn);
return CL5_OBJSET_ERROR;
@@ -5283,7 +5355,7 @@
}
else if ((cnt + 1) >= MAX_TRIALS)
{
- slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl, "_cl5WriteOperation: retry (%d) the transaction (csn=%s) failed (rc=%d)\n", cnt, (char*)key.data, rc);
+ slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl, "_cl5WriteOperation: retry (%d) the transaction (csn=%s) failed (rc=%d (%s))\n", cnt, (char*)key.data, rc, db_strerror(rc));
}
}
cnt ++;
@@ -6235,6 +6307,8 @@
file_name = NULL;
if (tmpObj) /* this file already exist */
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5DBOpenFileByReplicaName: Found DB object %p for replica %s\n", tmpObj, replName);
/* if we were asked for file handle - keep the handle */
if (obj)
{
@@ -6281,6 +6355,8 @@
/* Mark the DB File initialize */
_cl5DBFileInitialized(tmpObj);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5DBOpenFileByReplicaName: created new DB object %p\n", tmpObj);
if (obj)
{
*obj = tmpObj;
@@ -6325,6 +6401,11 @@
object_release (tmpObj);
return CL5_OBJSET_ERROR;
}
+ else
+ {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "_cl5AddDBFile: Added new DB object %p\n", tmpObj);
+ }
if (obj)
{
@@ -6516,6 +6597,11 @@
file = *(CL5DBFile**)data;
+ PR_ASSERT (file);
+
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBCloseFile: "
+ "Closing database %s/%s\n", s_cl5Desc.dbDir, file->name);
+
/* close the file */
/* if this is normal close or close after import, update entry count */
if ((s_cl5Desc.dbOpenMode == CL5_OPEN_NORMAL && s_cl5Desc.dbState == CL5_STATE_CLOSING) ||
@@ -6527,28 +6613,38 @@
}
/* close the db */
- if (file->db)
+ if (file->db) {
file->db->close(file->db, 0);
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBCloseFile: "
+ "Closed the changelog database handle for %s/%s\n", s_cl5Desc.dbDir, file->name);
+ file->db = NULL;
+ }
if (file->flags & DB_FILE_DELETED)
- {
- int rc = 0;
- /* We need to use the libdb API to delete the files, otherwise we'll
- * run into problems when we try to checkpoint transactions later. */
- PR_snprintf(fullpathname, MAXPATHLEN, "%s/%s", s_cl5Desc.dbDir, file->name);
- rc = s_cl5Desc.dbEnv->dbremove(s_cl5Desc.dbEnv, 0, fullpathname, 0, 0);
- if (rc != 0)
- {
- slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBCloseFile: "
- "failed to remove (%s) file; libdb error - %d (%s)\n",
- fullpathname, rc, db_strerror(rc));
- }
+ {
+ int rc = 0;
+ /* We need to use the libdb API to delete the files, otherwise we'll
+ * run into problems when we try to checkpoint transactions later. */
+ PR_snprintf(fullpathname, MAXPATHLEN, "%s/%s", s_cl5Desc.dbDir, file->name);
+ rc = s_cl5Desc.dbEnv->dbremove(s_cl5Desc.dbEnv, 0, fullpathname, 0, 0);
+ if (rc != 0)
+ {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBCloseFile: "
+ "failed to remove (%s) file; libdb error - %d (%s)\n",
+ fullpathname, rc, db_strerror(rc));
+ } else {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBCloseFile: "
+ "Deleted the changelog database file %s/%s\n", s_cl5Desc.dbDir, file->name);
+
}
+ }
/* slapi_ch_free accepts NULL pointer */
slapi_ch_free ((void**)&file->name);
slapi_ch_free ((void**)&file->replName);
slapi_ch_free ((void**)&file->replGen);
+ ruv_destroy(&file->maxRUV);
+ ruv_destroy(&file->purgeRUV);
if (file->sema) {
PR_CloseSemaphore (file->sema);
PR_DeleteSemaphore (file->semaName);
@@ -6568,13 +6664,18 @@
fileName = _cl5Replica2FileName (replica);
*obj = objset_find(s_cl5Desc.dbFiles, _cl5CompareDBFile, fileName);
- slapi_ch_free ((void**)&fileName);
if (*obj)
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5GetDBFile: "
+ "found DB object %p for database %s\n", *obj, fileName);
+ slapi_ch_free_string(&fileName);
return CL5_SUCCESS;
}
else
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5GetDBFile: "
+ "no DB object found for database %s\n", fileName);
+ slapi_ch_free_string(&fileName);
return CL5_NOTFOUND;
}
}
@@ -6589,13 +6690,18 @@
fileName = _cl5MakeFileName (replName, replGen);
*obj = objset_find(s_cl5Desc.dbFiles, _cl5CompareDBFile, fileName);
- slapi_ch_free ((void**)&fileName);
if (*obj)
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5GetDBFileByReplicaName: "
+ "found DB object %p for database %s\n", *obj, fileName);
+ slapi_ch_free_string(&fileName);
return CL5_SUCCESS;
}
else
{
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5GetDBFileByReplicaName: "
+ "no DB object found for database %s\n", fileName);
+ slapi_ch_free_string(&fileName);
return CL5_NOTFOUND;
}
}
@@ -6603,13 +6709,21 @@
static void _cl5DBDeleteFile (Object *obj)
{
CL5DBFile *file;
+ int rc = 0;
PR_ASSERT (obj);
file = (CL5DBFile*)object_get_data (obj);
PR_ASSERT (file);
file->flags |= DB_FILE_DELETED;
- objset_remove_obj(s_cl5Desc.dbFiles, obj);
+ rc = objset_remove_obj(s_cl5Desc.dbFiles, obj);
+ if (rc != OBJSET_SUCCESS) {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBDeleteFile: "
+ "could not find DB object %p\n", obj);
+ } else {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl, "_cl5DBDeleteFile: "
+ "removed DB object %p\n", obj);
+ }
object_release (obj);
}
Index: cl5_clcache.c
===================================================================
RCS file: /cvs/dirsec/ldapserver/ldap/servers/plugins/replication/cl5_clcache.c,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- cl5_clcache.c 5 Dec 2008 22:41:51 -0000 1.9
+++ cl5_clcache.c 4 Mar 2009 18:58:05 -0000 1.10
@@ -178,6 +178,9 @@
int
clcache_init ( DB_ENV **dbenv )
{
+ if (_pool) {
+ return 0; /* already initialized */
+ }
_pool = (struct clc_pool*) slapi_ch_calloc ( 1, sizeof ( struct clc_pool ));
_pool->pl_dbenv = dbenv;
_pool->pl_buffer_cnt_min = DEFAULT_CLC_BUFFER_COUNT_MIN;
@@ -225,12 +228,23 @@
clcache_get_buffer ( CLC_Buffer **buf, DB *db, ReplicaId consumer_rid, const RUV *consumer_ruv, const RUV *local_ruv )
{
int rc = 0;
+ int need_new;
if ( buf == NULL ) return CL5_BAD_DATA;
*buf = NULL;
- if ( NULL != ( *buf = (CLC_Buffer*) get_thread_private_cache()) ) {
+ /* if the pool was re-initialized, the thread private cache will be invalid,
+ so we must get a new one */
+ need_new = (!_pool || !_pool->pl_busy_lists || !_pool->pl_busy_lists->bl_buffers);
+
+ if ( (!need_new) && (NULL != ( *buf = (CLC_Buffer*) get_thread_private_cache())) ) {
+ slapi_log_error ( SLAPI_LOG_REPL, get_thread_private_agmtname(),
+ "clcache_get_buffer: found thread private buffer cache %p\n", *buf);
+ slapi_log_error ( SLAPI_LOG_REPL, get_thread_private_agmtname(),
+ "clcache_get_buffer: _pool is %p _pool->pl_busy_lists is %p _pool->pl_busy_lists->bl_buffers is %p\n",
+ _pool, _pool ? _pool->pl_busy_lists : NULL,
+ (_pool && _pool->pl_busy_lists) ? _pool->pl_busy_lists->bl_buffers : NULL);
(*buf)->buf_state = CLC_STATE_READY;
(*buf)->buf_load_cnt = 0;
(*buf)->buf_record_cnt = 0;
@@ -481,6 +495,7 @@
int i;
for ( i = 0; i < buf->buf_num_cscbs; i++ ) {
+ csn_free(&buf->buf_cscbs[i]->consumer_maxcsn);
ruv_get_largest_csn_for_replica (
buf->buf_consumer_ruv,
buf->buf_cscbs[i]->rid,
@@ -841,8 +856,22 @@
clcache_delete_busy_list ( CLC_Busy_List **bl )
{
if ( bl && *bl ) {
+ CLC_Buffer *buf = NULL;
if ( (*bl)->bl_lock ) {
+ PR_Lock ( (*bl)->bl_lock );
+ }
+ buf = (*bl)->bl_buffers;
+ while (buf) {
+ CLC_Buffer *next = buf->buf_next;
+ clcache_delete_buffer(&buf);
+ buf = next;
+ }
+ (*bl)->bl_buffers = NULL;
+ (*bl)->bl_db = NULL;
+ if ( (*bl)->bl_lock ) {
+ PR_Unlock ( (*bl)->bl_lock );
PR_DestroyLock ( (*bl)->bl_lock );
+ (*bl)->bl_lock = NULL;
}
/* csn_free (&( (*bl)->bl_max_csn )); */
slapi_ch_free ( (void **) bl );
@@ -951,3 +980,29 @@
*csn1 = csn_new();
csn_init_by_csn ( *csn1, csn2 );
}
+
+void
+clcache_destroy()
+{
+ if (_pool) {
+ CLC_Busy_List *bl = NULL;
+ if (_pool->pl_lock) {
+ PR_RWLock_Wlock (_pool->pl_lock);
+ }
+
+ bl = _pool->pl_busy_lists;
+ while (bl) {
+ CLC_Busy_List *next = bl->bl_next;
+ clcache_delete_busy_list(&bl);
+ bl = next;
+ }
+ _pool->pl_busy_lists = NULL;
+ _pool->pl_dbenv = NULL;
+ if (_pool->pl_lock) {
+ PR_RWLock_Unlock(_pool->pl_lock);
+ PR_DestroyRWLock(_pool->pl_lock);
+ _pool->pl_lock = NULL;
+ }
+ slapi_ch_free ( (void **) &_pool );
+ }
+}
Index: cl5_clcache.h
===================================================================
RCS file: /cvs/dirsec/ldapserver/ldap/servers/plugins/replication/cl5_clcache.h,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- cl5_clcache.h 10 Nov 2006 23:45:17 -0000 1.5
+++ cl5_clcache.h 4 Mar 2009 18:58:05 -0000 1.6
@@ -55,5 +55,6 @@
int clcache_load_buffer ( CLC_Buffer *buf, CSN *startCSN, int flag );
void clcache_return_buffer ( CLC_Buffer **buf );
int clcache_get_next_change ( CLC_Buffer *buf, void **key, size_t *keylen, void **data, size_t *datalen, CSN **csn );
+void clcache_destroy ();
#endif
Index: cl5_config.c
===================================================================
RCS file: /cvs/dirsec/ldapserver/ldap/servers/plugins/replication/cl5_config.c,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- cl5_config.c 5 Dec 2008 22:41:51 -0000 1.9
+++ cl5_config.c 4 Mar 2009 18:58:05 -0000 1.10
@@ -497,8 +497,6 @@
"old dir - %s, new dir - %s; recreating changelog.\n",
currentDir, config.dir);
- /* this call will block until all threads using changelog
- release changelog by calling cl5RemoveThread () */
rc = cl5Close ();
if (rc != CL5_SUCCESS)
{
@@ -511,6 +509,9 @@
slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,
"changelog5_config_modify: failed to close changelog\n");
goto done;
+ } else {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "changelog5_config_modify: closed the changelog\n");
}
rc = cl5Delete (currentDir);
@@ -525,6 +526,9 @@
slapi_log_error(SLAPI_LOG_FATAL, repl_plugin_name_cl,
"changelog5_config_modify: failed to remove changelog\n");
goto done;
+ } else {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "changelog5_config_modify: deleted the changelog at %s\n", currentDir);
}
rc = cl5Open (config.dir, &config.dbconfig);
@@ -544,6 +548,9 @@
"changelog5_config_modify: failed to restore previous changelog\n");
}
goto done;
+ } else {
+ slapi_log_error(SLAPI_LOG_REPL, repl_plugin_name_cl,
+ "changelog5_config_modify: opened the changelog at %s\n", config.dir);
}
}
}
