public class oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder extends oadd.org.apache.hadoop.io.erasurecode.rawcoder.AbstractNativeRawEncoder
{
public void <init>(oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions)
{
java.lang.Throwable v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder v;
java.util.concurrent.locks.ReentrantReadWriteLock v, v, v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v;
oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions v;
int v, v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder;
v := @parameter: oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions;
specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.AbstractNativeRawEncoder: void <init>(oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions)>(v);
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions: int getNumDataUnits()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.io.erasurecode.ErasureCoderOptions: int getNumParityUnits()>();
specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: void initImpl(int,int)>(v, v);
label:
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected void performEncodeImpl(java.nio.ByteBuffer[], int[], int, java.nio.ByteBuffer[], int[]) throws java.io.IOException
{
oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder v;
java.nio.ByteBuffer[] v, v;
int[] v, v;
int v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder;
v := @parameter: java.nio.ByteBuffer[];
v := @parameter: int[];
v := @parameter: int;
v := @parameter: java.nio.ByteBuffer[];
v := @parameter: int[];
specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: void encodeImpl(java.nio.ByteBuffer[],int[],int,java.nio.ByteBuffer[],int[])>(v, v, v, v, v);
return;
}
public void release()
{
java.lang.Throwable v;
oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder v;
java.util.concurrent.locks.ReentrantReadWriteLock v, v, v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
label:
specialinvoke v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: void destroyImpl()>();
label:
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder: java.util.concurrent.locks.ReentrantReadWriteLock encoderLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean preferDirectBuffer()
{
oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder v;
v := @this: oadd.org.apache.hadoop.io.erasurecode.rawcoder.NativeRSRawEncoder;
return 1;
}
private native void initImpl(int, int);
private native void encodeImpl(java.nio.ByteBuffer[], int[], int, java.nio.ByteBuffer[], int[]) throws java.io.IOException;
private native void destroyImpl();
static void <clinit>()
{
staticinvoke <oadd.org.apache.hadoop.io.erasurecode.ErasureCodeNative: void checkNativeCodeLoaded()>();
return;
}
}