Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java')
-rw-r--r--org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java198
1 files changed, 99 insertions, 99 deletions
diff --git a/org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java b/org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java
index c9720d547..70ebc00eb 100644
--- a/org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java
+++ b/org.eclipse.debug.core/core/org/eclipse/debug/internal/core/StreamsProxy.java
@@ -1,99 +1,99 @@
-package org.eclipse.debug.internal.core;
-
-/*
- * (c) Copyright IBM Corp. 2000, 2001.
- * All Rights Reserved.
- */
-
-import org.eclipse.debug.core.model.IStreamMonitor;
-import org.eclipse.debug.core.model.IStreamsProxy;
-import java.io.IOException;
-
-public class StreamsProxy implements IStreamsProxy {
- /**
- * The monitor for the output stream (connected to standard out of the process)
- */
- private OutputStreamMonitor fOutputMonitor;
- /**
- * The monitor for the error stream (connected to standard error of the process)
- */
- private OutputStreamMonitor fErrorMonitor;
- /**
- * The monitor for the input stream (connected to standard in of the process)
- */
- private InputStreamMonitor fInputMonitor;
- /**
- * Records the open/closed state of communications with
- * the underlying streams.
- */
- private boolean fClosed= false;
- /**
- * Creates a <code>StreamsProxy</code> on the streams
- * of the given <code>IProcess</code>.
- */
- public StreamsProxy(RuntimeProcess process) {
- if (process == null) {
- return;
- }
- fOutputMonitor= new OutputStreamMonitor(process.getInputStream());
- fErrorMonitor= new OutputStreamMonitor(process.getErrorStream());
- fInputMonitor= new InputStreamMonitor(process.getOutputStream());
- fOutputMonitor.startMonitoring();
- fErrorMonitor.startMonitoring();
- fInputMonitor.startMonitoring();
- }
-
- /**
- * Causes the proxy to close all
- * communications between it and the
- * underlying streams after all remaining data
- * in the streams is read.
- */
- protected void close() {
- if (!fClosed) {
- fClosed= true;
- fOutputMonitor.close();
- fErrorMonitor.close();
- fInputMonitor.close();
- }
- }
-
- /**
- * Causes the proxy to close all
- * communications between it and the
- * underlying streams immediately.
- * Data remaining in the streams is lost.
- */
- protected void kill() {
- fClosed= true;
- fOutputMonitor.kill();
- fErrorMonitor.kill();
- fInputMonitor.close();
- }
-
- /**
- * @see IStreamsProxy#getErrorStreamMonitor()
- */
- public IStreamMonitor getErrorStreamMonitor() {
- return fErrorMonitor;
- }
-
- /**
- * @see IStreamsProxy#getOutputStreamMonitor()
- */
- public IStreamMonitor getOutputStreamMonitor() {
- return fOutputMonitor;
- }
-
- /**
- * @see IStreamsProxy#write(String)
- */
- public void write(String input) throws IOException {
- if (!fClosed) {
- fInputMonitor.write(input);
- } else {
- throw new IOException();
- }
- }
-
-}
+package org.eclipse.debug.internal.core;
+
+/*
+ * (c) Copyright IBM Corp. 2000, 2001.
+ * All Rights Reserved.
+ */
+
+import org.eclipse.debug.core.model.IStreamMonitor;
+import org.eclipse.debug.core.model.IStreamsProxy;
+import java.io.IOException;
+
+public class StreamsProxy implements IStreamsProxy {
+ /**
+ * The monitor for the output stream (connected to standard out of the process)
+ */
+ private OutputStreamMonitor fOutputMonitor;
+ /**
+ * The monitor for the error stream (connected to standard error of the process)
+ */
+ private OutputStreamMonitor fErrorMonitor;
+ /**
+ * The monitor for the input stream (connected to standard in of the process)
+ */
+ private InputStreamMonitor fInputMonitor;
+ /**
+ * Records the open/closed state of communications with
+ * the underlying streams.
+ */
+ private boolean fClosed= false;
+ /**
+ * Creates a <code>StreamsProxy</code> on the streams
+ * of the given <code>IProcess</code>.
+ */
+ public StreamsProxy(RuntimeProcess process) {
+ if (process == null) {
+ return;
+ }
+ fOutputMonitor= new OutputStreamMonitor(process.getInputStream());
+ fErrorMonitor= new OutputStreamMonitor(process.getErrorStream());
+ fInputMonitor= new InputStreamMonitor(process.getOutputStream());
+ fOutputMonitor.startMonitoring();
+ fErrorMonitor.startMonitoring();
+ fInputMonitor.startMonitoring();
+ }
+
+ /**
+ * Causes the proxy to close all
+ * communications between it and the
+ * underlying streams after all remaining data
+ * in the streams is read.
+ */
+ protected void close() {
+ if (!fClosed) {
+ fClosed= true;
+ fOutputMonitor.close();
+ fErrorMonitor.close();
+ fInputMonitor.close();
+ }
+ }
+
+ /**
+ * Causes the proxy to close all
+ * communications between it and the
+ * underlying streams immediately.
+ * Data remaining in the streams is lost.
+ */
+ protected void kill() {
+ fClosed= true;
+ fOutputMonitor.kill();
+ fErrorMonitor.kill();
+ fInputMonitor.close();
+ }
+
+ /**
+ * @see IStreamsProxy#getErrorStreamMonitor()
+ */
+ public IStreamMonitor getErrorStreamMonitor() {
+ return fErrorMonitor;
+ }
+
+ /**
+ * @see IStreamsProxy#getOutputStreamMonitor()
+ */
+ public IStreamMonitor getOutputStreamMonitor() {
+ return fOutputMonitor;
+ }
+
+ /**
+ * @see IStreamsProxy#write(String)
+ */
+ public void write(String input) throws IOException {
+ if (!fClosed) {
+ fInputMonitor.write(input);
+ } else {
+ throw new IOException();
+ }
+ }
+
+}

Back to the top