/*
|
* 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 2006-2007 Sun Microsystems, Inc.
|
*/
|
|
package org.opends.statuspanel;
|
|
import java.awt.event.WindowAdapter;
|
import java.awt.event.WindowEvent;
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.util.ArrayList;
|
import java.util.Map;
|
|
import javax.swing.SwingUtilities;
|
|
import org.opends.server.core.DirectoryServer;
|
|
import org.opends.quicksetup.CurrentInstallStatus;
|
import org.opends.quicksetup.ui.UIFactory;
|
import org.opends.quicksetup.util.BackgroundTask;
|
import org.opends.quicksetup.util.HtmlProgressMessageFormatter;
|
import org.opends.quicksetup.util.Utils;
|
|
import org.opends.statuspanel.event.ServerStatusChangeEvent;
|
import org.opends.statuspanel.event.ServerStatusChangeListener;
|
import org.opends.statuspanel.event.StatusPanelButtonListener;
|
import org.opends.statuspanel.i18n.ResourceProvider;
|
import org.opends.statuspanel.ui.LoginDialog;
|
import org.opends.statuspanel.ui.ProgressDialog;
|
import org.opends.statuspanel.ui.StatusPanelDialog;
|
|
/**
|
* This is the main class of the status panel.
|
*
|
* It is in charge of all the logic behind the displaying of the dialogs and
|
* the one that initializes everything. This is also the class that ultimately
|
* listens to user events (notably button clicks) and executes the associated
|
* operations with these user events.
|
*
|
*/
|
public class StatusPanelController implements ServerStatusChangeListener,
|
StatusPanelButtonListener
|
{
|
private LoginDialog loginDialog;
|
private StatusPanelDialog controlPanelDialog;
|
private ProgressDialog progressDialog;
|
private ServerStatusPooler serverStatusPooler;
|
private HtmlProgressMessageFormatter formatter =
|
new HtmlProgressMessageFormatter();
|
|
private boolean isStarting;
|
private boolean isStopping;
|
private boolean isRestarting;
|
|
private boolean mustDisplayAuthenticateDialog;
|
|
private ServerStatusDescriptor desc;
|
|
private String lastDetail;
|
private String lastSummary;
|
|
private Thread progressUpdater;
|
|
//Update period of the progress dialog.
|
private static final int UPDATE_PERIOD = 500;
|
|
/**
|
* This method creates the control panel dialogs and to check the current
|
* install status. This method must be called outside the event thread because
|
* it can perform long operations which can make the user think that the UI is
|
* blocked.
|
*
|
* Note that there is no synchronization code between threads. The
|
* synchronization code is not required as all the start/stop/restart actions
|
* are launched in the event thread so just using booleans that are updated
|
* in the event thread is enough to guarantee that there are no multiple
|
* operations launched at the same time.
|
*
|
* @param args for the moment this parameter is not used but we keep it in
|
* order to (in case of need) pass parameters through the command line.
|
*/
|
public void initialize(String[] args)
|
{
|
DirectoryServer.bootstrapClient();
|
initLookAndFeel();
|
/* Call this methods to create the dialogs (the control panel dialog
|
* is generated when we call getLoginDialog()). */
|
getLoginDialog();
|
getProgressDialog();
|
serverStatusPooler = new ServerStatusPooler();
|
serverStatusPooler.addServerStatusChangeListener(this);
|
serverStatusPooler.startPooling();
|
desc = serverStatusPooler.getLastDescriptor();
|
while (desc == null)
|
{
|
try
|
{
|
Thread.sleep(100);
|
}
|
catch (Exception ex)
|
{
|
}
|
desc = serverStatusPooler.getLastDescriptor();
|
}
|
}
|
|
/**
|
* This method displays the required dialog. This method must be called from
|
* the event thread.
|
*/
|
public void display()
|
{
|
getStatusPanelDialog().packAndShow();
|
if (!isAuthenticated())
|
{
|
if (desc.getStatus() == ServerStatusDescriptor.ServerStatus.STARTED)
|
{
|
authenticateClicked();
|
}
|
}
|
}
|
|
/**
|
* ServerStatusChangeListener implementation. This method is called when
|
* a new ServerStatusDescriptor has been generated by the ServerStatusPooler.
|
* @param ev the event we receive.
|
*/
|
public void statusChanged(final ServerStatusChangeEvent ev)
|
{
|
/* Here we assume that this events are not very frequent (not frequent
|
* at least to generate flickering). This is acceptable since the
|
* ServerStatusPooler does pooling every second.
|
*/
|
if (SwingUtilities.isEventDispatchThread())
|
{
|
getStatusPanelDialog().updateContents(ev.getStatusDescriptor());
|
}
|
else
|
{
|
SwingUtilities.invokeLater(new Runnable()
|
{
|
public void run()
|
{
|
getStatusPanelDialog().updateContents(ev.getStatusDescriptor());
|
}
|
});
|
}
|
}
|
|
/**
|
* Method called when user clicks on Quit button.
|
* StatusPanelButtonListener implementation.
|
*/
|
public void quitClicked()
|
{
|
System.exit(0);
|
}
|
|
/**
|
* Method called when user clicks on Start button.
|
* StatusPanelButtonListener implementation.
|
*/
|
public void startClicked()
|
{
|
if (isStarting)
|
{
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().setVisible(true);
|
}
|
}
|
else if (isStopping)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else if (isRestarting)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else
|
{
|
isStarting = true;
|
lastDetail = null;
|
getProgressDialog().setSummary(
|
getFormattedSummary(getMsg("summary-starting")));
|
getProgressDialog().setDetails("");
|
serverStatusPooler.beginServerStart();
|
getProgressDialog().setCloseButtonEnabled(false);
|
getStatusPanelDialog().setStartButtonEnabled(false);
|
getStatusPanelDialog().setStopButtonEnabled(false);
|
getStatusPanelDialog().setRestartButtonEnabled(false);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(false);
|
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().pack();
|
Utils.centerOnComponent(getProgressDialog(), getStatusPanelDialog());
|
getProgressDialog().setVisible(true);
|
}
|
|
BackgroundTask task = new BackgroundTask()
|
{
|
public Object processBackgroundTask()
|
{
|
if (progressUpdater == null)
|
{
|
runProgressUpdater();
|
}
|
mustDisplayAuthenticateDialog = startServer() && !isAuthenticated();
|
serverStatusPooler.endServerStart();
|
return null;
|
}
|
public void backgroundTaskCompleted(Object value, Throwable t)
|
{
|
if (t != null)
|
{
|
// Bug
|
t.printStackTrace();
|
}
|
getStatusPanelDialog().setStartButtonEnabled(true);
|
getStatusPanelDialog().setStopButtonEnabled(true);
|
getStatusPanelDialog().setRestartButtonEnabled(true);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(
|
!isAuthenticated());
|
getProgressDialog().setCloseButtonEnabled(true);
|
isStarting = false;
|
}
|
};
|
task.startBackgroundTask();
|
}
|
}
|
|
/**
|
* Method called when user clicks on Stop button.
|
* StatusPanelButtonListener implementation.
|
*/
|
public void stopClicked()
|
{
|
if (isStopping)
|
{
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().setVisible(true);
|
}
|
}
|
else if (isStarting)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else if (isRestarting)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else
|
{
|
boolean stopServer = confirmStop();
|
|
if (stopServer)
|
{
|
isStopping = true;
|
lastDetail = null;
|
getProgressDialog().setSummary(
|
getFormattedSummary(getMsg("summary-stopping")));
|
getProgressDialog().setDetails("");
|
serverStatusPooler.beginServerStop();
|
getProgressDialog().setCloseButtonEnabled(false);
|
getStatusPanelDialog().setStartButtonEnabled(false);
|
getStatusPanelDialog().setStopButtonEnabled(false);
|
getStatusPanelDialog().setRestartButtonEnabled(false);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(false);
|
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().pack();
|
Utils.centerOnComponent(getProgressDialog(), getStatusPanelDialog());
|
getProgressDialog().setVisible(true);
|
}
|
|
BackgroundTask task = new BackgroundTask()
|
{
|
public Object processBackgroundTask()
|
{
|
if (progressUpdater == null)
|
{
|
runProgressUpdater();
|
}
|
stopServer();
|
serverStatusPooler.endServerStop();
|
mustDisplayAuthenticateDialog = false;
|
return null;
|
}
|
public void backgroundTaskCompleted(Object value, Throwable t)
|
{
|
if (t != null)
|
{
|
// Bug
|
t.printStackTrace();
|
}
|
getStatusPanelDialog().setStartButtonEnabled(true);
|
getStatusPanelDialog().setStopButtonEnabled(true);
|
getStatusPanelDialog().setRestartButtonEnabled(true);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(false);
|
getProgressDialog().setCloseButtonEnabled(true);
|
isStopping = false;
|
}
|
};
|
task.startBackgroundTask();
|
}
|
}
|
}
|
|
/**
|
* Method called when user clicks on Restart button.
|
* StatusPanelButtonListener implementation.
|
*/
|
public void restartClicked()
|
{
|
if (isRestarting)
|
{
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().setVisible(true);
|
}
|
}
|
else if (isStopping)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else if (isStarting)
|
{
|
/* Should not happen */
|
Thread.dumpStack();
|
}
|
else
|
{
|
boolean restartServer = confirmRestart();
|
|
if (restartServer)
|
{
|
isRestarting = true;
|
lastDetail = null;
|
getProgressDialog().setSummary(
|
getFormattedSummary(getMsg("summary-stopping")));
|
getProgressDialog().setDetails("");
|
serverStatusPooler.beginServerStop();
|
getProgressDialog().setCloseButtonEnabled(false);
|
getStatusPanelDialog().setStartButtonEnabled(false);
|
getStatusPanelDialog().setStopButtonEnabled(false);
|
getStatusPanelDialog().setRestartButtonEnabled(false);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(false);
|
|
if (!getProgressDialog().isVisible())
|
{
|
getProgressDialog().pack();
|
Utils.centerOnComponent(getProgressDialog(), getStatusPanelDialog());
|
getProgressDialog().setVisible(true);
|
}
|
|
BackgroundTask task = new BackgroundTask()
|
{
|
public Object processBackgroundTask()
|
{
|
if (progressUpdater == null)
|
{
|
runProgressUpdater();
|
}
|
if (stopServer())
|
{
|
serverStatusPooler.endServerStop();
|
serverStatusPooler.beginServerStart();
|
mustDisplayAuthenticateDialog = startServer() &&
|
!isAuthenticated();
|
serverStatusPooler.endServerStart();
|
}
|
else
|
{
|
serverStatusPooler.endServerStop();
|
mustDisplayAuthenticateDialog = false;
|
}
|
return null;
|
}
|
public void backgroundTaskCompleted(Object value, Throwable t)
|
{
|
if (t != null)
|
{
|
// Bug
|
t.printStackTrace();
|
}
|
getStatusPanelDialog().setStartButtonEnabled(true);
|
getStatusPanelDialog().setStopButtonEnabled(true);
|
getStatusPanelDialog().setRestartButtonEnabled(true);
|
getStatusPanelDialog().setAuthenticateButtonEnabled(
|
!isAuthenticated());
|
getProgressDialog().setCloseButtonEnabled(true);
|
isRestarting = false;
|
}
|
};
|
task.startBackgroundTask();
|
}
|
}
|
}
|
|
/**
|
* Method called when user clicks on Authenticate button.
|
* StatusPanelButtonListener implementation.
|
*/
|
public void authenticateClicked()
|
{
|
getLoginDialog().pack();
|
Utils.centerOnComponent(getLoginDialog(), getStatusPanelDialog());
|
getLoginDialog().setVisible(true);
|
if (!getLoginDialog().isCancelled())
|
{
|
serverStatusPooler.setAuthentication(
|
getLoginDialog().getDirectoryManagerDn(),
|
getLoginDialog().getDirectoryManagerPwd());
|
}
|
}
|
|
/**
|
* A method to initialize the look and feel.
|
*
|
*/
|
private void initLookAndFeel()
|
{
|
UIFactory.initialize();
|
}
|
|
/**
|
* Returns the login dialog and creates it if it does not exist.
|
* @return the login dialog.
|
*/
|
private LoginDialog getLoginDialog()
|
{
|
if (loginDialog == null)
|
{
|
loginDialog = new LoginDialog(getStatusPanelDialog());
|
loginDialog.setModal(true);
|
}
|
return loginDialog;
|
}
|
|
/**
|
* Returns the progress dialog and creates it if it does not exist.
|
* As we only can run an operation at a time (considering the nature of the
|
* operations we provide today) having a single progress dialog is enough.
|
* @return the progress dialog.
|
*/
|
private ProgressDialog getProgressDialog()
|
{
|
if (progressDialog == null)
|
{
|
progressDialog = new ProgressDialog(getStatusPanelDialog());
|
progressDialog.addWindowListener(new WindowAdapter()
|
{
|
public void windowClosed(WindowEvent ev)
|
{
|
if (mustDisplayAuthenticateDialog)
|
{
|
mustDisplayAuthenticateDialog = false;
|
authenticateClicked();
|
}
|
}
|
});
|
}
|
return progressDialog;
|
}
|
|
/**
|
* Returns the status panel dialog and creates it if it does not exist. This
|
* is the dialog that displays the status information to the user.
|
* @return the status panel dialog.
|
*/
|
private StatusPanelDialog getStatusPanelDialog()
|
{
|
if (controlPanelDialog == null)
|
{
|
controlPanelDialog = new StatusPanelDialog();
|
controlPanelDialog.addButtonListener(this);
|
}
|
return controlPanelDialog;
|
}
|
|
/**
|
* This methods starts the server and updates the progress with the start
|
* messages.
|
* @return <CODE>true</CODE> if the server started successfully and
|
* <CODE>false</CODE> otherwise.
|
*/
|
protected boolean startServer()
|
{
|
boolean started = false;
|
|
if (isRestarting)
|
{
|
updateProgress(
|
getFormattedSummary(getMsg("summary-starting")),
|
getTaskSeparator());
|
}
|
updateProgress(
|
getFormattedSummary(getMsg("summary-starting")),
|
getFormattedProgress(getMsg("progress-starting")) + getLineBreak());
|
|
ArrayList<String> argList = new ArrayList<String>();
|
|
if (Utils.isWindows())
|
{
|
argList.add(Utils.getPath(getBinariesPath(), "start-ds.bat"));
|
} else
|
{
|
argList.add(Utils.getPath(getBinariesPath(), "start-ds"));
|
}
|
|
String[] args = new String[argList.size()];
|
argList.toArray(args);
|
ProcessBuilder pb = new ProcessBuilder(args);
|
Map<String, String> env = pb.environment();
|
env.put("JAVA_HOME", System.getProperty("java.home"));
|
/* Remove JAVA_BIN to be sure that we use the JVM running the installer
|
* JVM to start the server.
|
*/
|
env.remove("JAVA_BIN");
|
|
try
|
{
|
Process process = pb.start();
|
|
BufferedReader err =
|
new BufferedReader(new InputStreamReader(process.getErrorStream()));
|
BufferedReader out =
|
new BufferedReader(new InputStreamReader(process.getInputStream()));
|
|
/* Create these objects to resend the stop process output to the details
|
* area.
|
*/
|
new ProgressReader(err, true, true);
|
new ProgressReader(out, false, true);
|
|
int returnValue = process.waitFor();
|
|
if (returnValue == 0)
|
{
|
/*
|
* There are no exceptions from the readers and they are marked as
|
* finished. This means that the server has written in its output the
|
* message id informing that it started. So it seems that everything
|
* went fine.
|
*
|
* However we can have issues with the firewalls or do not have rights
|
* to connect. Just check if we can connect to the server.
|
* Try 5 times with an interval of 1 second between try.
|
*/
|
boolean running = false;
|
for (int i=0; i<5 && !running; i++)
|
{
|
running = CurrentInstallStatus.isServerRunning();
|
}
|
|
if (!running)
|
{
|
try
|
{
|
Thread.sleep(1000);
|
}
|
catch (Throwable t)
|
{
|
}
|
}
|
if (!running)
|
{
|
updateProgress(getFormattedError(getMsg("summary-start-error")),
|
getFormattedError(getMsg("error-starting-server-generic"),
|
true));
|
}
|
else
|
{
|
updateProgress(
|
getFormattedSuccess(getMsg("summary-start-success")),
|
"");
|
started = true;
|
}
|
}
|
else
|
{
|
String[] arg = {String.valueOf(returnValue)};
|
String msg = getMsg("error-starting-server-code", arg);
|
|
/*
|
* The return code is not the one expected, assume the server could
|
* not be started.
|
*/
|
updateProgress(
|
getFormattedError(getMsg("summary-start-error")),
|
msg);
|
}
|
|
} catch (IOException ioe)
|
{
|
String msg = getThrowableMsg("error-starting-server", ioe);
|
updateProgress(
|
getFormattedError(getMsg("summary-start-error")),
|
msg);
|
}
|
catch (InterruptedException ie)
|
{
|
String msg = getThrowableMsg("error-starting-server", ie);
|
updateProgress(
|
getFormattedError(getMsg("summary-start-error")),
|
msg);
|
}
|
|
return started;
|
}
|
|
/**
|
* This methods stops the server and updates the progress with the stop
|
* messages.
|
* @return <CODE>true</CODE> if the server stopped successfully and
|
* <CODE>false</CODE> otherwise.
|
*/
|
private boolean stopServer()
|
{
|
boolean stopped = false;
|
updateProgress(
|
getFormattedSummary(getMsg("summary-stopping")),
|
getFormattedProgress(getMsg("progress-stopping")) + getLineBreak());
|
|
ArrayList<String> argList = new ArrayList<String>();
|
|
if (Utils.isWindows())
|
{
|
argList.add(Utils.getPath(getBinariesPath(),
|
Utils.getWindowsStopFileName()));
|
} else
|
{
|
argList.add(Utils.getPath(getBinariesPath(),
|
Utils.getUnixStopFileName()));
|
}
|
String[] args = new String[argList.size()];
|
argList.toArray(args);
|
ProcessBuilder pb = new ProcessBuilder(args);
|
Map<String, String> env = pb.environment();
|
env.put("JAVA_HOME", System.getProperty("java.home"));
|
/* Remove JAVA_BIN to be sure that we use the JVM running the uninstaller
|
* JVM to stop the server.
|
*/
|
env.remove("JAVA_BIN");
|
|
try
|
{
|
Process process = pb.start();
|
|
BufferedReader err =
|
new BufferedReader(new InputStreamReader(process.getErrorStream()));
|
BufferedReader out =
|
new BufferedReader(new InputStreamReader(process.getInputStream()));
|
|
/* Create these objects to resend the stop process output to the details
|
* area.
|
*/
|
new ProgressReader(err, true, false);
|
new ProgressReader(out, false, false);
|
|
int returnValue = process.waitFor();
|
|
int clientSideError =
|
org.opends.server.protocols.ldap.LDAPResultCode.CLIENT_SIDE_CONNECT_ERROR;
|
if ((returnValue == clientSideError) || (returnValue == 0))
|
{
|
if (Utils.isWindows())
|
{
|
/*
|
* Sometimes the server keeps some locks on the files.
|
* TODO: remove this code once stop-ds returns properly when server
|
* is stopped.
|
*/
|
int nTries = 10;
|
for (int i=0; i<nTries && !stopped; i++)
|
{
|
stopped = !CurrentInstallStatus.isServerRunning();
|
if (!stopped)
|
{
|
String msg =
|
getFormattedLog(getMsg("progress-server-waiting-to-stop"))+
|
getLineBreak();
|
updateProgress(
|
getFormattedSummary(getMsg("summary-stopping")),
|
msg);
|
try
|
{
|
Thread.sleep(5000);
|
}
|
catch (Exception ex)
|
{
|
|
}
|
}
|
}
|
if (!stopped)
|
{
|
returnValue = -1;
|
}
|
}
|
}
|
|
if (returnValue == clientSideError)
|
{
|
String msg = getLineBreak() +
|
getFormattedLog(getMsg("progress-server-already-stopped"))+
|
getLineBreak();
|
if (!isRestarting)
|
{
|
updateProgress(
|
getFormattedSuccess(getMsg("summary-stop-success")),
|
msg);
|
}
|
else
|
{
|
updateProgress(
|
getFormattedSummary(getMsg("summary-stop-success")),
|
msg);
|
}
|
stopped = true;
|
}
|
else if (returnValue != 0)
|
{
|
String[] arg = {String.valueOf(returnValue)};
|
String msg = getMsg("error-stopping-server-code", arg);
|
|
/*
|
* The return code is not the one expected, assume the server could
|
* not be stopped.
|
*/
|
updateProgress(
|
getFormattedError(getMsg("summary-stop-error")),
|
msg);
|
}
|
else
|
{
|
String msg = getFormattedLog(getMsg("progress-server-stopped"));
|
if (!isRestarting)
|
{
|
updateProgress(
|
getFormattedSuccess(getMsg("summary-stop-success")),
|
msg);
|
}
|
else
|
{
|
updateProgress(
|
getFormattedSummary(getMsg("summary-stop-success")),
|
msg);
|
}
|
stopped = true;
|
}
|
|
} catch (IOException ioe)
|
{
|
String msg = getThrowableMsg("error-stopping-server", ioe);
|
updateProgress(
|
getFormattedError(getMsg("summary-stop-error")),
|
msg);
|
}
|
catch (InterruptedException ie)
|
{
|
String msg = getThrowableMsg("error-stopping-server", ie);
|
updateProgress(
|
getFormattedError(getMsg("summary-stop-error")),
|
msg);
|
}
|
return stopped;
|
}
|
|
|
/**
|
* Updates the progress variables used to update the progress dialog during
|
* start/stop/restart.
|
*
|
* @param summary the summary for the start/stop/restart operation.
|
* @param newDetail the new detail for the start/stop/restart operation.
|
*/
|
private synchronized void updateProgress(final String summary,
|
final String newDetail)
|
{
|
if (lastDetail == null)
|
{
|
lastDetail = newDetail;
|
}
|
else
|
{
|
lastDetail += newDetail;
|
}
|
lastSummary = summary;
|
}
|
|
/**
|
* This method is used to update the progress dialog.
|
*
|
* We are receiving notifications from the installer and uninstaller (this
|
* class is a ProgressListener). However if we lots of notifications updating
|
* the progress panel every time we get a progress update can result of a lot
|
* of flickering. So the idea here is to have a minimal time between 2 updates
|
* of the progress dialog (specified by UPDATE_PERIOD).
|
*/
|
private void runProgressUpdater()
|
{
|
progressUpdater = new Thread()
|
{
|
public void run()
|
{
|
try
|
{
|
String lastDisplayedSummary = null;
|
String lastDisplayedDetail = null;
|
while (true)
|
{
|
if (lastSummary != null)
|
{
|
if (lastSummary != lastDisplayedSummary)
|
{
|
lastDisplayedSummary = lastSummary;
|
SwingUtilities.invokeLater(new Runnable()
|
{
|
public void run()
|
{
|
getProgressDialog().setSummary(lastSummary);
|
}
|
});
|
}
|
}
|
|
if (lastDetail != null)
|
{
|
if (lastDetail != lastDisplayedDetail)
|
{
|
lastDisplayedDetail = lastDetail;
|
SwingUtilities.invokeLater(new Runnable()
|
{
|
public void run()
|
{
|
getProgressDialog().setDetails(lastDetail);
|
}
|
});
|
}
|
}
|
|
try
|
{
|
Thread.sleep(UPDATE_PERIOD);
|
} catch (Exception ex)
|
{
|
}
|
}
|
} catch (Throwable t)
|
{
|
// Bug
|
t.printStackTrace();
|
}
|
}
|
};
|
progressUpdater.start();
|
}
|
|
/**
|
* Returns a localized message for a key value. In the properties file we
|
* have something of type:
|
* key=value
|
*
|
* @see ResourceProvider.getMsg(String key)
|
* @param key the key in the properties file.
|
* @return the value associated to the key in the properties file.
|
* properties file.
|
*/
|
private String getMsg(String key)
|
{
|
return getI18n().getMsg(key);
|
}
|
|
/**
|
* Returns a localized message for a key value. In the properties file we
|
* have something of type:
|
* key=value
|
*
|
* For instance if we pass as key "mykey" and as arguments {"value1"} and
|
* in the properties file we have:
|
* mykey=value with argument {0}.
|
*
|
* This method will return "value with argument value1".
|
* @see ResourceProvider.getMsg(String key, String[] args)
|
* @param key the key in the properties file.
|
* @param args the arguments to be passed to generate the resulting value.
|
* @return the value associated to the key in the properties file.
|
*/
|
private String getMsg(String key, String[] args)
|
{
|
return getI18n().getMsg(key, args);
|
}
|
|
/**
|
* Returns a ResourceProvider instance.
|
* @return a ResourceProvider instance.
|
*/
|
private ResourceProvider getI18n()
|
{
|
return ResourceProvider.getInstance();
|
}
|
|
/**
|
* Returns the path to the binaries.
|
* @return the path to the binaries.
|
*/
|
private String getBinariesPath()
|
{
|
return Utils.getPath(Utils.getInstallPathFromClasspath(),
|
Utils.getBinariesRelativePath());
|
}
|
|
/**
|
* Returns the formatted representation of the text that is the summary of the
|
* installation process (the one that goes in the UI next to the progress
|
* bar).
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of an error for the given text.
|
*/
|
private String getFormattedSummary(String text)
|
{
|
return formatter.getFormattedSummary(text);
|
}
|
|
/**
|
* Returns the formatted representation of a success message for a given text.
|
* @param text the source text from which we want to get the formatted
|
* representation.
|
* @return the formatted representation of an success message for the given
|
* text.
|
*/
|
private String getFormattedSuccess(String text)
|
{
|
return formatter.getFormattedSuccess(text);
|
}
|
|
/**
|
* Returns the formatted representation of an error for a given text.
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of an error for the given text.
|
*/
|
private String getFormattedError(String text)
|
{
|
return formatter.getFormattedError(text, false);
|
}
|
|
/**
|
* Returns the formatted representation of an error for a given text.
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of an error for the given text.
|
*/
|
private String getFormattedError(String text, boolean applyMargin)
|
{
|
return formatter.getFormattedError(text, applyMargin);
|
}
|
|
/**
|
* Returns the formatted representation of a log error message for a given
|
* text.
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of a log error message for the given
|
* text.
|
*/
|
private String getFormattedLogError(String text)
|
{
|
return formatter.getFormattedLogError(text);
|
}
|
|
/**
|
* Returns the formatted representation of a log message for a given text.
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of a log message for the given text.
|
*/
|
private String getFormattedLog(String text)
|
{
|
return formatter.getFormattedLog(text);
|
}
|
|
/**
|
* Returns the line break formatted.
|
* @return the line break formatted.
|
*/
|
private String getLineBreak()
|
{
|
return formatter.getLineBreak();
|
}
|
|
/**
|
* Returns the task separator formatted.
|
* @return the task separator formatted.
|
*/
|
private String getTaskSeparator()
|
{
|
return formatter.getTaskSeparator();
|
}
|
|
/**
|
* Returns the formatted representation of a progress message for a given
|
* text.
|
* @param text the source text from which we want to get the formatted
|
* representation
|
* @return the formatted representation of a progress message for the given
|
* text.
|
*/
|
private String getFormattedProgress(String text)
|
{
|
return formatter.getFormattedProgress(text);
|
}
|
|
/**
|
* Returns a localized message for a given properties key and throwable.
|
* @param key the key of the message in the properties file.
|
* @param t the throwable for which we want to get a message.
|
* @return a localized message for a given properties key and throwable.
|
*/
|
private String getThrowableMsg(String key, Throwable t)
|
{
|
return getThrowableMsg(key, null, t);
|
}
|
|
/**
|
* Returns a localized message for a given properties key and throwable.
|
* @param key the key of the message in the properties file.
|
* @param args the arguments of the message in the properties file.
|
* @param t the throwable for which we want to get a message.
|
*
|
* @return a localized message for a given properties key and throwable.
|
*/
|
private String getThrowableMsg(String key, String[] args, Throwable t)
|
{
|
return Utils.getThrowableMsg(getI18n(), key, args, t);
|
}
|
|
/**
|
* This class is used to read the standard error and standard output of the
|
* Stop/Start process.
|
*
|
* When a new log message is found notifies the progress listeners of it. If
|
* an error occurs it also notifies the listeners.
|
*
|
*/
|
private class ProgressReader
|
{
|
private boolean isFirstLine;
|
private String errorMsg;
|
|
/**
|
* The protected constructor.
|
* @param reader the BufferedReader of the stop process.
|
* @param isError a boolean indicating whether the BufferedReader
|
* corresponds to the standard error or to the standard output.
|
* @param isStart a boolean indicating whether we are starting or stopping
|
* the server.
|
*/
|
public ProgressReader(final BufferedReader reader, final boolean isError,
|
final boolean isStart)
|
{
|
final String errorTag =
|
isError ? "error-reading-erroroutput" : "error-reading-output";
|
|
isFirstLine = true;
|
|
Thread t = new Thread(new Runnable()
|
{
|
public void run()
|
{
|
try
|
{
|
String line = reader.readLine();
|
while (line != null)
|
{
|
StringBuffer buf = new StringBuffer();
|
if (!isFirstLine)
|
{
|
buf.append(formatter.getLineBreak());
|
}
|
if (isError)
|
{
|
buf.append(getFormattedLogError(line));
|
} else
|
{
|
buf.append(getFormattedLog(line));
|
}
|
String summary = isStart?
|
getFormattedSummary(getMsg("summary-starting")):
|
getFormattedSummary(getMsg("summary-stopping"));
|
updateProgress(summary, buf.toString());
|
isFirstLine = false;
|
|
line = reader.readLine();
|
}
|
} catch (IOException ioe)
|
{
|
errorMsg = getThrowableMsg(errorTag, ioe);
|
|
} catch (Throwable t)
|
{
|
errorMsg = getThrowableMsg(errorTag, t);
|
}
|
}
|
});
|
t.start();
|
}
|
|
public String getErrorMessage()
|
{
|
return errorMsg;
|
}
|
}
|
|
/**
|
* Displays a confirmation dialog asking the user whether to stop the server
|
* or not.
|
* @return <CODE>true</CODE> if the server confirms that (s)he wants to stop
|
* the server and <CODE>false</CODE> otherwise.
|
*/
|
private boolean confirmStop()
|
{
|
return Utils.displayConfirmation(getStatusPanelDialog(),
|
getMsg("confirm-stop-message"), getMsg("confirm-stop-title"));
|
}
|
|
/**
|
* Displays a confirmation dialog asking the user whether to restart the
|
* server or not.
|
* @return <CODE>true</CODE> if the server confirms that (s)he wants to
|
* restart the server and <CODE>false</CODE> otherwise.
|
*/
|
private boolean confirmRestart()
|
{
|
return Utils.displayConfirmation(getStatusPanelDialog(),
|
getMsg("confirm-restart-message"), getMsg("confirm-restart-title"));
|
}
|
|
/**
|
* Returns whether the user provided LDAP authentication or not.
|
* @return <CODE>true</CODE> if the server provided LDAP authentication and
|
* <CODE>false</CODE> otherwise.
|
*/
|
private boolean isAuthenticated()
|
{
|
return serverStatusPooler.isAuthenticated();
|
}
|
}
|
