1 files changed, 98 insertions, 0 deletions
diff --git a/core/org.eclipse.cdt.core.native/utils/org/eclipse/cdt/utils/pty/PTYInputStream.java b/core/org.eclipse.cdt.core.native/utils/org/eclipse/cdt/utils/pty/PTYInputStream.java
new file mode 100644
index 00000000000..c2506a006d2
--- /dev/null
+++ b/core/org.eclipse.cdt.core.native/utils/org/eclipse/cdt/utils/pty/PTYInputStream.java
@@ -0,0 +1,98 @@
+/*******************************************************************************
+ * Copyright (c) 2000, 2014 QNX Software Systems and others.
+ * 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:
+ *     QNX Software Systems - Initial API and implementation
+ *     Wind River Systems   - bug 286162
+ *     Martin Oberhuber (Wind River) - [303083] Split out the Spawner
+ *******************************************************************************/
+package org.eclipse.cdt.utils.pty;
+
+
+import java.io.IOException;
+import java.io.InputStream;
+
+import org.eclipse.cdt.internal.core.spawner.Messages;
+import org.eclipse.cdt.utils.pty.PTY.MasterFD;
+
+class PTYInputStream extends InputStream {
+
+	MasterFD master;
+
+	/**
+	 * From a Unix valid file descriptor set a Reader.
+	 * @param fd file descriptor.
+	 */
+	public PTYInputStream(MasterFD fd) {
+		master = fd;
+	}
+
+	/**
+	 * Implementation of read for the InputStream.
+	 *
+	 * @exception IOException on error.
+	 */
+	@Override
+	public int read() throws IOException {
+		byte b[] = new byte[1];
+		if (1 != read(b, 0, 1))
+			return -1;
+		return b[0];
+	}
+
+	/**
+	 * @see InputStream#read(byte[], int, int)
+	 */
+	@Override
+	public int read(byte[] buf, int off, int len) throws IOException {
+		if (buf == null) {
+			throw new NullPointerException();
+		} else if ((off < 0) || (off > buf.length)
+					|| (len < 0) || ((off + len) > buf.length)
+					|| ((off + len) < 0)) {
+			throw new IndexOutOfBoundsException();
+		} else if (len == 0) {
+			return 0;
+		}
+		byte[] tmpBuf = new byte[len];
+
+		len = read0(master.getFD(), tmpBuf, len);
+		if (len <= 0)
+			return -1;
+
+		System.arraycopy(tmpBuf, 0, buf, off, len);
+		return len;
+	}
+
+	/**
+	 * Close the Reader
+	 * @exception IOException on error.
+	 */
+	@Override
+	public void close() throws IOException {
+		if (master.getFD() == -1)
+			return;
+		close0(master.getFD());
+		// ignore error on close - see bug 286162
+//		if (status == -1)
+//			throw new IOException(Messages.Util_exception_closeError);
+		master.setFD(-1);
+	}
+
+	@Override
+	protected void finalize() throws IOException {
+		close();
+	}
+
+	private native int read0(int fd, byte[] buf, int len) throws IOException;
+	private native int close0(int fd) throws IOException;
+
+	static {
+		System.loadLibrary("pty"); //$NON-NLS-1$
+	}
+
+}