From e3add78e22e130ef6ece000a7989f4f4317d4da8 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 04 Oct 2013 14:03:02 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/server/changelog/je/DbHandler.java b/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
similarity index 96%
rename from opends/src/server/org/opends/server/replication/server/changelog/je/DbHandler.java
rename to opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
index eeb52b2..ea7962b 100644
--- a/opends/src/server/org/opends/server/replication/server/changelog/je/DbHandler.java
+++ b/opends/src/server/org/opends/server/replication/server/changelog/je/JEReplicaDB.java
@@ -65,7 +65,7 @@
*
* This class publish some monitoring information below cn=monitor.
*/
-public class DbHandler implements Runnable
+public class JEReplicaDB implements Runnable
{
/**
* The msgQueue holds all the updates not yet saved to stable storage.
@@ -129,17 +129,17 @@
private long trimAge;
/**
- * Creates a new dbHandler associated to a given LDAP server.
+ * Creates a new ReplicaDB associated to a given LDAP server.
*
* @param id Identifier of the DB.
* @param baseDN the baseDN for which this DB was created.
- * @param replicationServer The ReplicationServer that creates this dbHandler.
+ * @param replicationServer The ReplicationServer that creates this ReplicaDB.
* @param dbenv the Database Env to use to create the ReplicationServer DB.
* server for this domain.
- * @param queueSize The queueSize to use when creating the dbHandler.
+ * @param queueSize The queueSize to use when creating the ReplicaDB.
* @throws ChangelogException If a database problem happened
*/
- public DbHandler(int id, DN baseDN, ReplicationServer replicationServer,
+ public JEReplicaDB(int id, DN baseDN, ReplicationServer replicationServer,
ReplicationDbEnv dbenv, int queueSize) throws ChangelogException
{
this.replicationServer = replicationServer;
@@ -260,13 +260,13 @@
/**
* Generate a new {@link ReplicaDBCursor} that allows to browse the db managed
- * by this dbHandler and starting at the position defined by a given CSN.
+ * by this ReplicaDB and starting at the position defined by a given CSN.
*
* @param startAfterCSN
* The position where the cursor must start. If null, start from the
* oldest CSN
* @return a new {@link ReplicaDBCursor} that allows to browse the db managed
- * by this dbHandler and starting at the position defined by a given
+ * by this ReplicaDB and starting at the position defined by a given
* CSN.
* @throws ChangelogException
* if a database problem happened.
@@ -306,7 +306,7 @@
}
/**
- * Shutdown this dbHandler.
+ * Shutdown this ReplicaDB.
*/
public void shutdown()
{
@@ -519,8 +519,8 @@
}
/**
- * This internal class is used to implement the Monitoring capabilities
- * of the dbHandler.
+ * This internal class is used to implement the Monitoring capabilities of the
+ * ReplicaDB.
*/
private class DbMonitorProvider extends MonitorProvider<MonitorProviderCfg>
{
@@ -625,7 +625,7 @@
}
/**
- * Return the size of the msgQueue (the memory cache of the DbHandler).
+ * Return the size of the msgQueue (the memory cache of the ReplicaDB).
* For test purpose.
* @return The memory queue size.
*/
--
Gitblit v1.10.0