public class oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream extends java.io.InputStream implements oadd.org.apache.hadoop.io.compress.bzip.BZip2Constants { public static final long BLOCK_DELIMITER; public static final long EOS_DELIMITER; private static final int DELIMITER_BIT_LENGTH; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE readMode; private long reportedBytesReadFromCompressedStream; private long bytesReadFromCompressedStream; private boolean lazyInitialization; private byte[] array; private int last; private int origPtr; private int blockSize100k; private boolean blockRandomised; private long bsBuff; private long bsLive; private final oadd.org.apache.hadoop.io.compress.bzip.CRC crc; private int nInUse; private java.io.BufferedInputStream in; private int currentChar; private oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE currentState; private int storedBlockCRC; private int storedCombinedCRC; private int computedBlockCRC; private int computedCombinedCRC; private boolean skipResult; private boolean skipDecompression; private int su_count; private int su_ch; private int su_chPrev; private int su_i; private int su_j; private int su_rNToGo; private int su_rTPos; private int su_tPos; private char su_z; private oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data data; public long getProcessedByteCount() { long v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; return v; } protected void updateProcessedByteCount(int) { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; int v; long v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: int; v = v.; v = v + v; v. = v; return; } public void updateReportedByteCount(int) { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; int v; long v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: int; v = v.; v = v + v; v. = v; virtualinvoke v.(v); return; } private int readAByte(java.io.InputStream) throws java.io.IOException { int v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: java.io.InputStream; v = virtualinvoke v.(); if v < 0 goto label; virtualinvoke v.(1); label: return v; } public boolean skipToNextMarker(long, int) throws java.io.IOException, java.lang.IllegalArgumentException { long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; byte v, v; int v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; java.lang.IllegalArgumentException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: long; v := @parameter: int; label: if v <= 63 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("skipToNextMarker can not find patterns greater than 63 bits"); throw v; label: v = specialinvoke v.(v); v = v cmp -1L; if v != 0 goto label; v = v.; v. = v; label: return 0; label: v = v cmp v; if v != 0 goto label; v = v.; v = v + v; v = v + 7L; v = v / 8L; v = v.; v = v - v; v. = v; label: return 1; label: v = v << 1; v = 1L << v; v = v - 1L; v = v & v; v = specialinvoke v.(1L); v = (int) -1; if v == v goto label; v = v | v; goto label; label: v = v.; v. = v; label: return 0; label: v := @caughtexception; v = v.; v. = v; return 0; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } protected void reportCRCError() throws java.io.IOException { java.io.IOException v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("crc error"); throw v; } private void makeMaps() { byte[] v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; boolean[] v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v; int v, v, v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; v = v.; v = v.; v = 0; v = 0; label: if v >= 256 goto label; v = v[v]; if v == 0 goto label; v = v; v = v + 1; v[v] = v; label: v = v + 1; goto label; label: v. = v; return; } public void (java.io.InputStream, oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE) throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: java.io.InputStream; v := @parameter: oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE; specialinvoke v.(java.io.InputStream,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE,boolean)>(v, v, 0); return; } private void (java.io.InputStream, oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE, boolean) throws java.io.IOException { byte[] v; java.io.BufferedInputStream v; oadd.org.apache.hadoop.io.compress.bzip.CRC v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v, v, v; int v, v; boolean v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: java.io.InputStream; v := @parameter: oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE; v := @parameter: boolean; specialinvoke v.()>(); v = ; v. = v; v. = 0L; v. = 0L; v. = 0; v = newarray (byte)[1]; v. = v; v. = 0; v = new oadd.org.apache.hadoop.io.compress.bzip.CRC; specialinvoke v.()>(); v. = v; v = (int) -1; v. = v; v = ; v. = v; v. = 0; v. = 0; v. = 9; v = new java.io.BufferedInputStream; specialinvoke v.(java.io.InputStream,int)>(v, 9216); v. = v; v. = v; v. = v; v = ; if v != v goto label; v = ; v. = v; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v. = v; v = v.; if v != 0 goto label; specialinvoke v.(); goto label; label: v = ; if v != v goto label; v = ; v. = v; v = virtualinvoke v.(54156738319193L, 48); v. = v; if v != 0 goto label; specialinvoke v.(); label: return; } public static long numberOfBytesTillNextMarker(java.io.InputStream) throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v; long v; java.io.InputStream v; v := @parameter: java.io.InputStream; v = new oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = ; specialinvoke v.(java.io.InputStream,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE,boolean)>(v, v, 1); v = virtualinvoke v.(); return v; } public void (java.io.InputStream) throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: java.io.InputStream; v = ; specialinvoke v.(java.io.InputStream,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE)>(v, v); return; } private void changeStateToProcessABlock() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; if v != 1 goto label; specialinvoke v.(); specialinvoke v.(); goto label; label: v = ; v. = v; label: return; } public int read() throws java.io.IOException { byte[] v, v; java.io.BufferedInputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; short v; byte v; int v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v, 0, 1); v = v.; v = v[0]; v = 255 & v; if v <= 0 goto label; v = v; goto label; label: v = v; label: return v; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("stream closed"); throw v; } public int read(byte[], int, int) throws java.io.IOException { byte[] v; java.lang.IndexOutOfBoundsException v, v, v; java.io.BufferedInputStream v; int v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; boolean v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; if v >= 0 goto label; v = new java.lang.IndexOutOfBoundsException; v = dynamicinvoke "makeConcatWithConstants" (v) ("offs(\u) < 0."); specialinvoke v.(java.lang.String)>(v); throw v; label: if v >= 0 goto label; v = new java.lang.IndexOutOfBoundsException; v = dynamicinvoke "makeConcatWithConstants" (v) ("len(\u) < 0."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v + v; v = lengthof v; if v <= v goto label; v = new java.lang.IndexOutOfBoundsException; v = lengthof v; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("offs(\u) + len(\u) > dest.length(\u)."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != null goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("stream closed"); throw v; label: v = v.; if v == 0 goto label; specialinvoke v.(); v. = 0; label: v = v.; if v == 0 goto label; specialinvoke v.(); v. = 0; label: v = v + v; v = v; v = 0; label: if v >= v goto label; v = specialinvoke v.(); v = v; if v < 0 goto label; v = v; v = v + 1; v[v] = v; goto label; label: v = v - v; if v != 0 goto label; v = v; v = virtualinvoke v.(54156738319193L, 48); v. = v; specialinvoke v.(); label: return v; } private int read0() throws java.io.IOException { java.lang.IllegalStateException v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; int[] v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v; int v, v, v, v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = ; v = v.; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; default: goto label; }; label: v = (int) -1; return v; label: v = (int) -2; return v; label: v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: specialinvoke v.(); goto label; label: specialinvoke v.(); goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: specialinvoke v.(); goto label; label: specialinvoke v.(); goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.()>(); throw v; label: return v; } private void init() throws java.io.IOException { java.io.BufferedInputStream v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v, v; int v, v, v; java.lang.String v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = specialinvoke v.(v); if v == 104 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Stream is not BZip formatted: expected \'h\' as first byte but got \'\u0001\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = specialinvoke v.(v); if v < 49 goto label; if v <= 57 goto label; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Stream is not BZip formatted: illegal blocksize \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v - 48; v. = v; specialinvoke v.(); specialinvoke v.(); return; } private void initBlock() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CRC v, v; long v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v, v, v; byte v, v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v, v, v; int v, v, v, v; boolean v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; char v, v, v, v, v, v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = ; if v != v goto label; v = specialinvoke v.(); v. = v; v = specialinvoke v.(1L); v = v cmp 1L; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v. = v; v = v.; if v != null goto label; v = new oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data; v = v.; specialinvoke v.(int)>(v); v. = v; label: specialinvoke v.(); v = v.; virtualinvoke v.(); v = ; v. = v; return; label: v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); v = specialinvoke v.(); if v != 23 goto label; if v != 114 goto label; if v != 69 goto label; if v != 56 goto label; if v != 80 goto label; if v != 144 goto label; specialinvoke v.(); goto label; label: if v != 49 goto label; if v != 65 goto label; if v != 89 goto label; if v != 38 goto label; if v != 83 goto label; if v == 89 goto label; label: v = ; v. = v; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("bad block header"); throw v; label: v = specialinvoke v.(); v. = v; v = specialinvoke v.(1L); v = v cmp 1L; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v. = v; v = v.; if v != null goto label; v = new oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data; v = v.; specialinvoke v.(int)>(v); v. = v; label: specialinvoke v.(); v = v.; virtualinvoke v.(); v = ; v. = v; label: return; } private void endBlock() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CRC v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; if v == v goto label; v = v.; v = v << 1; v = v.; v = v >>> 31; v = v | v; v. = v; v = v.; v = v.; v = v ^ v; v. = v; virtualinvoke v.(); label: v = v.; v = v << 1; v = v.; v = v >>> 31; v = v | v; v. = v; v = v.; v = v.; v = v ^ v; v. = v; return; } private void complete() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v; int v, v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = specialinvoke v.(); v. = v; v = ; v. = v; v. = null; v = v.; v = v.; if v == v goto label; virtualinvoke v.(); label: return; } public void close() throws java.io.IOException { java.lang.Throwable v; java.io.BufferedInputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; if v == null goto label; label: v = ; if v == v goto label; virtualinvoke v.(); label: v. = null; v. = null; goto label; label: v := @caughtexception; v. = null; v. = null; throw v; label: return; catch java.lang.Throwable from label to label with label; } private long bsR(long) throws java.io.IOException { java.io.BufferedInputStream v; long v, v, v, v, v, v, v, v, v, v; byte v, v; int v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: long; v = v.; v = v.; v = v cmp v; if v >= 0 goto label; v = v.; label: v = specialinvoke v.(v); if v >= 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v << 8; v = v | v; v = v + 8L; v = v cmp v; if v < 0 goto label; v. = v; label: v = v - v; v. = v; v = v - v; v = v >> v; v = 1L << v; v = v - 1L; v = v & v; return v; } private boolean bsGetBit() throws java.io.IOException { java.io.BufferedInputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; long v, v, v, v, v, v, v; byte v, v; int v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; v = v cmp 1L; if v >= 0 goto label; v = v.; v = specialinvoke v.(v); if v >= 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v << 8; v = v | v; v = v + 8L; v. = v; label: v = v - 1L; v. = v; v = v - 1L; v = v >> v; v = v & 1L; v = v cmp 0L; if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private char bsGetUByte() throws java.io.IOException { int v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; specialinvoke v.(8L); return v; } private int bsGetInt() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; long v, v, v, v, v, v, v, v, v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = specialinvoke v.(8L); v = v << 8; v = specialinvoke v.(8L); v = v | v; v = v << 8; v = specialinvoke v.(8L); v = v | v; v = v << 8; v = specialinvoke v.(8L); v = v | v; return v; } private static void hbCreateDecodeTables(int[], int[], int[], char[], int, int, int) { int[] v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; char v, v; char[] v; v := @parameter: int[]; v := @parameter: int[]; v := @parameter: int[]; v := @parameter: char[]; v := @parameter: int; v := @parameter: int; v := @parameter: int; v = v; v = 0; label: if v > v goto label; v = 0; label: if v >= v goto label; v = v[v]; if v != v goto label; v = v; v = v + 1; v[v] = v; label: v = v + 1; goto label; label: v = v + 1; goto label; label: v = 23; label: v = v - 1; if v <= 0 goto label; v[v] = 0; v[v] = 0; goto label; label: v = 0; label: if v >= v goto label; v = v[v]; v = v + 1; v = v[v]; v = v + 1; v[v] = v; v = v + 1; goto label; label: v = 1; v = v[0]; label: if v >= 23 goto label; v = v[v]; v = v + v; v[v] = v; v = v + 1; goto label; label: v = v; v = 0; v = v[v]; label: if v > v goto label; v = v + 1; v = v[v]; v = v - v; v = v + v; v = v; v = v - 1; v[v] = v; v = v << 1; v = v + 1; goto label; label: v = v + 1; label: if v > v goto label; v = v - 1; v = v[v]; v = v + 1; v = v << 1; v = v[v]; v = v - v; v[v] = v; v = v + 1; goto label; label: return; } private void recvDecodingTables() throws java.io.IOException { byte[] v, v, v; char[][] v; byte v, v, v; boolean v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; long v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean[] v; char[] v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; v = v.; v = v.; v = v.; v = 0; v = 0; label: if v >= 16 goto label; v = specialinvoke v.(); if v == 0 goto label; v = 1 << v; v = v | v; label: v = v + 1; goto label; label: v = 256; label: v = v - 1; if v < 0 goto label; v[v] = 0; goto label; label: v = 0; label: if v >= 16 goto label; v = 1 << v; v = v & v; if v == 0 goto label; v = v << 4; v = 0; label: if v >= 16 goto label; v = specialinvoke v.(); if v == 0 goto label; v = v + v; v[v] = 1; label: v = v + 1; goto label; label: v = v + 1; goto label; label: specialinvoke v.(); v = v.; v = v + 2; v = specialinvoke v.(3L); v = specialinvoke v.(15L); v = 0; label: if v >= v goto label; v = 0; label: v = specialinvoke v.(); if v == 0 goto label; v = v + 1; goto label; label: v[v] = v; v = v + 1; goto label; label: v = v; label: v = v - 1; if v < 0 goto label; v[v] = v; goto label; label: v = 0; label: if v >= v goto label; v = v[v]; v = v & 255; v = v[v]; label: if v <= 0 goto label; v = v - 1; v = v[v]; v[v] = v; v = v - 1; goto label; label: v[0] = v; v[v] = v; v = v + 1; goto label; label: v = v.; v = 0; label: if v >= v goto label; specialinvoke v.(5L); v = v[v]; v = 0; label: if v >= v goto label; label: v = specialinvoke v.(); if v == 0 goto label; specialinvoke v.(); goto label; label: v[v] = v; v = v + 1; goto label; label: v = v + 1; goto label; label: specialinvoke v.(v, v); return; } private void createHuffmanDecodingTables(int, int) { int[][] v, v, v; char[][] v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v; int[] v, v, v, v; int v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; char v; char[] v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: int; v := @parameter: int; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = 0; label: if v >= v goto label; v = 32; v = 0; v = v[v]; v = v; label: v = v - 1; if v < 0 goto label; v = v[v]; if v <= v goto label; v = v; label: if v >= v goto label; v = v; goto label; label: v = v[v]; v = v[v]; v = v[v]; v = v[v]; staticinvoke (v, v, v, v, v, v, v); v[v] = v; v = v + 1; goto label; label: return; } private void getAndMoveToFrontDecode() throws java.io.IOException { byte[] v, v, v; java.io.BufferedInputStream v; byte v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; long v, v, v, v, v; short v, v, v, v, v; java.io.IOException v, v, v, v, v, v; char[] v; int[][] v, v, v; int[] v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; char v, v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = specialinvoke v.(24L); v. = v; specialinvoke v.(); v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = v * 100000; v = 256; label: v = v - 1; if v < 0 goto label; v[v] = v; v[v] = 0; goto label; label: v = 0; v = 49; v = v.; v = v + 1; v = specialinvoke v.(0); v = v.; v = v.; v = (int) -1; v = v; v = v[0]; v = v & 255; v = v[v]; v = v[v]; v = v[v]; v = v[v]; label: if v == v goto label; if v == 0 goto label; if v != 1 goto label; label: v = (int) -1; v = v; v = 1; label: if v != 0 goto label; v = v + v; goto label; label: if v != 1 goto label; v = v << 1; v = v + v; label: if v != 0 goto label; v = 49; v = v + 1; v = v[v]; v = v & 255; v = v[v]; v = v[v]; v = v[v]; v = v[v]; goto label; label: v = v - 1; label: v = v; label: if v >= v goto label; v = specialinvoke v.(v); if v < 0 goto label; v = v << 8; v = v | v; v = v + 8; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v - v; v = v >> v; v = 1 << v; v = v - 1; v = v & v; v = v - v; label: v = v[v]; v = v cmp v; if v <= 0 goto label; v = v + 1; label: if v >= 1 goto label; v = specialinvoke v.(v); if v < 0 goto label; v = v << 8; v = v | v; v = v + 8; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v - 1; v = v << 1; v = v >> v; v = v & 1; v = v | v; goto label; label: v = v[v]; v = v - v; v = v[v]; v = v << 1; goto label; label: v = v[0]; v = v[v]; v = v & 255; v = v[v]; v = v + 1; v = v + v; v[v] = v; label: v = v; v = v - 1; if v < 0 goto label; v = v + 1; v[v] = v; goto label; label: if v < v goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("block overrun"); throw v; label: v = v + 1; if v < v goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("block overrun"); throw v; label: v = v - 1; v = v[v]; v = v[v]; v = v & 255; v = v[v]; v = v + 1; v[v] = v; v = v[v]; v[v] = v; if v > 16 goto label; v = v - 1; label: if v <= 0 goto label; v = v; v = v - 1; v = v[v]; v[v] = v; goto label; label: v = v - 1; staticinvoke (v, 0, v, 1, v); label: v[0] = v; if v != 0 goto label; v = 49; v = v + 1; v = v[v]; v = v & 255; v = v[v]; v = v[v]; v = v[v]; v = v[v]; goto label; label: v = v - 1; label: v = v; label: if v >= v goto label; v = specialinvoke v.(v); if v < 0 goto label; v = v << 8; v = v | v; v = v + 8; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v - v; v = v >> v; v = 1 << v; v = v - 1; v = v & v; v = v - v; label: v = v[v]; if v <= v goto label; v = v + 1; label: if v >= 1 goto label; v = specialinvoke v.(v); if v < 0 goto label; v = v << 8; v = v | v; v = v + 8; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v - 1; v = v << 1; v = v >> v; v = v & 1; v = v | v; goto label; label: v = v[v]; v = v - v; v = v[v]; goto label; label: v. = v; v. = v; v. = v; return; } private int getAndMoveToFrontDecode0(int) throws java.io.IOException { byte[] v; int[][] v, v, v; java.io.BufferedInputStream v; long v, v, v; short v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v; byte v; int[] v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v := @parameter: int; v = v.; v = v.; v = v.; v = v[v]; v = v & 255; v = v.; v = v[v]; v = v.; v = v[v]; v = specialinvoke v.(v); v = v.; v = v.; label: v = v[v]; if v <= v goto label; v = v + 1; label: if v >= 1 goto label; v = specialinvoke v.(v); if v < 0 goto label; v = v << 8; v = v | v; v = v + 8; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("unexpected end of stream"); throw v; label: v = v - 1; v = v << 1; v = v >> v; v = v & 1; v = v | v; goto label; label: v. = v; v. = v; v = v.; v = v[v]; v = v.; v = v[v]; v = v[v]; v = v - v; v = v[v]; return v; } private void setupBlock() throws java.io.IOException { byte[] v; short v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v, v, v, v; byte v; int[] v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; java.io.IOException v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; if v != null goto label; return; label: v = v.; v = v.; v = v.; v = v.; v = v + 1; v = virtualinvoke v.(v); v = v.; v = v.; v[0] = 0; v = v.; v = v.; staticinvoke (v, 0, v, 1, 256); v = 1; v = v[0]; label: if v > 256 goto label; v = v[v]; v = v + v; v[v] = v; v = v + 1; goto label; label: v = 0; v = v.; label: if v > v goto label; v = v[v]; v = v & 255; v = v[v]; v = v + 1; v[v] = v; v[v] = v; v = v + 1; goto label; label: v = v.; if v < 0 goto label; v = v.; v = lengthof v; if v < v goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("stream corrupted"); throw v; label: v = v.; v = v[v]; v. = v; v. = 0; v. = 0; v. = 256; v = v.; if v == 0 goto label; v. = 0; v. = 0; specialinvoke v.(); goto label; label: specialinvoke v.(); label: return; } private void setupRandPartA() throws java.io.IOException { byte[] v; oadd.org.apache.hadoop.io.compress.bzip.CRC v; byte v; int[] v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v, v; boolean v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; short v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; if v > v goto label; v = v.; v. = v; v = v.; v = v.; v = v.; v = v[v]; v = v & 255; v = v.; v = v.; v = v.; v = v[v]; v. = v; v = v.; if v != 0 goto label; v = ; v = v.; v = v[v]; v = v - 1; v. = v; v = v.; v = v + 1; v. = v; if v != 512 goto label; v. = 0; goto label; label: v = v.; v = v - 1; v. = v; label: v = v.; if v != 1 goto label; v = 1; goto label; label: v = 0; label: v = v ^ v; v. = v; v = v.; v = v + 1; v. = v; v. = v; v = ; v. = v; v = v.; virtualinvoke v.(v); goto label; label: specialinvoke v.(); v = v.; v = ; if v != v goto label; specialinvoke v.(); specialinvoke v.(); goto label; label: v = v.; v = ; if v != v goto label; v = ; v. = v; label: return; } private void setupNoRandPartA() throws java.io.IOException { byte[] v; oadd.org.apache.hadoop.io.compress.bzip.CRC v; short v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v; byte v; int[] v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v, v, v; int v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; if v > v goto label; v = v.; v. = v; v = v.; v = v.; v = v.; v = v[v]; v = v & 255; v. = v; v = v.; v = v.; v = v.; v = v[v]; v. = v; v = v.; v = v + 1; v. = v; v. = v; v = ; v. = v; v = v.; virtualinvoke v.(v); goto label; label: v = ; v. = v; specialinvoke v.(); v = v.; v = ; if v != v goto label; specialinvoke v.(); specialinvoke v.(); goto label; label: v = v.; v = ; if v != v goto label; v = ; v. = v; label: return; } private void setupRandPartB() throws java.io.IOException { byte[] v; short v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$Data v, v; byte v; int[] v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream$STATE v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; char v, v; v := @this: oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; v = v.; if v == v goto label; v = ; v. = v; v. = 1; specialinvoke v.(); goto label; label: v = v.; v = v + 1; v. = v; if v < 4 goto label; v = v.; v = v.; v = v.; v = v[v]; v = v & 255; v. = v; v = v.; v = v.; v = v.; v = v[v]; v. = v; v = v.; if v != 0 goto label; v = ; v = v.; v = v[v]; v = v - 1; v. = v; v = v.; v = v + 1; v. = v; if v != 512 goto label; v.