public class oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator extends java.lang.Object
{
private final oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder decoder;
private java.nio.ByteBuffer buffer;
private int[] newValidIndexes;
private int newErasedIndex;
public void <init>(oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder)
{
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder decoder> = v;
return;
}
public void validate(java.nio.ByteBuffer[], int[], java.nio.ByteBuffer[]) throws java.io.IOException
{
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
java.nio.ByteBuffer v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int[] v, v, v, v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder v;
boolean v, v, v, v;
java.nio.ByteBuffer[] v, v, v, v;
java.lang.Throwable v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.InvalidDecodingException v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v := @parameter: java.nio.ByteBuffer[];
v := @parameter: int[];
v := @parameter: java.nio.ByteBuffer[];
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void markBuffers(java.nio.ByteBuffer[])>(v);
label:
v = staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.CoderUtil: java.lang.Object findFirstValidInput(java.lang.Object[])>(v);
v = virtualinvoke v.<java.nio.ByteBuffer: boolean isDirect()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int capacity()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean isDirect()>();
if v != v goto label;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int capacity()>();
if v >= v goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer allocateBuffer(boolean,int)>(v, v);
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer> = v;
label:
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer clear()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer limit(int)>(v);
v = lengthof v;
v = newarray (java.nio.ByteBuffer)[v];
v = 0;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = v[v];
v[v] = v;
v = v + 1;
v = v + 1;
goto label;
label:
v = (int) -1;
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int newErasedIndex> = v;
v = 0;
v = staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.CoderUtil: int[] getValidIndexes(java.lang.Object[])>(v);
v = lengthof v;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
if v == v goto label;
if v != 0 goto label;
v = v[v];
if v == null goto label;
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int newErasedIndex> = v;
v[v] = null;
v = 1;
goto label;
label:
v = v[v];
if v != null goto label;
v = v[v];
v[v] = v;
v = v[v];
if v == null goto label;
v = v + 1;
label:
v = v + 1;
goto label;
label:
v = staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.CoderUtil: int[] getValidIndexes(java.lang.Object[])>(v);
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int[] newValidIndexes> = v;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder decoder>;
v = newarray (int)[1];
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int newErasedIndex>;
v[0] = v;
v = newarray (java.nio.ByteBuffer)[1];
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
v[0] = v;
virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.RawErasureDecoder: void decode(java.nio.ByteBuffer[],int[],java.nio.ByteBuffer[])>(v, v, v);
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int newErasedIndex>;
v = v[v];
v = virtualinvoke v.<java.nio.ByteBuffer: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new oadd.org.apache.hadoop.io.erasurecode.rawcoder.InvalidDecodingException;
specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.InvalidDecodingException: void <init>(java.lang.String)>("Failed to validate decoding");
throw v;
label:
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void toLimits(java.nio.ByteBuffer[])>(v);
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void resetBuffers(java.nio.ByteBuffer[])>(v);
goto label;
label:
v := @caughtexception;
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void toLimits(java.nio.ByteBuffer[])>(v);
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void resetBuffers(java.nio.ByteBuffer[])>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void validate(oadd.org.apache.hadoop.io.erasurecode.ECChunk[], int[], oadd.org.apache.hadoop.io.erasurecode.ECChunk[]) throws java.io.IOException
{
java.nio.ByteBuffer[] v, v;
int[] v;
oadd.org.apache.hadoop.io.erasurecode.ECChunk[] v, v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ECChunk[];
v := @parameter: int[];
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ECChunk[];
v = staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.CoderUtil: java.nio.ByteBuffer[] toBuffers(oadd.org.apache.hadoop.io.erasurecode.ECChunk[])>(v);
v = staticinvoke <oadd.org.apache.hadoop.io.erasurecode.rawcoder.CoderUtil: java.nio.ByteBuffer[] toBuffers(oadd.org.apache.hadoop.io.erasurecode.ECChunk[])>(v);
virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: void validate(java.nio.ByteBuffer[],int[],java.nio.ByteBuffer[])>(v, v, v);
return;
}
private java.nio.ByteBuffer allocateBuffer(boolean, int)
{
int v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
java.nio.ByteBuffer v, v, v;
boolean v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v := @parameter: boolean;
v := @parameter: int;
if v == 0 goto label;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocateDirect(int)>(v);
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer> = v;
goto label;
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer> = v;
label:
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: java.nio.ByteBuffer buffer>;
return v;
}
private static void markBuffers(java.nio.ByteBuffer[])
{
java.nio.ByteBuffer[] v;
int v, v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
if v == null goto label;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer mark()>();
label:
v = v + 1;
goto label;
label:
return;
}
private static void resetBuffers(java.nio.ByteBuffer[])
{
java.nio.ByteBuffer[] v;
int v, v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
if v == null goto label;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer reset()>();
label:
v = v + 1;
goto label;
label:
return;
}
private static void toLimits(java.nio.ByteBuffer[])
{
java.nio.ByteBuffer[] v;
int v, v, v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
if v == null goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: int limit()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
label:
v = v + 1;
goto label;
label:
return;
}
protected int[] getNewValidIndexes()
{
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
int[] v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int[] newValidIndexes>;
return v;
}
protected int getNewErasedIndex()
{
int v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.DecodingValidator: int newErasedIndex>;
return v;
}
}