diff options
Diffstat (limited to 'org.fox.ttcomics/src/main/java/org/fox/ttcomics2/junrar/io/ReadOnlyAccessInputStream.java')
-rw-r--r-- | org.fox.ttcomics/src/main/java/org/fox/ttcomics2/junrar/io/ReadOnlyAccessInputStream.java | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/org.fox.ttcomics/src/main/java/org/fox/ttcomics2/junrar/io/ReadOnlyAccessInputStream.java b/org.fox.ttcomics/src/main/java/org/fox/ttcomics2/junrar/io/ReadOnlyAccessInputStream.java new file mode 100644 index 0000000..e1b778b --- /dev/null +++ b/org.fox.ttcomics/src/main/java/org/fox/ttcomics2/junrar/io/ReadOnlyAccessInputStream.java @@ -0,0 +1,73 @@ +/* + * Copyright (c) 2007 innoSysTec (R) GmbH, Germany. All rights reserved. + * Original author: Edmund Wagner + * Creation date: 26.06.2007 + * + * Source: $HeadURL$ + * Last changed: $LastChangedDate$ + * + * the unrar licence applies to all junrar source and binary distributions + * you are not allowed to use this source to re-create the RAR compression + * algorithm + * + * Here some html entities which can be used for escaping javadoc tags: + * "&": "&" or "&" + * "<": "<" or "<" + * ">": ">" or ">" + * "@": "@" + */ +package org.fox.ttcomics2.junrar.io; + +import java.io.IOException; +import java.io.InputStream; + +public class ReadOnlyAccessInputStream extends InputStream { + private final long startPos; + private final long endPos; + private IReadOnlyAccess file; + private long curPos; + + public ReadOnlyAccessInputStream(IReadOnlyAccess file, long startPos, + long endPos) throws IOException { + super(); + this.file = file; + this.startPos = startPos; + curPos = startPos; + this.endPos = endPos; + file.setPosition(curPos); + } + + @Override + public int read() throws IOException { + if (curPos == endPos) { + return -1; + } else { + int b = file.read(); + curPos++; + return b; + } + } + + @Override + public int read(byte[] b, int off, int len) throws IOException { + if (len == 0) { + return 0; + } + if (curPos == endPos) { + return -1; + } + int bytesRead = file.read(b, off, + (int) Math.min(len, endPos - curPos)); + curPos += bytesRead; + return bytesRead; + } + + @Override + public int read(byte[] b) throws IOException { + return read(b, 0, b.length); + } +// +// public void close() throws IOException { +// file.close(); +// } +} |