| | |
| | | ds-cfg-allowed-task: org.opends.server.tasks.EnterLockdownModeTask |
| | | ds-cfg-allowed-task: org.opends.server.tasks.ExportTask |
| | | ds-cfg-allowed-task: org.opends.server.tasks.ImportTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.service.InitializeTargetTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.service.InitializeTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.service.SetGenerationIdTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.plugin.InitializeTargetTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.plugin.InitializeTask |
| | | ds-cfg-allowed-task: org.opends.server.replication.plugin.SetGenerationIdTask |
| | | ds-cfg-allowed-task: org.opends.server.tasks.LeaveLockdownModeTask |
| | | ds-cfg-allowed-task: org.opends.server.tasks.RebuildTask |
| | | ds-cfg-allowed-task: org.opends.server.tasks.RestoreTask |
| | |
| | | SEVERE_ERR_INVALID_IMPORT_SOURCE_45=Invalid source for the import |
| | | SEVERE_ERR_INVALID_EXPORT_TARGET_46=Invalid target for the export |
| | | SEVERE_ERR_NO_REACHABLE_PEER_IN_THE_DOMAIN_47=No reachable peer in the domain |
| | | SEVERE_ERR_NO_MATCHING_DOMAIN_48=No domain matches the base DN provided |
| | | SEVERE_ERR_NO_MATCHING_DOMAIN_48=No domain matches the provided base DN '%s' |
| | | SEVERE_ERR_MULTIPLE_MATCHING_DOMAIN_49=Multiple domains match the base DN \ |
| | | provided |
| | | SEVERE_ERR_INVALID_PROVIDER_50=The provider class does not allow the \ |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.quicksetup.installer; |
| | | |
| | |
| | | attrs.put(oc); |
| | | attrs.put( |
| | | "ds-task-class-name", |
| | | "org.opends.server.replication.service.InitializeTask"); |
| | | "org.opends.server.replication.plugin.InitializeTask"); |
| | | attrs.put("ds-task-initialize-domain-dn", suffixDn); |
| | | attrs.put("ds-task-initialize-replica-server-id", |
| | | String.valueOf(replicaId)); |
| | |
| | | oc.add("ds-task-reset-generation-id"); |
| | | attrs.put(oc); |
| | | attrs.put("ds-task-class-name", |
| | | "org.opends.server.replication.service.SetGenerationIdTask"); |
| | | "org.opends.server.replication.plugin.SetGenerationIdTask"); |
| | | attrs.put("ds-task-reset-generation-id-domain-base-dn", suffixDn); |
| | | while (!taskCreated) |
| | | { |
| File was renamed from opends/src/server/org/opends/server/replication/service/InitializeTargetTask.java |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication.service; |
| | | package org.opends.server.replication.plugin; |
| | | import org.opends.server.tasks.TaskUtils; |
| | | |
| | | import org.opends.messages.TaskMessages; |
| | |
| | | import org.opends.server.backends.task.TaskState; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.Entry; |
| | | |
| | |
| | | |
| | | // Config properties |
| | | private String domainString = null; |
| | | private ReplicationDomain domain = null; |
| | | private LDAPReplicationDomain domain = null; |
| | | private short target; |
| | | private long total; |
| | | |
| | |
| | | |
| | | try |
| | | { |
| | | domain = ReplicationDomain.retrievesReplicationDomain(domainString); |
| | | DN dn = DN.decode(domainString); |
| | | // We can assume that this is an LDAP replication domain |
| | | domain = LDAPReplicationDomain.retrievesReplicationDomain(dn); |
| | | } |
| | | catch(DirectoryException e) |
| | | { |
| File was renamed from opends/src/server/org/opends/server/replication/service/InitializeTask.java |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication.service; |
| | | package org.opends.server.replication.plugin; |
| | | import org.opends.server.tasks.TaskUtils; |
| | | |
| | | import org.opends.server.types.ResultCode; |
| | |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.Entry; |
| | | |
| | |
| | | |
| | | private String domainString = null; |
| | | private short source; |
| | | private ReplicationDomain domain = null; |
| | | private LDAPReplicationDomain domain = null; |
| | | private TaskState initState; |
| | | |
| | | // The total number of entries expected to be processed when this import |
| | |
| | | |
| | | try |
| | | { |
| | | domain = ReplicationDomain.retrievesReplicationDomain(domainString); |
| | | DN dn = DN.decode(domainString); |
| | | // We can assume that this is an LDAP replication domain |
| | | domain = LDAPReplicationDomain.retrievesReplicationDomain(dn); |
| | | } |
| | | catch(DirectoryException e) |
| | | { |
| | |
| | | |
| | | if (replicationDomain == null) |
| | | { |
| | | MessageBuilder mb = new MessageBuilder(ERR_NO_MATCHING_DOMAIN.get()); |
| | | mb.append(" "); |
| | | mb.append(String.valueOf(baseDn)); |
| | | throw new DirectoryException(ResultCode.OTHER, |
| | | mb.toMessage()); |
| | | ERR_NO_MATCHING_DOMAIN.get(String.valueOf(baseDn))); |
| | | } |
| | | return replicationDomain; |
| | | } |
| | |
| | | |
| | | return attributes; |
| | | } |
| | | |
| | | /** |
| | | * Verifies that the given string represents a valid source |
| | | * from which this server can be initialized. |
| | | * @param sourceString The string representing the source |
| | | * @return The source as a short value |
| | | * @throws DirectoryException if the string is not valid |
| | | */ |
| | | short decodeSource(String sourceString) |
| | | throws DirectoryException |
| | | { |
| | | short source = 0; |
| | | Throwable cause = null; |
| | | try |
| | | { |
| | | source = Integer.decode(sourceString).shortValue(); |
| | | if ((source >= -1) && (source != serverId)) |
| | | { |
| | | // TODO Verifies serverID is in the domain |
| | | // We should check here that this is a server implied |
| | | // in the current domain. |
| | | return source; |
| | | } |
| | | } |
| | | catch(Exception e) |
| | | { |
| | | cause = e; |
| | | } |
| | | |
| | | ResultCode resultCode = ResultCode.OTHER; |
| | | Message message = ERR_INVALID_IMPORT_SOURCE.get(); |
| | | if (cause != null) |
| | | { |
| | | throw new DirectoryException( |
| | | resultCode, message, cause); |
| | | } |
| | | else |
| | | { |
| | | throw new DirectoryException( |
| | | resultCode, message); |
| | | } |
| | | } |
| | | } |
| File was renamed from opends/src/server/org/opends/server/replication/service/SetGenerationIdTask.java |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication.service; |
| | | package org.opends.server.replication.plugin; |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.core.DirectoryServer.getAttributeType; |
| | | |
| | | import org.opends.server.replication.service.ReplicationDomain; |
| | | import org.opends.server.tasks.TaskUtils; |
| | | |
| | | |
| | |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.AttributeType; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.Entry; |
| | | import org.opends.server.types.ResultCode; |
| | |
| | | |
| | | try |
| | | { |
| | | domain = ReplicationDomain.retrievesReplicationDomain(domainString); |
| | | DN dn = DN.decode(domainString); |
| | | domain = LDAPReplicationDomain.retrievesReplicationDomain(dn); |
| | | } |
| | | catch(DirectoryException e) |
| | | { |
| | |
| | | |
| | | import org.opends.server.config.ConfigException; |
| | | import java.util.Collection; |
| | | |
| | | import org.opends.server.replication.plugin.InitializeTargetTask; |
| | | import org.opends.server.replication.plugin.InitializeTask; |
| | | import org.opends.server.replication.protocol.ReplSessionSecurity; |
| | | import org.opends.server.replication.protocol.ResetGenerationIdMsg; |
| | | |
| | |
| | | ReplicationDomain replicationDomain = domains.get(serviceID); |
| | | if (replicationDomain == null) |
| | | { |
| | | MessageBuilder mb = new MessageBuilder(ERR_NO_MATCHING_DOMAIN.get()); |
| | | mb.append(" "); |
| | | mb.append(serviceID); |
| | | throw new DirectoryException(ResultCode.OTHER, |
| | | mb.toMessage()); |
| | | ERR_NO_MATCHING_DOMAIN.get(serviceID)); |
| | | } |
| | | return replicationDomain; |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | * Process the initialization of some other server or servers in the topology |
| | | * specified by the target argument. |
| | | * Initializes a remote server from this server. |
| | | * <p> |
| | | * The {@link #exportBackend(OutputStream)} will therefore be called |
| | | * on this server, and the {@link #importBackend(InputStream)} |
| | | * will be called on the remote server. |
| | | * <p> |
| | | * The InputStream and OutpuStream given as a parameter to those |
| | | * methods will be connected through the replication protocol. |
| | | * |
| | | * @param target The target that should be initialized |
| | | * @param initTask The task that triggers this initialization and that should |
| | | * be updated with its progress. |
| | | * @param target The server-id of the server that should be initialized. |
| | | * The target can be discovered using the |
| | | * {@link #getDsList()} method. |
| | | * @param initTask The task that triggers this initialization and that should |
| | | * be updated with its progress. |
| | | * |
| | | * @exception DirectoryException If the Replication Initialization protocol |
| | | * failed. |
| | | * @throws DirectoryException If it was not possible to publish the |
| | | * Initialization message to the Topology. |
| | | */ |
| | | void initializeRemote(short target, Task initTask) |
| | | public void initializeRemote(short target, Task initTask) |
| | | throws DirectoryException |
| | | { |
| | | initializeRemote(target, serverID, initTask); |
| | |
| | | * @param source The server-id of the source from which to initialize. |
| | | * The source can be discovered using the |
| | | * {@link #getDsList()} method. |
| | | |
| | | * |
| | | * @throws DirectoryException If it was not possible to publish the |
| | | * Initialization message to the Topology. |
| | | */ |
| | |
| | | |
| | | /** |
| | | * Initializes this domain from another source server. |
| | | * <p> |
| | | * When this method is called, a request for initialization will |
| | | * be sent to the source server asking for initialization. |
| | | * <p> |
| | | * The {@link #exportBackend(OutputStream)} will therefore be called |
| | | * on the source server, and the {@link #importBackend(InputStream)} |
| | | * will be called on his server. |
| | | * <p> |
| | | * The InputStream and OutpuStream given as a parameter to those |
| | | * methods will be connected through the replication protocol. |
| | | * |
| | | * @param source The source from which to initialize |
| | | * @param source The server-id of the source from which to initialize. |
| | | * The source can be discovered using the |
| | | * {@link #getDsList()} method. |
| | | * @param initTask The task that launched the initialization |
| | | * and should be updated of its progress. |
| | | * @throws DirectoryException when an error occurs |
| | | * |
| | | * @throws DirectoryException If it was not possible to publish the |
| | | * Initialization message to the Topology. |
| | | */ |
| | | void initializeFromRemote(short source, Task initTask) |
| | | public void initializeFromRemote(short source, Task initTask) |
| | | throws DirectoryException |
| | | { |
| | | if (debugEnabled()) |
| | |
| | | } |
| | | |
| | | /** |
| | | * Verifies that the given string represents a valid source |
| | | * from which this server can be initialized. |
| | | * @param sourceString The string representing the source |
| | | * @return The source as a short value |
| | | * @throws DirectoryException if the string is not valid |
| | | */ |
| | | short decodeSource(String sourceString) |
| | | throws DirectoryException |
| | | { |
| | | short source = 0; |
| | | Throwable cause = null; |
| | | try |
| | | { |
| | | source = Integer.decode(sourceString).shortValue(); |
| | | if ((source >= -1) && (source != serverID)) |
| | | { |
| | | // TODO Verifies serverID is in the domain |
| | | // We should check here that this is a server implied |
| | | // in the current domain. |
| | | return source; |
| | | } |
| | | } |
| | | catch(Exception e) |
| | | { |
| | | cause = e; |
| | | } |
| | | |
| | | ResultCode resultCode = ResultCode.OTHER; |
| | | Message message = ERR_INVALID_IMPORT_SOURCE.get(); |
| | | if (cause != null) |
| | | { |
| | | throw new DirectoryException( |
| | | resultCode, message, cause); |
| | | } |
| | | else |
| | | { |
| | | throw new DirectoryException( |
| | | resultCode, message); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Check the value of the Replication Servers generation ID. |
| | | * |
| | | * @param generationID The expected value of the generation ID. |
| | |
| | | * @param generationIdNewValue The new value of the generation Id. |
| | | * @throws DirectoryException When an error occurs |
| | | */ |
| | | void resetGenerationId(Long generationIdNewValue) |
| | | public void resetGenerationId(Long generationIdNewValue) |
| | | throws DirectoryException |
| | | { |
| | | if (debugEnabled()) |
| | |
| | | oc.add("ds-task-reset-generation-id"); |
| | | attrs.put(oc); |
| | | attrs.put("ds-task-class-name", |
| | | "org.opends.server.replication.service.SetGenerationIdTask"); |
| | | "org.opends.server.replication.plugin.SetGenerationIdTask"); |
| | | if (isPre) |
| | | { |
| | | if (!localOnly) |
| | |
| | | oc.add("ds-task-initialize-remote-replica"); |
| | | attrs.put(oc); |
| | | attrs.put("ds-task-class-name", |
| | | "org.opends.server.replication.service.InitializeTargetTask"); |
| | | "org.opends.server.replication.plugin.InitializeTargetTask"); |
| | | attrs.put("ds-task-initialize-domain-dn", baseDN); |
| | | attrs.put("ds-task-initialize-replica-server-id", "all"); |
| | | while (!taskCreated) |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication; |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | } |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-reset-generation-id", |
| | | "ds-task-class-name: org.opends.server.replication.service.SetGenerationIdTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.SetGenerationIdTask", |
| | | "ds-task-reset-generation-id-domain-base-dn: " + baseDnStr); |
| | | addTask(taskReset, ResultCode.SUCCESS, null); |
| | | waitTaskState(taskReset, TaskState.COMPLETED_SUCCESSFULLY, null); |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-reset-generation-id", |
| | | "ds-task-class-name: org.opends.server.replication.service.SetGenerationIdTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.SetGenerationIdTask", |
| | | "ds-task-reset-generation-id-domain-base-dn: " + baseDnStr); |
| | | |
| | | addTask(taskReset, ResultCode.SUCCESS, null); |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-reset-generation-id", |
| | | "ds-task-class-name: org.opends.server.replication.service.SetGenerationIdTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.SetGenerationIdTask", |
| | | "ds-task-reset-generation-id-domain-base-dn: " + baseDnStr); |
| | | addTask(taskReset, ResultCode.SUCCESS, null); |
| | | waitTaskState(taskReset, TaskState.COMPLETED_SUCCESSFULLY, null); |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-reset-generation-id", |
| | | "ds-task-class-name: org.opends.server.replication.service.SetGenerationIdTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.SetGenerationIdTask", |
| | | "ds-task-reset-generation-id-domain-base-dn: " + baseDnStr, |
| | | "ds-task-reset-generation-id-new-value: -1"); |
| | | addTask(taskReset, ResultCode.SUCCESS, null); |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Copyright 2006-2008 Sun Microsystems, Inc. |
| | | * Copyright 2006-2009 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.replication; |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + EXAMPLE_DN, |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: " + EXAMPLE_DN, |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: " + EXAMPLE_DN, |
| | | "ds-task-initialize-replica-server-id: all"); |
| | | } |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: foo", |
| | | "ds-task-initialize-remote-replica-server-id: " + server2ID); |
| | | addTask(taskInitTarget, ResultCode.INVALID_DN_SYNTAX, |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: dc=foo", |
| | | "ds-task-initialize-remote-replica-server-id: " + server2ID); |
| | | addTask(taskInitTarget, ResultCode.OTHER, |
| | | ERR_NO_MATCHING_DOMAIN.get()); |
| | | ERR_NO_MATCHING_DOMAIN.get("")); |
| | | |
| | | // Invalid scope |
| | | // createTask(taskInitTargetS2); |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-initialize-domain-dn: foo", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: dc=foo", |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | addTask(taskInit, ResultCode.INVALID_DN_SYNTAX, |
| | | ERR_NO_MATCHING_DOMAIN.get()); |
| | | ERR_NO_MATCHING_DOMAIN.get("dc=foo")); |
| | | |
| | | // Domain base dn not related to any domain |
| | | taskInit = TestCaseUtils.makeEntry( |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: dc=foo", |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | addTask(taskInit, ResultCode.INVALID_DN_SYNTAX, |
| | | ERR_NO_MATCHING_DOMAIN.get()); |
| | | ERR_NO_MATCHING_DOMAIN.get("dc=foo")); |
| | | |
| | | // Invalid Source |
| | | taskInit = TestCaseUtils.makeEntry( |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: -3"); |
| | | addTask(taskInit, ResultCode.OTHER, |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + 20); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + server1ID); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTargetTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTargetTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + 0); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | |
| | |
| | | "objectclass: top", |
| | | "objectclass: ds-task", |
| | | "objectclass: ds-task-initialize-from-remote-replica", |
| | | "ds-task-class-name: org.opends.server.replication.service.InitializeTask", |
| | | "ds-task-class-name: org.opends.server.replication.plugin.InitializeTask", |
| | | "ds-task-initialize-domain-dn: " + baseDn, |
| | | "ds-task-initialize-replica-server-id: " + server2ID); |
| | | |
| | |
| | | throws Exception |
| | | { |
| | | String buildRoot = System.getProperty(TestCaseUtils.PROPERTY_BUILD_ROOT); |
| | | String path = buildRoot + File.separator + "build" + |
| | | File.separator + "unit-tests" + File.separator + |
| | | "package-instance"+ File.separator + "exportLDIF.ldif"; |
| | | String path = "exportLDIF.ldif"; |
| | | return TestCaseUtils.makeEntry( |
| | | "dn: ds-task-id=" + UUID.randomUUID() + ",cn=Scheduled Tasks,cn=Tasks", |
| | | "objectclass: top", |
| | |
| | | { |
| | | String root = suffix.substring(suffix.indexOf('=')+1, suffix.indexOf(',')); |
| | | String buildRoot = System.getProperty(TestCaseUtils.PROPERTY_BUILD_ROOT); |
| | | String path = buildRoot + File.separator + "build" + |
| | | File.separator + "unit-tests" + File.separator + |
| | | "package-instance"+ File.separator + "exportLDIF" + root +".ldif"; |
| | | String path = "exportLDIF" + root +".ldif"; |
| | | return TestCaseUtils.makeEntry( |
| | | "dn: ds-task-id=" + UUID.randomUUID() + ",cn=Scheduled Tasks,cn=Tasks", |
| | | "objectclass: top", |