From 5ec0cb08889c9f1a24fd4cc8b139dcdb942dd92a Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Fri, 14 Aug 2009 12:37:19 +0000
Subject: [PATCH] Support for External change log compatible with draft-good-ldap-changelog-04.txt , March 2003
---
opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java | 18 ++++++++++++++++--
1 files changed, 16 insertions(+), 2 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java b/opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java
index 960cd6f..4ed5700 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/server/DbHandler.java
@@ -28,6 +28,7 @@
import org.opends.messages.MessageBuilder;
import static org.opends.server.loggers.ErrorLogger.logError;
+import static org.opends.server.loggers.debug.DebugLogger.getTracer;
import static org.opends.messages.ReplicationMessages.*;
import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
@@ -46,6 +47,7 @@
import org.opends.server.types.InitializationException;
import org.opends.server.util.TimeThread;
import org.opends.server.core.DirectoryServer;
+import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.replication.common.ChangeNumber;
import org.opends.server.replication.protocol.UpdateMsg;
import org.opends.server.replication.server.ReplicationDB.ReplServerDBCursor;
@@ -121,6 +123,7 @@
*
*/
private long trimage;
+ private static final DebugTracer TRACER = getTracer();
/**
* Creates a new dbHandler associated to a given LDAP server.
@@ -291,13 +294,14 @@
ChangeNumber recentChangeNumber = null;
if (changeNumber == null)
+ {
flush();
-
+ }
synchronized (msgQueue)
{
try
{
- UpdateMsg msg = msgQueue.getFirst();
+ UpdateMsg msg = msgQueue.getLast();
recentChangeNumber = msg.getChangeNumber();
}
catch (NoSuchElementException e)
@@ -654,4 +658,14 @@
lastChange = db.readLastChange();
}
}
+
+ /**
+ * Getter fot the serverID of the server for which this database is managed.
+ *
+ * @return the serverId.
+ */
+ public short getServerId()
+ {
+ return this.serverId;
+ }
}
--
Gitblit v1.10.0