core/org.eclipse.ptp.launch/src/org/eclipse/ptp/launch/internal/ParallelLaunchConfigurationDelegate.java - ptp/org.eclipse.ptp - Git at Google

 /*******************************************************************************
  * Copyright (c) 2005 The Regents of the University of California.
  * This material was produced under U.S. Government contract W-7405-ENG-36
  * for Los Alamos National Laboratory, which is operated by the University
  * of California for the U.S. Department of Energy. The U.S. Government has
  * rights to use, reproduce, and distribute this software. NEITHER THE
  * GOVERNMENT NOR THE UNIVERSITY MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR
  * ASSUMES ANY LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified
  * to produce derivative works, such modified software should be clearly marked,
  * so as not to confuse it with the version available from LANL.
  *
  * Additionally, this program and the accompanying materials
  * are made available under the terms of the Eclipse Public License v1.0
  * which accompanies this distribution, and is available at
  * http://www.eclipse.org/legal/epl-v10.html
  *
  * LA-CC 04-115
  *******************************************************************************/
 package org.eclipse.ptp.launch.internal;

 import java.text.MessageFormat;
 import java.util.ArrayList;
 import java.util.Arrays;

 import org.eclipse.cdt.core.IBinaryParser.IBinaryObject;
 import org.eclipse.core.runtime.CoreException;
 import org.eclipse.core.runtime.IPath;
 import org.eclipse.core.runtime.IProgressMonitor;
 import org.eclipse.core.runtime.IStatus;
 import org.eclipse.core.runtime.NullProgressMonitor;
 import org.eclipse.core.runtime.Path;
 import org.eclipse.debug.core.ILaunch;
 import org.eclipse.debug.core.ILaunchConfiguration;
 import org.eclipse.debug.core.ILaunchManager;
 import org.eclipse.jface.preference.IPreferenceStore;
 import org.eclipse.ptp.core.PTPCorePlugin;
 import org.eclipse.ptp.core.attributes.AttributeManager;
 import org.eclipse.ptp.core.attributes.StringAttribute;
 import org.eclipse.ptp.core.elements.IPJob;
 import org.eclipse.ptp.core.elements.attributes.ElementAttributes;
 import org.eclipse.ptp.core.elements.attributes.JobAttributes;
 import org.eclipse.ptp.debug.core.IAbstractDebugger;
 import org.eclipse.ptp.debug.core.IPDebugConfiguration;
 import org.eclipse.ptp.debug.core.IPDebugConstants;
 import org.eclipse.ptp.debug.core.PTPDebugCorePlugin;
 import org.eclipse.ptp.debug.core.launch.IPLaunch;
 import org.eclipse.ptp.debug.ui.IPTPDebugUIConstants;
 import org.eclipse.ptp.debug.ui.PTPDebugUIPlugin;
 import org.eclipse.ptp.launch.PTPLaunchPlugin;
 import org.eclipse.ptp.launch.internal.ui.LaunchMessages;
 import org.eclipse.swt.widgets.Display;
 import org.eclipse.ui.IWorkbenchPage;
 import org.eclipse.ui.IWorkbenchWindow;
 import org.eclipse.ui.PartInitException;
 /**
  *
  */
 public class ParallelLaunchConfigurationDelegate
 	extends AbstractParallelLaunchConfigurationDelegate {

 	/* (non-Javadoc)
 	 * @see org.eclipse.ptp.launch.internal.AbstractParallelLaunchConfigurationDelegate#doCompleteJobLaunch(org.eclipse.ptp.core.elements.IPJob)
 	 */
 	protected void doCompleteJobLaunch(ILaunchConfiguration configuration, String mode, IPLaunch launch,
 			AttributeManager mgr, IAbstractDebugger debugger, IPJob job) {
 		launch.setAttribute(ElementAttributes.getIdAttributeDefinition().getId(), job.getID());
 		if (mode.equals(ILaunchManager.DEBUG_MODE)) {
 			// show ptp debug view
 			showPTPDebugView(IPTPDebugUIConstants.ID_VIEW_PARALLELDEBUG);
 			launch.setPJob(job);
 			IBinaryObject exeFile = null;
 			try {
 				exeFile = verifyBinary(configuration);
 				setDefaultSourceLocator(launch, configuration);
 			} catch (CoreException e) {
 				//FIXME: Error dialog?
 				System.out.println("Error completing debug job launch");
 				return;
 			}
 			/*
 			 * Wait for the incoming debug server connection. This can be canceled by the user.
 			 */
 			try {
 				PTPDebugCorePlugin.getDebugModel().createDebuggerSession(debugger, launch, exeFile, new NullProgressMonitor());
 			} catch (CoreException e) {
 				//FIXME: progress monitor?
 				System.out.println("Debug server failed to connect");
 			}
 		} else {
 			new RuntimeProcess(launch, job, null);
 		}
 	}

 	/* (non-Javadoc)
 	 * @see org.eclipse.debug.core.model.ILaunchConfigurationDelegate#launch(org.eclipse.debug.core.ILaunchConfiguration, java.lang.String, org.eclipse.debug.core.ILaunch, org.eclipse.core.runtime.IProgressMonitor)
 	 */
 	public void launch(ILaunchConfiguration configuration, String mode, ILaunch launch,
 			IProgressMonitor monitor) throws CoreException {
 		if (!(launch instanceof IPLaunch)) {
 			abort(LaunchMessages.getResourceString("ParallelLaunchConfigurationDelegate.Invalid_launch_object"), null, 0);
 		}
 		if (monitor == null) {
 			monitor = new NullProgressMonitor();
 		}
 		monitor.beginTask("", 250);
 		monitor.setTaskName(MessageFormat.format("{0} . . .", new Object[] { "Launching " + configuration.getName() }));
 		if (monitor.isCanceled()) {
 			return;
 		}
 		IAbstractDebugger debugger = null;
 		IPJob job = null;

 		AttributeManager attrManager = getAttributeManager(configuration);

 		try {
 			IPreferenceStore store = PTPDebugUIPlugin.getDefault().getPreferenceStore();
 			if (mode.equals(ILaunchManager.DEBUG_MODE)) {
 				monitor.subTask("Configuring debug setting . . .");

 				String dbgFile = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_FILE);

 				ArrayList<String> dbgArgs = new ArrayList<String>();

 				dbgArgs.add("--host=" + store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_HOST));
 				dbgArgs.add("--debugger=" + store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_BACKEND));

 				String dbgPath = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_BACKEND_PATH);
 				if (dbgPath.length() > 0) {
 					dbgArgs.add("--debugger_path=" + dbgPath);
 				}

 				String dbgExtraArgs = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_ARGS);
 				if (dbgExtraArgs.length() > 0) {
 					dbgArgs.addAll(Arrays.asList(dbgExtraArgs.split(" ")));
 				}

 				verifyDebuggerPath(dbgFile);

 				/*
 				 * Create the debugger extension, then the connection point for the debug server.
 				 * The debug server is created when the job is launched via the submitJob()
 				 * command.
 				 */
 				IPDebugConfiguration debugConfig = getDebugConfig(configuration);
 				debugger = debugConfig.createDebugger();
 				int timeout = store.getInt(IPDebugConstants.PREF_PTP_DEBUG_COMM_TIMEOUT);
 				debugger.createConnection(timeout);

 				dbgArgs.add("--port=" + debugger.getDebuggerPort());

 				// remote setting
 				String dbgExePath = getDebuggerExePath(configuration);
 				if (dbgExePath == null) {
 					dbgExePath = dbgFile;
 				}

 				IPath path = new Path(dbgExePath);
 				attrManager.addAttribute(JobAttributes.getDebuggerExecutableNameAttributeDefinition().create(path.lastSegment()));
 				attrManager.addAttribute(JobAttributes.getDebuggerExecutablePathAttributeDefinition().create(path.removeLastSegments(1).toOSString()));

 					String dbgWD = getDebuggerWorkDirectory(configuration);
 				if (dbgWD != null) {
 					StringAttribute wdAttr = (StringAttribute) attrManager.getAttribute(JobAttributes.getWorkingDirectoryAttributeDefinition());
 					if (wdAttr != null) {
 						wdAttr.setValueAsString(dbgWD);
 					} else {
 						attrManager.addAttribute(JobAttributes.getWorkingDirectoryAttributeDefinition().create(dbgWD));

 					}
 				}
 				attrManager.addAttribute(JobAttributes.getDebuggerArgumentsAttributeDefinition().create(dbgArgs.toArray(new String[0])));
 				attrManager.addAttribute(JobAttributes.getDebugFlagAttributeDefinition().create(true));
 			}

 			monitor.worked(10);
 			monitor.subTask("Submitting the job . . .");

 			submitJob(configuration, mode, (IPLaunch)launch, attrManager, debugger, monitor);

 			monitor.worked(10);
 		} catch (CoreException e) {
 			if (e.getStatus().getPlugin().equals(PTPCorePlugin.PLUGIN_ID)) {
 				String msg = e.getMessage();
 				if (msg == null)
 					msg = "";
 				else
 					msg = msg + "\n\n";
 				abort(msg + LaunchMessages.getResourceString("ParallelLaunchConfigurationDelegate.Control_system_does_not_exist"), null, 0);
 			}
 			if (mode.equals(ILaunchManager.DEBUG_MODE)) {
 				PTPDebugCorePlugin.getDebugModel().shutdownSession(job);
 				/*
 				if (debugger != null) {
 					debugger.stopDebugger();
 				}
 				*/
 			}
 			if (e.getStatus().getCode() != IStatus.CANCEL) {
 				throw e;
 			}
 		} finally {
 			monitor.done();
 		}
 	}

 	/**
 	 * @param viewID
 	 */
 	private void showPTPDebugView(final String viewID) {
 		Display display = Display.getCurrent();
 		if (display == null) {
 			display = Display.getDefault();
 		}
 		if (display != null && !display.isDisposed()) {
 			display.syncExec(new Runnable() {
 				public void run() {
 					IWorkbenchWindow window = PTPLaunchPlugin.getActiveWorkbenchWindow();
 					if (window != null) {
 						IWorkbenchPage page = window.getActivePage();
 						if (page != null) {
 							try {
 								page.showView(viewID, null, IWorkbenchPage.VIEW_CREATE);
 							} catch (PartInitException e) {}
 						}
 					}
 				}
 			});
 		}
 	}
 }
	/*******************************************************************************
	* Copyright (c) 2005 The Regents of the University of California.
	* This material was produced under U.S. Government contract W-7405-ENG-36
	* for Los Alamos National Laboratory, which is operated by the University
	* of California for the U.S. Department of Energy. The U.S. Government has
	* rights to use, reproduce, and distribute this software. NEITHER THE
	* GOVERNMENT NOR THE UNIVERSITY MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR
	* ASSUMES ANY LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified
	* to produce derivative works, such modified software should be clearly marked,
	* so as not to confuse it with the version available from LANL.
	*
	* Additionally, this program and the accompanying materials
	* are made available under the terms of the Eclipse Public License v1.0
	* which accompanies this distribution, and is available at
	* http://www.eclipse.org/legal/epl-v10.html
	*
	* LA-CC 04-115
	*******************************************************************************/
	package org.eclipse.ptp.launch.internal;

	import java.text.MessageFormat;
	import java.util.ArrayList;
	import java.util.Arrays;

	import org.eclipse.cdt.core.IBinaryParser.IBinaryObject;
	import org.eclipse.core.runtime.CoreException;
	import org.eclipse.core.runtime.IPath;
	import org.eclipse.core.runtime.IProgressMonitor;
	import org.eclipse.core.runtime.IStatus;
	import org.eclipse.core.runtime.NullProgressMonitor;
	import org.eclipse.core.runtime.Path;
	import org.eclipse.debug.core.ILaunch;
	import org.eclipse.debug.core.ILaunchConfiguration;
	import org.eclipse.debug.core.ILaunchManager;
	import org.eclipse.jface.preference.IPreferenceStore;
	import org.eclipse.ptp.core.PTPCorePlugin;
	import org.eclipse.ptp.core.attributes.AttributeManager;
	import org.eclipse.ptp.core.attributes.StringAttribute;
	import org.eclipse.ptp.core.elements.IPJob;
	import org.eclipse.ptp.core.elements.attributes.ElementAttributes;
	import org.eclipse.ptp.core.elements.attributes.JobAttributes;
	import org.eclipse.ptp.debug.core.IAbstractDebugger;
	import org.eclipse.ptp.debug.core.IPDebugConfiguration;
	import org.eclipse.ptp.debug.core.IPDebugConstants;
	import org.eclipse.ptp.debug.core.PTPDebugCorePlugin;
	import org.eclipse.ptp.debug.core.launch.IPLaunch;
	import org.eclipse.ptp.debug.ui.IPTPDebugUIConstants;
	import org.eclipse.ptp.debug.ui.PTPDebugUIPlugin;
	import org.eclipse.ptp.launch.PTPLaunchPlugin;
	import org.eclipse.ptp.launch.internal.ui.LaunchMessages;
	import org.eclipse.swt.widgets.Display;
	import org.eclipse.ui.IWorkbenchPage;
	import org.eclipse.ui.IWorkbenchWindow;
	import org.eclipse.ui.PartInitException;
	/**
	*
	*/
	public class ParallelLaunchConfigurationDelegate
	extends AbstractParallelLaunchConfigurationDelegate {

	/* (non-Javadoc)
	* @see org.eclipse.ptp.launch.internal.AbstractParallelLaunchConfigurationDelegate#doCompleteJobLaunch(org.eclipse.ptp.core.elements.IPJob)
	*/
	protected void doCompleteJobLaunch(ILaunchConfiguration configuration, String mode, IPLaunch launch,
	AttributeManager mgr, IAbstractDebugger debugger, IPJob job) {
	launch.setAttribute(ElementAttributes.getIdAttributeDefinition().getId(), job.getID());
	if (mode.equals(ILaunchManager.DEBUG_MODE)) {
	// show ptp debug view
	showPTPDebugView(IPTPDebugUIConstants.ID_VIEW_PARALLELDEBUG);
	launch.setPJob(job);
	IBinaryObject exeFile = null;
	try {
	exeFile = verifyBinary(configuration);
	setDefaultSourceLocator(launch, configuration);
	} catch (CoreException e) {
	//FIXME: Error dialog?
	System.out.println("Error completing debug job launch");
	return;
	}
	/*
	* Wait for the incoming debug server connection. This can be canceled by the user.
	*/
	try {
	PTPDebugCorePlugin.getDebugModel().createDebuggerSession(debugger, launch, exeFile, new NullProgressMonitor());
	} catch (CoreException e) {
	//FIXME: progress monitor?
	System.out.println("Debug server failed to connect");
	}
	} else {
	new RuntimeProcess(launch, job, null);
	}
	}

	/* (non-Javadoc)
	* @see org.eclipse.debug.core.model.ILaunchConfigurationDelegate#launch(org.eclipse.debug.core.ILaunchConfiguration, java.lang.String, org.eclipse.debug.core.ILaunch, org.eclipse.core.runtime.IProgressMonitor)
	*/
	public void launch(ILaunchConfiguration configuration, String mode, ILaunch launch,
	IProgressMonitor monitor) throws CoreException {
	if (!(launch instanceof IPLaunch)) {
	abort(LaunchMessages.getResourceString("ParallelLaunchConfigurationDelegate.Invalid_launch_object"), null, 0);
	}
	if (monitor == null) {
	monitor = new NullProgressMonitor();
	}
	monitor.beginTask("", 250);
	monitor.setTaskName(MessageFormat.format("{0} . . .", new Object[] { "Launching " + configuration.getName() }));
	if (monitor.isCanceled()) {
	return;
	}
	IAbstractDebugger debugger = null;
	IPJob job = null;

	AttributeManager attrManager = getAttributeManager(configuration);

	try {
	IPreferenceStore store = PTPDebugUIPlugin.getDefault().getPreferenceStore();
	if (mode.equals(ILaunchManager.DEBUG_MODE)) {
	monitor.subTask("Configuring debug setting . . .");

	String dbgFile = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_FILE);

	ArrayList<String> dbgArgs = new ArrayList<String>();

	dbgArgs.add("--host=" + store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_HOST));
	dbgArgs.add("--debugger=" + store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_BACKEND));

	String dbgPath = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_BACKEND_PATH);
	if (dbgPath.length() > 0) {
	dbgArgs.add("--debugger_path=" + dbgPath);
	}

	String dbgExtraArgs = store.getString(IPDebugConstants.PREF_PTP_DEBUGGER_ARGS);
	if (dbgExtraArgs.length() > 0) {
	dbgArgs.addAll(Arrays.asList(dbgExtraArgs.split(" ")));
	}

	verifyDebuggerPath(dbgFile);

	/*
	* Create the debugger extension, then the connection point for the debug server.
	* The debug server is created when the job is launched via the submitJob()
	* command.
	*/
	IPDebugConfiguration debugConfig = getDebugConfig(configuration);
	debugger = debugConfig.createDebugger();
	int timeout = store.getInt(IPDebugConstants.PREF_PTP_DEBUG_COMM_TIMEOUT);
	debugger.createConnection(timeout);

	dbgArgs.add("--port=" + debugger.getDebuggerPort());

	// remote setting
	String dbgExePath = getDebuggerExePath(configuration);
	if (dbgExePath == null) {
	dbgExePath = dbgFile;
	}

	IPath path = new Path(dbgExePath);
	attrManager.addAttribute(JobAttributes.getDebuggerExecutableNameAttributeDefinition().create(path.lastSegment()));
	attrManager.addAttribute(JobAttributes.getDebuggerExecutablePathAttributeDefinition().create(path.removeLastSegments(1).toOSString()));

	String dbgWD = getDebuggerWorkDirectory(configuration);
	if (dbgWD != null) {
	StringAttribute wdAttr = (StringAttribute) attrManager.getAttribute(JobAttributes.getWorkingDirectoryAttributeDefinition());
	if (wdAttr != null) {
	wdAttr.setValueAsString(dbgWD);
	} else {
	attrManager.addAttribute(JobAttributes.getWorkingDirectoryAttributeDefinition().create(dbgWD));

	}
	}
	attrManager.addAttribute(JobAttributes.getDebuggerArgumentsAttributeDefinition().create(dbgArgs.toArray(new String[0])));
	attrManager.addAttribute(JobAttributes.getDebugFlagAttributeDefinition().create(true));
	}

	monitor.worked(10);
	monitor.subTask("Submitting the job . . .");

	submitJob(configuration, mode, (IPLaunch)launch, attrManager, debugger, monitor);

	monitor.worked(10);
	} catch (CoreException e) {
	if (e.getStatus().getPlugin().equals(PTPCorePlugin.PLUGIN_ID)) {
	String msg = e.getMessage();
	if (msg == null)
	msg = "";
	else
	msg = msg + "\n\n";
	abort(msg + LaunchMessages.getResourceString("ParallelLaunchConfigurationDelegate.Control_system_does_not_exist"), null, 0);
	}
	if (mode.equals(ILaunchManager.DEBUG_MODE)) {
	PTPDebugCorePlugin.getDebugModel().shutdownSession(job);
	/*
	if (debugger != null) {
	debugger.stopDebugger();
	}
	*/
	}
	if (e.getStatus().getCode() != IStatus.CANCEL) {
	throw e;
	}
	} finally {
	monitor.done();
	}
	}

	/**
	* @param viewID
	*/
	private void showPTPDebugView(final String viewID) {
	Display display = Display.getCurrent();
	if (display == null) {
	display = Display.getDefault();
	}
	if (display != null && !display.isDisposed()) {
	display.syncExec(new Runnable() {
	public void run() {
	IWorkbenchWindow window = PTPLaunchPlugin.getActiveWorkbenchWindow();
	if (window != null) {
	IWorkbenchPage page = window.getActivePage();
	if (page != null) {
	try {
	page.showView(viewID, null, IWorkbenchPage.VIEW_CREATE);
	} catch (PartInitException e) {}
	}
	}
	}
	});
	}
	}
	}