public class org.apache.drill.exec.rpc.RpcCheckedFuture extends org.apache.drill.common.concurrent.AbstractCheckedFuture implements org.apache.drill.exec.rpc.DrillRpcFuture
{
private volatile io.netty.buffer.ByteBuf buffer;
public void <init>(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture)
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture v;
org.apache.drill.exec.rpc.RpcCheckedFuture v;
v := @this: org.apache.drill.exec.rpc.RpcCheckedFuture;
v := @parameter: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture;
specialinvoke v.<org.apache.drill.common.concurrent.AbstractCheckedFuture: void <init>(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture)>(v);
return;
}
public void setBuffer(io.netty.buffer.ByteBuf)
{
io.netty.buffer.ByteBuf v;
org.apache.drill.exec.rpc.RpcCheckedFuture v;
v := @this: org.apache.drill.exec.rpc.RpcCheckedFuture;
v := @parameter: io.netty.buffer.ByteBuf;
if v == null goto label;
virtualinvoke v.<io.netty.buffer.ByteBuf: io.netty.buffer.ByteBuf retain()>();
v.<org.apache.drill.exec.rpc.RpcCheckedFuture: io.netty.buffer.ByteBuf buffer> = v;
label:
return;
}
protected org.apache.drill.exec.rpc.RpcException mapException(java.lang.Exception)
{
java.lang.Exception v;
org.apache.drill.exec.rpc.RpcCheckedFuture v;
org.apache.drill.exec.rpc.RpcException v;
v := @this: org.apache.drill.exec.rpc.RpcCheckedFuture;
v := @parameter: java.lang.Exception;
v = staticinvoke <org.apache.drill.exec.rpc.RpcException: org.apache.drill.exec.rpc.RpcException mapException(java.lang.Throwable)>(v);
return v;
}
public io.netty.buffer.ByteBuf getBuffer()
{
io.netty.buffer.ByteBuf v;
org.apache.drill.exec.rpc.RpcCheckedFuture v;
v := @this: org.apache.drill.exec.rpc.RpcCheckedFuture;
v = v.<org.apache.drill.exec.rpc.RpcCheckedFuture: io.netty.buffer.ByteBuf buffer>;
return v;
}
}