From e07cdcbd253fd366c5002f7368470e0158bfcc2c Mon Sep 17 00:00:00 2001
From: gbellato <gbellato@localhost>
Date: Mon, 13 Nov 2006 08:31:12 +0000
Subject: [PATCH] Fix for 982 : reorganize synchronization code :
---
opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java
index f73ca4b..69dd07f 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java
@@ -49,6 +49,11 @@
import org.opends.server.core.ModifyOperation;
import org.opends.server.core.Operation;
import org.opends.server.protocols.internal.InternalClientConnection;
+import org.opends.server.synchronization.plugin.ChangelogBroker;
+import org.opends.server.synchronization.plugin.MultimasterSynchronization;
+import org.opends.server.synchronization.plugin.PersistentServerState;
+import org.opends.server.synchronization.protocol.AddMsg;
+import org.opends.server.synchronization.protocol.SynchronizationMessage;
import org.opends.server.types.Attribute;
import org.opends.server.types.AttributeType;
import org.opends.server.types.AttributeValue;
@@ -397,7 +402,7 @@
private ChangelogBroker openChangelogSession(final DN baseDn, short serverId)
throws Exception, SocketException
{
- ServerState state = new ServerState(baseDn);
+ PersistentServerState state = new PersistentServerState(baseDn);
state.loadState();
ChangelogBroker broker = new ChangelogBroker(state, baseDn,
serverId, 0, 0, 0, 0, 100);
--
Gitblit v1.10.0