/*
|
* CDDL HEADER START
|
*
|
* The contents of this file are subject to the terms of the
|
* Common Development and Distribution License, Version 1.0 only
|
* (the "License"). You may not use this file except in compliance
|
* with the License.
|
*
|
* You can obtain a copy of the license at
|
* trunk/opends/resource/legal-notices/OpenDS.LICENSE
|
* or https://OpenDS.dev.java.net/OpenDS.LICENSE.
|
* See the License for the specific language governing permissions
|
* and limitations under the License.
|
*
|
* When distributing Covered Code, include this CDDL HEADER in each
|
* file and include the License file at
|
* trunk/opends/resource/legal-notices/OpenDS.LICENSE. If applicable,
|
* add the following below this CDDL HEADER, with the fields enclosed
|
* by brackets "[]" replaced with your own identifying information:
|
* Portions Copyright [yyyy] [name of copyright owner]
|
*
|
* CDDL HEADER END
|
*
|
*
|
* Portions Copyright 2007 Sun Microsystems, Inc.
|
*/
|
|
package org.opends.guitools.replicationcli;
|
|
import static org.opends.guitools.replicationcli.ReplicationCliReturnCode.*;
|
import static org.opends.messages.AdminToolMessages.*;
|
import static org.opends.messages.QuickSetupMessages.*;
|
import static org.opends.messages.ToolMessages.*;
|
import static org.opends.server.util.ServerConstants.MAX_LINE_WIDTH;
|
import static org.opends.server.util.StaticUtils.wrapText;
|
|
import java.io.File;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.io.PrintStream;
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.HashMap;
|
import java.util.HashSet;
|
import java.util.LinkedHashSet;
|
import java.util.LinkedList;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.TreeSet;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
|
import javax.naming.NamingException;
|
import javax.naming.ldap.InitialLdapContext;
|
|
import org.opends.admin.ads.ADSContext;
|
import org.opends.admin.ads.ADSContextException;
|
import org.opends.admin.ads.ReplicaDescriptor;
|
import org.opends.admin.ads.ServerDescriptor;
|
import org.opends.admin.ads.SuffixDescriptor;
|
import org.opends.admin.ads.TopologyCache;
|
import org.opends.admin.ads.TopologyCacheException;
|
import org.opends.admin.ads.util.ApplicationTrustManager;
|
import org.opends.admin.ads.util.ConnectionUtils;
|
import org.opends.admin.ads.util.ServerLoader;
|
import org.opends.messages.Message;
|
import org.opends.messages.MessageBuilder;
|
import org.opends.quicksetup.ApplicationException;
|
import org.opends.quicksetup.CliApplicationHelper;
|
import org.opends.quicksetup.Constants;
|
import org.opends.quicksetup.QuickSetupLog;
|
import org.opends.quicksetup.event.ProgressUpdateEvent;
|
import org.opends.quicksetup.event.ProgressUpdateListener;
|
import org.opends.quicksetup.installer.InstallerHelper;
|
import org.opends.quicksetup.installer.PeerNotFoundException;
|
import org.opends.quicksetup.installer.offline.OfflineInstaller;
|
import org.opends.quicksetup.util.PlainTextProgressMessageFormatter;
|
import org.opends.quicksetup.util.Utils;
|
import org.opends.server.admin.AttributeTypePropertyDefinition;
|
import org.opends.server.admin.ClassLoaderProvider;
|
import org.opends.server.admin.ClassPropertyDefinition;
|
import org.opends.server.admin.DefaultBehaviorException;
|
import org.opends.server.admin.ManagedObjectNotFoundException;
|
import org.opends.server.admin.client.ManagementContext;
|
import org.opends.server.admin.client.ldap.JNDIDirContextAdaptor;
|
import org.opends.server.admin.client.ldap.LDAPManagementContext;
|
import org.opends.server.admin.std.client.*;
|
import org.opends.server.admin.std.meta.*;
|
import org.opends.server.core.DirectoryServer;
|
import org.opends.server.types.DN;
|
import org.opends.server.types.InitializationException;
|
import org.opends.server.types.NullOutputStream;
|
import org.opends.server.types.OpenDsException;
|
import org.opends.server.util.SetupUtils;
|
import org.opends.server.util.args.ArgumentException;
|
|
/**
|
* This class provides a tool that can be used to enable and disable replication
|
* and also to initialize the contents of a replicated suffix with the contents
|
* of another suffix.
|
*/
|
public class ReplicationCliMain extends CliApplicationHelper
|
{
|
/**
|
* The fully-qualified name of this class.
|
*/
|
private static final String CLASS_NAME = ReplicationCliMain.class.getName();
|
|
/** Prefix for log files. */
|
static public final String LOG_FILE_PREFIX = "opends-replication-";
|
|
/** Suffix for log files. */
|
static public final String LOG_FILE_SUFFIX = ".log";
|
|
private static final Logger LOG =
|
Logger.getLogger(CliApplicationHelper.class.getName());
|
|
// The argument parser to be used.
|
private ReplicationCliArgumentParser argParser;
|
|
// The message formatter
|
PlainTextProgressMessageFormatter formatter =
|
new PlainTextProgressMessageFormatter();
|
|
/**
|
* Constructor for the ReplicationCliMain object.
|
*
|
* @param out the print stream to use for standard output.
|
* @param err the print stream to use for standard error.
|
* @param in the input stream to use for standard input.
|
*/
|
public ReplicationCliMain(PrintStream out, PrintStream err, InputStream in)
|
{
|
super(out, err, in);
|
}
|
|
/**
|
* The main method for the replication tool.
|
*
|
* @param args the command-line arguments provided to this program.
|
*/
|
|
public static void main(String[] args)
|
{
|
int retCode = mainCLI(args, true, System.out, System.err, System.in);
|
|
System.exit(retCode);
|
}
|
|
/**
|
* Parses the provided command-line arguments and uses that information to
|
* run the replication tool.
|
*
|
* @param args the command-line arguments provided to this program.
|
*
|
* @return The error code.
|
*/
|
|
public static int mainCLI(String[] args)
|
{
|
return mainCLI(args, true, System.out, System.err, System.in);
|
}
|
|
/**
|
* Parses the provided command-line arguments and uses that information to
|
* run the replication tool.
|
*
|
* @param args The command-line arguments provided to this
|
* program.
|
* @param initializeServer Indicates whether to initialize the server.
|
* @param outStream The output stream to use for standard output, or
|
* <CODE>null</CODE> if standard output is not
|
* needed.
|
* @param errStream The output stream to use for standard error, or
|
* <CODE>null</CODE> if standard error is not
|
* needed.
|
* @param inStream The input stream to use for standard input.
|
* @return The error code.
|
*/
|
|
public static int mainCLI(String[] args, boolean initializeServer,
|
OutputStream outStream, OutputStream errStream, InputStream inStream)
|
{
|
PrintStream out;
|
if (outStream == null)
|
{
|
out = NullOutputStream.printStream();
|
}
|
else
|
{
|
out = new PrintStream(outStream);
|
}
|
|
PrintStream err;
|
if (errStream == null)
|
{
|
err = NullOutputStream.printStream();
|
}
|
else
|
{
|
err = new PrintStream(errStream);
|
}
|
|
try {
|
QuickSetupLog.initLogFileHandler(
|
File.createTempFile(LOG_FILE_PREFIX, LOG_FILE_SUFFIX),
|
"org.opends.guitools.replicationcli");
|
QuickSetupLog.disableConsoleLogging();
|
} catch (Throwable t) {
|
System.err.println("Unable to initialize log");
|
t.printStackTrace();
|
}
|
|
ReplicationCliMain replicationCli = new ReplicationCliMain(out, err,
|
inStream);
|
return replicationCli.execute(args, initializeServer);
|
}
|
|
/**
|
* Parses the provided command-line arguments and uses that information to
|
* run the replication tool.
|
*
|
* @param args the command-line arguments provided to this program.
|
* @param initializeServer Indicates whether to initialize the server.
|
*
|
* @return The error code.
|
*/
|
public int execute(String[] args, boolean initializeServer)
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
// Create the command-line argument parser for use with this
|
// program.
|
try
|
{
|
argParser = new ReplicationCliArgumentParser(CLASS_NAME);
|
argParser.initializeParser(out);
|
}
|
catch (ArgumentException ae)
|
{
|
Message message = ERR_CANNOT_INITIALIZE_ARGS.get(ae.getMessage());
|
printErrorMessage(message);
|
LOG.log(Level.SEVERE, "Complete error stack:", ae);
|
returnValue = CANNOT_INITIALIZE_ARGS;
|
}
|
|
if (returnValue == SUCCESSFUL_NOP)
|
{
|
// Parse the command-line arguments provided to this program.
|
try
|
{
|
argParser.parseArguments(args);
|
}
|
catch (ArgumentException ae)
|
{
|
Message message = ERR_ERROR_PARSING_ARGS.get(ae.getMessage());
|
|
printErrorMessage(message);
|
printLineBreak();
|
printErrorMessage(argParser.getUsage());
|
LOG.log(Level.SEVERE, "Complete error stack:", ae);
|
returnValue = ERROR_USER_DATA;
|
}
|
}
|
|
if (!argParser.usageOrVersionDisplayed())
|
{
|
if (returnValue == SUCCESSFUL_NOP)
|
{
|
/* Check that the provided parameters are compatible.
|
*/
|
MessageBuilder buf = new MessageBuilder();
|
argParser.validateOptions(buf);
|
if (buf.length() > 0)
|
{
|
err.println(wrapText(buf.toMessage(), MAX_LINE_WIDTH));
|
err.println(argParser.getUsage());
|
returnValue = ERROR_USER_DATA;
|
}
|
}
|
if (initializeServer)
|
{
|
DirectoryServer.bootstrapClient();
|
|
// Bootstrap definition classes.
|
try
|
{
|
ClassLoaderProvider.getInstance().enable();
|
// Switch off class name validation in client.
|
ClassPropertyDefinition.setAllowClassValidation(false);
|
|
// Switch off attribute type name validation in client.
|
AttributeTypePropertyDefinition.setCheckSchema(false);
|
}
|
catch (InitializationException ie)
|
{
|
printErrorMessage(ie.getMessage());
|
returnValue = ERROR_INITIALIZING_ADMINISTRATION_FRAMEWORK;
|
}
|
}
|
|
if (returnValue == SUCCESSFUL_NOP)
|
{
|
if (argParser.isEnableReplicationSubcommand())
|
{
|
returnValue = enableReplication();
|
}
|
else if (argParser.isDisableReplicationSubcommand())
|
{
|
returnValue = disableReplication();
|
}
|
else if (argParser.isInitializeReplicationSubcommand())
|
{
|
returnValue = initializeReplication();
|
}
|
else
|
{
|
err.println(wrapText(ERR_REPLICATION_VALID_SUBCOMMAND_NOT_FOUND.get(),
|
MAX_LINE_WIDTH));
|
err.println(argParser.getUsage());
|
returnValue = ERROR_USER_DATA;
|
}
|
}
|
}
|
return returnValue.getReturnCode();
|
}
|
|
/**
|
* {@inheritDoc}
|
*/
|
protected boolean isQuiet()
|
{
|
return argParser.isQuiet();
|
}
|
|
/**
|
* Based on the data provided in the command-line it enables replication
|
* between two servers.
|
* @return the error code if the operation failed and 0 if it was successful.
|
*/
|
private ReplicationCliReturnCode enableReplication()
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
EnableReplicationUserData uData = new EnableReplicationUserData();
|
if (argParser.isInteractive())
|
{
|
if (promptIfRequired(uData))
|
{
|
returnValue = enableReplication(uData);
|
}
|
else
|
{
|
returnValue = USER_CANCELLED;
|
}
|
}
|
else
|
{
|
initializeWithArgParser(uData);
|
returnValue = enableReplication(uData);
|
}
|
return returnValue;
|
}
|
|
/**
|
* Based on the data provided in the command-line it disables replication
|
* in the server.
|
* @return the error code if the operation failed and SUCCESSFUL if it was
|
* successful.
|
*/
|
private ReplicationCliReturnCode disableReplication()
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
DisableReplicationUserData uData = new DisableReplicationUserData();
|
if (argParser.isInteractive())
|
{
|
if (promptIfRequired(uData))
|
{
|
returnValue = disableReplication(uData);
|
}
|
else
|
{
|
returnValue = USER_CANCELLED;
|
}
|
}
|
else
|
{
|
initializeWithArgParser(uData);
|
returnValue = disableReplication(uData);
|
}
|
return returnValue;
|
}
|
|
/**
|
* Based on the data provided in the command-line it initializes replication
|
* between two servers.
|
* @return the error code if the operation failed and SUCCESSFUL if it was
|
* successful.
|
*/
|
private ReplicationCliReturnCode initializeReplication()
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
InitializeReplicationUserData uData = new InitializeReplicationUserData();
|
if (argParser.isInteractive())
|
{
|
if (promptIfRequired(uData))
|
{
|
returnValue = initializeReplication(uData);
|
}
|
else
|
{
|
returnValue = USER_CANCELLED;
|
}
|
}
|
else
|
{
|
initializeWithArgParser(uData);
|
returnValue = initializeReplication(uData);
|
}
|
return returnValue;
|
}
|
|
/**
|
* Updates the contents of the provided EnableReplicationUserData object
|
* with the information provided in the command-line. If some information
|
* is missing, ask the user to provide valid data.
|
* We assume that if this method is called we are in interactive mode.
|
* @param uData the object to be updated.
|
* @return <CODE>true</CODE> if the object was successfully updated and
|
* <CODE>false</CODE> if the user cancelled the operation.
|
*/
|
private boolean promptIfRequired(EnableReplicationUserData uData)
|
{
|
boolean cancelled = false;
|
|
boolean administratorDefined = false;
|
|
String adminPwd = argParser.getBindPasswordAdmin();
|
String adminUid = argParser.getAdministratorUID();
|
|
boolean prompted = false;
|
/*
|
* Prompt for information on the first server.
|
*/
|
String host1 = argParser.getHostName1();
|
if (host1 == null)
|
{
|
host1 = promptForString(
|
INFO_REPLICATION_ENABLE_HOSTNAME1_PROMPT.get(),
|
argParser.getDefaultHostName1(), false);
|
prompted = true;
|
}
|
int port1 = argParser.getPort1();
|
if (port1 == -1)
|
{
|
port1 = promptForPort(
|
INFO_REPLICATION_ENABLE_PORT1_PROMPT.get(),
|
argParser.getDefaultPort1(), false);
|
prompted = true;
|
}
|
boolean useSSL1 = argParser.useSSL1();
|
boolean useStartTLS1 = argParser.useStartTLS1();
|
if (!useSSL1 && !useStartTLS1)
|
{
|
useSSL1 = confirm(INFO_CLI_USESSL_PROMPT.get(), false);
|
prompted = true;
|
if (!useSSL1)
|
{
|
useStartTLS1 =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), false);
|
prompted = true;
|
}
|
}
|
|
String bindDn1 = argParser.getBindDn1();
|
String pwd1 = argParser.getBindPassword1();
|
if ((bindDn1 == null) && (pwd1 == null) && (adminPwd != null) &&
|
(adminUid != null))
|
{
|
// No information provided to connect to the first server. Try
|
// to use global administrator.
|
bindDn1 = ADSContext.getAdministratorDN(adminUid);
|
pwd1 = adminPwd;
|
}
|
else
|
{
|
// Ask for the bind dn to connect to server 1.
|
if (bindDn1 == null)
|
{
|
bindDn1 = promptForString(
|
INFO_REPLICATION_ENABLE_BINDDN1_PROMPT.get(),
|
getValue(bindDn1, argParser.getDefaultBindDn1()), false);
|
prompted = true;
|
}
|
if (pwd1 == null)
|
{
|
pwd1 = promptForPassword(
|
INFO_REPLICATION_ENABLE_PASSWORD1_PROMPT.get(bindDn1));
|
prompted = true;
|
}
|
}
|
|
/*
|
* Try to connect to the first server.
|
*/
|
InitialLdapContext ctx1 = null;
|
// Boolean used to only ask for the information that was not explicitly
|
// provided the first time we ask. After we ask for all the information.
|
|
while ((ctx1 == null) && !cancelled)
|
{
|
try
|
{
|
ctx1 = createContext(host1, port1, useSSL1, useStartTLS1, bindDn1,
|
pwd1, getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
prompted = true;
|
LOG.log(Level.WARNING, "Error connecting to "+host1+":"+port1, ne);
|
if (Utils.isCertificateException(ne))
|
{
|
String usedUrl = ConnectionUtils.getLDAPUrl(host1, port1, useSSL1);
|
if (!promptForCertificateConfirmation(ne, getTrustManager(), usedUrl))
|
{
|
cancelled = true;
|
}
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
host1+":"+port1, ne.toString()));
|
|
printLineBreak();
|
host1 = promptForString(
|
INFO_REPLICATION_ENABLE_HOSTNAME1_PROMPT.get(),
|
getValue(host1, argParser.getDefaultHostName1()), false);
|
port1 = promptForPort(INFO_REPLICATION_ENABLE_PORT1_PROMPT.get(),
|
getValue(port1, argParser.getDefaultPort1()), false);
|
|
bindDn1 = promptForString(
|
INFO_REPLICATION_ENABLE_BINDDN1_PROMPT.get(),
|
getValue(bindDn1, argParser.getDefaultBindDn1()), false);
|
pwd1 = promptForPassword(
|
INFO_REPLICATION_ENABLE_PASSWORD1_PROMPT.get(bindDn1));
|
|
useSSL1 = confirm(INFO_CLI_USESSL_PROMPT.get(), useSSL1);
|
if (!useSSL1)
|
{
|
useStartTLS1 = confirm(INFO_CLI_USESTARTTLS_PROMPT.get(),
|
useStartTLS1);
|
}
|
}
|
}
|
}
|
if (!cancelled)
|
{
|
uData.setHostName1(host1);
|
uData.setPort1(port1);
|
uData.setBindDn1(bindDn1);
|
uData.setPwd1(pwd1);
|
uData.setUseSSL1(useSSL1);
|
uData.setUseStartTLS1(useStartTLS1);
|
}
|
int replicationPort1 = -1;
|
if (ctx1 != null)
|
{
|
// Try to get the replication port for server 1 only if it is required.
|
if (!hasReplicationPort(ctx1))
|
{
|
boolean tryWithDefault = argParser.getReplicationPort1() != -1;
|
while (replicationPort1 == -1)
|
{
|
if (tryWithDefault)
|
{
|
replicationPort1 = argParser.getReplicationPort1();
|
tryWithDefault = false;
|
}
|
else
|
{
|
replicationPort1 = promptForPort(
|
INFO_REPLICATION_ENABLE_REPLICATIONPORT1_PROMPT.get(),
|
argParser.getDefaultReplicationPort1(), false);
|
}
|
if (!argParser.skipReplicationPortCheck())
|
{
|
if (!SetupUtils.canUseAsPort(replicationPort1))
|
{
|
printLineBreak();
|
printErrorMessage(getCannotBindToPortError(replicationPort1));
|
printLineBreak();
|
replicationPort1 = -1;
|
}
|
}
|
else
|
{
|
// This is something that we must do in any case... this test is
|
// already included when we call SetupUtils.canUseAsPort
|
if (replicationPort1 == port1)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_REPLICATION_PORT_AND_REPLICATION_PORT_EQUAL.get(
|
host1, String.valueOf(replicationPort1)));
|
replicationPort1 = -1;
|
}
|
}
|
}
|
}
|
// If the server contains an ADS. Try to load it and only load it: if
|
// there are issues with the ADS they will be encountered in the
|
// enableReplication(EnableReplicationUserData) method. Here we have
|
// to load the ADS to ask the user to accept the certificates and
|
// eventually admin authentication data.
|
cancelled = !loadADSAndAcceptCertificates(ctx1, uData, true);
|
if (!cancelled)
|
{
|
administratorDefined |= hasAdministrator(ctx1);
|
}
|
}
|
uData.setReplicationPort1(replicationPort1);
|
|
/*
|
* Prompt for information on the second server.
|
*/
|
String host2 = null;
|
int port2 = -1;
|
String bindDn2 = null;
|
String pwd2 = null;
|
boolean useSSL2 = false;
|
boolean useStartTLS2 = false;
|
if (!cancelled)
|
{
|
host2 = argParser.getHostName2();
|
if (prompted)
|
{
|
printLineBreak();
|
}
|
if (host2 == null)
|
{
|
host2 = promptForString(
|
INFO_REPLICATION_ENABLE_HOSTNAME2_PROMPT.get(),
|
argParser.getDefaultHostName2(), false);
|
}
|
port2 = argParser.getPort2();
|
while (port2 == -1)
|
{
|
port2 = promptForPort(
|
INFO_REPLICATION_ENABLE_PORT2_PROMPT.get(),
|
argParser.getDefaultPort2(), false);
|
if (host1.equalsIgnoreCase(host2))
|
{
|
if (port1 == port2)
|
{
|
port2 = -1;
|
Message message = ERR_REPLICATION_SAME_SERVER_PORT.get(
|
host1, String.valueOf(port1));
|
printLineBreak();
|
printErrorMessage(message);
|
printLineBreak();
|
}
|
}
|
}
|
useSSL2 = argParser.useSSL2();
|
useStartTLS2 = argParser.useStartTLS2();
|
if (!useSSL2 && !useStartTLS2)
|
{
|
useSSL2 = confirm(INFO_CLI_USESSL_PROMPT.get(), false);
|
if (!useSSL2)
|
{
|
useStartTLS2 =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), false);
|
}
|
}
|
|
bindDn2 = argParser.getBindDn2();
|
pwd2 = argParser.getBindPassword2();
|
if ((bindDn2 == null) && (pwd2 == null) && (adminPwd != null) &&
|
(adminUid != null))
|
{
|
// No information provided to connect to the first server. Try
|
// to use global administrator.
|
bindDn2 = ADSContext.getAdministratorDN(adminUid);
|
pwd2 = adminPwd;
|
}
|
else
|
{
|
// Ask for the bind dn to connect to server 2.
|
if (bindDn2 == null)
|
{
|
bindDn2 = promptForString(
|
INFO_REPLICATION_ENABLE_BINDDN2_PROMPT.get(),
|
getValue(bindDn2, argParser.getDefaultBindDn2()), false);
|
}
|
if (pwd2 == null)
|
{
|
pwd2 = promptForPassword(
|
INFO_REPLICATION_ENABLE_PASSWORD2_PROMPT.get(bindDn1));
|
}
|
}
|
}
|
/**
|
* Try to connect to second server
|
*/
|
InitialLdapContext ctx2 = null;
|
|
while ((ctx2 == null) && !cancelled)
|
{
|
try
|
{
|
ctx2 = createContext(host2, port2, useSSL2, useStartTLS2, bindDn2,
|
pwd2, getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
LOG.log(Level.WARNING, "Error connecting to "+host2+":"+port2, ne);
|
if (Utils.isCertificateException(ne))
|
{
|
String usedUrl = ConnectionUtils.getLDAPUrl(host2, port2, useSSL2);
|
if (!promptForCertificateConfirmation(ne, getTrustManager(), usedUrl))
|
{
|
cancelled = true;
|
}
|
}
|
else
|
{
|
if (pwd2 != null)
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
host2+":"+port2, ne.toString()));
|
}
|
printLineBreak();
|
|
host2 = promptForString(
|
INFO_REPLICATION_ENABLE_HOSTNAME2_PROMPT.get(),
|
getValue(host2, argParser.getDefaultHostName2()), false);
|
port2 = promptForPort(INFO_REPLICATION_ENABLE_PORT2_PROMPT.get(),
|
getValue(port2, argParser.getDefaultPort2()), false);
|
bindDn2 = promptForString(
|
INFO_REPLICATION_ENABLE_BINDDN2_PROMPT.get(),
|
getValue(bindDn2, argParser.getDefaultBindDn2()), false);
|
pwd2 = promptForPassword(
|
INFO_REPLICATION_ENABLE_PASSWORD2_PROMPT.get(bindDn2));
|
useSSL2 = confirm(INFO_CLI_USESSL_PROMPT.get(),
|
useSSL2);
|
if (!useSSL2)
|
{
|
useStartTLS2 = confirm(INFO_CLI_USESTARTTLS_PROMPT.get(),
|
useStartTLS2);
|
}
|
}
|
}
|
}
|
if (!cancelled)
|
{
|
uData.setHostName2(host2);
|
uData.setPort2(port2);
|
uData.setBindDn2(bindDn2);
|
uData.setPwd2(pwd2);
|
uData.setUseSSL2(useSSL2);
|
uData.setUseStartTLS2(useStartTLS2);
|
}
|
int replicationPort2 = -1;
|
if (ctx2 != null)
|
{
|
if (!hasReplicationPort(ctx2))
|
{
|
boolean tryWithDefault = argParser.getReplicationPort2() != -1;
|
while (replicationPort2 == -1)
|
{
|
if (tryWithDefault)
|
{
|
replicationPort2 = argParser.getReplicationPort2();
|
tryWithDefault = false;
|
}
|
else
|
{
|
replicationPort2 = promptForPort(
|
INFO_REPLICATION_ENABLE_REPLICATIONPORT2_PROMPT.get(),
|
argParser.getDefaultReplicationPort2(), false);
|
}
|
if (!argParser.skipReplicationPortCheck())
|
{
|
if (!SetupUtils.canUseAsPort(replicationPort2))
|
{
|
printLineBreak();
|
printErrorMessage(getCannotBindToPortError(replicationPort2));
|
printLineBreak();
|
replicationPort2 = -1;
|
}
|
}
|
else
|
{
|
// This is something that we must do in any case... this test is
|
// already included when we call SetupUtils.canUseAsPort
|
if (replicationPort2 == port2)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_REPLICATION_PORT_AND_REPLICATION_PORT_EQUAL.get(
|
host2, String.valueOf(replicationPort2)));
|
replicationPort2 = -1;
|
}
|
}
|
if (host1.equalsIgnoreCase(host2))
|
{
|
if (replicationPort1 == replicationPort2)
|
{
|
printLineBreak();
|
printErrorMessage(ERR_REPLICATION_SAME_REPLICATION_PORT.get(
|
String.valueOf(replicationPort1), host1));
|
printLineBreak();
|
replicationPort2 = -1;
|
}
|
}
|
}
|
}
|
// If the server contains an ADS. Try to load it and only load it: if
|
// there are issues with the ADS they will be encountered in the
|
// enableReplication(EnableReplicationUserData) method. Here we have
|
// to load the ADS to ask the user to accept the certificates.
|
cancelled = !loadADSAndAcceptCertificates(ctx2, uData, false);
|
if (!cancelled)
|
{
|
administratorDefined |= hasAdministrator(ctx2);
|
}
|
}
|
uData.setReplicationPort2(replicationPort2);
|
|
// If the adminUid and adminPwd are not set in the EnableReplicationUserData
|
// object, that means that there are no administrators and that they
|
// must be created. The adminUId and adminPwd are updated inside
|
// loadADSAndAcceptCertificates.
|
boolean promptedForAdmin = false;
|
|
// There is a case where we haven't had need for the administrator
|
// credentials even if the administrators are defined: where all the servers
|
// can be accessed with another user (for instance if all the server have
|
// defined cn=directory manager and all the entries have the same password).
|
if (!cancelled && (uData.getAdminUid() == null) && !administratorDefined)
|
{
|
if (adminUid == null)
|
{
|
printLine(INFO_REPLICATION_ENABLE_ADMINISTRATOR_MUST_BE_CREATED.get(),
|
true);
|
promptedForAdmin = true;
|
adminUid= askForAdministratorUID(
|
argParser.getDefaultAdministratorUID());
|
}
|
uData.setAdminUid(adminUid);
|
}
|
|
if (!cancelled && (uData.getAdminPwd() == null) && !administratorDefined)
|
{
|
while (adminPwd == null)
|
{
|
if (!promptedForAdmin)
|
{
|
printLine(INFO_REPLICATION_ENABLE_ADMINISTRATOR_MUST_BE_CREATED.get(),
|
true);
|
}
|
adminPwd = askForAdministratorPwd();
|
String adminPwdConfirm =
|
promptForPassword(INFO_ADMINISTRATOR_PWD_CONFIRM_PROMPT.get());
|
if (!adminPwd.equals(adminPwdConfirm))
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ADMINISTRATOR_PWD_DO_NOT_MATCH.get());
|
printLineBreak();
|
adminPwd = null;
|
}
|
}
|
uData.setAdminPwd(adminPwd);
|
}
|
|
if (!cancelled)
|
{
|
LinkedList<String> suffixes = argParser.getBaseDNs();
|
checkSuffixesForEnableReplication(suffixes, ctx1, ctx2, true);
|
cancelled = suffixes.isEmpty();
|
|
uData.setBaseDNs(suffixes);
|
}
|
|
if (ctx1 != null)
|
{
|
try
|
{
|
ctx1.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
|
if (ctx2 != null)
|
{
|
try
|
{
|
ctx2.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
return !cancelled;
|
}
|
|
/**
|
* Updates the contents of the provided DisableReplicationUserData object
|
* with the information provided in the command-line. If some information
|
* is missing, ask the user to provide valid data.
|
* We assume that if this method is called we are in interactive mode.
|
* @param uData the object to be updated.
|
* @return <CODE>true</CODE> if the object was successfully updated and
|
* <CODE>false</CODE> if the user cancelled the operation.
|
*/
|
private boolean promptIfRequired(DisableReplicationUserData uData)
|
{
|
boolean cancelled = false;
|
|
String adminPwd = argParser.getBindPasswordAdmin();
|
String adminUid = argParser.getAdministratorUID();
|
String bindDn = argParser.getBindDNToDisable();
|
|
String host = argParser.getHostNameToDisable();
|
if (host == null)
|
{
|
host = promptForString(
|
INFO_REPLICATION_DISABLE_HOSTNAME_PROMPT.get(),
|
argParser.getDefaultHostNameToDisable(), false);
|
}
|
int port = argParser.getPortToDisable();
|
if (port == -1)
|
{
|
port = promptForPort(
|
INFO_REPLICATION_DISABLE_PORT_PROMPT.get(),
|
argParser.getDefaultPortToDisable(), false);
|
}
|
boolean useSSL = argParser.useSSLToDisable();
|
boolean useStartTLS = argParser.useStartTLSToDisable();
|
if (!useSSL && !useStartTLS)
|
{
|
useSSL = confirm(INFO_CLI_USESSL_PROMPT.get(), false);
|
if (!useSSL)
|
{
|
useStartTLS =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), false);
|
}
|
}
|
if ((adminUid == null) && (bindDn == null))
|
{
|
String v = askForBindDnDisable(argParser.getDefaultAdministratorUID());
|
if (Utils.isDn(v))
|
{
|
bindDn = v;
|
}
|
else
|
{
|
adminUid = v;
|
}
|
}
|
|
if (adminPwd == null)
|
{
|
adminPwd = askForPasswordDisable(adminUid != null ? adminUid : bindDn);
|
}
|
|
/*
|
* Try to connect to the server.
|
*/
|
InitialLdapContext ctx = null;
|
|
while ((ctx == null) && !cancelled)
|
{
|
String lastBindDn;
|
if (adminUid != null)
|
{
|
lastBindDn = ADSContext.getAdministratorDN(adminUid);
|
}
|
else
|
{
|
lastBindDn = bindDn;
|
}
|
try
|
{
|
ctx = createContext(host, port, useSSL, useStartTLS, lastBindDn,
|
adminPwd, getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
LOG.log(Level.WARNING, "Error connecting to "+host+":"+port, ne);
|
if (Utils.isCertificateException(ne))
|
{
|
String usedUrl = ConnectionUtils.getLDAPUrl(host, port, useSSL);
|
if (!promptForCertificateConfirmation(ne, getTrustManager(), usedUrl))
|
{
|
cancelled = true;
|
}
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
host+":"+port, ne.toString()));
|
printLineBreak();
|
host = promptForString(
|
INFO_REPLICATION_DISABLE_HOSTNAME_PROMPT.get(),
|
getValue(host, argParser.getDefaultHostNameToDisable()), false);
|
port = promptForPort(
|
INFO_REPLICATION_DISABLE_PORT_PROMPT.get(),
|
getValue(port, argParser.getDefaultPortToDisable()), false);
|
useSSL = confirm(INFO_CLI_USESSL_PROMPT.get(), useSSL);
|
if (!useSSL)
|
{
|
useStartTLS =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), useStartTLS);
|
}
|
adminUid = null;
|
bindDn = null;
|
String v = askForBindDnDisable(lastBindDn);
|
if (Utils.isDn(v))
|
{
|
bindDn = v;
|
}
|
else
|
{
|
adminUid = v;
|
}
|
adminPwd = askForPasswordDisable(adminUid != null ?
|
adminUid : bindDn);
|
}
|
}
|
}
|
if (!cancelled)
|
{
|
uData.setHostName(host);
|
uData.setPort(port);
|
uData.setUseSSL(useSSL);
|
uData.setUseStartTLS(useStartTLS);
|
uData.setAdminUid(adminUid);
|
uData.setBindDn(bindDn);
|
uData.setAdminPwd(adminPwd);
|
}
|
if ((ctx != null) && (adminUid != null))
|
{
|
// If the server contains an ADS, try to load it and only load it: if
|
// there are issues with the ADS they will be encountered in the
|
// disableReplication(DisableReplicationUserData) method. Here we have
|
// to load the ADS to ask the user to accept the certificates and
|
// eventually admin authentication data.
|
cancelled = !loadADSAndAcceptCertificates(ctx, uData, false);
|
}
|
|
if (!cancelled)
|
{
|
LinkedList<String> suffixes = argParser.getBaseDNs();
|
checkSuffixesForDisableReplication(suffixes, ctx, true);
|
cancelled = suffixes.isEmpty();
|
|
uData.setBaseDNs(suffixes);
|
}
|
|
if (!cancelled)
|
{
|
// Ask for confirmation to disable.
|
boolean disableADS = false;
|
for (String dn : uData.getBaseDNs())
|
{
|
if (Utils.areDnsEqual(ADSContext.getAdministrationSuffixDN(), dn))
|
{
|
disableADS = true;
|
break;
|
}
|
}
|
if (disableADS)
|
{
|
printLineBreak();
|
cancelled = !confirm(INFO_REPLICATION_CONFIRM_DISABLE_ADS.get(
|
ADSContext.getAdministrationSuffixDN()));
|
}
|
else
|
{
|
printLineBreak();
|
cancelled = !confirm(INFO_REPLICATION_CONFIRM_DISABLE_GENERIC.get());
|
}
|
}
|
|
if (ctx != null)
|
{
|
try
|
{
|
ctx.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
|
return !cancelled;
|
}
|
|
/**
|
* Updates the contents of the provided InitializeReplicationUserData object
|
* with the information provided in the command-line. If some information
|
* is missing, ask the user to provide valid data.
|
* We assume that if this method is called we are in interactive mode.
|
* @param uData the object to be updated.
|
* @return <CODE>true</CODE> if the object was successfully updated and
|
* <CODE>false</CODE> if the user cancelled the operation.
|
*/
|
private boolean promptIfRequired(InitializeReplicationUserData uData)
|
{
|
boolean cancelled = false;
|
|
String adminPwd = argParser.getBindPasswordAdmin();
|
String adminUid = argParser.getAdministratorUID();
|
|
if (adminUid == null)
|
{
|
adminUid = askForAdministratorUID(argParser.getDefaultAdministratorUID());
|
}
|
|
if (adminPwd == null)
|
{
|
adminPwd = askForAdministratorPwd();
|
}
|
|
String hostSource = argParser.getHostNameSource();
|
if (hostSource == null)
|
{
|
hostSource = promptForString(
|
INFO_REPLICATION_INITIALIZE_HOSTNAMESOURCE_PROMPT.get(),
|
argParser.getDefaultHostNameSource(), false);
|
}
|
int portSource = argParser.getPortSource();
|
if (portSource == -1)
|
{
|
portSource = promptForPort(
|
INFO_REPLICATION_INITIALIZE_PORTSOURCE_PROMPT.get(),
|
argParser.getDefaultPortSource(), false);
|
}
|
boolean useSSLSource = argParser.useSSLSource();
|
boolean useStartTLSSource = argParser.useStartTLSSource();
|
if (!useSSLSource && !useStartTLSSource)
|
{
|
useSSLSource = confirm(INFO_CLI_USESSL_PROMPT.get(), false);
|
if (!useSSLSource)
|
{
|
useStartTLSSource =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), false);
|
}
|
}
|
/*
|
* Try to connect to the source server.
|
*/
|
InitialLdapContext ctxSource = null;
|
while ((ctxSource == null) && !cancelled)
|
{
|
try
|
{
|
ctxSource = createContext(hostSource, portSource, useSSLSource,
|
useStartTLSSource, ADSContext.getAdministratorDN(adminUid),
|
adminPwd, getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
LOG.log(Level.WARNING, "Error connecting to "+hostSource+":"+portSource,
|
ne);
|
if (Utils.isCertificateException(ne))
|
{
|
String usedUrl = ConnectionUtils.getLDAPUrl(hostSource, portSource,
|
useSSLSource);
|
if (!promptForCertificateConfirmation(ne, getTrustManager(), usedUrl))
|
{
|
cancelled = true;
|
}
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
hostSource+":"+portSource, ne.toString()));
|
printLineBreak();
|
hostSource = promptForString(
|
INFO_REPLICATION_INITIALIZE_HOSTNAMESOURCE_PROMPT.get(),
|
getValue(hostSource, argParser.getDefaultHostNameSource()),
|
false);
|
portSource = promptForPort(
|
INFO_REPLICATION_INITIALIZE_PORTSOURCE_PROMPT.get(),
|
getValue(portSource, argParser.getDefaultPortSource()), false);
|
adminUid = askForAdministratorUID(adminUid);
|
adminPwd = askForAdministratorPwd();
|
useSSLSource = confirm(INFO_CLI_USESSL_PROMPT.get(), useSSLSource);
|
if (!useSSLSource)
|
{
|
useStartTLSSource =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), useStartTLSSource);
|
}
|
}
|
}
|
}
|
if (!cancelled)
|
{
|
uData.setHostNameSource(hostSource);
|
uData.setPortSource(portSource);
|
uData.setUseSSLSource(useSSLSource);
|
uData.setUseStartTLSSource(useStartTLSSource);
|
uData.setAdminUid(adminUid);
|
uData.setAdminPwd(adminPwd);
|
}
|
|
/* Prompt for destination server credentials */
|
String hostDestination = argParser.getHostNameDestination();
|
if (hostDestination == null)
|
{
|
hostDestination = promptForString(
|
INFO_REPLICATION_INITIALIZE_HOSTNAMEDESTINATION_PROMPT.get(),
|
argParser.getDefaultHostNameDestination(), false);
|
}
|
int portDestination = argParser.getPortDestination();
|
while (portDestination == -1)
|
{
|
portDestination = promptForPort(
|
INFO_REPLICATION_INITIALIZE_PORTDESTINATION_PROMPT.get(),
|
argParser.getDefaultPortDestination(), false);
|
if (hostSource.equalsIgnoreCase(hostDestination))
|
{
|
if (portSource == portDestination)
|
{
|
portDestination = -1;
|
Message message = ERR_REPLICATION_SAME_SERVER_PORT.get(
|
hostSource, String.valueOf(portSource));
|
printLineBreak();
|
printErrorMessage(message);
|
printLineBreak();
|
}
|
}
|
}
|
|
boolean useSSLDestination = argParser.useSSLDestination();
|
boolean useStartTLSDestination = argParser.useStartTLSDestination();
|
if (!useSSLDestination && !useStartTLSDestination)
|
{
|
useSSLDestination = confirm(INFO_CLI_USESSL_PROMPT.get(), false);
|
if (!useSSLDestination)
|
{
|
useStartTLSDestination =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(), false);
|
}
|
}
|
/*
|
* Try to connect to the destination server.
|
*/
|
InitialLdapContext ctxDestination = null;
|
while ((ctxDestination == null) && !cancelled)
|
{
|
try
|
{
|
ctxDestination = createContext(hostDestination, portDestination,
|
useSSLDestination, useStartTLSDestination,
|
ADSContext.getAdministratorDN(adminUid),
|
adminPwd, getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
LOG.log(Level.WARNING, "Error connecting to "+hostDestination+":"+
|
portDestination, ne);
|
|
if (Utils.isCertificateException(ne))
|
{
|
String usedUrl = ConnectionUtils.getLDAPUrl(hostDestination,
|
portDestination, useSSLDestination);
|
if (!promptForCertificateConfirmation(ne, getTrustManager(), usedUrl))
|
{
|
cancelled = true;
|
}
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
hostDestination+":"+portDestination, ne.toString()));
|
printLineBreak();
|
hostDestination = promptForString(
|
INFO_REPLICATION_INITIALIZE_HOSTNAMEDESTINATION_PROMPT.get(),
|
getValue(hostDestination,
|
argParser.getDefaultHostNameDestination()), false);
|
portDestination = promptForPort(
|
INFO_REPLICATION_INITIALIZE_PORTDESTINATION_PROMPT.get(),
|
getValue(portDestination,
|
argParser.getDefaultPortDestination()), false);
|
useSSLDestination = confirm(INFO_CLI_USESSL_PROMPT.get(),
|
useSSLDestination);
|
if (!useSSLDestination)
|
{
|
useStartTLSDestination =
|
confirm(INFO_CLI_USESTARTTLS_PROMPT.get(),
|
useStartTLSDestination);
|
}
|
}
|
}
|
}
|
if (!cancelled)
|
{
|
uData.setHostNameDestination(hostDestination);
|
uData.setPortDestination(portDestination);
|
uData.setUseSSLDestination(useSSLDestination);
|
uData.setUseStartTLSDestination(useStartTLSDestination);
|
}
|
|
if (!cancelled)
|
{
|
LinkedList<String> suffixes = argParser.getBaseDNs();
|
checkSuffixesForInitializeReplication(suffixes, ctxSource, ctxDestination,
|
true);
|
cancelled = suffixes.isEmpty();
|
|
uData.setBaseDNs(suffixes);
|
}
|
|
if (!cancelled)
|
{
|
// Ask for confirmation to initialize.
|
boolean initializeADS = false;
|
for (String dn : uData.getBaseDNs())
|
{
|
if (Utils.areDnsEqual(ADSContext.getAdministrationSuffixDN(), dn))
|
{
|
initializeADS = true;
|
break;
|
}
|
}
|
String hostPortSource = ConnectionUtils.getHostPort(ctxSource);
|
String hostPortDestination = ConnectionUtils.getHostPort(ctxDestination);
|
if (initializeADS)
|
{
|
printLineBreak();
|
cancelled = !confirm(INFO_REPLICATION_CONFIRM_INITIALIZE_ADS.get(
|
ADSContext.getAdministrationSuffixDN(), hostPortDestination,
|
hostPortSource));
|
}
|
else
|
{
|
printLineBreak();
|
cancelled = !confirm(INFO_REPLICATION_CONFIRM_INITIALIZE_GENERIC.get(
|
hostPortDestination, hostPortSource));
|
}
|
}
|
|
if (ctxSource != null)
|
{
|
try
|
{
|
ctxSource.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
|
if (ctxDestination != null)
|
{
|
try
|
{
|
ctxDestination.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
return !cancelled;
|
}
|
|
/**
|
* Commodity method that simply checks if a provided value is null or not,
|
* if it is not <CODE>null</CODE> returns it and if it is <CODE>null</CODE>
|
* returns the provided default value.
|
* @param v the value to analyze.
|
* @param defaultValue the default value.
|
* @return if the provided value is not <CODE>null</CODE> returns it and if it
|
* is <CODE>null</CODE> returns the provided default value.
|
*/
|
private String getValue(String v, String defaultValue)
|
{
|
if (v != null)
|
{
|
return v;
|
}
|
else
|
{
|
return defaultValue;
|
}
|
}
|
|
/**
|
* Commodity method that simply checks if a provided value is -1 or not,
|
* if it is not -1 returns it and if it is -1 returns the provided default
|
* value.
|
* @param v the value to analyze.
|
* @param defaultValue the default value.
|
* @return if the provided value is not -1 returns it and if it is -1 returns
|
* the provided default value.
|
*/
|
private int getValue(int v, int defaultValue)
|
{
|
if (v != -1)
|
{
|
return v;
|
}
|
else
|
{
|
return defaultValue;
|
}
|
}
|
|
/**
|
* Returns the trust manager to be used by this application.
|
* @return the trust manager to be used by this application.
|
*/
|
private ApplicationTrustManager getTrustManager()
|
{
|
return argParser.getTrustManager();
|
}
|
|
/**
|
* Initializes the contents of the provided enable replication user data
|
* object with what was provided in the command-line without prompting to the
|
* user.
|
* @param uData the enable replication user data object to be initialized.
|
*/
|
private void initializeWithArgParser(EnableReplicationUserData uData)
|
{
|
uData.setBaseDNs(new LinkedList<String>(argParser.getBaseDNs()));
|
String adminUid = getValue(argParser.getAdministratorUID(),
|
argParser.getDefaultAdministratorUID());
|
uData.setAdminUid(adminUid);
|
String adminPwd = argParser.getBindPasswordAdmin();
|
uData.setAdminPwd(adminPwd);
|
|
String host1Name = getValue(argParser.getHostName1(),
|
argParser.getDefaultHostName1());
|
uData.setHostName1(host1Name);
|
int port1 = getValue(argParser.getPort1(),
|
argParser.getDefaultPort1());
|
uData.setPort1(port1);
|
uData.setUseSSL1(argParser.useSSL1());
|
uData.setUseStartTLS1(argParser.useStartTLS1());
|
String pwd1 = argParser.getBindPassword1();
|
if (pwd1 == null)
|
{
|
uData.setBindDn1(ADSContext.getAdministratorDN(adminUid));
|
uData.setPwd1(adminPwd);
|
}
|
else
|
{
|
String bindDn = getValue(argParser.getBindDn1(),
|
argParser.getDefaultBindDn1());
|
uData.setBindDn1(bindDn);
|
uData.setPwd1(pwd1);
|
}
|
int replicationPort1 = getValue(argParser.getReplicationPort1(),
|
argParser.getDefaultReplicationPort1());
|
uData.setReplicationPort1(replicationPort1);
|
|
String host2Name = getValue(argParser.getHostName2(),
|
argParser.getDefaultHostName2());
|
uData.setHostName2(host2Name);
|
int port2 = getValue(argParser.getPort2(),
|
argParser.getDefaultPort2());
|
uData.setPort2(port2);
|
uData.setUseSSL2(argParser.useSSL2());
|
uData.setUseStartTLS2(argParser.useStartTLS2());
|
String pwd2 = argParser.getBindPassword2();
|
if (pwd2 == null)
|
{
|
uData.setBindDn2(ADSContext.getAdministratorDN(adminUid));
|
uData.setPwd2(adminPwd);
|
}
|
else
|
{
|
String bindDn = getValue(argParser.getBindDn2(),
|
argParser.getDefaultBindDn2());
|
uData.setBindDn2(bindDn);
|
uData.setPwd2(pwd2);
|
}
|
uData.setReplicationPort1(replicationPort1);
|
}
|
|
/**
|
* Initializes the contents of the provided initialize replication user data
|
* object with what was provided in the command-line without prompting to the
|
* user.
|
* @param uData the initialize replication user data object to be initialized.
|
*/
|
private void initializeWithArgParser(InitializeReplicationUserData uData)
|
{
|
uData.setBaseDNs(new LinkedList<String>(argParser.getBaseDNs()));
|
String adminUid = getValue(argParser.getAdministratorUID(),
|
argParser.getDefaultAdministratorUID());
|
uData.setAdminUid(adminUid);
|
String adminPwd = argParser.getBindPasswordAdmin();
|
uData.setAdminPwd(adminPwd);
|
|
String hostNameSource = getValue(argParser.getHostNameSource(),
|
argParser.getDefaultHostNameSource());
|
uData.setHostNameSource(hostNameSource);
|
int portSource = getValue(argParser.getPortSource(),
|
argParser.getDefaultPortSource());
|
uData.setPortSource(portSource);
|
uData.setUseSSLSource(argParser.useSSLSource());
|
uData.setUseStartTLSSource(argParser.useStartTLSSource());
|
|
String hostNameDestination = getValue(
|
argParser.getHostNameDestination(),
|
argParser.getDefaultHostNameDestination());
|
uData.setHostNameDestination(hostNameDestination);
|
int portDestination = getValue(argParser.getPortSource(),
|
argParser.getDefaultPortDestination());
|
uData.setPortDestination(portDestination);
|
uData.setUseSSLDestination(argParser.useSSLDestination());
|
uData.setUseStartTLSDestination(argParser.useStartTLSDestination());
|
}
|
|
/**
|
* Initializes the contents of the provided disable replication user data
|
* object with what was provided in the command-line without prompting to the
|
* user.
|
* @param uData the disable replication user data object to be initialized.
|
*/
|
private void initializeWithArgParser(DisableReplicationUserData uData)
|
{
|
uData.setBaseDNs(new LinkedList<String>(argParser.getBaseDNs()));
|
String adminUid = argParser.getAdministratorUID();
|
String bindDn = argParser.getBindDN();
|
if ((bindDn == null) && (adminUid == null))
|
{
|
adminUid = argParser.getDefaultAdministratorUID();
|
}
|
uData.setAdminUid(adminUid);
|
uData.setBindDn(bindDn);
|
String adminPwd = argParser.getBindPasswordAdmin();
|
uData.setAdminPwd(adminPwd);
|
|
String hostName = getValue(argParser.getHostNameToDisable(),
|
argParser.getDefaultHostNameToDisable());
|
uData.setHostName(hostName);
|
int port = getValue(argParser.getPortToDisable(),
|
argParser.getDefaultPortToDisable());
|
uData.setPort(port);
|
uData.setUseSSL(argParser.useSSLToDisable());
|
uData.setUseStartTLS(argParser.useStartTLSToDisable());
|
}
|
|
/**
|
* Tells whether the server to which the LdapContext is connected has a
|
* replication port or not.
|
* @param ctx the InitialLdapContext to be used.
|
* @return <CODE>true</CODE> if the replication port for the server could
|
* be found and <CODE>false</CODE> otherwise.
|
*/
|
private boolean hasReplicationPort(InitialLdapContext ctx)
|
{
|
return getReplicationPort(ctx) != -1;
|
}
|
|
/**
|
* Returns the replication port of server to which the LdapContext is
|
* connected and -1 if the replication port could not be found.
|
* @param ctx the InitialLdapContext to be used.
|
* @return the replication port of server to which the LdapContext is
|
* connected and -1 if the replication port could not be found.
|
*/
|
private int getReplicationPort(InitialLdapContext ctx)
|
{
|
int replicationPort = -1;
|
try
|
{
|
ManagementContext mCtx = LDAPManagementContext.createFromContext(
|
JNDIDirContextAdaptor.adapt(ctx));
|
RootCfgClient root = mCtx.getRootConfiguration();
|
|
MultimasterSynchronizationProviderCfgClient sync = null;
|
sync = (MultimasterSynchronizationProviderCfgClient)
|
root.getSynchronizationProvider("Multimaster Synchronization");
|
/*
|
* Configure the replication server.
|
*/
|
if (sync.hasReplicationServer())
|
{
|
ReplicationServerCfgClient replicationServer =
|
sync.getReplicationServer();
|
replicationPort = replicationServer.getReplicationPort();
|
}
|
}
|
catch (Throwable t)
|
{
|
LOG.log(Level.WARNING,
|
"Unexpected error retrieving the replication port: "+t, t);
|
}
|
return replicationPort;
|
}
|
|
/**
|
* Loads the ADS with the provided context. If there are certificates to
|
* be accepted we prompt them to the user. If there are errors loading the
|
* servers we display them to the user and we ask for confirmation. If the
|
* provided ctx is not using Global Administrator credentials, we prompt the
|
* user to provide them and update the provide ReplicationUserData
|
* accordingly.
|
* @param ctx the Ldap context to be used.
|
* @param uData the ReplicationUserData to be udpated.
|
* @param isFirstOrSourceServer whether this is the first server in the
|
* enable replication subcommand or the source server in the initialize server
|
* subcommand.
|
* @return <CODE>true</CODE> if everything went fine and the user accepted
|
* all the certificates and confirmed everything. Returns <CODE>false</CODE>
|
* if a critical error occurred or the user did not accept a certificate or
|
* any of the confirmation messages.
|
*/
|
private boolean loadADSAndAcceptCertificates(InitialLdapContext ctx,
|
ReplicationUserData uData, boolean isFirstOrSourceServer)
|
{
|
boolean cancelled = false;
|
boolean triedWithUserProvidedAdmin = false;
|
String host = ConnectionUtils.getHostName(ctx);
|
int port = ConnectionUtils.getPort(ctx);
|
boolean isSSL = ConnectionUtils.isSSL(ctx);
|
boolean isStartTLS = ConnectionUtils.isStartTLS(ctx);
|
try
|
{
|
ADSContext adsContext = new ADSContext(ctx);
|
if (adsContext.hasAdminData())
|
{
|
TopologyCache cache = new TopologyCache(adsContext, getTrustManager());
|
boolean reloadTopology = true;
|
LinkedList<Message> exceptionMsgs = new LinkedList<Message>();
|
while (reloadTopology && !cancelled)
|
{
|
cache.reloadTopology();
|
|
reloadTopology = false;
|
exceptionMsgs.clear();
|
|
/* Analyze if we had any exception while loading servers. For the
|
* moment only throw the exception found if the user did not provide
|
* the Administrator DN and this caused a problem authenticating in
|
* one server or if there is a certificate problem.
|
*/
|
Set<TopologyCacheException> exceptions =
|
new HashSet<TopologyCacheException>();
|
Set<ServerDescriptor> servers = cache.getServers();
|
for (ServerDescriptor server : servers)
|
{
|
TopologyCacheException e = server.getLastException();
|
if (e != null)
|
{
|
exceptions.add(e);
|
}
|
}
|
/* Check the exceptions and see if we throw them or not. */
|
for (TopologyCacheException e : exceptions)
|
{
|
switch (e.getType())
|
{
|
case NOT_GLOBAL_ADMINISTRATOR:
|
printLineBreak();
|
printErrorMessage(INFO_NOT_GLOBAL_ADMINISTRATOR_PROVIDED.get());
|
boolean connected = false;
|
|
String adminUid = uData.getAdminUid();
|
String adminPwd = uData.getAdminPwd();
|
while (!connected)
|
{
|
if ((!triedWithUserProvidedAdmin) && (adminPwd == null))
|
{
|
adminUid = getValue(argParser.getAdministratorUID(),
|
argParser.getDefaultAdministratorUID());
|
adminPwd = argParser.getBindPasswordAdmin();
|
triedWithUserProvidedAdmin = true;
|
}
|
if (adminPwd == null)
|
{
|
adminUid = askForAdministratorUID(
|
argParser.getDefaultAdministratorUID());
|
adminPwd = askForAdministratorPwd();
|
}
|
try
|
{
|
ctx.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
try
|
{
|
ctx = createContext(host, port, isSSL, isStartTLS,
|
ADSContext.getAdministratorDN(adminUid), adminPwd,
|
getTrustManager());
|
adsContext = new ADSContext(ctx);
|
cache = new TopologyCache(adsContext, getTrustManager());
|
}
|
catch (Throwable t)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_ERROR_CONNECTING_TO_SERVER_PROMPT_AGAIN.get(
|
host+":"+port, t.getMessage()));
|
LOG.log(Level.WARNING, "Complete error stack:", t);
|
printLineBreak();
|
}
|
}
|
uData.setAdminUid(adminUid);
|
uData.setAdminPwd(adminPwd);
|
if (uData instanceof EnableReplicationUserData)
|
{
|
EnableReplicationUserData enableData =
|
(EnableReplicationUserData)uData;
|
if (isFirstOrSourceServer)
|
{
|
enableData.setBindDn1(
|
ADSContext.getAdministratorDN(adminUid));
|
enableData.setPwd1(adminPwd);
|
}
|
else
|
{
|
enableData.setBindDn2(
|
ADSContext.getAdministratorDN(adminUid));
|
enableData.setPwd2(adminPwd);
|
}
|
}
|
reloadTopology = true;
|
break;
|
case GENERIC_CREATING_CONNECTION:
|
if ((e.getCause() != null) &&
|
Utils.isCertificateException(e.getCause()))
|
{
|
reloadTopology = true;
|
cancelled = !promptForCertificateConfirmation(e.getCause(),
|
getTrustManager(), e.getLdapUrl());
|
}
|
else
|
{
|
exceptionMsgs.add(Utils.getMessage(e));
|
}
|
break;
|
default:
|
exceptionMsgs.add(Utils.getMessage(e));
|
}
|
}
|
}
|
if ((exceptionMsgs.size() > 0) && !cancelled)
|
{
|
cancelled = !confirm(
|
ERR_REPLICATION_READING_REGISTERED_SERVERS_CONFIRM_UPDATE_REMOTE.
|
get(Utils.getMessageFromCollection(exceptionMsgs,
|
Constants.LINE_SEPARATOR).toString()));
|
}
|
}
|
}
|
catch (ADSContextException ace)
|
{
|
printLineBreak();
|
printErrorMessage(Utils.getThrowableMsg(INFO_BUG_MSG.get(), ace));
|
|
LOG.log(Level.SEVERE, "Complete error stack:", ace);
|
cancelled = true;
|
}
|
catch (TopologyCacheException tce)
|
{
|
printLineBreak();
|
printErrorMessage(Utils.getMessage(tce));
|
|
LOG.log(Level.SEVERE, "Complete error stack:", tce);
|
cancelled = true;
|
}
|
return !cancelled;
|
}
|
|
/**
|
* Tells whether there is a Global Administrator defined in the server
|
* to which the InitialLdapContext is connected.
|
* @param ctx the InitialLdapContext.
|
* @return <CODE>true</CODE> if we could find an administrator and
|
* <CODE>false</CODE> otherwise.
|
*/
|
private boolean hasAdministrator(InitialLdapContext ctx)
|
{
|
boolean isAdminDefined = false;
|
try
|
{
|
ADSContext adsContext = new ADSContext(ctx);
|
if (adsContext.hasAdminData())
|
{
|
Set administrators = adsContext.readAdministratorRegistry();
|
isAdminDefined = administrators.size() > 0;
|
}
|
}
|
catch (Throwable t)
|
{
|
LOG.log(Level.WARNING,
|
"Unexpected error retrieving the ADS data: "+t, t);
|
}
|
return isAdminDefined;
|
}
|
|
/**
|
* Returns a Collection containing a list of suffixes that are defined in
|
* two servers at the same time (depending on the value of the argument
|
* replicated this list contains only the suffixes that are replicated
|
* between the servers or the list of suffixes that are not replicated
|
* between the servers).
|
* @param ctx1 the connection to the first server.
|
* @param ctx2 the connection to the second server.
|
* @param type whether to return a list with the suffixes that are
|
* replicated, fully replicated (replicas have exactly the same list of
|
* replication servers), not replicated or all the common suffixes.
|
* @return a Collection containing a list of suffixes that are replicated
|
* (or those that can be replicated) in two servers.
|
*/
|
private enum SuffixRelationType
|
{
|
NOT_REPLICATED, FULLY_REPLICATED, REPLICATED, NOT_FULLY_REPLICATED, ALL
|
};
|
private Collection<String> getCommonSuffixes(
|
InitialLdapContext ctx1, InitialLdapContext ctx2, SuffixRelationType type)
|
{
|
LinkedList<String> suffixes = new LinkedList<String>();
|
try
|
{
|
ServerDescriptor server1 = ServerDescriptor.createStandalone(ctx1);
|
ServerDescriptor server2 = ServerDescriptor.createStandalone(ctx2);
|
Set<ReplicaDescriptor> replicas1 = server1.getReplicas();
|
Set<ReplicaDescriptor> replicas2 = server2.getReplicas();
|
|
for (ReplicaDescriptor rep1 : replicas1)
|
{
|
for (ReplicaDescriptor rep2 : replicas2)
|
{
|
switch (type)
|
{
|
case NOT_REPLICATED:
|
if (!areReplicated(rep1, rep2) &&
|
Utils.areDnsEqual(rep1.getSuffix().getDN(),
|
rep2.getSuffix().getDN()))
|
{
|
suffixes.add(rep1.getSuffix().getDN());
|
}
|
break;
|
case FULLY_REPLICATED:
|
if (areFullyReplicated(rep1, rep2))
|
{
|
suffixes.add(rep1.getSuffix().getDN());
|
}
|
break;
|
case REPLICATED:
|
if (areReplicated(rep1, rep2))
|
{
|
suffixes.add(rep1.getSuffix().getDN());
|
}
|
break;
|
case NOT_FULLY_REPLICATED:
|
if (!areFullyReplicated(rep1, rep2) &&
|
Utils.areDnsEqual(rep1.getSuffix().getDN(),
|
rep2.getSuffix().getDN()))
|
{
|
suffixes.add(rep1.getSuffix().getDN());
|
}
|
break;
|
case ALL:
|
if (Utils.areDnsEqual(rep1.getSuffix().getDN(),
|
rep2.getSuffix().getDN()))
|
{
|
suffixes.add(rep1.getSuffix().getDN());
|
}
|
break;
|
default:
|
throw new IllegalStateException("Unknown type: "+type);
|
}
|
}
|
}
|
}
|
catch (Throwable t)
|
{
|
LOG.log(Level.WARNING,
|
"Unexpected error retrieving the server configuration: "+t, t);
|
}
|
return suffixes;
|
}
|
|
/**
|
* Tells whether the two provided replicas are fully replicated or not. The
|
* code in fact checks that both replicas have the same DN that they are
|
* replicated if both servers are replication servers and that both replicas
|
* make reference to the other replication server.
|
* @param rep1 the first replica.
|
* @param rep2 the second replica.
|
* @return <CODE>true</CODE> if we can assure that the two replicas are
|
* replicated using the replication server and replication port information
|
* and <CODE>false</CODE> otherwise.
|
*/
|
private boolean areFullyReplicated(ReplicaDescriptor rep1,
|
ReplicaDescriptor rep2)
|
{
|
boolean areFullyReplicated = false;
|
if (Utils.areDnsEqual(rep1.getSuffix().getDN(), rep2.getSuffix().getDN()) &&
|
rep1.isReplicated() && rep2.isReplicated() &&
|
rep1.getServer().isReplicationServer() &&
|
rep2.getServer().isReplicationServer())
|
{
|
Set<String> servers1 = rep1.getReplicationServers();
|
Set<String> servers2 = rep2.getReplicationServers();
|
String server1 = rep1.getServer().getReplicationServerHostPort();
|
String server2 = rep2.getServer().getReplicationServerHostPort();
|
areFullyReplicated = servers1.contains(server2) &&
|
servers2.contains(server1);
|
}
|
return areFullyReplicated;
|
}
|
|
/**
|
* Tells whether the two provided replicas are replicated or not. The
|
* code in fact checks that both replicas have the same DN and that they
|
* have at least one common replication server referenced.
|
* @param rep1 the first replica.
|
* @param rep2 the second replica.
|
* @return <CODE>true</CODE> if we can assure that the two replicas are
|
* replicated and <CODE>false</CODE> otherwise.
|
*/
|
private boolean areReplicated(ReplicaDescriptor rep1, ReplicaDescriptor rep2)
|
{
|
boolean areReplicated = false;
|
if (Utils.areDnsEqual(rep1.getSuffix().getDN(), rep2.getSuffix().getDN()) &&
|
rep1.isReplicated() && rep2.isReplicated())
|
{
|
Set<String> servers1 = rep1.getReplicationServers();
|
Set<String> servers2 = rep2.getReplicationServers();
|
servers1.retainAll(servers2);
|
areReplicated = !servers1.isEmpty();
|
}
|
return areReplicated;
|
}
|
|
/**
|
* Returns a Collection containing a list of replicas in a server.
|
* @param ctx the connection to the server.
|
* @return a Collection containing a list of replicas in a server.
|
*/
|
private Collection<ReplicaDescriptor> getReplicas(InitialLdapContext ctx)
|
{
|
LinkedList<ReplicaDescriptor> suffixes =
|
new LinkedList<ReplicaDescriptor>();
|
try
|
{
|
ServerDescriptor server = ServerDescriptor.createStandalone(ctx);
|
suffixes.addAll(server.getReplicas());
|
}
|
catch (Throwable t)
|
{
|
LOG.log(Level.WARNING,
|
"Unexpected error retrieving the server configuration: "+t, t);
|
}
|
return suffixes;
|
}
|
|
/**
|
* Enables the replication between two servers using the parameters in the
|
* provided EnableReplicationUserData. This method does not prompt to the
|
* user for information if something is missing.
|
* @param uData the EnableReplicationUserData object.
|
* @return ReplicationCliReturnCode.SUCCESSFUL if the operation was
|
* successful.
|
* and the replication could be enabled and an error code otherwise.
|
*/
|
private ReplicationCliReturnCode enableReplication(
|
EnableReplicationUserData uData)
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
InitialLdapContext ctx1 = null;
|
InitialLdapContext ctx2 = null;
|
|
String host1 = uData.getHostName1();
|
String host2 = uData.getHostName2();
|
int port1 = uData.getPort1();
|
int port2 = uData.getPort2();
|
|
LinkedList<Message> errorMessages = new LinkedList<Message>();
|
|
printProgressMessage(
|
formatter.getFormattedWithPoints(INFO_REPLICATION_CONNECTING.get()));
|
try
|
{
|
ctx1 = createContext(host1, port1, uData.useSSL1(), uData.useStartTLS1(),
|
uData.getBindDn1(), uData.getPwd1(), getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = host1+":"+port1;
|
errorMessages.add(getMessageForException(ne, hostPort));
|
|
LOG.log(Level.SEVERE, "Complete error stack:", ne);
|
}
|
try
|
{
|
ctx2 = createContext(host2, port2, uData.useSSL2(), uData.useStartTLS2(),
|
uData.getBindDn2(), uData.getPwd2(), getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = host2+":"+port2;
|
errorMessages.add(getMessageForException(ne, hostPort));
|
|
LOG.log(Level.SEVERE, "Complete error stack:", ne);
|
}
|
|
if (errorMessages.size() > 0)
|
{
|
returnValue = ERROR_CONNECTING;
|
}
|
|
if (errorMessages.isEmpty())
|
{
|
// This done is for the message informing that we are connecting.
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
|
// If we are not in interactive mode do some checks...
|
if (!argParser.isInteractive())
|
{
|
boolean hasReplicationPort1 = hasReplicationPort(ctx1);
|
boolean hasReplicationPort2 = hasReplicationPort(ctx2);
|
int replPort1 = uData.getReplicationPort1();
|
int replPort2 = uData.getReplicationPort2();
|
|
if (!hasReplicationPort1)
|
{
|
if (!argParser.skipReplicationPortCheck() &&
|
!SetupUtils.canUseAsPort(replPort1))
|
{
|
errorMessages.add(getCannotBindToPortError(replPort1));
|
}
|
}
|
if (!hasReplicationPort2)
|
{
|
if (!argParser.skipReplicationPortCheck() &&
|
!SetupUtils.canUseAsPort(replPort2))
|
{
|
errorMessages.add(getCannotBindToPortError(replPort2));
|
}
|
}
|
if (!hasReplicationPort1 && !hasReplicationPort2 &&
|
(replPort1 == replPort2) &&
|
(host1.equalsIgnoreCase(host2)))
|
{
|
errorMessages.add(ERR_REPLICATION_SAME_REPLICATION_PORT.get(
|
String.valueOf(replPort1), host1));
|
}
|
|
if (argParser.skipReplicationPortCheck())
|
{
|
// This is something that we must do in any case... this test is
|
// already included when we call SetupUtils.canUseAsPort
|
if (replPort1 == port1)
|
{
|
errorMessages.add(
|
ERR_REPLICATION_PORT_AND_REPLICATION_PORT_EQUAL.get(
|
host1, String.valueOf(replPort1)));
|
}
|
|
if (replPort2 == port2)
|
{
|
errorMessages.add(
|
ERR_REPLICATION_PORT_AND_REPLICATION_PORT_EQUAL.get(
|
host2, String.valueOf(replPort2)));
|
}
|
}
|
}
|
if (errorMessages.size() > 0)
|
{
|
returnValue = ERROR_USER_DATA;
|
}
|
}
|
|
if (errorMessages.isEmpty())
|
{
|
LinkedList<String> suffixes = uData.getBaseDNs();
|
checkSuffixesForEnableReplication(suffixes, ctx1, ctx2, false);
|
if (!suffixes.isEmpty())
|
{
|
uData.setBaseDNs(suffixes);
|
try
|
{
|
updateConfiguration(ctx1, ctx2, uData);
|
returnValue = SUCCESSFUL;
|
}
|
catch (ReplicationCliException rce)
|
{
|
returnValue = rce.getErrorCode();
|
printLineBreak();
|
printErrorMessage(rce.getMessageObject());
|
LOG.log(Level.SEVERE, "Complete error stack:", rce);
|
}
|
}
|
else
|
{
|
// The error messages are already displayed in the method
|
// checkSuffixesForEnableReplication.
|
returnValue = REPLICATION_CANNOT_BE_ENABLED_ON_BASEDN;
|
}
|
}
|
|
for (Message msg : errorMessages)
|
{
|
printLineBreak();
|
printErrorMessage(msg);
|
}
|
|
if (ctx1 != null)
|
{
|
try
|
{
|
ctx1.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
|
if (ctx2 != null)
|
{
|
try
|
{
|
ctx2.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
return returnValue;
|
}
|
|
/**
|
* Disbles the replication in the server for the provided suffixes using the
|
* data in the DisableReplicationUserData object. This method does not prompt
|
* to the user for information if something is missing.
|
* @param uData the DisableReplicationUserData object.
|
* @return ReplicationCliReturnCode.SUCCESSFUL if the operation was
|
* successful.
|
* and the replication could be enabled and an error code otherwise.
|
*/
|
private ReplicationCliReturnCode disableReplication(
|
DisableReplicationUserData uData)
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
InitialLdapContext ctx = null;
|
printProgressMessage(
|
formatter.getFormattedWithPoints(INFO_REPLICATION_CONNECTING.get()));
|
String bindDn = uData.getAdminUid() == null ? uData.getBindDn() :
|
ADSContext.getAdministratorDN(uData.getAdminUid());
|
try
|
{
|
ctx = createContext(uData.getHostName(), uData.getPort(),
|
uData.useSSL(), uData.useStartTLS(), bindDn, uData.getAdminPwd(),
|
getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = uData.getHostName()+":"+uData.getPort();
|
printLineBreak();
|
printErrorMessage(getMessageForException(ne, hostPort));
|
LOG.log(Level.SEVERE, "Complete error stack:", ne);
|
}
|
|
if (ctx != null)
|
{
|
// This done is for the message informing that we are connecting.
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
LinkedList<String> suffixes = uData.getBaseDNs();
|
checkSuffixesForDisableReplication(suffixes, ctx, false);
|
if (!suffixes.isEmpty())
|
{
|
uData.setBaseDNs(suffixes);
|
try
|
{
|
updateConfiguration(ctx, uData);
|
returnValue = SUCCESSFUL;
|
}
|
catch (ReplicationCliException rce)
|
{
|
returnValue = rce.getErrorCode();
|
printLineBreak();
|
printErrorMessage(rce.getMessageObject());
|
LOG.log(Level.SEVERE, "Complete error stack:", rce);
|
}
|
}
|
else
|
{
|
returnValue = REPLICATION_CANNOT_BE_DISABLED_ON_BASEDN;
|
}
|
}
|
else
|
{
|
returnValue = ERROR_CONNECTING;
|
}
|
|
if (ctx != null)
|
{
|
try
|
{
|
ctx.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
return returnValue;
|
}
|
|
/**
|
* Initializes the contents of one server with the contents of the other
|
* using the parameters in the provided InitializeReplicationUserData.
|
* This method does not prompt to the user for information if something is
|
* missing.
|
* @param uData the InitializeReplicationUserData object.
|
* @return ReplicationCliReturnCode.SUCCESSFUL if the operation was
|
* successful.
|
* and the replication could be enabled and an error code otherwise.
|
*/
|
private ReplicationCliReturnCode initializeReplication(
|
InitializeReplicationUserData uData)
|
{
|
ReplicationCliReturnCode returnValue = SUCCESSFUL_NOP;
|
InitialLdapContext ctxSource = null;
|
InitialLdapContext ctxDestination = null;
|
try
|
{
|
ctxSource = createContext(uData.getHostNameSource(),
|
uData.getPortSource(), uData.useSSLSource(),
|
uData.useStartTLSSource(),
|
ADSContext.getAdministratorDN(uData.getAdminUid()),
|
uData.getAdminPwd(), getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = uData.getHostNameSource()+":"+uData.getPortSource();
|
printLineBreak();
|
printErrorMessage(getMessageForException(ne, hostPort));
|
LOG.log(Level.SEVERE, "Complete error stack:", ne);
|
}
|
try
|
{
|
ctxDestination = createContext(uData.getHostNameDestination(),
|
uData.getPortDestination(), uData.useSSLDestination(),
|
uData.useStartTLSDestination(),
|
ADSContext.getAdministratorDN(uData.getAdminUid()),
|
uData.getAdminPwd(), getTrustManager());
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = uData.getHostNameDestination()+":"+
|
uData.getPortDestination();
|
printLineBreak();
|
printErrorMessage(getMessageForException(ne, hostPort));
|
LOG.log(Level.SEVERE, "Complete error stack:", ne);
|
}
|
if ((ctxSource != null) && (ctxDestination != null))
|
{
|
LinkedList<String> baseDNs = uData.getBaseDNs();
|
checkSuffixesForInitializeReplication(baseDNs, ctxSource, ctxDestination,
|
false);
|
if (!baseDNs.isEmpty())
|
{
|
for (String baseDN : baseDNs)
|
{
|
try
|
{
|
Message msg = formatter.getFormattedProgress(
|
INFO_PROGRESS_INITIALIZING_SUFFIX.get(baseDN,
|
ConnectionUtils.getHostPort(ctxDestination)));
|
printProgressMessage(msg);
|
printProgressLineBreak();
|
initializeSuffix(baseDN, ctxSource, ctxDestination, true);
|
}
|
catch (ReplicationCliException rce)
|
{
|
printLineBreak();
|
printErrorMessage(rce.getMessageObject());
|
returnValue = rce.getErrorCode();
|
LOG.log(Level.SEVERE, "Complete error stack:", rce);
|
}
|
}
|
}
|
else
|
{
|
returnValue = REPLICATION_CANNOT_BE_INITIALIZED_ON_BASEDN;
|
}
|
}
|
else
|
{
|
returnValue = ERROR_CONNECTING;
|
}
|
|
if (ctxSource != null)
|
{
|
try
|
{
|
ctxSource.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
|
if (ctxDestination != null)
|
{
|
try
|
{
|
ctxDestination.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
return returnValue;
|
}
|
|
/**
|
* Checks that replication can actually be enabled in the provided baseDNs
|
* for the two servers.
|
* @param suffixes the suffixes provided by the user. This Collection is
|
* updated by removing the base DNs that cannot be enabled and with the
|
* base DNs that the user provided interactively.
|
* @param ctx1 connection to the first server.
|
* @param ctx2 connection to the second server.
|
* @param interactive whether to ask the user to provide interactively
|
* base DNs if none of the provided base DNs can be enabled.
|
*/
|
private void checkSuffixesForEnableReplication(Collection<String> suffixes,
|
InitialLdapContext ctx1, InitialLdapContext ctx2,
|
boolean interactive)
|
{
|
TreeSet<String> availableSuffixes =
|
new TreeSet<String>(getCommonSuffixes(ctx1, ctx2,
|
SuffixRelationType.NOT_FULLY_REPLICATED));
|
TreeSet<String> alreadyReplicatedSuffixes =
|
new TreeSet<String>(getCommonSuffixes(ctx1, ctx2,
|
SuffixRelationType.FULLY_REPLICATED));
|
|
if (availableSuffixes.size() == 0)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_ENABLE_REPLICATION.get());
|
|
LinkedList<String> userProvidedSuffixes = argParser.getBaseDNs();
|
TreeSet<String> userProvidedReplicatedSuffixes = new TreeSet<String>();
|
|
for (String s1 : userProvidedSuffixes)
|
{
|
for (String s2 : alreadyReplicatedSuffixes)
|
{
|
if (Utils.areDnsEqual(s1, s2))
|
{
|
userProvidedReplicatedSuffixes.add(s1);
|
}
|
}
|
}
|
if (userProvidedReplicatedSuffixes.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(
|
INFO_ALREADY_REPLICATED_SUFFIXES.get(
|
Utils.getStringFromCollection(userProvidedReplicatedSuffixes,
|
Constants.LINE_SEPARATOR)));
|
}
|
suffixes.clear();
|
}
|
else
|
{
|
// Verify that the provided suffixes are configured in the servers.
|
TreeSet<String> notFound = new TreeSet<String>();
|
TreeSet<String> alreadyReplicated = new TreeSet<String>();
|
for (String dn : suffixes)
|
{
|
boolean found = false;
|
for (String dn1 : availableSuffixes)
|
{
|
if (Utils.areDnsEqual(dn, dn1))
|
{
|
found = true;
|
break;
|
}
|
}
|
if (!found)
|
{
|
boolean isReplicated = false;
|
for (String s : alreadyReplicatedSuffixes)
|
{
|
if (Utils.areDnsEqual(s, dn))
|
{
|
isReplicated = true;
|
break;
|
}
|
}
|
if (isReplicated)
|
{
|
alreadyReplicated.add(dn);
|
}
|
else
|
{
|
notFound.add(dn);
|
}
|
}
|
}
|
suffixes.removeAll(notFound);
|
suffixes.removeAll(alreadyReplicated);
|
if (notFound.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(ERR_REPLICATION_ENABLE_SUFFIXES_NOT_FOUND.get(
|
Utils.getStringFromCollection(notFound,
|
Constants.LINE_SEPARATOR)));
|
}
|
if (alreadyReplicated.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(INFO_ALREADY_REPLICATED_SUFFIXES.get(
|
Utils.getStringFromCollection(alreadyReplicated,
|
Constants.LINE_SEPARATOR)));
|
}
|
if (interactive)
|
{
|
|
while (suffixes.isEmpty())
|
{
|
if ((availableSuffixes.size() == 1) &&
|
Utils.areDnsEqual(availableSuffixes.first(),
|
ADSContext.getAdministrationSuffixDN()))
|
{
|
// In interactive mode we do not propose to manage the
|
// administration suffix.
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_ENABLE_REPLICATION.get());
|
break;
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_NO_SUFFIXES_SELECTED_TO_REPLICATE.get());
|
for (String dn : availableSuffixes)
|
{
|
if (!Utils.areDnsEqual(ADSContext.getAdministrationSuffixDN(),
|
dn))
|
{
|
if (confirm(INFO_REPLICATION_ENABLE_SUFFIX_PROMPT.get(dn)))
|
{
|
suffixes.add(dn);
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* Checks that replication can actually be disabled in the provided baseDNs
|
* for the server.
|
* @param suffixes the suffixes provided by the user. This Collection is
|
* updated by removing the base DNs that cannot be enabled and with the
|
* base DNs that the user provided interactively.
|
* @param ctx connection to the server.
|
* @param interactive whether to ask the user to provide interactively
|
* base DNs if none of the provided base DNs can be disabled.
|
*/
|
private void checkSuffixesForDisableReplication(Collection<String> suffixes,
|
InitialLdapContext ctx, boolean interactive)
|
{
|
TreeSet<String> availableSuffixes = new TreeSet<String>();
|
TreeSet<String> notReplicatedSuffixes = new TreeSet<String>();
|
|
Collection<ReplicaDescriptor> replicas = getReplicas(ctx);
|
for (ReplicaDescriptor rep : replicas)
|
{
|
String dn = rep.getSuffix().getDN();
|
if (rep.isReplicated())
|
{
|
availableSuffixes.add(dn);
|
}
|
else
|
{
|
notReplicatedSuffixes.add(dn);
|
}
|
}
|
if (availableSuffixes.size() == 0)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_DISABLE_REPLICATION.get());
|
LinkedList<String> userProvidedSuffixes = argParser.getBaseDNs();
|
TreeSet<String> userProvidedNotReplicatedSuffixes =
|
new TreeSet<String>();
|
for (String s1 : userProvidedSuffixes)
|
{
|
for (String s2 : notReplicatedSuffixes)
|
{
|
if (Utils.areDnsEqual(s1, s2))
|
{
|
userProvidedNotReplicatedSuffixes.add(s1);
|
}
|
}
|
}
|
if (userProvidedNotReplicatedSuffixes.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(
|
INFO_ALREADY_NOT_REPLICATED_SUFFIXES.get(
|
Utils.getStringFromCollection(
|
userProvidedNotReplicatedSuffixes,
|
Constants.LINE_SEPARATOR)));
|
}
|
suffixes.clear();
|
}
|
else
|
{
|
// Verify that the provided suffixes are configured in the servers.
|
TreeSet<String> notFound = new TreeSet<String>();
|
TreeSet<String> alreadyNotReplicated = new TreeSet<String>();
|
for (String dn : suffixes)
|
{
|
boolean found = false;
|
for (String dn1 : availableSuffixes)
|
{
|
if (Utils.areDnsEqual(dn, dn1))
|
{
|
found = true;
|
break;
|
}
|
}
|
if (!found)
|
{
|
boolean notReplicated = false;
|
for (String s : notReplicatedSuffixes)
|
{
|
if (Utils.areDnsEqual(s, dn))
|
{
|
notReplicated = true;
|
break;
|
}
|
}
|
if (notReplicated)
|
{
|
alreadyNotReplicated.add(dn);
|
}
|
else
|
{
|
notFound.add(dn);
|
}
|
}
|
}
|
suffixes.removeAll(notFound);
|
suffixes.removeAll(alreadyNotReplicated);
|
if (notFound.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(ERR_REPLICATION_DISABLE_SUFFIXES_NOT_FOUND.get(
|
Utils.getStringFromCollection(notFound,
|
Constants.LINE_SEPARATOR)));
|
}
|
if (alreadyNotReplicated.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(INFO_ALREADY_NOT_REPLICATED_SUFFIXES.get(
|
Utils.getStringFromCollection(alreadyNotReplicated,
|
Constants.LINE_SEPARATOR)));
|
}
|
if (interactive)
|
{
|
while (suffixes.isEmpty())
|
{
|
if ((availableSuffixes.size() == 1) &&
|
Utils.areDnsEqual(availableSuffixes.first(),
|
ADSContext.getAdministrationSuffixDN()))
|
{
|
// In interactive mode we do not propose to manage the
|
// administration suffix.
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_DISABLE_REPLICATION.get());
|
break;
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_NO_SUFFIXES_SELECTED_TO_DISABLE.get());
|
for (String dn : availableSuffixes)
|
{
|
if (!Utils.areDnsEqual(ADSContext.getAdministrationSuffixDN(),
|
dn))
|
{
|
if (confirm(INFO_REPLICATION_DISABLE_SUFFIX_PROMPT.get(dn)))
|
{
|
suffixes.add(dn);
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* Checks that we can initialize the provided baseDNs between the two servers.
|
* @param suffixes the suffixes provided by the user. This Collection is
|
* updated by removing the base DNs that cannot be enabled and with the
|
* base DNs that the user provided interactively.
|
* @param ctxSource connection to the source server.
|
* @param ctxDestination connection to the destination server.
|
* @param interactive whether to ask the user to provide interactively
|
* base DNs if none of the provided base DNs can be initialized.
|
*/
|
private void checkSuffixesForInitializeReplication(
|
Collection<String> suffixes, InitialLdapContext ctxSource,
|
InitialLdapContext ctxDestination, boolean interactive)
|
{
|
TreeSet<String> availableSuffixes = new TreeSet<String>(
|
getCommonSuffixes(ctxSource, ctxDestination,
|
SuffixRelationType.REPLICATED));
|
if (availableSuffixes.size() == 0)
|
{
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_INITIALIZE_REPLICATION.get());
|
suffixes.clear();
|
}
|
else
|
{
|
// Verify that the provided suffixes are configured in the servers.
|
LinkedList<String> notFound = new LinkedList<String>();
|
for (String dn : suffixes)
|
{
|
boolean found = false;
|
for (String dn1 : availableSuffixes)
|
{
|
if (Utils.areDnsEqual(dn, dn1))
|
{
|
found = true;
|
break;
|
}
|
}
|
if (!found)
|
{
|
notFound.add(dn);
|
}
|
}
|
suffixes.removeAll(notFound);
|
if (notFound.size() > 0)
|
{
|
printLineBreak();
|
printErrorMessage(ERR_SUFFIXES_CANNOT_BE_INITIALIZED.get(
|
Utils.getStringFromCollection(notFound,
|
Constants.LINE_SEPARATOR)));
|
}
|
if (interactive)
|
{
|
while (suffixes.isEmpty())
|
{
|
if ((availableSuffixes.size() == 1) &&
|
Utils.areDnsEqual(availableSuffixes.first(),
|
ADSContext.getAdministrationSuffixDN()))
|
{
|
// In interactive mode we do not propose to manage the
|
// administration suffix.
|
printLineBreak();
|
printErrorMessage(
|
ERR_NO_SUFFIXES_AVAILABLE_TO_INITIALIZE_REPLICATION.get());
|
break;
|
}
|
else
|
{
|
printLineBreak();
|
printErrorMessage(ERR_NO_SUFFIXES_SELECTED_TO_INITIALIZE.get());
|
|
for (String dn : availableSuffixes)
|
{
|
if (!Utils.areDnsEqual(ADSContext.getAdministrationSuffixDN(),
|
dn))
|
{
|
if (confirm(INFO_REPLICATION_INITIALIZE_SUFFIX_PROMPT.get(dn)))
|
{
|
suffixes.add(dn);
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* Updates the configuration in the two servers (and in other servers if
|
* they are referenced) to enable replication.
|
* @param ctx1 the connection to the first server.
|
* @param ctx2 the connection to the second server.
|
* @param uData the EnableReplicationUserData object containing the required
|
* parameters to update the confgiuration.
|
* @throws ReplicationCliException if there is an error.
|
*/
|
private void updateConfiguration(InitialLdapContext ctx1,
|
InitialLdapContext ctx2, EnableReplicationUserData uData)
|
throws ReplicationCliException
|
{
|
LinkedHashSet<String> twoReplServers = new LinkedHashSet<String>();
|
LinkedHashSet<String> allRepServers = new LinkedHashSet<String>();
|
HashMap<String, LinkedHashSet<String>> hmRepServers =
|
new HashMap<String, LinkedHashSet<String>>();
|
Set<Integer> usedReplicationServerIds = new HashSet<Integer>();
|
HashMap<String, Set<Integer>> hmUsedReplicationDomainIds =
|
new HashMap<String, Set<Integer>>();
|
|
ServerDescriptor server1;
|
try
|
{
|
server1 = ServerDescriptor.createStandalone(ctx1);
|
}
|
catch (NamingException ne)
|
{
|
throw new ReplicationCliException(
|
getMessageForException(ne, ConnectionUtils.getHostPort(ctx1)),
|
ERROR_READING_CONFIGURATION, ne);
|
}
|
ServerDescriptor server2;
|
try
|
{
|
server2 = ServerDescriptor.createStandalone(ctx2);
|
}
|
catch (NamingException ne)
|
{
|
throw new ReplicationCliException(
|
getMessageForException(ne, ConnectionUtils.getHostPort(ctx2)),
|
ERROR_READING_CONFIGURATION, ne);
|
}
|
|
ADSContext adsCtx1 = new ADSContext(ctx1);
|
ADSContext adsCtx2 = new ADSContext(ctx2);
|
|
// These are used to identify which server we use to initialize
|
// the contents of the other server (if any).
|
InitialLdapContext ctxSource = null;
|
InitialLdapContext ctxDestination = null;
|
ADSContext adsCtxSource = null;
|
|
boolean adsAlreadyReplicated = false;
|
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_REPLICATION_ENABLE_UPDATING_ADS_CONTENTS.get()));
|
try
|
{
|
if (adsCtx1.hasAdminData() && adsCtx2.hasAdminData())
|
{
|
Set<Map<ADSContext.ServerProperty, Object>> registry1 =
|
adsCtx1.readServerRegistry();
|
Set<Map<ADSContext.ServerProperty, Object>> registry2 =
|
adsCtx2.readServerRegistry();
|
if (registry2.size() <= 1)
|
{
|
// Only the server itself registered.
|
if (!hasAdministrator(adsCtx1.getDirContext()))
|
{
|
adsCtx1.createAdministrator(getAdministratorProperties(uData));
|
}
|
if (registry2.size() == 0)
|
{
|
server2.updateAdsPropertiesWithServerProperties();
|
adsCtx1.registerServer(server2.getAdsProperties());
|
}
|
else
|
{
|
adsCtx1.registerServer(registry2.iterator().next());
|
}
|
|
ctxSource = ctx1;
|
ctxDestination = ctx2;
|
adsCtxSource = adsCtx1;
|
}
|
else if (registry1.size() <= 1)
|
{
|
// Only the server itself registered.
|
if (!hasAdministrator(adsCtx2.getDirContext()))
|
{
|
adsCtx2.createAdministrator(getAdministratorProperties(uData));
|
}
|
if (registry1.size() == 0)
|
{
|
server1.updateAdsPropertiesWithServerProperties();
|
adsCtx2.registerServer(server1.getAdsProperties());
|
}
|
else
|
{
|
adsCtx2.registerServer(registry1.iterator().next());
|
}
|
|
ctxSource = ctx2;
|
ctxDestination = ctx1;
|
adsCtxSource = adsCtx2;
|
}
|
else if (!registry1.equals(registry2))
|
{
|
// TO COMPLETE: we may want to merge the ADS but for the moment
|
// just say this is not supported.
|
throw new ReplicationCliException(
|
ERR_REPLICATION_ADS_MERGE_NOT_SUPPORTED.get(
|
ConnectionUtils.getHostPort(ctx1),
|
ConnectionUtils.getHostPort(ctx2)),
|
REPLICATION_ADS_MERGE_NOT_SUPPORTED, null);
|
}
|
else
|
{
|
// They are already replicated: nothing to do in terms of ADS
|
// initialization or ADS update data
|
adsAlreadyReplicated = true;
|
}
|
}
|
else if (!adsCtx1.hasAdminData() && adsCtx2.hasAdminData())
|
{
|
adsCtx1.createAdministrationSuffix(null);
|
if (!hasAdministrator(adsCtx2.getDirContext()))
|
{
|
adsCtx2.createAdministrator(getAdministratorProperties(uData));
|
}
|
server1.updateAdsPropertiesWithServerProperties();
|
adsCtx2.registerServer(server1.getAdsProperties());
|
|
ctxSource = ctx2;
|
ctxDestination = ctx1;
|
adsCtxSource = adsCtx2;
|
}
|
else if (adsCtx1.hasAdminData() && !adsCtx2.hasAdminData())
|
{
|
adsCtx2.createAdministrationSuffix(null);
|
if (!hasAdministrator(adsCtx1.getDirContext()))
|
{
|
adsCtx1.createAdministrator(getAdministratorProperties(uData));
|
}
|
server2.updateAdsPropertiesWithServerProperties();
|
adsCtx1.registerServer(server2.getAdsProperties());
|
|
ctxSource = ctx1;
|
ctxDestination = ctx2;
|
adsCtxSource = adsCtx1;
|
}
|
else
|
{
|
adsCtx1.createAdminData(null);
|
adsCtx1.createAdministrator(getAdministratorProperties(uData));
|
server1.updateAdsPropertiesWithServerProperties();
|
adsCtx1.registerServer(server1.getAdsProperties());
|
server2.updateAdsPropertiesWithServerProperties();
|
adsCtx1.registerServer(server2.getAdsProperties());
|
adsCtx2.createAdministrationSuffix(null);
|
|
ctxSource = ctx1;
|
ctxDestination = ctx2;
|
adsCtxSource = adsCtx1;
|
}
|
}
|
catch (ADSContextException adce)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_UPDATING_ADS.get(adce.getMessage()),
|
ERROR_UPDATING_ADS, adce);
|
}
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
|
LinkedList<String> baseDNs = uData.getBaseDNs();
|
if (!adsAlreadyReplicated)
|
{
|
boolean found = false;
|
for (String dn : baseDNs)
|
{
|
if (Utils.areDnsEqual(dn, ADSContext.getAdministrationSuffixDN()))
|
{
|
found = true;
|
break;
|
}
|
}
|
if (!found)
|
{
|
baseDNs.add(ADSContext.getAdministrationSuffixDN());
|
uData.setBaseDNs(baseDNs);
|
}
|
}
|
|
TopologyCache cache1 = null;
|
TopologyCache cache2 = null;
|
try
|
{
|
if (adsCtx1.hasAdminData())
|
{
|
cache1 = new TopologyCache(adsCtx1, getTrustManager());
|
cache1.reloadTopology();
|
usedReplicationServerIds.addAll(getReplicationServerIds(cache1));
|
}
|
|
if (adsCtx2.hasAdminData())
|
{
|
cache2 = new TopologyCache(adsCtx2, getTrustManager());
|
cache2.reloadTopology();
|
usedReplicationServerIds.addAll(getReplicationServerIds(cache2));
|
}
|
}
|
catch (ADSContextException adce)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_READING_ADS.get(adce.getMessage()),
|
ERROR_READING_ADS, adce);
|
}
|
catch (TopologyCacheException tce)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_READING_ADS.get(tce.getMessage()),
|
ERROR_READING_TOPOLOGY_CACHE, tce);
|
}
|
|
if (!argParser.isInteractive())
|
{
|
// Inform the user of the potential errors that we found.
|
LinkedHashSet<Message> messages = new LinkedHashSet<Message>();
|
if (cache1 != null)
|
{
|
messages.addAll(getErrorMessages(cache1));
|
}
|
if (cache2 != null)
|
{
|
messages.addAll(getErrorMessages(cache2));
|
}
|
if (!messages.isEmpty())
|
{
|
printWarningMessage(
|
ERR_REPLICATION_READING_REGISTERED_SERVERS_WARNING.get(
|
Utils.getMessageFromCollection(messages,
|
Constants.LINE_SEPARATOR).toString()));
|
}
|
}
|
|
if (server1.isReplicationServer())
|
{
|
twoReplServers.add(server1.getReplicationServerHostPort());
|
usedReplicationServerIds.add(server1.getReplicationServerId());
|
}
|
else
|
{
|
twoReplServers.add(
|
ConnectionUtils.getHostName(ctx1)+":"+uData.getReplicationPort1());
|
}
|
if (server2.isReplicationServer())
|
{
|
twoReplServers.add(server2.getReplicationServerHostPort());
|
usedReplicationServerIds.add(server2.getReplicationServerId());
|
}
|
else
|
{
|
twoReplServers.add(
|
ConnectionUtils.getHostName(ctx2)+":"+uData.getReplicationPort2());
|
}
|
|
for (String baseDN : uData.getBaseDNs())
|
{
|
LinkedHashSet<String> repServersForBaseDN = new LinkedHashSet<String>();
|
repServersForBaseDN.addAll(getReplicationServers(baseDN, cache1,
|
server1));
|
repServersForBaseDN.addAll(getReplicationServers(baseDN, cache2,
|
server2));
|
repServersForBaseDN.addAll(twoReplServers);
|
hmRepServers.put(baseDN, repServersForBaseDN);
|
|
Set<Integer> ids = new HashSet<Integer>();
|
ids.addAll(getReplicationDomainIds(baseDN, server1));
|
ids.addAll(getReplicationDomainIds(baseDN, server2));
|
if (cache1 != null)
|
{
|
for (ServerDescriptor server : cache1.getServers())
|
{
|
ids.addAll(getReplicationDomainIds(baseDN, server));
|
}
|
}
|
if (cache2 != null)
|
{
|
for (ServerDescriptor server : cache2.getServers())
|
{
|
ids.addAll(getReplicationDomainIds(baseDN, server));
|
}
|
}
|
hmUsedReplicationDomainIds.put(baseDN, ids);
|
}
|
for (LinkedHashSet<String> v : hmRepServers.values())
|
{
|
allRepServers.addAll(v);
|
}
|
|
if (!server1.isReplicationServer())
|
{
|
try
|
{
|
configureAsReplicationServer(ctx1, uData.getReplicationPort1(),
|
allRepServers, usedReplicationServerIds);
|
}
|
catch (OpenDsException ode)
|
{
|
throw new ReplicationCliException(
|
getMessageForReplicationServerException(ode,
|
ConnectionUtils.getHostPort(ctx1)),
|
ERROR_CONFIGURING_REPLICATIONSERVER, ode);
|
}
|
}
|
if (!server2.isReplicationServer())
|
{
|
try
|
{
|
configureAsReplicationServer(ctx2, uData.getReplicationPort2(),
|
allRepServers, usedReplicationServerIds);
|
}
|
catch (OpenDsException ode)
|
{
|
throw new ReplicationCliException(
|
getMessageForReplicationServerException(ode,
|
ConnectionUtils.getHostPort(ctx1)),
|
ERROR_CONFIGURING_REPLICATIONSERVER, ode);
|
}
|
}
|
|
for (String baseDN : uData.getBaseDNs())
|
{
|
LinkedHashSet<String> repServers = hmRepServers.get(baseDN);
|
Set<Integer> usedIds = hmUsedReplicationDomainIds.get(baseDN);
|
Set<String> alreadyConfiguredServers = new HashSet<String>();
|
|
try
|
{
|
configureToReplicateBaseDN(ctx1, baseDN, repServers, usedIds);
|
}
|
catch (OpenDsException ode)
|
{
|
Message msg = getMessageForEnableException(ode,
|
ConnectionUtils.getHostPort(ctx1), baseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_ENABLING_REPLICATION_ON_BASEDN, ode);
|
}
|
alreadyConfiguredServers.add(server1.getId());
|
try
|
{
|
configureToReplicateBaseDN(ctx2, baseDN, repServers, usedIds);
|
}
|
catch (OpenDsException ode)
|
{
|
Message msg = getMessageForEnableException(ode,
|
ConnectionUtils.getHostPort(ctx2), baseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_ENABLING_REPLICATION_ON_BASEDN, ode);
|
}
|
alreadyConfiguredServers.add(server2.getId());
|
|
if (cache1 != null)
|
{
|
configureToReplicateBaseDN(baseDN, repServers, usedIds, cache1, server1,
|
alreadyConfiguredServers);
|
}
|
if (cache2 != null)
|
{
|
configureToReplicateBaseDN(baseDN, repServers, usedIds, cache2, server2,
|
alreadyConfiguredServers);
|
}
|
}
|
|
// Now that replication is configured in all servers, simply try to
|
// initialize the contents of one ADS with the other (in the case where
|
// already both servers were replicating the same ADS there is nothing to be
|
// done).
|
if ((ctxSource != null) && (ctxDestination != null))
|
{
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_ENABLE_REPLICATION_INITIALIZING_ADS.get(
|
ConnectionUtils.getHostPort(ctxDestination),
|
ConnectionUtils.getHostPort(ctxSource))));
|
|
try
|
{
|
ServerDescriptor.seedAdsTrustStore(ctxDestination,
|
adsCtxSource.getTrustedCertificates());
|
}
|
catch (Throwable t)
|
{
|
LOG.log(Level.SEVERE, "Error seeding truststores: "+t, t);
|
throw new ReplicationCliException(
|
ERR_REPLICATION_ENABLE_SEEDING_TRUSTSTORE.get(t.toString()),
|
ERROR_SEEDING_TRUSTORE, t);
|
}
|
initializeSuffix(ADSContext.getAdministrationSuffixDN(), ctxSource,
|
ctxDestination, false);
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
}
|
}
|
|
/**
|
* Updates the configuration in the server (and in other servers if
|
* they are referenced) to disable replication.
|
* @param ctx the connection to the server.
|
* @param uData the DisableReplicationUserData object containing the required
|
* parameters to update the confgiuration.
|
* @throws ReplicationCliException if there is an error.
|
*/
|
private void updateConfiguration(InitialLdapContext ctx,
|
DisableReplicationUserData uData) throws ReplicationCliException
|
{
|
ServerDescriptor server;
|
try
|
{
|
server = ServerDescriptor.createStandalone(ctx);
|
}
|
catch (NamingException ne)
|
{
|
throw new ReplicationCliException(
|
getMessageForException(ne, ConnectionUtils.getHostPort(ctx)),
|
ERROR_READING_CONFIGURATION, ne);
|
}
|
|
ADSContext adsCtx = new ADSContext(ctx);
|
|
TopologyCache cache = null;
|
// Only try to update remote server if the user provided a Global
|
// Administrator to authenticate.
|
boolean tryToUpdateRemote = uData.getAdminUid() != null;
|
try
|
{
|
if (adsCtx.hasAdminData() && tryToUpdateRemote)
|
{
|
cache = new TopologyCache(adsCtx, getTrustManager());
|
cache.reloadTopology();
|
}
|
}
|
catch (ADSContextException adce)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_READING_ADS.get(adce.getMessage()),
|
ERROR_READING_ADS, adce);
|
}
|
catch (TopologyCacheException tce)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_READING_ADS.get(tce.getMessage()),
|
ERROR_READING_TOPOLOGY_CACHE, tce);
|
}
|
if (!argParser.isInteractive())
|
{
|
// Inform the user of the potential errors that we found.
|
LinkedHashSet<Message> messages = new LinkedHashSet<Message>();
|
if (cache != null)
|
{
|
messages.addAll(getErrorMessages(cache));
|
}
|
if (!messages.isEmpty())
|
{
|
printWarningMessage(
|
ERR_REPLICATION_READING_REGISTERED_SERVERS_WARNING.get(
|
Utils.getMessageFromCollection(messages,
|
Constants.LINE_SEPARATOR).toString()));
|
}
|
}
|
|
String replicationServerHostPort = server.getReplicationServerHostPort();
|
for (String baseDN : uData.getBaseDNs())
|
{
|
try
|
{
|
deleteReplicationDomain(ctx, baseDN);
|
}
|
catch (OpenDsException ode)
|
{
|
Message msg = getMessageForDisableException(ode,
|
ConnectionUtils.getHostPort(ctx), baseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_DISABLING_REPLICATION_ON_BASEDN, ode);
|
}
|
}
|
|
if ((replicationServerHostPort != null) && (cache != null))
|
{
|
Set<ServerDescriptor> serversToUpdate =
|
new LinkedHashSet<ServerDescriptor>();
|
for (String baseDN : uData.getBaseDNs())
|
{
|
SuffixDescriptor suffix = getSuffix(baseDN, cache, server);
|
if (suffix != null)
|
{
|
for (ReplicaDescriptor replica : suffix.getReplicas())
|
{
|
serversToUpdate.add(replica.getServer());
|
}
|
}
|
}
|
String bindDn = ConnectionUtils.getBindDN(ctx);
|
String pwd = ConnectionUtils.getBindPassword(ctx);
|
for (ServerDescriptor s : serversToUpdate)
|
{
|
removeReferencesInServer(s, replicationServerHostPort, bindDn, pwd,
|
uData.getBaseDNs());
|
}
|
}
|
}
|
|
/**
|
* Retrieves all the replication servers for a given baseDN. The
|
* ServerDescriptor is used to identify the server where the suffix is
|
* defined and it cannot be null. The TopologyCache is used to retrieve
|
* replication servers defined in other replicas but not in the one we
|
* get in the ServerDescriptor.
|
* @param baseDN the base DN.
|
* @param cache the TopologyCache (might be null).
|
* @param server the ServerDescriptor.
|
* @return a Set containing the replication servers currently being used
|
* to replicate the baseDN defined in the server described by the
|
* ServerDescriptor.
|
*/
|
private LinkedHashSet<String> getReplicationServers(String baseDN,
|
TopologyCache cache, ServerDescriptor server)
|
{
|
LinkedHashSet<String> servers = new LinkedHashSet<String>();
|
for (ReplicaDescriptor replica : server.getReplicas())
|
{
|
if (Utils.areDnsEqual(replica.getSuffix().getDN(), baseDN))
|
{
|
servers.addAll(replica.getReplicationServers());
|
break;
|
}
|
}
|
if (cache != null)
|
{
|
Set<SuffixDescriptor> suffixes = cache.getSuffixes();
|
for (SuffixDescriptor suffix : suffixes)
|
{
|
if (Utils.areDnsEqual(suffix.getDN(), baseDN))
|
{
|
Set<String> s = suffix.getReplicationServers();
|
// Test that at least we share one of the replication servers.
|
// If we do: we are dealing with the same replication topology
|
// (we must consider the case of disjoint replication topologies
|
// replicating the same base DN).
|
HashSet<String> copy = new HashSet<String>(s);
|
copy.retainAll(servers);
|
if (!copy.isEmpty())
|
{
|
servers.addAll(s);
|
break;
|
}
|
}
|
}
|
}
|
return servers;
|
}
|
|
/**
|
* Retrieves the suffix in the TopologyCache for a given baseDN. The
|
* ServerDescriptor is used to identify the server where the suffix is
|
* defined.
|
* @param baseDN the base DN.
|
* @param cache the TopologyCache.
|
* @param server the ServerDescriptor.
|
* @return the suffix in the TopologyCache for a given baseDN.
|
*/
|
private SuffixDescriptor getSuffix(String baseDN, TopologyCache cache,
|
ServerDescriptor server)
|
{
|
SuffixDescriptor returnValue = null;
|
Set<String> servers = new LinkedHashSet<String>();
|
for (ReplicaDescriptor replica : server.getReplicas())
|
{
|
if (Utils.areDnsEqual(replica.getSuffix().getDN(), baseDN))
|
{
|
servers.addAll(replica.getReplicationServers());
|
break;
|
}
|
}
|
|
Set<SuffixDescriptor> suffixes = cache.getSuffixes();
|
for (SuffixDescriptor suffix : suffixes)
|
{
|
if (Utils.areDnsEqual(suffix.getDN(), baseDN))
|
{
|
Set<String> s = suffix.getReplicationServers();
|
// Test that at least we share one of the replication servers.
|
// If we do: we are dealing with the same replication topology
|
// (we must consider the case of disjoint replication topologies
|
// replicating the same base DN).
|
HashSet<String> copy = new HashSet<String>(s);
|
copy.retainAll(servers);
|
if (!copy.isEmpty())
|
{
|
returnValue = suffix;
|
break;
|
}
|
}
|
}
|
return returnValue;
|
}
|
|
/**
|
* Retrieves all the replication domain IDs for a given baseDN in the
|
* ServerDescriptor.
|
* @param baseDN the base DN.
|
* @param server the ServerDescriptor.
|
* @return a Set containing the replication domain IDs for a given baseDN in
|
* the ServerDescriptor.
|
*/
|
private Set<Integer> getReplicationDomainIds(String baseDN,
|
ServerDescriptor server)
|
{
|
Set<Integer> ids = new HashSet<Integer>();
|
for (ReplicaDescriptor replica : server.getReplicas())
|
{
|
if ((replica.isReplicated()) &&
|
Utils.areDnsEqual(replica.getSuffix().getDN(), baseDN))
|
{
|
ids.add(replica.getReplicationId());
|
break;
|
}
|
}
|
return ids;
|
}
|
|
/**
|
* Configures the server to which the provided InitialLdapContext is connected
|
* as a replication server. The replication server listens in the provided
|
* port.
|
* @param ctx the context connected to the server that we want to configure.
|
* @param replicationPort the replication port of the replication server.
|
* @param replicationServers the list of replication servers to which the
|
* replication server will communicate with.
|
* @param usedReplicationServerIds the set of replication server IDs that
|
* are already in use. The set will be updated with the replication ID
|
* that will be used by the newly configured replication server.
|
* @throws OpenDsException if there is an error updating the configuration.
|
*/
|
private void configureAsReplicationServer(InitialLdapContext ctx,
|
int replicationPort, LinkedHashSet<String> replicationServers,
|
Set<Integer> usedReplicationServerIds) throws OpenDsException
|
{
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_REPLICATION_ENABLE_CONFIGURING_REPLICATION_SERVER.get(
|
ConnectionUtils.getHostPort(ctx))));
|
|
ManagementContext mCtx = LDAPManagementContext.createFromContext(
|
JNDIDirContextAdaptor.adapt(ctx));
|
RootCfgClient root = mCtx.getRootConfiguration();
|
|
/*
|
* Configure Synchronization plugin.
|
*/
|
MultimasterSynchronizationProviderCfgClient sync = null;
|
try
|
{
|
sync = (MultimasterSynchronizationProviderCfgClient)
|
root.getSynchronizationProvider("Multimaster Synchronization");
|
}
|
catch (ManagedObjectNotFoundException monfe)
|
{
|
LOG.log(Level.INFO, "Synchronization server does not exist in "+
|
ConnectionUtils.getHostPort(ctx));
|
}
|
if (sync == null)
|
{
|
MultimasterSynchronizationProviderCfgDefn provider =
|
MultimasterSynchronizationProviderCfgDefn.getInstance();
|
sync = root.createSynchronizationProvider(provider,
|
"Multimaster Synchronization",
|
new ArrayList<DefaultBehaviorException>());
|
sync.setJavaImplementationClass(
|
org.opends.server.replication.plugin.MultimasterReplication.class.
|
getName());
|
sync.setEnabled(Boolean.TRUE);
|
}
|
else
|
{
|
if (!sync.isEnabled())
|
{
|
sync.setEnabled(Boolean.TRUE);
|
}
|
}
|
sync.commit();
|
|
/*
|
* Configure the replication server.
|
*/
|
ReplicationServerCfgClient replicationServer = null;
|
|
boolean mustCommit = false;
|
|
if (!sync.hasReplicationServer())
|
{
|
int id = InstallerHelper.getReplicationId(usedReplicationServerIds);
|
usedReplicationServerIds.add(id);
|
replicationServer = sync.createReplicationServer(
|
ReplicationServerCfgDefn.getInstance(),
|
new ArrayList<DefaultBehaviorException>());
|
replicationServer.setReplicationServerId(id);
|
replicationServer.setReplicationPort(replicationPort);
|
replicationServer.setReplicationServer(replicationServers);
|
mustCommit = true;
|
}
|
else
|
{
|
replicationServer = sync.getReplicationServer();
|
usedReplicationServerIds.add(
|
replicationServer.getReplicationServerId());
|
Set<String> servers = replicationServer.getReplicationServer();
|
if (servers == null)
|
{
|
replicationServer.setReplicationServer(servers);
|
mustCommit = true;
|
}
|
else if (!servers.equals(replicationServers))
|
{
|
replicationServers.addAll(servers);
|
replicationServer.setReplicationServer(replicationServers);
|
mustCommit = true;
|
}
|
}
|
if (mustCommit)
|
{
|
replicationServer.commit();
|
}
|
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
}
|
|
/**
|
* Returns a Set containing all the replication server ids found in the
|
* servers of a given TopologyCache object.
|
* @param cache the TopologyCache object to use.
|
* @return a Set containing all the replication server ids found in a given
|
* TopologyCache object.
|
*/
|
private Set<Integer> getReplicationServerIds(TopologyCache cache)
|
{
|
Set<Integer> ids = new HashSet<Integer>();
|
for (ServerDescriptor server : cache.getServers())
|
{
|
if (server.isReplicationServer())
|
{
|
ids.add(server.getReplicationServerId());
|
}
|
}
|
return ids;
|
}
|
|
/**
|
* Configures a replication domain for a given base DN in the server to which
|
* the provided InitialLdapContext is connected.
|
* @param ctx the context connected to the server that we want to configure.
|
* @param baseDN the base DN of the replication domain to configure.
|
* @param replicationServers the list of replication servers to which the
|
* replication domain will communicate with.
|
* @param usedReplicationDomainIds the set of replication domain IDs that
|
* are already in use. The set will be updated with the replication ID
|
* that will be used by the newly configured replication server.
|
* @throws OpenDsException if there is an error updating the configuration.
|
*/
|
private void configureToReplicateBaseDN(InitialLdapContext ctx,
|
String baseDN,
|
LinkedHashSet<String> replicationServers,
|
Set<Integer> usedReplicationDomainIds) throws OpenDsException
|
{
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_REPLICATION_ENABLE_CONFIGURING_BASEDN.get(baseDN,
|
ConnectionUtils.getHostPort(ctx))));
|
|
ManagementContext mCtx = LDAPManagementContext.createFromContext(
|
JNDIDirContextAdaptor.adapt(ctx));
|
RootCfgClient root = mCtx.getRootConfiguration();
|
|
MultimasterSynchronizationProviderCfgClient sync =
|
(MultimasterSynchronizationProviderCfgClient)
|
root.getSynchronizationProvider("Multimaster Synchronization");
|
|
String[] domainNames = sync.listMultimasterDomains();
|
if (domainNames == null)
|
{
|
domainNames = new String[]{};
|
}
|
MultimasterDomainCfgClient[] domains =
|
new MultimasterDomainCfgClient[domainNames.length];
|
for (int i=0; i<domains.length; i++)
|
{
|
domains[i] = sync.getMultimasterDomain(domainNames[i]);
|
}
|
MultimasterDomainCfgClient domain = null;
|
String domainName = null;
|
for (int i=0; i<domains.length && (domain == null); i++)
|
{
|
if (Utils.areDnsEqual(baseDN, domains[i].getReplicationDN().toString()))
|
{
|
domain = domains[i];
|
domainName = domainNames[i];
|
}
|
}
|
boolean mustCommit = false;
|
if (domain == null)
|
{
|
int domainId = InstallerHelper.getReplicationId(usedReplicationDomainIds);
|
usedReplicationDomainIds.add(domainId);
|
domainName = InstallerHelper.getDomainName(domainNames, domainId);
|
domain = sync.createMultimasterDomain(
|
MultimasterDomainCfgDefn.getInstance(), domainName,
|
new ArrayList<DefaultBehaviorException>());
|
domain.setServerId(domainId);
|
domain.setReplicationDN(DN.decode(baseDN));
|
domain.setReplicationServer(replicationServers);
|
mustCommit = true;
|
}
|
else
|
{
|
Set<String> servers = domain.getReplicationServer();
|
if (servers == null)
|
{
|
domain.setReplicationServer(servers);
|
mustCommit = true;
|
}
|
else if (!servers.equals(replicationServers))
|
{
|
replicationServers.addAll(servers);
|
domain.setReplicationServer(replicationServers);
|
mustCommit = true;
|
}
|
}
|
|
if (mustCommit)
|
{
|
domain.commit();
|
}
|
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
}
|
|
/**
|
* Configures the baseDN to replicate in all the Replicas found in a Topology
|
* Cache that are replicated with the Replica of the same base DN in the
|
* provided ServerDescriptor object.
|
* @param baseDN the base DN to replicate.
|
* @param repServers the replication servers to be defined in the domain.
|
* @param usedIds the replication domain Ids already used. This Set is
|
* updated with the new domains that are used.
|
* @param cache the TopologyCache used to retrieve the different defined
|
* replicas.
|
* @param server the ServerDescriptor that is used to identify the
|
* replication topology that we are interested at (we only update the replicas
|
* that are already replicated with this server).
|
* @param alreadyConfiguredServers the list of already configured servers. If
|
* a server is in this list no updates are performed.
|
* @throws ReplicationCliException if something goes wrong.
|
*/
|
private void configureToReplicateBaseDN(String baseDN,
|
LinkedHashSet<String> repServers, Set<Integer> usedIds,
|
TopologyCache cache, ServerDescriptor server,
|
Set<String>alreadyConfiguredServers) throws ReplicationCliException
|
{
|
SuffixDescriptor suffix = getSuffix(baseDN, cache, server);
|
if (suffix != null)
|
{
|
for (ReplicaDescriptor replica: suffix.getReplicas())
|
{
|
ServerDescriptor s = replica.getServer();
|
if (!alreadyConfiguredServers.contains(s.getId()))
|
{
|
String dn = ConnectionUtils.getBindDN(
|
cache.getAdsContext().getDirContext());
|
String pwd = ConnectionUtils.getBindPassword(
|
cache.getAdsContext().getDirContext());
|
|
ServerLoader loader = new ServerLoader(server.getAdsProperties(),
|
dn, pwd, getTrustManager());
|
InitialLdapContext ctx = null;
|
try
|
{
|
ctx = loader.createContext();
|
configureToReplicateBaseDN(ctx, baseDN, repServers, usedIds);
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = server.getHostPort(true);
|
Message msg = getMessageForException(ne, hostPort);
|
throw new ReplicationCliException(msg, ERROR_CONNECTING, ne);
|
}
|
catch (OpenDsException ode)
|
{
|
String hostPort = server.getHostPort(true);
|
Message msg = getMessageForEnableException(ode, hostPort, baseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_ENABLING_REPLICATION_ON_BASEDN, ode);
|
}
|
finally
|
{
|
if (ctx != null)
|
{
|
try
|
{
|
ctx.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
}
|
alreadyConfiguredServers.add(s.getId());
|
}
|
}
|
}
|
}
|
|
/**
|
* Returns the Map of properties to be used to update the ADS.
|
* This map uses the data provided by the user.
|
* @return the Map of properties to be used to update the ADS.
|
* This map uses the data provided by the user
|
*/
|
private Map<ADSContext.AdministratorProperty, Object>
|
getAdministratorProperties(ReplicationUserData uData)
|
{
|
Map<ADSContext.AdministratorProperty, Object> adminProperties =
|
new HashMap<ADSContext.AdministratorProperty, Object>();
|
adminProperties.put(ADSContext.AdministratorProperty.UID,
|
uData.getAdminUid());
|
adminProperties.put(ADSContext.AdministratorProperty.PASSWORD,
|
uData.getAdminPwd());
|
adminProperties.put(ADSContext.AdministratorProperty.DESCRIPTION,
|
INFO_GLOBAL_ADMINISTRATOR_DESCRIPTION.get().toString());
|
return adminProperties;
|
}
|
|
private void initializeSuffix(String baseDN, InitialLdapContext ctxSource,
|
InitialLdapContext ctxDestination, boolean displayProgress)
|
throws ReplicationCliException
|
{
|
int replicationId = -1;
|
try
|
{
|
ServerDescriptor source = ServerDescriptor.createStandalone(
|
ctxSource);
|
for (ReplicaDescriptor replica : source.getReplicas())
|
{
|
if (Utils.areDnsEqual(replica.getSuffix().getDN(), baseDN))
|
{
|
replicationId = replica.getReplicationId();
|
break;
|
}
|
}
|
}
|
catch (NamingException ne)
|
{
|
String hostPort = ConnectionUtils.getHostPort(ctxSource);
|
Message msg = getMessageForException(ne, hostPort);
|
throw new ReplicationCliException(msg, ERROR_READING_CONFIGURATION, ne);
|
}
|
|
if (replicationId == -1)
|
{
|
throw new ReplicationCliException(
|
ERR_INITIALIZING_REPLICATIONID_NOT_FOUND.get(
|
ConnectionUtils.getHostPort(ctxSource), baseDN),
|
REPLICATIONID_NOT_FOUND, null);
|
}
|
|
OfflineInstaller installer = new OfflineInstaller();
|
installer.setProgressMessageFormatter(formatter);
|
installer.addProgressUpdateListener(new ProgressUpdateListener()
|
{
|
public void progressUpdate(ProgressUpdateEvent ev)
|
{
|
Message newLogDetails = ev.getNewLogs();
|
if ((newLogDetails != null) &&
|
!newLogDetails.toString().trim().equals(""))
|
{
|
printProgressMessage(newLogDetails);
|
printProgressLineBreak();
|
}
|
}
|
});
|
int nTries = 5;
|
boolean initDone = false;
|
while (!initDone)
|
{
|
try
|
{
|
installer.initializeSuffix(ctxDestination, replicationId, baseDN,
|
displayProgress, ConnectionUtils.getHostPort(ctxSource));
|
initDone = true;
|
}
|
catch (PeerNotFoundException pnfe)
|
{
|
LOG.log(Level.INFO, "Peer could not be found");
|
if (nTries == 1)
|
{
|
throw new ReplicationCliException(
|
ERR_REPLICATION_INITIALIZING_TRIES_COMPLETED.get(
|
pnfe.getMessageObject().toString()),
|
INITIALIZING_TRIES_COMPLETED, pnfe);
|
}
|
try
|
{
|
Thread.sleep((5 - nTries) * 3000);
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
catch (ApplicationException ae)
|
{
|
throw new ReplicationCliException(ae.getMessageObject(),
|
ERROR_INITIALIZING_BASEDN_GENERIC, ae);
|
}
|
nTries--;
|
}
|
}
|
|
/**
|
* Returns a set of error messages encountered in the provided TopologyCache.
|
* @param cache the topology cache.
|
* @return a set of error messages encountered in the provided TopologyCache.
|
*/
|
private LinkedHashSet<Message> getErrorMessages(TopologyCache cache)
|
{
|
Set<TopologyCacheException> exceptions =
|
new HashSet<TopologyCacheException>();
|
Set<ServerDescriptor> servers = cache.getServers();
|
LinkedHashSet<Message> exceptionMsgs = new LinkedHashSet<Message>();
|
for (ServerDescriptor server : servers)
|
{
|
TopologyCacheException e = server.getLastException();
|
if (e != null)
|
{
|
exceptions.add(e);
|
}
|
}
|
/* Check the exceptions and see if we throw them or not. */
|
for (TopologyCacheException e : exceptions)
|
{
|
switch (e.getType())
|
{
|
case NOT_GLOBAL_ADMINISTRATOR:
|
exceptionMsgs.add(INFO_NOT_GLOBAL_ADMINISTRATOR_PROVIDED.get());
|
|
break;
|
case GENERIC_CREATING_CONNECTION:
|
if ((e.getCause() != null) &&
|
Utils.isCertificateException(e.getCause()))
|
{
|
exceptionMsgs.add(
|
INFO_ERROR_READING_CONFIG_LDAP_CERTIFICATE_SERVER.get(
|
e.getHostPort(), e.getCause().getMessage()));
|
}
|
else
|
{
|
exceptionMsgs.add(Utils.getMessage(e));
|
}
|
break;
|
default:
|
exceptionMsgs.add(Utils.getMessage(e));
|
}
|
}
|
return exceptionMsgs;
|
}
|
|
/**
|
* Removes the references to a replication server in the base DNs of a
|
* given server.
|
* @param server the server that we want to update.
|
* @param replicationServer the replication server whose references we want
|
* to remove.
|
* @param bindDn the bindDn that must be used to log to the server.
|
* @param pwd the password that must be used to log to the server.
|
* @param baseDNs the list of base DNs where we want to remove the references
|
* to the provided replication server.
|
* @throws ReplicationCliException if there is an error updating the
|
* configuration.
|
*/
|
private void removeReferencesInServer(ServerDescriptor server,
|
String replicationServer, String bindDn, String pwd,
|
Collection<String> baseDNs)
|
throws ReplicationCliException
|
{
|
ServerLoader loader = new ServerLoader(server.getAdsProperties(), bindDn,
|
pwd, getTrustManager());
|
InitialLdapContext ctx = null;
|
String lastBaseDN = null;
|
String hostPort = null;
|
try
|
{
|
ctx = loader.createContext();
|
hostPort = ConnectionUtils.getHostPort(ctx);
|
ManagementContext mCtx = LDAPManagementContext.createFromContext(
|
JNDIDirContextAdaptor.adapt(ctx));
|
RootCfgClient root = mCtx.getRootConfiguration();
|
MultimasterSynchronizationProviderCfgClient sync = null;
|
try
|
{
|
sync = (MultimasterSynchronizationProviderCfgClient)
|
root.getSynchronizationProvider("Multimaster Synchronization");
|
}
|
catch (ManagedObjectNotFoundException monfe)
|
{
|
// It does not exist.
|
LOG.log(Level.INFO, "No synchronization found on "+ hostPort +".",
|
monfe);
|
}
|
if (sync != null)
|
{
|
String[] domainNames = sync.listMultimasterDomains();
|
if (domainNames != null)
|
{
|
for (int i=0; i<domainNames.length; i++)
|
{
|
MultimasterDomainCfgClient domain =
|
sync.getMultimasterDomain(domainNames[i]);
|
for (String baseDN : baseDNs)
|
{
|
lastBaseDN = baseDN;
|
if (Utils.areDnsEqual(domain.getReplicationDN().toString(),
|
baseDN))
|
{
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_REPLICATION_REMOVING_REFERENCES_ON_REMOTE.get(baseDN,
|
hostPort)));
|
Set<String> replServers = domain.getReplicationServer();
|
if (replServers != null)
|
{
|
String replServer = null;
|
for (String o : replServers)
|
{
|
if (replicationServer.equalsIgnoreCase(o))
|
{
|
replServer = o;
|
break;
|
}
|
}
|
if (replServer != null)
|
{
|
LOG.log(Level.INFO, "Updating references in domain " +
|
domain.getReplicationDN()+" on " + hostPort + ".");
|
replServers.remove(replServer);
|
if (replServers.size() > 0)
|
{
|
domain.setReplicationServer(replServers);
|
domain.commit();
|
}
|
else
|
{
|
sync.removeMultimasterDomain(domainNames[i]);
|
sync.commit();
|
}
|
}
|
}
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
}
|
}
|
}
|
}
|
}
|
}
|
catch (NamingException ne)
|
{
|
hostPort = server.getHostPort(true);
|
Message msg = getMessageForException(ne, hostPort);
|
throw new ReplicationCliException(msg, ERROR_CONNECTING, ne);
|
}
|
catch (OpenDsException ode)
|
{
|
if (lastBaseDN != null)
|
{
|
Message msg = getMessageForDisableException(ode, hostPort, lastBaseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_DISABLING_REPLICATION_REMOVE_REFERENCE_ON_BASEDN, ode);
|
}
|
else
|
{
|
Message msg = ERR_REPLICATION_ERROR_READING_CONFIGURATION.get(hostPort,
|
ode.getMessage());
|
throw new ReplicationCliException(msg, ERROR_CONNECTING, ode);
|
}
|
}
|
finally
|
{
|
if (ctx != null)
|
{
|
try
|
{
|
ctx.close();
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
}
|
}
|
|
/**
|
* Deletes a replication domain in a server for a given base DN (disable
|
* replication of the base DN).
|
* @param ctx the connection to the server.
|
* @param baseDN the base DN of the replication domain that we want to
|
* delete.
|
* @throws ReplicationCliException if there is an error updating the
|
* configuration of the server.
|
*/
|
private void deleteReplicationDomain(InitialLdapContext ctx,
|
String baseDN) throws ReplicationCliException
|
{
|
String hostPort = ConnectionUtils.getHostPort(ctx);
|
try
|
{
|
ManagementContext mCtx = LDAPManagementContext.createFromContext(
|
JNDIDirContextAdaptor.adapt(ctx));
|
RootCfgClient root = mCtx.getRootConfiguration();
|
MultimasterSynchronizationProviderCfgClient sync = null;
|
try
|
{
|
sync = (MultimasterSynchronizationProviderCfgClient)
|
root.getSynchronizationProvider("Multimaster Synchronization");
|
}
|
catch (ManagedObjectNotFoundException monfe)
|
{
|
// It does not exist.
|
LOG.log(Level.INFO, "No synchronization found on "+ hostPort +".",
|
monfe);
|
}
|
if (sync != null)
|
{
|
String[] domainNames = sync.listMultimasterDomains();
|
if (domainNames != null)
|
{
|
for (int i=0; i<domainNames.length; i++)
|
{
|
MultimasterDomainCfgClient domain =
|
sync.getMultimasterDomain(domainNames[i]);
|
if (Utils.areDnsEqual(domain.getReplicationDN().toString(), baseDN))
|
{
|
printProgressMessage(formatter.getFormattedWithPoints(
|
INFO_REPLICATION_DISABLING_BASEDN.get(baseDN,
|
hostPort)));
|
sync.removeMultimasterDomain(domainNames[i]);
|
sync.commit();
|
|
printProgressMessage(formatter.getFormattedDone());
|
printProgressMessage(formatter.getLineBreak());
|
}
|
}
|
}
|
}
|
}
|
catch (OpenDsException ode)
|
{
|
Message msg = getMessageForDisableException(ode, hostPort, baseDN);
|
throw new ReplicationCliException(msg,
|
ERROR_DISABLING_REPLICATION_REMOVE_REFERENCE_ON_BASEDN, ode);
|
}
|
}
|
|
/**
|
* Returns a message object for the given NamingException.
|
* @param ne the NamingException.
|
* @param hostPort the hostPort representation of the server we were
|
* contacting when the NamingException occurred.
|
* @return a message object for the given NamingException.
|
*/
|
private Message getMessageForException(NamingException ne, String hostPort)
|
{
|
Message msg;
|
if (Utils.isCertificateException(ne))
|
{
|
msg = INFO_ERROR_READING_CONFIG_LDAP_CERTIFICATE_SERVER.get(
|
hostPort, ne.toString());
|
}
|
else
|
{
|
msg = INFO_CANNOT_CONNECT_TO_REMOTE_GENERIC.get(
|
hostPort, ne.toString());
|
}
|
return msg;
|
}
|
|
/**
|
* Returns a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring the replication server.
|
* @param ode the OpenDsException.
|
* @param hostPort the hostPort representation of the server we were
|
* contacting when the OpenDsException occurred.
|
* @return a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring the replication server.
|
*/
|
private Message getMessageForReplicationServerException(OpenDsException ode,
|
String hostPort)
|
{
|
return ERR_REPLICATION_CONFIGURING_REPLICATIONSERVER.get(hostPort);
|
}
|
|
/**
|
* Returns a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring some replication domain (creating
|
* the replication domain or updating the list of replication servers of
|
* the replication domain).
|
* @param ode the OpenDsException.
|
* @param hostPort the hostPort representation of the server we were
|
* contacting when the OpenDsException occurred.
|
* @return a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring some replication domain (creating
|
* the replication domain or updating the list of replication servers of
|
* the replication domain).
|
*/
|
private Message getMessageForEnableException(OpenDsException ode,
|
String hostPort, String baseDN)
|
{
|
return ERR_REPLICATION_CONFIGURING_BASEDN.get(baseDN, hostPort);
|
}
|
|
/**
|
* Returns a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring some replication domain (deleting
|
* the replication domain or updating the list of replication servers of
|
* the replication domain).
|
* @param ode the OpenDsException.
|
* @param hostPort the hostPort representation of the server we were
|
* contacting when the OpenDsException occurred.
|
* @return a message for a given OpenDsException (we assume that was an
|
* exception generated updating the configuration of the server) that
|
* occurred when we were configuring some replication domain (deleting
|
* the replication domain or updating the list of replication servers of
|
* the replication domain).
|
*/
|
private Message getMessageForDisableException(OpenDsException ode,
|
String hostPort, String baseDN)
|
{
|
return ERR_REPLICATION_CONFIGURING_BASEDN.get(baseDN, hostPort);
|
}
|
|
/**
|
* Asks the user to provide the global administrator UID or the bindDN to
|
* be used to bind to the server and disable replication.
|
* @param defaultValue the default value to be proposed.
|
* @return the UID or DN provided by the user.
|
*/
|
private String askForBindDnDisable(String defaultValue)
|
{
|
return promptForString(INFO_REPLICATION_DISABLE_BINDDN_PROMPT.get(),
|
defaultValue, false);
|
}
|
|
/**
|
* Asks the user to provide the password to be used to bind to the server and
|
* disable replication.
|
* @param userId the user we are asking the password for.
|
* @return the password provided by the user.
|
*/
|
private String askForPasswordDisable(String userId)
|
{
|
return promptForPassword(INFO_REPLICATION_DISABLE_PASSWORD_PROMPT.get(
|
userId));
|
}
|
|
/**
|
* REturns a message informing the user that the provided port cannot be used.
|
* @param port the port that cannot be used.
|
* @return a message informing the user that the provided port cannot be used.
|
*/
|
private Message getCannotBindToPortError(int port)
|
{
|
Message message;
|
if (SetupUtils.isPriviledgedPort(port))
|
{
|
message = ERR_INSTALLDS_CANNOT_BIND_TO_PRIVILEGED_PORT.get(port);
|
}
|
else
|
{
|
message = ERR_INSTALLDS_CANNOT_BIND_TO_PORT.get(port);
|
}
|
return message;
|
}
|
}
|
