From e28129952012344616a9227effc31c8f13f08b4f Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Wed, 09 Dec 2009 09:56:00 +0000
Subject: [PATCH] Minor fix to improve reliability of unit test ECLSimultaneousPsearches
---
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java | 2 ++
opends/src/server/org/opends/server/replication/service/ReplicationBroker.java | 11 +++++++++++
2 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java b/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
index 91ec9ea..3bc4795 100644
--- a/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
+++ b/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
@@ -2583,6 +2583,17 @@
}
/**
+ * Set a new change time heartbeat interval to this broker.
+ * @param changeTimeHeartbeatInterval The new interval (in ms).
+ */
+ public void setChangeTimeHeartbeatInterval(int changeTimeHeartbeatInterval)
+ {
+ stopChangeTimeHeartBeatPublishing();
+ this.changeTimeHeartbeatSendInterval = changeTimeHeartbeatInterval;
+ startChangeTimeHeartBeatPublishing();
+ }
+
+ /**
* Set the connectRequiresRecovery to the provided value.
* This flag is used to indicate if a recovery of Update is necessary
* after a reconnection to a RS.
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java
index 6db04d7..30cdaca 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ExternalChangeLogTest.java
@@ -1939,6 +1939,7 @@
DN.decode(TEST_ROOT_DN_STRING), 1201,
100, replicationServerPort,
brokerSessionTimeout, true);
+ server01.setChangeTimeHeartbeatInterval(100); //ms
int ts = 1;
// Create broker on o=test2
@@ -1946,6 +1947,7 @@
DN.decode(TEST_ROOT_DN_STRING2), 1202,
100, replicationServerPort,
brokerSessionTimeout, true, EMPTY_DN_GENID);
+ server02.setChangeTimeHeartbeatInterval(100); //ms
// Produce update 1
ChangeNumber cn1 =
--
Gitblit v1.10.0