From 5349c97806bb0a00038d8dc3dee4254fad187649 Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Wed, 25 Apr 2007 16:35:36 +0000
Subject: [PATCH] Second set of renaming for issue 1090 Rename org.opends.server.replication.changelog into org.opends.server.synchronization.changelog Use replication instead of synchronization in many places in the code/comment/file names
---
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java | 29 ++++++++++++++---------------
1 files changed, 14 insertions(+), 15 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
index e5b83f5..1d565db 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
@@ -47,7 +47,7 @@
import org.opends.server.protocols.internal.InternalClientConnection;
import org.opends.server.replication.plugin.ChangelogBroker;
import org.opends.server.replication.protocol.AddMsg;
-import org.opends.server.replication.protocol.SynchronizationMessage;
+import org.opends.server.replication.protocol.ReplicationMessage;
import org.opends.server.types.Attribute;
import org.opends.server.types.AttributeType;
import org.opends.server.types.AttributeValue;
@@ -67,13 +67,13 @@
/**
* Stress test for the synchronization code using the ChangelogBroker API.
*/
-public class StressTest extends SynchronizationTestCase
+public class StressTest extends ReplicationTestCase
{
- private static final String SYNCHRONIZATION_STRESS_TEST =
- "Synchronization Stress Test";
+ private static final String REPLICATION_STRESS_TEST =
+ "Replication Stress Test";
/**
- * The Synchronization config manager entry
+ * The replication config manager entry
*/
private String synchroStringDN;
@@ -104,7 +104,7 @@
{
logError(ErrorLogCategory.SYNCHRONIZATION,
ErrorLogSeverity.NOTICE,
- "Starting Synchronization StressTest : fromServertoBroker" , 1);
+ "Starting replication StressTest : fromServertoBroker" , 1);
final DN baseDn = DN.decode("ou=People,dc=example,dc=com");
final int TOTAL_MESSAGES = 1000;
@@ -134,18 +134,18 @@
if (ResultCode.SUCCESS == addOp.getResultCode())
{
// Check if the client has received the msg
- SynchronizationMessage msg = broker.receive();
+ ReplicationMessage msg = broker.receive();
assertTrue(msg instanceof AddMsg,
- "The received synchronization message is not an ADD msg");
+ "The received replication message is not an ADD msg");
AddMsg addMsg = (AddMsg) msg;
Operation receivedOp = addMsg.createOperation(connection);
assertTrue(OperationType.ADD.compareTo(receivedOp.getOperationType()) == 0,
- "The received synchronization message is not an ADD msg");
+ "The received replication message is not an ADD msg");
assertEquals(DN.decode(addMsg.getDn()),personEntry.getDN(),
- "The received ADD synchronization message is not for the excepted DN");
+ "The received ADD replication message is not for the excepted DN");
}
reader = new BrokerReader(broker);
@@ -180,14 +180,13 @@
}
finally {
- DirectoryServer.deregisterMonitorProvider(SYNCHRONIZATION_STRESS_TEST);
+ DirectoryServer.deregisterMonitorProvider(REPLICATION_STRESS_TEST);
broker.stop();
}
}
/**
* Set up the environment for performing the tests in this Class.
- * synchronization
*
* @throws Exception
* If the environment could not be set up.
@@ -268,7 +267,7 @@
+ "userPassword: password\n" + "initials: AA\n";
personEntry = TestCaseUtils.entryFromLdifString(personLdif);
- configureSynchronization();
+ configureReplication();
}
/**
@@ -351,7 +350,7 @@
{
while (true)
{
- SynchronizationMessage msg = broker.receive();
+ ReplicationMessage msg = broker.receive();
if (msg == null)
break;
count ++;
@@ -423,7 +422,7 @@
@Override
public String getMonitorInstanceName()
{
- return SYNCHRONIZATION_STRESS_TEST;
+ return REPLICATION_STRESS_TEST;
}
@Override
--
Gitblit v1.10.0