/*******************************************************************************
 * Copyright (c) 2000, 2011 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
 *******************************************************************************/
package org.eclipse.cdt.utils.pty;

import java.io.*;

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];
  }

  @Override public int read(byte[] buf, int off, int len) throws IOException {
    if (buf == null) {
      throw new NullPointerException();
    }
    if ((off < 0) || (off > buf.length) || (len < 0) || ((off + len) > buf.length) || ((off + len) < 0)) {
      throw new IndexOutOfBoundsException();
    }
    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;
  }

  @Override public void close() throws IOException {
    if (master.getFD() == -1) {
      return;
    }
    close0(master.getFD());
    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.LIBRARY_NAME);
  }
}