public class oadd.org.apache.hadoop.io.compress.CompressorStream extends oadd.org.apache.hadoop.io.compress.CompressionOutputStream
{
protected oadd.org.apache.hadoop.io.compress.Compressor compressor;
protected byte[] buffer;
protected boolean closed;
private byte[] oneByte;
public void <init>(java.io.OutputStream, oadd.org.apache.hadoop.io.compress.Compressor, int)
{
java.io.OutputStream v;
byte[] v, v;
oadd.org.apache.hadoop.io.compress.Compressor v;
java.lang.IllegalArgumentException v;
java.lang.NullPointerException v;
int v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v := @parameter: java.io.OutputStream;
v := @parameter: oadd.org.apache.hadoop.io.compress.Compressor;
v := @parameter: int;
specialinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionOutputStream: void <init>(java.io.OutputStream)>(v);
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: boolean closed> = 0;
v = newarray (byte)[1];
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] oneByte> = v;
if v == null goto label;
if v != null goto label;
label:
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>()>();
throw v;
label:
if v > 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Illegal bufferSize");
throw v;
label:
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor> = v;
v = newarray (byte)[v];
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] buffer> = v;
return;
}
public void <init>(java.io.OutputStream, oadd.org.apache.hadoop.io.compress.Compressor)
{
java.io.OutputStream v;
oadd.org.apache.hadoop.io.compress.Compressor v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v := @parameter: java.io.OutputStream;
v := @parameter: oadd.org.apache.hadoop.io.compress.Compressor;
specialinvoke v.<oadd.org.apache.hadoop.io.compress.CompressorStream: void <init>(java.io.OutputStream,oadd.org.apache.hadoop.io.compress.Compressor,int)>(v, v, 512);
return;
}
protected void <init>(java.io.OutputStream)
{
java.io.OutputStream v;
byte[] v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v := @parameter: java.io.OutputStream;
specialinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionOutputStream: void <init>(java.io.OutputStream)>(v);
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: boolean closed> = 0;
v = newarray (byte)[1];
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] oneByte> = v;
return;
}
public void write(byte[], int, int) throws java.io.IOException
{
byte[] v;
java.lang.IndexOutOfBoundsException v;
oadd.org.apache.hadoop.io.compress.Compressor v, v, v;
int v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
boolean v, v;
java.io.IOException v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: boolean finished()>();
if v == 0 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("write beyond end of stream");
throw v;
label:
v = v | v;
v = v + v;
v = v | v;
v = lengthof v;
v = v + v;
v = v - v;
v = v | v;
if v >= 0 goto label;
v = new java.lang.IndexOutOfBoundsException;
specialinvoke v.<java.lang.IndexOutOfBoundsException: void <init>()>();
throw v;
label:
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: void setInput(byte[],int,int)>(v, v, v);
label:
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: boolean needsInput()>();
if v != 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.io.compress.CompressorStream: void compress()>();
goto label;
label:
return;
}
protected void compress() throws java.io.IOException
{
java.io.OutputStream v;
byte[] v, v, v;
oadd.org.apache.hadoop.io.compress.Compressor v;
int v, v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] buffer>;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] buffer>;
v = lengthof v;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: int compress(byte[],int,int)>(v, 0, v);
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: java.io.OutputStream out>;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] buffer>;
virtualinvoke v.<java.io.OutputStream: void write(byte[],int,int)>(v, 0, v);
label:
return;
}
public void finish() throws java.io.IOException
{
oadd.org.apache.hadoop.io.compress.Compressor v, v, v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
boolean v, v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: boolean finished()>();
if v != 0 goto label;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: void finish()>();
label:
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: boolean finished()>();
if v != 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.io.compress.CompressorStream: void compress()>();
goto label;
label:
return;
}
public void resetState() throws java.io.IOException
{
oadd.org.apache.hadoop.io.compress.Compressor v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: oadd.org.apache.hadoop.io.compress.Compressor compressor>;
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: void reset()>();
return;
}
public void close() throws java.io.IOException
{
oadd.org.apache.hadoop.io.compress.CompressorStream v;
boolean v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: boolean closed>;
if v != 0 goto label;
v.<oadd.org.apache.hadoop.io.compress.CompressorStream: boolean closed> = 1;
label:
return;
}
public void write(int) throws java.io.IOException
{
byte[] v, v, v;
int v, v, v;
oadd.org.apache.hadoop.io.compress.CompressorStream v;
v := @this: oadd.org.apache.hadoop.io.compress.CompressorStream;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] oneByte>;
v = v & 255;
v[0] = v;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] oneByte>;
v = v.<oadd.org.apache.hadoop.io.compress.CompressorStream: byte[] oneByte>;
v = lengthof v;
virtualinvoke v.<oadd.org.apache.hadoop.io.compress.CompressorStream: void write(byte[],int,int)>(v, 0, v);
return;
}
}