/*
* Copyright (c) 2007, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation. Oracle designates this
* particular file as subject to the "Classpath" exception as provided
* by Oracle in the LICENSE file that accompanied this code.
*
* This code 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
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
package com.sun.media.sound;
import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
/**
* Resource Interchange File Format (RIFF) stream decoder.
*
* @author Karl Helgason
*/
public class RIFFReader extends InputStream {
private RIFFReader root;
private long filepointer = 0;
private String fourcc;
private String riff_type = null;
private long ckSize = 0;
private InputStream stream;
private long avail;
private RIFFReader lastiterator = null;
public RIFFReader(InputStream stream) throws IOException {
if (stream instanceof RIFFReader)
root = ((RIFFReader)stream).root;
else
root = this;
this.stream = stream;
avail = Integer.MAX_VALUE;
ckSize = Integer.MAX_VALUE;
// Check for RIFF null paddings,
int b;
while (true) {
b = read();
if (b == -1) {
fourcc = ""; // don't put null value into fourcc,
// because it is expected to
// always contain a string value
riff_type = null;
avail = 0;
return;
}
if (b != 0)
break;
}
byte[] fourcc = new byte[4];
fourcc[0] = (byte) b;
readFully(fourcc, 1, 3);
this.fourcc = new String(fourcc, "ascii");
ckSize = readUnsignedInt();
avail = this.ckSize;
if (getFormat().equals("RIFF") || getFormat().equals("LIST")) {
byte[] format = new byte[4];
readFully(format);
this.riff_type = new String(format, "ascii");
}
}
public long getFilePointer() throws IOException {
return root.filepointer;
}
public boolean hasNextChunk() throws IOException {
if (lastiterator != null)
lastiterator.finish();
return avail != 0;
}
public RIFFReader nextChunk() throws IOException {
if (lastiterator != null)
lastiterator.finish();
if (avail == 0)
return null;
lastiterator = new RIFFReader(this);
return lastiterator;
}
public String getFormat() {
return fourcc;
}
public String getType() {
return riff_type;
}
public long getSize() {
return ckSize;
}
public int read() throws IOException {
if (avail == 0)
return -1;
int b = stream.read();
if (b == -1)
return -1;
avail--;
filepointer++;
return b;
}
public int read(byte[] b, int offset, int len) throws IOException {
if (avail == 0)
return -1;
if (len > avail) {
int rlen = stream.read(b, offset, (int)avail);
if (rlen != -1)
filepointer += rlen;
avail = 0;
return rlen;
} else {
int ret = stream.read(b, offset, len);
if (ret == -1)
return -1;
avail -= ret;
filepointer += ret;
return ret;
}
}
public final void readFully(byte b[]) throws IOException {
readFully(b, 0, b.length);
}
public final void readFully(byte b[], int off, int len) throws IOException {
if (len < 0)
throw new IndexOutOfBoundsException();
while (len > 0) {
int s = read(b, off, len);
if (s < 0)
throw new EOFException();
if (s == 0)
Thread.yield();
off += s;
len -= s;
}
}
public final long skipBytes(long n) throws IOException {
if (n < 0)
return 0;
long skipped = 0;
while (skipped != n) {
long s = skip(n - skipped);
if (s < 0)
break;
if (s == 0)
Thread.yield();
skipped += s;
}
return skipped;
}
public long skip(long n) throws IOException {
if (avail == 0)
return -1;
if (n > avail) {
long len = stream.skip(avail);
if (len != -1)
filepointer += len;
avail = 0;
return len;
} else {
long ret = stream.skip(n);
if (ret == -1)
return -1;
avail -= ret;
filepointer += ret;
return ret;
}
}
public int available() {
return (int)avail;
}
public void finish() throws IOException {
if (avail != 0) {
skipBytes(avail);
}
}
// Read ASCII chars from stream
public String readString(int len) throws IOException {
byte[] buff = new byte[len];
readFully(buff);
for (int i = 0; i < buff.length; i++) {
if (buff[i] == 0) {
return new String(buff, 0, i, "ascii");
}
}
return new String(buff, "ascii");
}
// Read 8 bit signed integer from stream
public byte readByte() throws IOException {
int ch = read();
if (ch < 0)
throw new EOFException();
return (byte) ch;
}
// Read 16 bit signed integer from stream
public short readShort() throws IOException {
int ch1 = read();
int ch2 = read();
if (ch1 < 0)
throw new EOFException();
if (ch2 < 0)
throw new EOFException();
return (short)(ch1 | (ch2 << 8));
}
// Read 32 bit signed integer from stream
public int readInt() throws IOException {
int ch1 = read();
int ch2 = read();
int ch3 = read();
int ch4 = read();
if (ch1 < 0)
throw new EOFException();
if (ch2 < 0)
throw new EOFException();
if (ch3 < 0)
throw new EOFException();
if (ch4 < 0)
throw new EOFException();
return ch1 + (ch2 << 8) | (ch3 << 16) | (ch4 << 24);
}
// Read 64 bit signed integer from stream
public long readLong() throws IOException {
long ch1 = read();
long ch2 = read();
long ch3 = read();
long ch4 = read();
long ch5 = read();
long ch6 = read();
long ch7 = read();
long ch8 = read();
if (ch1 < 0)
throw new EOFException();
if (ch2 < 0)
throw new EOFException();
if (ch3 < 0)
throw new EOFException();
if (ch4 < 0)
throw new EOFException();
if (ch5 < 0)
throw new EOFException();
if (ch6 < 0)
throw new EOFException();
if (ch7 < 0)
throw new EOFException();
if (ch8 < 0)
throw new EOFException();
return ch1 | (ch2 << 8) | (ch3 << 16) | (ch4 << 24)
| (ch5 << 32) | (ch6 << 40) | (ch7 << 48) | (ch8 << 56);
}
// Read 8 bit unsigned integer from stream
public int readUnsignedByte() throws IOException {
int ch = read();
if (ch < 0)
throw new EOFException();
return ch;
}
// Read 16 bit unsigned integer from stream
public int readUnsignedShort() throws IOException {
int ch1 = read();
int ch2 = read();
if (ch1 < 0)
throw new EOFException();
if (ch2 < 0)
throw new EOFException();
return ch1 | (ch2 << 8);
}
// Read 32 bit unsigned integer from stream
public long readUnsignedInt() throws IOException {
long ch1 = read();
long ch2 = read();
long ch3 = read();
long ch4 = read();
if (ch1 < 0)
throw new EOFException();
if (ch2 < 0)
throw new EOFException();
if (ch3 < 0)
throw new EOFException();
if (ch4 < 0)
throw new EOFException();
return ch1 + (ch2 << 8) | (ch3 << 16) | (ch4 << 24);
}
public void close() throws IOException {
finish();
if (this == root)
stream.close();
stream = null;
}
}