public class oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor extends java.lang.Object implements oadd.org.apache.hadoop.io.compress.Compressor { private static final org.slf4j.Logger LOG; private static final int DEFAULT_DIRECT_BUFFER_SIZE; private long stream; private oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel level; private oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy strategy; private final oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader windowBits; private int directBufferSize; private byte[] userBuf; private int userBufOff; private int userBufLen; private java.nio.Buffer uncompressedDirectBuf; private int uncompressedDirectBufOff; private int uncompressedDirectBufLen; private boolean keepUncompressedBuf; private java.nio.Buffer compressedDirectBuf; private boolean finish; private boolean finished; private static boolean nativeZlibLoaded; static boolean isNativeZlibLoaded() { boolean v; v = ; return v; } protected final void construct(oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel, oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy, oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader, int) { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy v; int v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader; v := @parameter: int; return; } public void () { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = ; v = ; v = ; specialinvoke v.(oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel,oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy,oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader,int)>(v, v, v, 65536); return; } public void (oadd.org.apache.hadoop.conf.Configuration) { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; oadd.org.apache.hadoop.conf.Configuration v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; v = staticinvoke (v); v = staticinvoke (v); v = ; specialinvoke v.(oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel,oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy,oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader,int)>(v, v, v, 65536); return; } public void (oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel, oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy, oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader, int) { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy v, v; long v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader v, v; java.nio.ByteBuffer v, v; java.nio.Buffer v; int v, v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy; v := @parameter: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader; v := @parameter: int; specialinvoke v.()>(); v. = null; v. = 0; v. = 0; v. = null; v. = 0; v. = 0; v. = 0; v. = null; v. = v; v. = v; v. = v; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); v. = v; v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = v.; virtualinvoke v.(v); return; } public void reinit(oadd.org.apache.hadoop.conf.Configuration) { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionLevel v, v; org.slf4j.Logger v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionStrategy v, v; long v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor$CompressionHeader v; int v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; oadd.org.apache.hadoop.conf.Configuration v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: oadd.org.apache.hadoop.conf.Configuration; virtualinvoke v.(); if v != null goto label; return; label: v = v.; staticinvoke (v); v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v, v); v. = v; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Reinit compressor with new compression configuration"); label: return; } public void setInput(byte[], int, int) { byte[] v; java.lang.ArrayIndexOutOfBoundsException v; java.lang.NullPointerException v; java.nio.Buffer v, v; int v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; if v != null goto label; v = new java.lang.NullPointerException; specialinvoke v.()>(); throw v; label: if v < 0 goto label; if v < 0 goto label; v = lengthof v; v = v - v; if v <= v goto label; label: v = new java.lang.ArrayIndexOutOfBoundsException; specialinvoke v.()>(); throw v; label: v. = v; v. = v; v. = v; v. = 0; virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); return; } void setInputFromSavedData() { byte[] v; java.nio.Buffer v, v, v; int v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v); v = v.; v = v - v; v. = v; v = v.; v = v + v; v. = v; v = v.; v = virtualinvoke v.(); v. = v; return; } public void setDictionary(byte[], int, int) { byte[] v; long v, v; java.lang.ArrayIndexOutOfBoundsException v; java.lang.NullPointerException v; byte v; int v, v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v = v.; v = v cmp 0L; if v == 0 goto label; if v != null goto label; label: v = new java.lang.NullPointerException; specialinvoke v.()>(); throw v; label: if v < 0 goto label; if v < 0 goto label; v = lengthof v; v = v - v; if v <= v goto label; label: v = new java.lang.ArrayIndexOutOfBoundsException; specialinvoke v.()>(); throw v; label: v = v.; staticinvoke (v, v, v, v); return; } public boolean needsInput() { java.nio.Buffer v, v, v; int v, v, v, v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; boolean v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; return 0; label: v = v.; if v == 0 goto label; v = v.; if v <= 0 goto label; return 0; label: v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; if v > 0 goto label; return 1; label: virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v <= 0 goto label; return 1; label: return 0; label: return 0; } public void finish() { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v. = 1; return; } public boolean finished() { java.nio.Buffer v; int v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; boolean v, v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int compress(byte[], int, int) throws java.io.IOException { byte[] v; java.lang.NullPointerException v; java.nio.Buffer v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v; java.lang.ArrayIndexOutOfBoundsException v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; if v != null goto label; v = new java.lang.NullPointerException; specialinvoke v.()>(); throw v; label: if v < 0 goto label; if v < 0 goto label; v = lengthof v; v = v - v; if v <= v goto label; label: v = new java.lang.ArrayIndexOutOfBoundsException; specialinvoke v.()>(); throw v; label: v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = staticinvoke (v, v); v = v.; virtualinvoke v.(v, v, v); return v; label: v = v.; virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.(v); v = specialinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; if v > 0 goto label; v. = 0; v = v.; virtualinvoke v.(); v. = 0; v. = 0; goto label; label: v. = 1; label: v = staticinvoke (v, v); v = v.; virtualinvoke v.(v, v, v); return v; } public long getBytesWritten() { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; long v, v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; specialinvoke v.(); v = v.; v = staticinvoke (v); return v; } public long getBytesRead() { oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; long v, v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; specialinvoke v.(); v = v.; v = staticinvoke (v); return v; } public void reset() { java.nio.Buffer v, v, v; int v, v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; long v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; specialinvoke v.(); v = v.; staticinvoke (v); v. = 0; v. = 0; v = v.; virtualinvoke v.(); v. = 0; v. = 0; v. = 0; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v. = 0; v. = 0; return; } public void end() { byte v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; long v, v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = v.; v = v cmp 0L; if v == 0 goto label; v = v.; staticinvoke (v); v. = 0L; label: return; } private void checkStream() { byte v; oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor v; long v; java.lang.NullPointerException v; v := @this: oadd.org.apache.hadoop.io.compress.zlib.ZlibCompressor; v = v.; v = v cmp 0L; if v != 0 goto label; v = new java.lang.NullPointerException; specialinvoke v.()>(); throw v; label: return; } private static native void initIDs(); private static native long init(int, int, int); private static native void setDictionary(long, byte[], int, int); private native int deflateBytesDirect(); private static native long getBytesRead(long); private static native long getBytesWritten(long); private static native void reset(long); private static native void end(long); public static native java.lang.String getLibraryName(); static void () { java.lang.Throwable v; org.slf4j.Logger v; boolean v; v = staticinvoke (class "Loadd/org/apache/hadoop/io/compress/zlib/ZlibCompressor;"); = v; = 0; v = staticinvoke (); if v == 0 goto label; label: staticinvoke (); = 1; label: goto label; label: v := @caughtexception; label: return; catch java.lang.Throwable from label to label with label; } }