public class oadd.org.apache.drill.exec.record.RawFragmentBatch extends java.lang.Object
{
private final oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch header;
private final oadd.io.netty.buffer.DrillBuf body;
private final oadd.org.apache.drill.exec.rpc.data.AckSender sender;
private final java.util.concurrent.atomic.AtomicBoolean ackSent;
public void <init>(oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch, oadd.io.netty.buffer.DrillBuf, oadd.org.apache.drill.exec.rpc.data.AckSender)
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.io.netty.buffer.DrillBuf v;
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch v;
oadd.org.apache.drill.exec.rpc.data.AckSender v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v := @parameter: oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch;
v := @parameter: oadd.io.netty.buffer.DrillBuf;
v := @parameter: oadd.org.apache.drill.exec.rpc.data.AckSender;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: java.util.concurrent.atomic.AtomicBoolean ackSent> = v;
v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch header> = v;
v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender> = v;
v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body> = v;
if v == null goto label;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: oadd.io.netty.buffer.ByteBuf retain(int)>(1);
label:
return;
}
public oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch getHeader()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch header>;
return v;
}
public oadd.io.netty.buffer.DrillBuf getBody()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.io.netty.buffer.DrillBuf v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
return v;
}
public java.lang.String toString()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.io.netty.buffer.DrillBuf v;
java.lang.String v;
oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch header>;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.drill.exec.proto.BitData$FragmentRecordBatch,oadd.io.netty.buffer.DrillBuf)>(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[])>("RawFragmentBatch [header=\u, body=\u]");
return v;
}
public void release()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.io.netty.buffer.DrillBuf v, v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: boolean release(int)>(1);
label:
return;
}
public oadd.org.apache.drill.exec.rpc.data.AckSender getSender()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.org.apache.drill.exec.rpc.data.AckSender v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender>;
return v;
}
public synchronized void sendOk()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.drill.exec.rpc.data.AckSender v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: java.util.concurrent.atomic.AtomicBoolean ackSent>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender>;
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.data.AckSender: void sendOk()>();
label:
return;
}
public synchronized void sendOk(int)
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
int v;
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.drill.exec.rpc.data.AckSender v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: java.util.concurrent.atomic.AtomicBoolean ackSent>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.org.apache.drill.exec.rpc.data.AckSender sender>;
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.data.AckSender: void sendOk(int)>(v);
label:
return;
}
public long getByteCount()
{
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
oadd.io.netty.buffer.DrillBuf v, v;
int v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: oadd.io.netty.buffer.DrillBuf body>;
v = virtualinvoke v.<oadd.io.netty.buffer.DrillBuf: int readableBytes()>();
label:
return v;
}
public boolean isAckSent()
{
java.util.concurrent.atomic.AtomicBoolean v;
oadd.org.apache.drill.exec.record.RawFragmentBatch v;
boolean v;
v := @this: oadd.org.apache.drill.exec.record.RawFragmentBatch;
v = v.<oadd.org.apache.drill.exec.record.RawFragmentBatch: java.util.concurrent.atomic.AtomicBoolean ackSent>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
}