First set of modifications for issue 1090 : rename synchronization components
Move from synchronization package name to replication.
93 files renamed
5 files modified
| | |
| | | objectClass: ds-cfg-ordering-matching-rule |
| | | objectClass: top |
| | | objectClass: ds-cfg-matching-rule |
| | | ds-cfg-matching-rule-class: org.opends.server.synchronization.plugin.HistoricalCsnOrderingMatchingRule |
| | | ds-cfg-matching-rule-class: org.opends.server.replication.plugin.HistoricalCsnOrderingMatchingRule |
| | | ds-cfg-matching-rule-enabled: true |
| | | cn: Historical CSN Ordering Matching Rule |
| | | |
| | |
| | | objectClass: ds-cfg-synchronization-provider |
| | | objectClass: ds-cfg-multimaster-synchronization-provider |
| | | ds-cfg-synchronization-provider-enabled: true |
| | | ds-cfg-synchronization-provider-class: org.opends.server.synchronization.plugin.MultimasterSynchronization |
| | | ds-cfg-synchronization-provider-class: org.opends.server.replication.plugin.MultimasterSynchronization |
| | | |
| | | dn: cn=domains, cn=Multimaster Synchronization,cn=Synchronization Providers,cn=config |
| | | objectClass: top |
| | |
| | | SYNTAX 1.3.6.1.4.1.1466.115.121.1.7 SINGLE-VALUE |
| | | X-ORIGIN 'OpenDS Directory Server' ) |
| | | attributeTypes: ( 1.3.6.1.4.1.26027.1.1.156 NAME 'ds-sync-hist' |
| | | ORDERING historicalCsnOrderingMatch SYNTAX 1.3.6.1.4.1.1466.115.121.1.15 |
| | | SYNTAX 1.3.6.1.4.1.1466.115.121.1.15 ORDERING historicalCsnOrderingMatch |
| | | USAGE directoryOperation X-ORIGIN 'OpenDS Directory Server' ) |
| | | attributeTypes: ( 1.3.6.1.4.1.26027.1.1.157 |
| | | NAME 'ds-cfg-receive-status' |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/AckMessageList.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.LinkedList; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class is used to store the list of acks received for |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/AckMessageListComparator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.Comparator; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/Changelog.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import org.opends.server.config.ConfigAttribute; |
| | | import org.opends.server.config.ConfigEntry; |
| | | import org.opends.server.config.ConfigException; |
| | | import org.opends.server.synchronization.protocol.SocketSession; |
| | | import org.opends.server.replication.protocol.SocketSession; |
| | | import org.opends.server.types.ConfigChangeResult; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.ErrorLogCategory; |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogAckMessageList.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class is used to store acks for update messages coming from |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogCache.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import java.util.Set; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.protocol.AckMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeRequestMessage; |
| | | import org.opends.server.synchronization.protocol.ErrorMessage; |
| | | import org.opends.server.synchronization.protocol.RoutableMessage; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.protocol.AckMessage; |
| | | import org.opends.server.replication.protocol.ErrorMessage; |
| | | import org.opends.server.replication.protocol.InitializeRequestMessage; |
| | | import org.opends.server.replication.protocol.RoutableMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogDB.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | import com.sleepycat.je.Cursor; |
| | | import com.sleepycat.je.DatabaseEntry; |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogDBException.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogData.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import com.sleepycat.je.DatabaseEntry; |
| | | |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | /** |
| | | * SuperClass of DatabaseEntry used for data stored in the Changelog Databases. |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogDbEnv.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogIterator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import com.sleepycat.je.DatabaseException; |
| | | |
| | | import org.opends.server.synchronization.changelog.ChangelogDB.ChangelogCursor; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.changelog.ChangelogDB.ChangelogCursor; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | /** |
| | | * This class allows to iterate through the changes received from a given |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogIteratorComparator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.Comparator; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This Class define a Comparator that allows to know which ChangelogIterator |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ChangelogKey.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | |
| | | import com.sleepycat.je.DatabaseEntry; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * Superclass of DatabaseEntry. |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/DbHandler.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import org.opends.server.types.InitializationException; |
| | | import org.opends.server.util.TimeThread; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.synchronization.changelog.ChangelogDB.ChangelogCursor; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.changelog.ChangelogDB.ChangelogCursor; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | import com.sleepycat.je.DatabaseException; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/MsgQueue.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.SortedMap; |
| | | import java.util.TreeMap; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | /** |
| | | * This class is used to build ordered lists of UpdateMessage. |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ServerHandler.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| | |
| | | import org.opends.server.config.ConfigEntry; |
| | | import org.opends.server.config.ConfigException; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.protocol.AckMessage; |
| | | import org.opends.server.synchronization.protocol.ChangelogStartMessage; |
| | | import org.opends.server.synchronization.protocol.HeartbeatThread; |
| | | import org.opends.server.synchronization.protocol.ProtocolSession; |
| | | import org.opends.server.synchronization.protocol.RoutableMessage; |
| | | import org.opends.server.synchronization.protocol.ServerStartMessage; |
| | | 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.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.protocol.AckMessage; |
| | | import org.opends.server.replication.protocol.ChangelogStartMessage; |
| | | import org.opends.server.replication.protocol.HeartbeatThread; |
| | | import org.opends.server.replication.protocol.ProtocolSession; |
| | | import org.opends.server.replication.protocol.RoutableMessage; |
| | | import org.opends.server.replication.protocol.ServerStartMessage; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.WindowMessage; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ServerReader.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import java.io.IOException; |
| | | |
| | | import org.opends.server.api.DirectoryThread; |
| | | import org.opends.server.synchronization.protocol.AckMessage; |
| | | import org.opends.server.synchronization.protocol.ErrorMessage; |
| | | import org.opends.server.synchronization.protocol.DoneMessage; |
| | | import org.opends.server.synchronization.protocol.EntryMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeRequestMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeTargetMessage; |
| | | import org.opends.server.synchronization.protocol.ProtocolSession; |
| | | 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.replication.protocol.AckMessage; |
| | | import org.opends.server.replication.protocol.DoneMessage; |
| | | import org.opends.server.replication.protocol.EntryMessage; |
| | | import org.opends.server.replication.protocol.ErrorMessage; |
| | | import org.opends.server.replication.protocol.InitializeRequestMessage; |
| | | import org.opends.server.replication.protocol.InitializeTargetMessage; |
| | | import org.opends.server.replication.protocol.ProtocolSession; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.WindowMessage; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/ServerWriter.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import java.util.NoSuchElementException; |
| | | |
| | | import org.opends.server.api.DirectoryThread; |
| | | import org.opends.server.synchronization.protocol.ProtocolSession; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.ProtocolSession; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/UpdateComparator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.Comparator; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | |
| | | /** |
| | | * Class to use for establishing an order within UpdateMessages. |
| File was renamed from opends/src/server/org/opends/server/synchronization/changelog/package-info.java |
| | |
| | | * </ul> |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| File was renamed from opends/src/server/org/opends/server/synchronization/common/ChangeNumber.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | /** |
| | | * Class used to represent Change Numbers. |
| File was renamed from opends/src/server/org/opends/server/synchronization/common/ChangeNumberGenerator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | import org.opends.server.util.TimeThread; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/common/ServerState.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.ArrayList; |
| File was renamed from opends/src/server/org/opends/server/synchronization/common/package-info.java |
| | |
| | | |
| | | /** |
| | | * This package contains utilities that can are used by all the packages |
| | | * below org.opends.server.synchronization. |
| | | * below org.opends.server.replication. |
| | | * <br> |
| | | * The main classes of this core are : |
| | | * <ul> |
| | |
| | | * </li> |
| | | * </ul> |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| File was renamed from opends/src/server/org/opends/server/synchronization/package-info.java |
| | |
| | | * This package contains the code for the synchronization feature |
| | | * which provides a Multi-Master replication system. |
| | | */ |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/AttrInfo.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Iterator; |
| | | import java.util.LinkedHashSet; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.AttributeValue; |
| | | |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/AttrInfoWithOptions.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.HashMap; |
| | | import java.util.Set; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| | |
| | | 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.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.protocol.ChangelogStartMessage; |
| | | import org.opends.server.replication.protocol.ProtocolSession; |
| | | import org.opends.server.replication.protocol.ServerStartMessage; |
| | | import org.opends.server.replication.protocol.SocketSession; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.WindowMessage; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DereferencePolicy; |
| | | import org.opends.server.types.ErrorLogCategory; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/ChangelogListener.java |
| | |
| | | * |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.List; |
| | | |
| | |
| | | import org.opends.server.admin.std.server.ChangelogServerCfg; |
| | | import org.opends.server.admin.std.server.MultimasterSynchronizationProviderCfg; |
| | | import org.opends.server.config.ConfigException; |
| | | import org.opends.server.synchronization.changelog.Changelog; |
| | | import org.opends.server.replication.changelog.Changelog; |
| | | import org.opends.server.types.ConfigChangeResult; |
| | | import org.opends.server.types.ResultCode; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/FakeOperation.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.types.Modification; |
| | | |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/FakeOperationComparator.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.Comparator; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/HeartbeatMonitor.java |
| | |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugInfo; |
| | |
| | | import java.io.IOException; |
| | | |
| | | import org.opends.server.api.DirectoryThread; |
| | | import org.opends.server.synchronization.protocol.ProtocolSession; |
| | | import org.opends.server.replication.protocol.ProtocolSession; |
| | | |
| | | /** |
| | | * This class implements a thread to monitor heartbeat messages from the |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/HistKey.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | /** |
| | | * Enumeration used for storing type of historical information. |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/HistVal.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.LinkedHashSet; |
| | | import java.util.Set; |
| | | |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/Historical.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.OperationContext; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.OperationContext; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/HistoricalCsnOrderingMatchingRule.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.api.OrderingMatchingRule; |
| | | import org.opends.server.config.ConfigEntry; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/ListenerThread.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString; |
| | | |
| | | import org.opends.server.api.DirectoryThread; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/ModifyFakeOperation.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.ModifyMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Modification; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/MultimasterSynchronization.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/PendingChange.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.Operation; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/PersistentServerState.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | |
| | | import org.opends.server.protocols.ldap.LDAPAttribute; |
| | | import org.opends.server.protocols.ldap.LDAPFilter; |
| | | import org.opends.server.protocols.ldap.LDAPModification; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/SynchroLDIFInputStream.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/SynchroLDIFOutputStream.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.io.IOException; |
| | | import java.io.OutputStream; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.opends.server.config.ConfigConstants.ATTR_BACKEND_BASE_DN; |
| | | import static org.opends.server.config.ConfigConstants.ATTR_BACKEND_CLASS; |
| | |
| | | import static org.opends.server.messages.MessageHandler.getMessage; |
| | | import static org.opends.server.messages.ToolMessages.*; |
| | | import static org.opends.server.messages.SynchronizationMessages.*; |
| | | import static org.opends.server.synchronization.plugin.Historical.ENTRYUIDNAME; |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.plugin.Historical.ENTRYUIDNAME; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | import static org.opends.server.util.StaticUtils.createEntry; |
| | | import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString; |
| | | |
| | |
| | | import org.opends.server.protocols.asn1.ASN1Exception; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.internal.InternalSearchOperation; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.protocol.AckMessage; |
| | | import org.opends.server.synchronization.protocol.AddContext; |
| | | import org.opends.server.synchronization.protocol.DeleteContext; |
| | | import org.opends.server.synchronization.protocol.DoneMessage; |
| | | import org.opends.server.synchronization.protocol.EntryMessage; |
| | | import org.opends.server.synchronization.protocol.ErrorMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeRequestMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeTargetMessage; |
| | | import org.opends.server.synchronization.protocol.ModifyContext; |
| | | import org.opends.server.synchronization.protocol.ModifyDNMsg; |
| | | import org.opends.server.synchronization.protocol.ModifyDnContext; |
| | | import org.opends.server.synchronization.protocol.OperationContext; |
| | | import org.opends.server.synchronization.protocol.RoutableMessage; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.protocol.AckMessage; |
| | | import org.opends.server.replication.protocol.AddContext; |
| | | import org.opends.server.replication.protocol.DeleteContext; |
| | | import org.opends.server.replication.protocol.DoneMessage; |
| | | import org.opends.server.replication.protocol.EntryMessage; |
| | | import org.opends.server.replication.protocol.ErrorMessage; |
| | | import org.opends.server.replication.protocol.InitializeRequestMessage; |
| | | import org.opends.server.replication.protocol.InitializeTargetMessage; |
| | | import org.opends.server.replication.protocol.ModifyContext; |
| | | import org.opends.server.replication.protocol.ModifyDNMsg; |
| | | import org.opends.server.replication.protocol.ModifyDnContext; |
| | | import org.opends.server.replication.protocol.OperationContext; |
| | | import org.opends.server.replication.protocol.RoutableMessage; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.tasks.InitializeTargetTask; |
| | | import org.opends.server.tasks.InitializeTask; |
| | | import org.opends.server.tasks.TaskUtils; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/SynchronizationMonitor.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.LinkedHashSet; |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/ValueInfo.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.AttributeValue; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/plugin/package-info.java |
| | |
| | | * </li> |
| | | * </ul> |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/AckMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.zip.DataFormatException; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * Used to send acks between LDAP and changelog servers. |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/AddContext.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class describe the Synchronization contexte that is attached to |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/AddMsg.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.core.DirectoryServer; |
| | |
| | | |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.ldap.LDAPAttribute; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeValue; |
| | | import org.opends.server.types.LDAPException; |
| | | import org.opends.server.types.RawAttribute; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | import static org.opends.server.util.StaticUtils.toLowerCase; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ChangelogStartMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.zip.DataFormatException; |
| | | |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.DN; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/DeleteContext.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class is used to describe the context attached to a Delete Operation. |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/DeleteMsg.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.zip.DataFormatException; |
| | |
| | | import org.opends.server.core.DeleteOperation; |
| | | import org.opends.server.protocols.asn1.ASN1OctetString; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.Operation; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/DoneMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/EntryMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ErrorMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/HeartbeatMessage.java |
| | |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.util.zip.DataFormatException; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/HeartbeatThread.java |
| | |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.api.DirectoryThread; |
| | | import static org.opends.server.loggers.debug.DebugLogger.debugEnabled; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/InitializeRequestMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/InitializeTargetMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ModifyContext.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class describe the synchronization context that is attached to |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ModifyDNMsg.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.zip.DataFormatException; |
| | |
| | | import org.opends.server.core.ModifyDNOperation; |
| | | import org.opends.server.protocols.asn1.ASN1OctetString; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.Operation; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ModifyDnContext.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | |
| | | /** |
| | | * This class describe the synchronization context that is attached to |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ModifyMsg.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.asn1.ASN1Exception; |
| | |
| | | import org.opends.server.protocols.ldap.LDAPModification; |
| | | import org.opends.server.protocols.asn1.ASN1Element; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.plugin.Historical; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.plugin.Historical; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeUsage; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/OperationContext.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.Operation; |
| | | |
| | | /** |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ProtocolSession.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.IOException; |
| | | import java.net.SocketException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/RoutableMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/ServerStartMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| | |
| | | import java.net.UnknownHostException; |
| | | import java.util.zip.DataFormatException; |
| | | |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.DN; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/SocketSession.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/SynchronizationMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.util.zip.DataFormatException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/UpdateMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| | |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.asn1.ASN1Exception; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.types.LDAPException; |
| | | import org.opends.server.types.Operation; |
| | | |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/WindowMessage.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import java.io.Serializable; |
| | | import java.io.UnsupportedEncodingException; |
| File was renamed from opends/src/server/org/opends/server/synchronization/protocol/package-info.java |
| | |
| | | * </ul> |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | |
| | | import org.opends.server.backends.task.TaskState; |
| | | import org.opends.server.messages.TaskMessages; |
| | | import org.opends.server.protocols.asn1.ASN1OctetString; |
| | | import org.opends.server.synchronization.plugin.SynchronizationDomain; |
| | | import org.opends.server.replication.plugin.SynchronizationDomain; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| | |
| | | import org.opends.server.backends.task.TaskState; |
| | | import org.opends.server.messages.TaskMessages; |
| | | import org.opends.server.protocols.asn1.ASN1OctetString; |
| | | import org.opends.server.synchronization.plugin.SynchronizationDomain; |
| | | import org.opends.server.replication.plugin.SynchronizationDomain; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/InitOnLineTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.loggers.Error.logError; |
| | |
| | | import org.opends.server.messages.TaskMessages; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.internal.InternalSearchOperation; |
| | | import org.opends.server.replication.changelog.Changelog; |
| | | import org.opends.server.replication.changelog.ChangelogFakeConfiguration; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.plugin.SynchronizationDomain; |
| | | import org.opends.server.replication.protocol.DoneMessage; |
| | | import org.opends.server.replication.protocol.EntryMessage; |
| | | import org.opends.server.replication.protocol.ErrorMessage; |
| | | import org.opends.server.replication.protocol.InitializeRequestMessage; |
| | | import org.opends.server.replication.protocol.InitializeTargetMessage; |
| | | import org.opends.server.replication.protocol.RoutableMessage; |
| | | import org.opends.server.replication.protocol.SocketSession; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.schema.DirectoryStringSyntax; |
| | | import org.opends.server.synchronization.changelog.Changelog; |
| | | import org.opends.server.synchronization.changelog.ChangelogFakeConfiguration; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.plugin.SynchronizationDomain; |
| | | import org.opends.server.synchronization.protocol.DoneMessage; |
| | | import org.opends.server.synchronization.protocol.EntryMessage; |
| | | import org.opends.server.synchronization.protocol.ErrorMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeRequestMessage; |
| | | import org.opends.server.synchronization.protocol.InitializeTargetMessage; |
| | | import org.opends.server.synchronization.protocol.RoutableMessage; |
| | | import org.opends.server.synchronization.protocol.SocketSession; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Entry; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/ProtocolWindowTest.java |
| | |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.testng.Assert.*; |
| | |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.internal.InternalSearchOperation; |
| | | import org.opends.server.protocols.ldap.LDAPFilter; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.protocol.AddMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | 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.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/ReSyncTest.java |
| | |
| | | * |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.config.ConfigConstants.ATTR_TASK_COMPLETION_TIME; |
| | | import static org.opends.server.config.ConfigConstants.ATTR_TASK_STATE; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/SchemaSynchronizationTest.java |
| | |
| | | * |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.testng.Assert.assertTrue; |
| | |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.ldap.LDAPModification; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.protocol.ModifyMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java |
| | |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.testng.Assert.assertEquals; |
| | |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.protocol.AddMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | 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.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/SynchronizationTestCase.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.testng.Assert.assertNotNull; |
| | |
| | | |
| | | import org.opends.server.DirectoryServerTestCase; |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.plugin.PersistentServerState; |
| | | import org.opends.server.schema.IntegerSyntax; |
| | | import org.opends.server.core.DeleteOperation; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.protocols.internal.InternalSearchOperation; |
| | | import org.opends.server.protocols.ldap.LDAPFilter; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.plugin.PersistentServerState; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Entry; |
| | | import org.opends.server.types.ByteStringFactory; |
| | |
| | | + "objectClass: ds-cfg-multimaster-synchronization-provider\n" |
| | | + "ds-cfg-synchronization-provider-enabled: true\n" |
| | | + "ds-cfg-synchronization-provider-class: " + |
| | | "org.opends.server.synchronization.plugin.MultimasterSynchronization\n"; |
| | | "org.opends.server.replication.plugin.MultimasterSynchronization\n"; |
| | | Entry synchroPluginEntry = TestCaseUtils.entryFromLdifString(synchroPluginLdif); |
| | | DirectoryServer.getConfigHandler().addEntry(synchroPluginEntry, null); |
| | | configEntryList.add(synchroPluginEntry.getDN()); |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/UpdateOperationTest.java |
| | |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization; |
| | | package org.opends.server.replication; |
| | | |
| | | import static org.opends.server.loggers.Error.logError; |
| | | import static org.testng.Assert.*; |
| | |
| | | |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.plugins.ShortCircuitPlugin; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.protocol.AddMsg; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.replication.protocol.HeartbeatThread; |
| | | import org.opends.server.replication.protocol.ModifyDNMsg; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.schema.DirectoryStringSyntax; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.protocol.AddMsg; |
| | | import org.opends.server.synchronization.protocol.DeleteMsg; |
| | | import org.opends.server.synchronization.protocol.ModifyDNMsg; |
| | | import org.opends.server.synchronization.protocol.ModifyMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.synchronization.protocol.HeartbeatThread; |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.core.DeleteOperation; |
| | | import org.opends.server.core.DirectoryServer; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/changelog/ChangelogFakeConfiguration.java |
| | |
| | | * |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.util.SortedSet; |
| | | |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/changelog/ChangelogTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import static org.testng.Assert.assertTrue; |
| | | import static org.testng.Assert.fail; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | |
| | | import java.net.ServerSocket; |
| | | import java.util.ArrayList; |
| | |
| | | |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.core.ModifyDNOperation; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.plugin.ChangelogBroker; |
| | | import org.opends.server.synchronization.protocol.AddMsg; |
| | | import org.opends.server.synchronization.protocol.DeleteMsg; |
| | | import org.opends.server.synchronization.protocol.ModifyDNMsg; |
| | | import org.opends.server.synchronization.protocol.ModifyDnContext; |
| | | import org.opends.server.synchronization.protocol.ModifyMsg; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.changelog.Changelog; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.protocol.AddMsg; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.replication.protocol.ModifyDNMsg; |
| | | import org.opends.server.replication.protocol.ModifyDnContext; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Entry; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/changelog/UpdateComparatorTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import org.testng.annotations.DataProvider; |
| | | import org.testng.annotations.Test; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.SYNCHROCONTEXT; |
| | | import static org.opends.server.replication.protocol.OperationContext.SYNCHROCONTEXT; |
| | | import static org.testng.Assert.*; |
| | | |
| | | |
| | | import org.opends.server.core.DeleteOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.changelog.UpdateComparator; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.DeleteContext; |
| | | import org.opends.server.synchronization.protocol.DeleteMsg; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.changelog.UpdateComparator; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.protocol.DeleteContext; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.util.TimeThread; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/changelog/dbHandlerTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.changelog; |
| | | package org.opends.server.replication.changelog; |
| | | |
| | | import java.io.File; |
| | | import java.net.ServerSocket; |
| | | |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.synchronization.protocol.DeleteMsg; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.changelog.Changelog; |
| | | import org.opends.server.replication.changelog.ChangelogDbEnv; |
| | | import org.opends.server.replication.changelog.DbHandler; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.types.DN; |
| | | import org.testng.annotations.Test; |
| | | import static org.testng.Assert.*; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/common/ChangeNumberGeneratorTest.java |
| | |
| | | * |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | import static org.testng.Assert.*; |
| | | |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.util.TimeThread; |
| | | import org.testng.annotations.Test; |
| | | |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/common/ChangeNumberTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | import org.testng.annotations.DataProvider; |
| | | import org.testng.annotations.Test; |
| | | import static org.testng.Assert.*; |
| | | |
| | | |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.util.TimeThread; |
| | | |
| | | |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/common/ServerStateTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.common; |
| | | package org.opends.server.replication.common; |
| | | |
| | | import static org.testng.Assert.*; |
| | | |
| | | import java.util.Set; |
| | | |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.util.TimeThread; |
| | | import org.testng.annotations.DataProvider; |
| | | import org.testng.annotations.Test; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/AttrInfoTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.LinkedHashSet; |
| | | |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.plugin.AttrInfo; |
| | | import org.opends.server.synchronization.plugin.ValueInfo; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.plugin.AttrInfo; |
| | | import org.opends.server.replication.plugin.ValueInfo; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| | | import org.opends.server.util.TimeThread; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/HistoricalTest.java |
| | |
| | | * Portions Copyright 2007 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.protocol.ModifyMsg; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.plugin.ChangelogBroker; |
| | | import org.opends.server.replication.plugin.Historical; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.tools.LDAPModify; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/ModifyConflictTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | |
| | | import org.testng.annotations.Test; |
| | | import static org.testng.Assert.*; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.asn1.ASN1OctetString; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.protocol.ModifyContext; |
| | | import org.opends.server.synchronization.protocol.SynchronizationMessage; |
| | | import org.opends.server.synchronization.protocol.UpdateMessage; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.plugin.FakeOperation; |
| | | import org.opends.server.replication.plugin.FakeOperationComparator; |
| | | import org.opends.server.replication.plugin.Historical; |
| | | import org.opends.server.replication.protocol.ModifyContext; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/PersistentServerStateTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.testng.Assert.assertEquals; |
| | | |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.plugin.PersistentServerState; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Entry; |
| | | import org.testng.annotations.BeforeClass; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/PersistentStateTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.testng.Assert.assertEquals; |
| | | |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.core.AddOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.plugin.PersistentServerState; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.Entry; |
| | | import org.testng.annotations.BeforeClass; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/plugin/ValueInfoTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.plugin; |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.plugin.ValueInfo; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.plugin.ValueInfo; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |
| | | import org.opends.server.util.TimeThread; |
| File was renamed from opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/protocol/SynchronizationMsgTest.java |
| | |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.synchronization.protocol; |
| | | package org.opends.server.replication.protocol; |
| | | |
| | | import static org.opends.server.synchronization.protocol.OperationContext.SYNCHROCONTEXT; |
| | | import static org.opends.server.replication.protocol.OperationContext.SYNCHROCONTEXT; |
| | | import static org.testng.Assert.assertEquals; |
| | | import static org.testng.Assert.assertFalse; |
| | | import static org.testng.Assert.assertTrue; |
| | |
| | | import org.opends.server.core.ModifyDNOperation; |
| | | import org.opends.server.core.ModifyOperation; |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.synchronization.SynchronizationTestCase; |
| | | import org.opends.server.synchronization.common.ChangeNumber; |
| | | import org.opends.server.synchronization.common.ServerState; |
| | | import org.opends.server.synchronization.plugin.PendingChange; |
| | | import org.opends.server.replication.SynchronizationTestCase; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.plugin.PendingChange; |
| | | import org.opends.server.replication.protocol.AckMessage; |
| | | import org.opends.server.replication.protocol.AddContext; |
| | | import org.opends.server.replication.protocol.AddMsg; |
| | | import org.opends.server.replication.protocol.ChangelogStartMessage; |
| | | import org.opends.server.replication.protocol.DeleteContext; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.replication.protocol.DoneMessage; |
| | | import org.opends.server.replication.protocol.EntryMessage; |
| | | import org.opends.server.replication.protocol.ErrorMessage; |
| | | import org.opends.server.replication.protocol.InitializeRequestMessage; |
| | | import org.opends.server.replication.protocol.InitializeTargetMessage; |
| | | import org.opends.server.replication.protocol.ModifyDNMsg; |
| | | import org.opends.server.replication.protocol.ModifyDnContext; |
| | | import org.opends.server.replication.protocol.ModifyMsg; |
| | | import org.opends.server.replication.protocol.OperationContext; |
| | | import org.opends.server.replication.protocol.ServerStartMessage; |
| | | import org.opends.server.replication.protocol.SynchronizationMessage; |
| | | import org.opends.server.replication.protocol.UpdateMessage; |
| | | import org.opends.server.replication.protocol.WindowMessage; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.AttributeValue; |