From 0bee1ee3a776af367c685d042155cd43ae71deab 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 : --- opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java | 15 +++++++++++---- 1 files changed, 11 insertions(+), 4 deletions(-) diff --git a/opendj-sdk/opends/src/server/org/opends/server/synchronization/ChangelogBroker.java b/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java similarity index 96% rename from opendj-sdk/opends/src/server/org/opends/server/synchronization/ChangelogBroker.java rename to opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java index 2778e34..f96b10a 100644 --- a/opendj-sdk/opends/src/server/org/opends/server/synchronization/ChangelogBroker.java +++ b/opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java @@ -24,11 +24,11 @@ * * Portions Copyright 2006 Sun Microsystems, Inc. */ -package org.opends.server.synchronization; +package org.opends.server.synchronization.plugin; import static org.opends.server.loggers.Error.logError; import static org.opends.server.messages.MessageHandler.getMessage; -import static org.opends.server.synchronization.SynchMessages.*; +import static org.opends.server.synchronization.common.LogMessages.*; import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString; import java.util.LinkedHashSet; @@ -43,13 +43,20 @@ import java.net.SocketException; import java.net.SocketTimeoutException; -import org.opends.server.changelog.ProtocolSession; -import org.opends.server.changelog.SocketSession; import org.opends.server.protocols.asn1.ASN1OctetString; import org.opends.server.protocols.internal.InternalClientConnection; import org.opends.server.protocols.internal.InternalSearchListener; import org.opends.server.protocols.internal.InternalSearchOperation; import org.opends.server.protocols.ldap.LDAPFilter; +import org.opends.server.synchronization.common.ChangeNumber; +import org.opends.server.synchronization.common.ServerState; +import org.opends.server.synchronization.protocol.ChangelogStartMessage; +import org.opends.server.synchronization.protocol.ProtocolSession; +import org.opends.server.synchronization.protocol.ServerStartMessage; +import org.opends.server.synchronization.protocol.SocketSession; +import org.opends.server.synchronization.protocol.SynchronizationMessage; +import org.opends.server.synchronization.protocol.UpdateMessage; +import org.opends.server.synchronization.protocol.WindowMessage; import org.opends.server.types.DN; import org.opends.server.types.DereferencePolicy; import org.opends.server.types.ErrorLogCategory; -- Gitblit v1.10.0