class oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker extends oadd.org.apache.hadoop.fs.FSInputChecker { public static final org.slf4j.Logger LOG; private static final int HEADER_LENGTH; private oadd.org.apache.hadoop.fs.ChecksumFs fs; private oadd.org.apache.hadoop.fs.FSDataInputStream datas; private oadd.org.apache.hadoop.fs.FSDataInputStream sums; private int bytesPerSum; private long fileLen; static final boolean $assertionsDisabled; public void (oadd.org.apache.hadoop.fs.ChecksumFs, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException, oadd.org.apache.hadoop.fs.UnresolvedLinkException { int v; oadd.org.apache.hadoop.fs.FsServerDefaults v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.ChecksumFs v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: oadd.org.apache.hadoop.fs.ChecksumFs; v := @parameter: oadd.org.apache.hadoop.fs.Path; v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.hadoop.fs.ChecksumFs,oadd.org.apache.hadoop.fs.Path,int)>(v, v, v); return; } public void (oadd.org.apache.hadoop.fs.ChecksumFs, oadd.org.apache.hadoop.fs.Path, int) throws java.io.IOException, oadd.org.apache.hadoop.fs.UnresolvedLinkException { byte[] v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; boolean v, v, v, v; java.io.FileNotFoundException v; oadd.org.apache.hadoop.fs.FileStatus v; java.util.zip.Checksum v; short v; int v, v, v, v, v, v; java.lang.String v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v, v; org.slf4j.Logger v; oadd.org.apache.hadoop.fs.AbstractFileSystem v, v; java.io.IOException v, v; oadd.org.apache.hadoop.fs.ChecksumFs v; oadd.org.apache.hadoop.fs.Path v, v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: oadd.org.apache.hadoop.fs.ChecksumFs; v := @parameter: oadd.org.apache.hadoop.fs.Path; v := @parameter: int; v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(oadd.org.apache.hadoop.fs.Path,int)>(v, v); v. = 1; v. = -1L; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v. = v; v. = v; v = virtualinvoke v.(v); label: v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v. = v; v = ; v = lengthof v; v = newarray (byte)[v]; v = v.; virtualinvoke v.(v); v = ; v = staticinvoke (v, v); if v != 0 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Not a checksum file: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = staticinvoke (); v = v.; virtualinvoke v.(v, v, v, 4); label: goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v, null, 1, 0); goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Problem opening checksum file: \u. Ignoring exception: "); interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(v, null, 1, 0); label: return; catch java.io.FileNotFoundException from label to label with label; catch java.io.IOException from label to label with label; } private long getChecksumFilePos(long) { int v; long v, v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v = v.; v = v / v; v = 4L * v; v = 8L + v; return v; } protected long getChunkPosition(long) { int v, v; long v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v = v.; v = v / v; v = v.; v = v * v; return v; } public int available() throws java.io.IOException { oadd.org.apache.hadoop.fs.FSDataInputStream v; int v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(); v = v + v; return v; } public int read(long, byte[], int, int) throws java.io.IOException, oadd.org.apache.hadoop.fs.UnresolvedLinkException { java.lang.Throwable v; byte[] v; long v; oadd.org.apache.hadoop.fs.ChecksumFs v; int v, v, v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v, v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; virtualinvoke v.(v, v, v, v); if v != 0 goto label; return 0; label: v = new oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v = v.; v = v.; specialinvoke v.(oadd.org.apache.hadoop.fs.ChecksumFs,oadd.org.apache.hadoop.fs.Path)>(v, v); label: virtualinvoke v.(v); v = virtualinvoke v.(v, v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return v; catch java.lang.Throwable from label to label with label; } public void close() throws java.io.IOException { oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; boolean v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v = v.; virtualinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; v = v.; virtualinvoke v.(v, null, 1, 0); return; } public boolean seekToNewSource(long) throws java.io.IOException { oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v, v; long v, v; oadd.org.apache.hadoop.fs.ChecksumFs v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; boolean v, v, v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v = specialinvoke v.(v); v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v, v, v); v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } protected int readChunk(long, byte[], int, int, byte[]) throws java.io.IOException { byte[] v, v; byte v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; boolean v, v, v, v, v; java.io.EOFException v; long v, v, v, v; java.lang.AssertionError v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; oadd.org.apache.hadoop.fs.FSDataInputStream v, v, v, v, v, v; oadd.org.apache.hadoop.fs.ChecksumException v; oadd.org.apache.hadoop.fs.Path v, v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v := @parameter: byte[]; v = 0; v = virtualinvoke v.(); if v == 0 goto label; v = ; if v != 0 goto label; if v != null goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; if v != 0 goto label; v = lengthof v; v = v % 4; if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; if v != 0 goto label; v = v.; if v >= v goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = v.; v = v / v; v = lengthof v; v = v / 4; v = staticinvoke (v, v); v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = 4 * v; v = virtualinvoke v.(v, 0, v); if v < 0 goto label; v = v % 4; if v == 0 goto label; v = new java.io.EOFException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Checksum file not a length multiple of checksum size in \u at \u checksumpos: \u sumLenread: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v > 0 goto label; v = 1; goto label; label: v = v.; v = v / 4; v = v * v; v = staticinvoke (v, v); label: v = v.; v = virtualinvoke v.(); v = v cmp v; if v == 0 goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = staticinvoke (v, v, v, v); if v == 0 goto label; if v <= 0 goto label; v = new oadd.org.apache.hadoop.fs.ChecksumException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Checksum error: \u at \u0001"); specialinvoke v.(java.lang.String,long)>(v, v); throw v; label: return v; } private long getFileLength() throws java.io.IOException, oadd.org.apache.hadoop.fs.UnresolvedLinkException { long v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs v; byte v; oadd.org.apache.hadoop.fs.FileStatus v; oadd.org.apache.hadoop.fs.Path v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v = v.; v = v cmp -1L; if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; label: v = v.; return v; } public synchronized long skip(long) throws java.io.IOException { byte v; long v, v, v, v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v = virtualinvoke v.(); v = specialinvoke v.(); v = v + v; v = v cmp v; if v <= 0 goto label; v = v - v; label: v = specialinvoke v.(v); return v; } public synchronized void seek(long) throws java.io.IOException { byte v; java.io.IOException v; long v, v; oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker v; v := @this: oadd.org.apache.hadoop.fs.ChecksumFs$ChecksumFSInputChecker; v := @parameter: long; v = specialinvoke v.(); v = v cmp v; if v <= 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Cannot seek after EOF"); throw v; label: specialinvoke v.(v); return; } static void () { org.slf4j.Logger v; java.lang.Class v; boolean v, v; v = class "Loadd/org/apache/hadoop/fs/ChecksumFs;"; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: = v; v = staticinvoke (class "Loadd/org/apache/hadoop/fs/FSInputChecker;"); = v; return; } }