class oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream extends oadd.org.apache.hadoop.io.compress.SplitCompressionInputStream { private oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream input; boolean needsReset; private java.io.BufferedInputStream bufferedIn; private boolean isHeaderStripped; private boolean isSubHeaderStripped; private oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE readMode; private long startingPos; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream$POS_ADVERTISEMENT_STATE_MACHINE posSM; long compressedStreamPosition; public void (java.io.InputStream) throws java.io.IOException { oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v; java.io.InputStream v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v := @parameter: java.io.InputStream; v = ; specialinvoke v.(java.io.InputStream,long,long,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE)>(v, 0L, 9223372036854775807L, v); return; } public void (java.io.InputStream, long, long, oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE) throws java.io.IOException { java.io.BufferedInputStream v, v, v, v, v; byte v, v, v, v, v, v; boolean v, v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v, v, v, v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream$POS_ADVERTISEMENT_STATE_MACHINE v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; long v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v; java.io.InputStream v, v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v := @parameter: java.io.InputStream; v := @parameter: long; v := @parameter: long; v := @parameter: oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE; specialinvoke v.(java.io.InputStream,long,long)>(v, v, v); v. = 0; v. = 0; v = ; v. = v; v. = 0L; v = ; v. = v; v. = 0L; v. = 0; v = new java.io.BufferedInputStream; v = v.; specialinvoke v.(java.io.InputStream)>(v); v. = v; v = specialinvoke v.(); v. = v; v. = v; v = 0L; v = v.; v = v cmp 0L; if v != 0 goto label; v = specialinvoke v.(); v. = v; goto label; label: v = v.; v = ; if v != v goto label; v = v.; v = ; v = ; v = v + v; v = v cmp v; if v > 0 goto label; v = ; v = ; v = v + v; v = v + 1; v = v.; v = v - v; v = v; label: v = v cmp 0L; if v <= 0 goto label; v = v.; v = virtualinvoke v.(v); v = v cmp 0L; if v <= 0 goto label; v = v - v; goto label; label: v = v.; v = virtualinvoke v.(); v = (int) -1; if v == v goto label; v = v - 1L; goto label; label: v = new oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; specialinvoke v.(java.io.InputStream,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE)>(v, v); v. = v; v = v.; if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v); label: v = v.; if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v); label: v = v cmp 0L; if v <= 0 goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = ; if v != v goto label; v = v.; v = v cmp 0L; if v == 0 goto label; label: specialinvoke v.(0); label: return; } private java.io.BufferedInputStream readStreamHeader() throws java.io.IOException { byte[] v; java.io.BufferedInputStream v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; java.nio.charset.Charset v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v, v; int v, v, v, v, v, v, v, v, v; java.lang.String v; java.io.IOException v; java.io.InputStream v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v = v.; if v == null goto label; v = v.; v = ; virtualinvoke v.(v); v = ; v = newarray (byte)[v]; v = v.; v = ; v = virtualinvoke v.(v, 0, v); v = (int) -1; if v == v goto label; v = new java.lang.String; v = ; specialinvoke v.(byte[],java.nio.charset.Charset)>(v, v); v = virtualinvoke v.("BZ"); if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v. = 1; v = v.; v = ; if v != v goto label; v = v.; v = ; v = virtualinvoke v.(v, 0, v); v = (int) -1; if v == v goto label; v. = 1; label: v = v.; if v != null goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Failed to read bzip stream."); throw v; label: v = v.; return v; } public void close() throws java.io.IOException { java.lang.Throwable v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v = v.; if v != 0 goto label; label: v = v.; virtualinvoke v.(); v. = 1; label: specialinvoke v.(); goto label; label: v := @caughtexception; specialinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public int read(byte[], int, int) throws java.io.IOException { byte[] v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v, v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; int v, v, v, v, v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream$POS_ADVERTISEMENT_STATE_MACHINE v, v, v, v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v = v.; if v == 0 goto label; specialinvoke v.(); label: v = v.; v = virtualinvoke v.(v, v, v); v = (int) -2; if v != v goto label; v = ; v. = v; label: v = v.; v = ; if v != v goto label; v = v.; v = v + 1; v = virtualinvoke v.(v, v, v); specialinvoke v.(1); v = ; v. = v; label: return v; } public int read() throws java.io.IOException { byte[] v; byte v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; int v, v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v = newarray (byte)[1]; v = virtualinvoke v.(v, 0, 1); if v >= 0 goto label; v = v; goto label; label: v = v[0]; v = v & 255; label: return v; } private void internalReset() throws java.io.IOException { java.io.BufferedInputStream v; oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v = v.; if v == 0 goto label; v. = 0; v = specialinvoke v.(); v = new oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream; v = v.; specialinvoke v.(java.io.InputStream,oadd.org.apache.hadoop.io.compress.SplittableCompressionCodec$READ_MODE)>(v, v); v. = v; label: return; } public void resetState() throws java.io.IOException { oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v. = 1; return; } public long getPos() { long v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v = v.; return v; } private void updatePos(boolean) { oadd.org.apache.hadoop.io.compress.bzip.CBZip2InputStream v; oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream v; long v, v, v, v; boolean v, v; v := @this: oadd.org.apache.hadoop.io.compress.BZip2Codec$BZip2CompressionInputStream; v := @parameter: boolean; if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = v.; v = v.; v = virtualinvoke v.(); v = v + v; v = v + v; v. = v; return; } }