class oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream extends oadd.org.apache.hadoop.fs.FSInputStream implements oadd.org.apache.hadoop.fs.HasFileDescriptor
{
private java.io.FileInputStream fis;
private long position;
final oadd.org.apache.hadoop.fs.RawLocalFileSystem this$0;
public void <init>(oadd.org.apache.hadoop.fs.RawLocalFileSystem, oadd.org.apache.hadoop.fs.Path) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
oadd.org.apache.hadoop.fs.Path v;
java.io.File v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: oadd.org.apache.hadoop.fs.RawLocalFileSystem;
v := @parameter: oadd.org.apache.hadoop.fs.Path;
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: oadd.org.apache.hadoop.fs.RawLocalFileSystem this$0> = v;
specialinvoke v.<oadd.org.apache.hadoop.fs.FSInputStream: void <init>()>();
v = new java.io.FileInputStream;
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem: java.io.File pathToFile(oadd.org.apache.hadoop.fs.Path)>(v);
specialinvoke v.<java.io.FileInputStream: void <init>(java.io.File)>(v);
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis> = v;
return;
}
public void seek(long) throws java.io.IOException
{
byte v;
long v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
java.io.EOFException v;
java.nio.channels.FileChannel v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: long;
v = v cmp 0L;
if v >= 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>(java.lang.String)>("Cannot seek to a negative offset");
throw v;
label:
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: java.nio.channels.FileChannel getChannel()>();
virtualinvoke v.<java.nio.channels.FileChannel: java.nio.channels.FileChannel position(long)>(v);
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position> = v;
return;
}
public long getPos() throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position>;
return v;
}
public boolean seekToNewSource(long) throws java.io.IOException
{
long v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: long;
return 0;
}
public int available() throws java.io.IOException
{
int v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: int available()>();
return v;
}
public void close() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
virtualinvoke v.<java.io.FileInputStream: void close()>();
return;
}
public boolean markSupported()
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
return 0;
}
public int read() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem v;
oadd.org.apache.hadoop.fs.FSError v;
java.io.IOException v;
long v, v;
java.io.FileInputStream v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
int v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
label:
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: int read()>();
if v < 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position>;
v = v + 1L;
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position> = v;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: oadd.org.apache.hadoop.fs.RawLocalFileSystem this$0>;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics: void incrementBytesRead(long)>(1L);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.FSError;
specialinvoke v.<oadd.org.apache.hadoop.fs.FSError: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public int read(byte[], int, int) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem v;
byte[] v;
oadd.org.apache.hadoop.fs.FSError v;
java.io.IOException v;
long v, v, v;
java.io.FileInputStream v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
int v, v, v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: void validatePositionedReadArgs(long,byte[],int,int)>(v, v, v, v);
label:
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: int read(byte[],int,int)>(v, v, v);
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position>;
v = v + v;
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position> = v;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: oadd.org.apache.hadoop.fs.RawLocalFileSystem this$0>;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics: void incrementBytesRead(long)>(v);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.FSError;
specialinvoke v.<oadd.org.apache.hadoop.fs.FSError: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public int read(long, byte[], int, int) throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem v;
byte[] v;
oadd.org.apache.hadoop.fs.FSError v;
java.io.IOException v;
long v;
java.io.FileInputStream v;
java.nio.ByteBuffer v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics v;
int v, v, v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.nio.channels.FileChannel v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: long;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: void validatePositionedReadArgs(long,byte[],int,int)>(v, v, v, v);
if v != 0 goto label;
return 0;
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[],int,int)>(v, v, v);
label:
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: java.nio.channels.FileChannel getChannel()>();
v = virtualinvoke v.<java.nio.channels.FileChannel: int read(java.nio.ByteBuffer,long)>(v, v);
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: oadd.org.apache.hadoop.fs.RawLocalFileSystem this$0>;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem: oadd.org.apache.hadoop.fs.FileSystem$Statistics statistics>;
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics: void incrementBytesRead(long)>(v);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.hadoop.fs.FSError;
specialinvoke v.<oadd.org.apache.hadoop.fs.FSError: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public long skip(long) throws java.io.IOException
{
byte v;
long v, v, v, v;
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: long skip(long)>(v);
v = v cmp 0L;
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position>;
v = v + v;
v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: long position> = v;
label:
return v;
}
public java.io.FileDescriptor getFileDescriptor() throws java.io.IOException
{
oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream v;
java.io.FileInputStream v;
java.io.FileDescriptor v;
v := @this: oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream;
v = v.<oadd.org.apache.hadoop.fs.RawLocalFileSystem$LocalFSFileInputStream: java.io.FileInputStream fis>;
v = virtualinvoke v.<java.io.FileInputStream: java.io.FileDescriptor getFD()>();
return v;
}
}