src/org/objectweb/cjdbc/common/stream/CJDBCInputStream.java

説明を見る。

package org.objectweb.cjdbc.common.stream;

import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.OptionalDataException;
import java.io.StreamCorruptedException;
import java.net.Socket;

public class CJDBCInputStream
{
  private ObjectInputStream input;
  private long              bytesRead;
  private Socket            socket;
  private boolean           useCompression = false;
  private long              speed          = -1;
  private long              dateCreated;

  public CJDBCInputStream(InputStream in) throws IOException,
      StreamCorruptedException
  {
    input = new ObjectInputStream(new BufferedInputStream(in));
    bytesRead = 0;
  }

  public CJDBCInputStream(Socket socket) throws IOException,
      StreamCorruptedException
  {
    this(socket.getInputStream());
    this.socket = socket;
    dateCreated = System.currentTimeMillis();
  }

  public Object readObject() throws ClassNotFoundException, IOException,
      OptionalDataException
  {
    if (useCompression)
    {
      int len = input.readInt();
      byte[] read = new byte[len];
      input.readFully(read);

      bytesRead += len + 4;
      // we read an integer in the pipe for the size of the array.
      return CJDBCStream.decompressObject(read);
    }
    else
    {
      // Use the unshared version to prevent the stream to keep references on
      // objects. This prevents objects sent through the channel from being
      // garbage collected and results in memory leaks.
      return input.readUnshared();
    }
  }

  public void close() throws IOException
  {
    input.close();
  }

  public boolean readBoolean() throws IOException
  {
    bytesRead++;
    return input.readBoolean();
  }

  public int readInt() throws IOException
  {
    bytesRead += 4;
    return input.readInt();
  }

  public long readLong() throws IOException
  {
    bytesRead += 8;
    return input.readLong();
  }

  public String readUTF() throws IOException
  {
    try
    {
      Object read = this.readObject();
      if (read == null)
        return null;
      bytesRead += ((String) read).length();
      return (String) read;
    }
    catch (ClassNotFoundException e)
    {
      // It's a string so that should never happen ...
      // but just to be sure
      throw new IOException(e.getMessage());
    }
  }

  public int available() throws IOException
  {
    return input.available();
  }

  public long getBytesRead()
  {
    return bytesRead;
  }

  public Socket getSocket()
  {
    return socket;
  }

  public boolean getUseCompression()
  {
    return useCompression;
  }

  public long getDateCreated()
  {
    return dateCreated;
  }

  public long getSpeed()
  {
    return speed;
  }
}

---