From 5589e80c0344aafd9db1b24ef4a820486620322a Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Thu, 13 Mar 2008 10:01:22 +0000
Subject: [PATCH] An update sent by a replicated LDAP server is tagged with a ChangeNumber generated by a ChangeNumberGenerator. One component of the ChangeNumber is a timestamp, Because we want the timestamp of the ChangeNumbers to be consistently growing across the whole topology and not only inside each server independently, the ChangeNumberGenerator must be adjusted with the timestamp of the updates received from the other servers of the topology. The code was already here but erroneously used.
---
opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java
index 6b248c7..1fb063b 100644
--- a/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java
+++ b/opendj-sdk/opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java
@@ -477,13 +477,16 @@
/*
* ChangeNumberGenerator is used to create new unique ChangeNumbers
- * for each operation done on the replication domain.
+ * for each operation done on this replication domain.
+ *
+ * The generator time is adjusted to the time of the last CN received from
+ * remote other servers.
*/
ChangeNumberGenerator generator =
new ChangeNumberGenerator(serverId, state);
pendingChanges =
- new PendingChanges(new ChangeNumberGenerator(serverId, state),
+ new PendingChanges(generator,
broker, state);
remotePendingChanges = new RemotePendingChanges(generator, state);
--
Gitblit v1.10.0