From 2cf4412179a4ca8610d7fbb2108040377290bf82 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Fri, 06 Jun 2014 13:12:34 +0000
Subject: [PATCH] OPENDJ-1453 (CR-3697) Change time heart beat change numbers should be synced with updates
---
opends/src/server/org/opends/server/replication/service/ReplicationDomain.java | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java b/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
index d539630..75b1242 100644
--- a/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
+++ b/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -214,7 +214,7 @@
/**
* Current status for this replicated domain.
*/
- protected ServerStatus status = ServerStatus.NOT_CONNECTED_STATUS;
+ private ServerStatus status = ServerStatus.NOT_CONNECTED_STATUS;
/**
* The tracer object for the debug logger.
@@ -2461,7 +2461,13 @@
* event.
* @param event The event that may make the status be changed
*/
- protected void setNewStatus(StatusMachineEvent event)
+ protected void signalNewStatus(StatusMachineEvent event)
+ {
+ setNewStatus(event);
+ broker.signalStatusChange(status);
+ }
+
+ private void setNewStatus(StatusMachineEvent event)
{
ServerStatus newStatus = StatusMachine.computeNewStatus(status, event);
if (newStatus == ServerStatus.INVALID_STATUS)
@@ -3433,7 +3439,7 @@
* receive this {@link UpdateMsg} through a call of the
* {@link #processUpdate(UpdateMsg)} message.
*
- * @param msg The UpdateMsg that should be pushed.
+ * @param msg The UpdateMsg that should be published.
*/
public void publish(UpdateMsg msg)
{
--
Gitblit v1.10.0