From dbb7add555b086d07776332278ba3a1142be2c32 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 28 Jun 2013 10:11:49 +0000
Subject: [PATCH] PendingChanges.java: Added comments.
---
opends/src/server/org/opends/server/replication/plugin/PendingChanges.java | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java b/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
index c7cf14e..edb376e 100644
--- a/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
+++ b/opends/src/server/org/opends/server/replication/plugin/PendingChanges.java
@@ -169,6 +169,7 @@
return numSentUpdates;
}
+ // peek the oldest changeNumber
ChangeNumber firstChangeNumber = pendingChanges.firstKey();
PendingChange firstChange = pendingChanges.get(firstChangeNumber);
@@ -185,6 +186,8 @@
}
else
{
+ // do not push updates until the RS catches up.
+ // @see #setRecovering(boolean)
domain.getServerState().update(updateMsg.getChangeNumber());
}
}
@@ -196,6 +199,7 @@
}
else
{
+ // peek the oldest changeNumber
firstChangeNumber = pendingChanges.firstKey();
firstChange = pendingChanges.get(firstChangeNumber);
}
--
Gitblit v1.10.0