Attachment 52461 Details for Bug 161838 – The modified HostShellAdapter.java from RSE 1.0RC2 that prints the isActive status.

The modified HostShellAdapter.java from RSE 1.0RC2 that prints the isActive status.

HostShellAdapter.java (text/plain), 3.61 KB, created by Lothar Werzinger

on 2006-10-21 11:38:54 EDT

(hide)

Description:

Filename:

MIME Type:

Creator: Lothar Werzinger

Created: 2006-10-21 11:38:54 EDT

Size: 3.61 KB

patch

obsolete

>/*******************************************************************************
> * Copyright (c) 2006 PalmSource, Inc.
> * All rights reserved. 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 
> * 
> * Contributors: 
> * Ewa Matejska (PalmSource)
> *******************************************************************************/
>
>package biz.tradescape.debug.launching;
>
>import java.io.IOException;
>import java.io.InputStream;
>import java.io.OutputStream;
>import java.io.PipedInputStream;
>import java.io.PipedOutputStream;
>
>import org.eclipse.rse.services.shells.IHostShell;
>import org.eclipse.rse.services.shells.IHostShellChangeEvent;
>import org.eclipse.rse.services.shells.IHostShellOutputListener;
>
>public class HostShellAdapter extends Process implements
>IHostShellOutputListener {
>
>	private IHostShell hostShell;
>	private PipedInputStream inputStream = null;
>	private PipedInputStream errorStream = null;
>	private HostShellOutputStream outputStream = null;
>	
>	private PipedOutputStream hostShellInput = null;
>	private PipedOutputStream hostShellError = null;
>	
>	
>	public HostShellAdapter(IHostShell hostShell) throws java.io.IOException {
>		this.hostShell = hostShell;
>		hostShellInput = new PipedOutputStream();
>		hostShellError = new PipedOutputStream();
>		inputStream = new PipedInputStream(hostShellInput);
>		errorStream = new PipedInputStream(hostShellError);
>		outputStream = new HostShellOutputStream(hostShell);
>		this.hostShell.getStandardOutputReader().addOutputListener(this);
>		this.hostShell.getStandardErrorReader().addOutputListener(this);
>	}
>	
>	public synchronized void destroy() {
>    System.out.println("destroy() - before hostShell.exit();");
>		hostShell.exit();
>    System.out.println("destroy() - after hostShell.exit();");
>		notifyAll();
>		try {
>			hostShellInput.close();
>			hostShellError.close();
>			inputStream.close();
>			errorStream.close();
>			outputStream.close();
>		} catch (IOException e) {
>			// Ignore
>		}	
>	}
>
>	public synchronized int exitValue() {
>    System.out.println("exitValue() - hostShell.isActive()=" + hostShell.isActive());
>		if(hostShell.isActive())
>			throw new IllegalThreadStateException();
>		// No way to tell what the exit value was.
>		return 0;
>	}
>
>	public InputStream getErrorStream() {
>		return errorStream;
>	}
>
>	public InputStream getInputStream() {
>		return inputStream;
>	}
>
>	public OutputStream getOutputStream() {
>		return outputStream;
>	}
>
>	public synchronized int waitFor() throws InterruptedException {
>		
>		while(hostShell.isActive()) {
>			try {
>				wait(1000);
>			} catch (InterruptedException e) {
>				// ignore because we're polling to see if shell is still active.
>			}
>		}
>		
>		try {
>			// Wait a second to try to get some more output from the target shell before closing.
>			wait(1000);
>			// Allow for the data from the stream to be read if it's available
>			if (inputStream.available() != 0 || errorStream.available() != 0)
>				throw new InterruptedException();
>	
>			hostShellInput.close();
>			hostShellError.close();
>			inputStream.close();
>			errorStream.close();
>			outputStream.close();
>		} catch (IOException e) {
>			// Ignore
>		}
>		return 0;
>	}
>	
>	public void shellOutputChanged(IHostShellChangeEvent event) {
>		Object[] input = event.getLines();
>		OutputStream outputStream = event.isError() ? hostShellError : hostShellInput;
>		try {
>		for(int i = 0; i < input.length; i++) {
>			outputStream.write(input[i].toString().getBytes());
>			outputStream.write('\n');
>			outputStream.flush();
>		}
>		} catch(IOException e) {
>			// Ignore
>		}
>	}
>
>}

Flags:

mober.at+eclipse: iplog+

Actions: View

Attachments on bug 161838: 52461 | 52645