aboutsummaryrefslogtreecommitdiffstats
path: root/src/jogl/classes
diff options
context:
space:
mode:
Diffstat (limited to 'src/jogl/classes')
-rw-r--r--src/jogl/classes/jogamp/opengl/util/jpeg/JPEGDecoder.java101
1 files changed, 32 insertions, 69 deletions
diff --git a/src/jogl/classes/jogamp/opengl/util/jpeg/JPEGDecoder.java b/src/jogl/classes/jogamp/opengl/util/jpeg/JPEGDecoder.java
index d5b01ef54..946ea8ff5 100644
--- a/src/jogl/classes/jogamp/opengl/util/jpeg/JPEGDecoder.java
+++ b/src/jogl/classes/jogamp/opengl/util/jpeg/JPEGDecoder.java
@@ -56,7 +56,6 @@
package jogamp.opengl.util.jpeg;
-import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
@@ -65,6 +64,7 @@ import java.util.Arrays;
import jogamp.opengl.Debug;
import com.jogamp.common.util.ArrayHashSet;
+import com.jogamp.common.util.Bitstream;
import com.jogamp.common.util.VersionNumber;
import com.jogamp.opengl.util.texture.TextureData;
import com.jogamp.opengl.util.texture.TextureData.ColorSpace;
@@ -446,9 +446,7 @@ public class JPEGDecoder {
return "JPEG[size "+width+"x"+height+", compOut "+compOuts+", "+jfifS+", "+exifS+", "+adobeS+"]";
}
- private BufferedInputStream istream;
- private int _ipos = 0;
- private int _iposSave = 0;
+ private final Bitstream<InputStream> bstream = new Bitstream<InputStream>(new Bitstream.ByteInputStream(null), false /* outputMode */);
private int width = 0;
private int height = 0;
@@ -463,50 +461,20 @@ public class JPEGDecoder {
public final int getWidth() { return width; }
public final int getHeight() { return height; }
- private final void resetInput(InputStream is) {
- if( is instanceof BufferedInputStream ) {
- istream = (BufferedInputStream) is;
- } else {
- istream = new BufferedInputStream(is);
+ private final void setStream(InputStream is) {
+ try {
+ bstream.setStream(is, false /* outputMode */);
+ } catch (Exception e) {
+ throw new RuntimeException(e); // should not happen, no flush()
}
- _ipos = 0;
}
- private final void markStream(int readLimit) {
- istream.mark(readLimit);
- _iposSave = _ipos;
- }
- private final void rewindStream() throws IOException {
- if(DEBUG_IN) { System.err.println("JPG.rewindStream: "+_ipos+" -> "+_iposSave); }
- istream.reset();
- _ipos = _iposSave;
- _iposSave = 0;
- }
private final int readUint8() throws IOException {
- final int r = istream.read();
- if( -1 < r ) {
- if(DEBUG_IN) { System.err.println("u8["+_ipos+"]: "+toHexString(r)); }
- _ipos++;
- } else if(DEBUG_IN) {
- System.err.println("u8["+_ipos+"]: EOS");
- }
- return r;
+ return bstream.readInt8(true /* msbFirst */);
}
private final int readUint16() throws IOException {
- final int hi = istream.read();
- if( -1 < hi ) {
- _ipos++;
- final int lo = istream.read();
- if( -1 < lo ) {
- _ipos++;
- final int r = hi << 8 | lo ;
- if(DEBUG_IN) { System.err.println("u16["+(_ipos-2)+"]: "+toHexString(r)); }
- return r;
- }
- }
- if(DEBUG_IN) { System.err.println("u16["+_ipos+"]: EOS"); }
- return -1;
+ return bstream.readInt16(true /* msbFirst */, true /* bigEndian */);
}
private final int readNumber() throws IOException {
@@ -531,14 +499,14 @@ public class JPEGDecoder {
for(int i=0; i<len; ) {
System.err.print(i%8+": ");
for(int j=0; j<8 && i<len; j++, i++) {
- System.err.println(toHexString(0x000000FF & data[offset+i])+", ");
+ System.err.print(toHexString(0x000000FF & data[offset+i])+", ");
}
System.err.println("");
}
}
public synchronized void clear(InputStream inputStream) {
- resetInput(inputStream);
+ setStream(inputStream);
width = 0;
height = 0;
jfif = null;
@@ -736,7 +704,7 @@ public class JPEGDecoder {
offset -= 3;
break;
} */
- throw new CodecException("unknown JPEG marker " + toHexString(fileMarker));
+ throw new CodecException("unknown JPEG marker " + toHexString(fileMarker) + ", " + bstream);
}
if( 0 == fileMarker ) {
fileMarker = readUint16();
@@ -775,13 +743,13 @@ public class JPEGDecoder {
if (maxH < component.h) maxH = component.h;
if (maxV < component.v) maxV = component.v;
}
- int mcusPerLine = (int) Math.ceil((float)frame.samplesPerLine / 8f / (float)maxH);
- int mcusPerColumn = (int) Math.ceil((float)frame.scanLines / 8f / (float)maxV);
+ int mcusPerLine = (int) Math.ceil(frame.samplesPerLine / 8f / maxH);
+ int mcusPerColumn = (int) Math.ceil(frame.scanLines / 8f / maxV);
// for (componentId in frame.components) {
for (int i=0; i<compCount; i++) {
final ComponentIn component = frame.getCompByIndex(i);
- final int blocksPerLine = (int) Math.ceil(Math.ceil((float)frame.samplesPerLine / 8f) * component.h / maxH);
- final int blocksPerColumn = (int) Math.ceil(Math.ceil((float)frame.scanLines / 8f) * component.v / maxV);
+ final int blocksPerLine = (int) Math.ceil(Math.ceil(frame.samplesPerLine / 8f) * component.h / maxH);
+ final int blocksPerColumn = (int) Math.ceil(Math.ceil(frame.scanLines / 8f) * component.v / maxV);
final int blocksPerLineForMcu = mcusPerLine * component.h;
final int blocksPerColumnForMcu = mcusPerColumn * component.v;
component.allocateBlocks(blocksPerColumn, blocksPerColumnForMcu, blocksPerLine, blocksPerLineForMcu);
@@ -1066,7 +1034,6 @@ public class JPEGDecoder {
private int mcusPerLine;
private boolean progressive;
// private int maxH, maxV;
- private int bitsData, bitsCount;
private int spectralStart, spectralEnd;
private int successive;
private int eobrun;
@@ -1081,8 +1048,7 @@ public class JPEGDecoder {
this.progressive = frame.progressive;
// this.maxH = frame.maxH;
// this.maxV = frame.maxV;
- this.bitsData = 0;
- this.bitsCount = 0;
+ bstream.skip( bstream.getBitCount() ); // align to next byte
this.spectralStart = spectralStart;
this.spectralEnd = spectralEnd;
this.successive = successive;
@@ -1149,16 +1115,16 @@ public class JPEGDecoder {
return markerException.getMarker();
} catch (CodecException codecException) {
if(DEBUG) { System.err.println("JPEG.decodeScan: Codec exception: "+codecException.getMessage()); codecException.printStackTrace(); }
- bitsCount = 0;
+ bstream.skip( bstream.getBitCount() ); // align to next byte
return M_EOI; // force end !
}
// find marker
- bitsCount = 0;
- markStream(2);
+ bstream.skip( bstream.getBitCount() ); // align to next byte
+ bstream.mark(2);
marker = readUint16();
if( marker < 0xFF00 ) {
- rewindStream();
+ bstream.reset();
throw new CodecException("marker not found @ mcu "+mcu+"/"+mcuExpected+", u16: "+toHexString(marker));
}
final boolean isRSTx = 0xFFD0 <= marker && marker <= 0xFFD7; // !RSTx
@@ -1172,28 +1138,25 @@ public class JPEGDecoder {
return marker;
}
- private int readBit() throws MarkerException, IOException {
- if (bitsCount > 0) {
- bitsCount--;
- return (bitsData >> bitsCount) & 1;
- }
- bitsData = readUint8();
- if( -1 == bitsData ) {
- return -1;
+ private final int readBit() throws MarkerException, IOException {
+ final int bit = bstream.readBit(true /* msbFirst */);
+ if( Bitstream.EOS == bit || 7 != bstream.getBitCount() ) {
+ return bit;
}
- if (bitsData == 0xFF) { // marker prefix
- final int nextByte = readUint8(); // marker signature
+ // new byte read, i.e. bitCount == 7
+ final int bitsData = bstream.getBitBuffer(); // peek for marker
+ if ( 0xFF == bitsData ) { // marker prefix
+ final int nextByte = bstream.getStream().read(); // snoop marker signature, will be dropped!
if( -1 == nextByte ) {
throw new CodecException("marked prefix 0xFF, then EOF");
}
if (0 != nextByte) {
final int marker = (bitsData << 8) | nextByte;
- throw new MarkerException(marker, "Marker at readBit file pos " + _ipos);
+ throw new MarkerException(marker, "Marker at readBit pos " + bstream);
}
// unstuff 0
}
- bitsCount = 7;
- return bitsData >>> 7;
+ return bit;
}
private int decodeHuffman(BinObj tree) throws IOException {
@@ -1205,7 +1168,7 @@ public class JPEGDecoder {
return 0x000000FF & node.getValue();
}
}
- throw new CodecException("EOF reached at "+_ipos);
+ throw new CodecException("EOF reached at "+bstream);
}
private int receive(int length) throws IOException {
int n = 0;
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-05 00:03:35 +0000