java/src/com/tightvnc/rfbplayer/FbsInputStream.java

//
//  Copyright (C) 2002 HorizonLive.com, Inc.  All Rights Reserved.
//
//  This is free software; you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation; either version 2 of the License, or
//  (at your option) any later version.
//
//  This software is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this software; if not, write to the Free Software
//  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,
//  USA.
//

//
// FbsInputStream.java
//

import java.io.*;
import java.util.*;

class FbsInputStream extends InputStream {

  protected InputStream in;
  protected long startTime;
  protected long timeOffset;
  protected long seekOffset;
  protected boolean paused;
  protected double playbackSpeed;

  protected byte[] buffer;
  protected int bufferSize;
  protected int bufferPos;

  protected Observer obs;

  //
  // Constructors.
  //

  FbsInputStream() throws IOException {
    throw new IOException("FbsInputStream: no such constructor");
  }

  //
  // Construct FbsInputStream object, begin playback.
  //

  FbsInputStream(InputStream in) throws IOException
  {
    this.in = in;
    startTime = System.currentTimeMillis();
    timeOffset = 0;
    seekOffset = -1;
    paused = false;
    playbackSpeed = 1.0;

    byte[] b = new byte[12];
    readFully(b);

    if (b[0] != 'F' || b[1] != 'B' || b[2] != 'S' || b[3] != ' ' ||
	b[4] != '0' || b[5] != '0' || b[6] != '1' || b[7] != '.' ||
	b[8] < '0' || b[8] > '9' || b[9] < '0' || b[9] > '9' ||
	b[10] < '0' || b[10] > '9' || b[11] != '\n') {
      throw new IOException("Incorrect protocol version");
    }

    buffer = null;
    bufferSize = 0;
    bufferPos = 0;
  }

  //
  // Basic methods overriding InputStream's methods.
  //

  public int read() throws IOException
  {
    while (bufferSize == 0) {
      if (!fillBuffer())
	return -1;
    }
    bufferSize--;
    return buffer[bufferPos++] & 0xFF;
  }

  public int available() throws IOException
  {
    // FIXME: This will work incorrectly if our caller will wait until
    // some amount of data is available when the buffer contains less
    // data than then that. Current implementation never reads more
    // data until the buffer is fully exhausted.
    return bufferSize;
  }

  public synchronized void close() throws IOException
  {
    in.close();
    in = null;
    startTime = -1;
    timeOffset = 0;
    seekOffset = -1;
    paused = false;
    playbackSpeed = 1.0;

    buffer = null;
    bufferSize = 0;
    bufferPos = 0;

    obs = null;
  }

  //
  // Methods providing additional functionality.
  //

  public synchronized long getTimeOffset()
  {
    long off = Math.max(seekOffset, timeOffset);
    return (long)(off * playbackSpeed);
  }

  public synchronized void setTimeOffset(long pos)
  {
    seekOffset = (long)(pos / playbackSpeed);
    notify();
  }

  public synchronized void setSpeed(double newSpeed)
  {
    long newOffset = (long)(timeOffset * playbackSpeed / newSpeed);
    startTime += timeOffset - newOffset;
    timeOffset = newOffset;
    if (isSeeking()) {
      seekOffset = (long)(seekOffset * playbackSpeed / newSpeed);
    }
    playbackSpeed = newSpeed;
  }

  public boolean isSeeking()
  {
    return (seekOffset >= 0);
  }

  public synchronized void pausePlayback()
  {
    paused = true;
    notify();
  }

  public synchronized void resumePlayback()
  {
    paused = false;
    startTime = System.currentTimeMillis() - timeOffset;
    notify();
  }

  public void addObserver(Observer target)
  {
    obs = target;
  }

  //
  // Methods for internal use.
  //

  private synchronized boolean fillBuffer() throws IOException
  {
    waitWhilePaused();

    bufferSize = (int)readUnsigned32();
    if (bufferSize >= 0) {
      int realSize = (bufferSize + 3) & 0xFFFFFFFC;
      buffer = new byte[realSize];
      readFully(buffer);
      bufferPos = 0;
      timeOffset = (long)(readUnsigned32() / playbackSpeed);
    }

    if (bufferSize < 0 || timeOffset < 0) {
      buffer = null;
      bufferSize = 0;
      bufferPos = 0;
      return false;
    }

    if (seekOffset >= 0) {
      if (timeOffset >= seekOffset) {
	startTime = System.currentTimeMillis() - seekOffset;
	seekOffset = -1;
      } else {
	return true;
      }
    }

    while (true) {
      long timeDiff = startTime + timeOffset - System.currentTimeMillis();
      if (timeDiff <= 0) {
	break;
      }
      try {
	wait(timeDiff);
      } catch (InterruptedException e) {
      }
      waitWhilePaused();
    }

    return true;
  }

  //
  // In paused mode, wait for external notification on this object.
  //

  private void waitWhilePaused()
  {
    while (paused && !isSeeking()) {
      synchronized(this) {
	try {
	  // Note: we call Observer.update(Observable,Object) method
	  // directly instead of maintaining an Observable object.
	  obs.update(null, null);
	  wait();
	} catch (InterruptedException e) {
	}
      }
    }
  }

  private long readUnsigned32() throws IOException
  {
    byte[] buf = new byte[4];
    if (!readFully(buf))
      return -1;

    return ((long)(buf[0] & 0xFF) << 24 |
	    (buf[1] & 0xFF) << 16 |
	    (buf[2] & 0xFF) << 8  |
	    (buf[3] & 0xFF));
  }

  private boolean readFully(byte[] b) throws IOException
  {
    int off = 0;
    int len = b.length;

    while (off != len) {
      int count = in.read(b, off, len - off);
      if (count < 0) {
	return false;
      }
      off += count;
    }

    return true;
  }
}