public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private final java.io.File f;
private final long position;
private final long count;
private long transferred;
private java.nio.channels.FileChannel file;
public void <init>(java.nio.channels.FileChannel, long, long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
java.lang.Object v;
long v, v, v, v;
java.nio.channels.FileChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "file");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: long checkPositiveOrZero(long,java.lang.String)>(v, "position");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: long checkPositiveOrZero(long,java.lang.String)>(v, "count");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.io.File f> = null;
return;
}
public void <init>(java.io.File, long, long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
java.lang.Object v;
long v, v, v, v;
java.io.File v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: long;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "f");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.io.File f> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: long checkPositiveOrZero(long,java.lang.String)>(v, "position");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: long checkPositiveOrZero(long,java.lang.String)>(v, "count");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count> = v;
return;
}
public boolean isOpen()
{
java.nio.channels.FileChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void open() throws java.io.IOException
{
java.io.RandomAccessFile v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
int v;
java.nio.channels.FileChannel v;
java.io.File v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: boolean isOpen()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: int refCnt()>();
if v <= 0 goto label;
v = new java.io.RandomAccessFile;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.io.File f>;
specialinvoke v.<java.io.RandomAccessFile: void <init>(java.io.File,java.lang.String)>(v, "r");
v = virtualinvoke v.<java.io.RandomAccessFile: java.nio.channels.FileChannel getChannel()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file> = v;
label:
return;
}
public long position()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position>;
return v;
}
public long count()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count>;
return v;
}
public long transfered()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred>;
return v;
}
public long transferred()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred>;
return v;
}
public long transferTo(java.nio.channels.WritableByteChannel, long) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IllegalReferenceCountException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
long v, v, v, v, v, v, v, v, v, v;
byte v, v, v, v, v;
int v;
java.lang.String v;
java.lang.IllegalArgumentException v;
java.nio.channels.WritableByteChannel v;
java.nio.channels.FileChannel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: java.nio.channels.WritableByteChannel;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count>;
v = v - v;
v = v cmp 0L;
if v < 0 goto label;
v = v cmp 0L;
if v >= 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count>;
v = v - 1L;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("position out of range: \u (expected: 0 - \u)");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v cmp 0L;
if v != 0 goto label;
return 0L;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: int refCnt()>();
if v != 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IllegalReferenceCountException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.IllegalReferenceCountException: void <init>(int)>(0);
throw v;
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: void open()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position>;
v = v + v;
v = virtualinvoke v.<java.nio.channels.FileChannel: long transferTo(long,long,java.nio.channels.WritableByteChannel)>(v, v, v);
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred>;
v = v + v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long transferred> = v;
goto label;
label:
v = v cmp 0L;
if v != 0 goto label;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: void validate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion,long)>(v, v);
label:
return v;
}
protected void deallocate()
{
java.nio.channels.FileChannel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file>;
if v != null goto label;
return;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file> = null;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion retain()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted retain()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion retain(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.AbstractReferenceCounted: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.ReferenceCounted retain(int)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion touch()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.FileRegion touch(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: java.lang.Object;
return v;
}
static void validate(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion, long) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion v;
java.io.IOException v;
long v, v, v, v, v, v, v, v;
byte v;
java.lang.String v;
java.nio.channels.FileChannel v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: java.nio.channels.FileChannel file>;
v = virtualinvoke v.<java.nio.channels.FileChannel: long size()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count>;
v = v - v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long position>;
v = v + v;
v = v + v;
v = v cmp v;
if v <= 0 goto label;
v = new java.io.IOException;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: long count>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Underlying file size \u smaller then requested count \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/channel/DefaultFileRegion;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultFileRegion: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}