public class oadd.org.apache.drill.exec.rpc.InboundRpcMessage extends oadd.org.apache.drill.exec.rpc.RpcMessage
{
public oadd.io.netty.buffer.ByteBuf pBody;
public oadd.io.netty.buffer.ByteBuf dBody;
public void <init>(oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode, int, int, oadd.io.netty.buffer.ByteBuf, oadd.io.netty.buffer.ByteBuf)
{
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
int v, v;
oadd.org.apache.drill.exec.rpc.InboundRpcMessage v;
oadd.io.netty.buffer.ByteBuf v, v;
v := @this: oadd.org.apache.drill.exec.rpc.InboundRpcMessage;
v := @parameter: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode;
v := @parameter: int;
v := @parameter: int;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
specialinvoke v.<oadd.org.apache.drill.exec.rpc.RpcMessage: void <init>(oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode,int,int)>(v, v, v);
v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody> = v;
v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody> = v;
return;
}
public int getBodySize()
{
int v, v;
oadd.org.apache.drill.exec.rpc.InboundRpcMessage v;
oadd.io.netty.buffer.ByteBuf v, v, v;
v := @this: oadd.org.apache.drill.exec.rpc.InboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody>;
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int capacity()>();
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody>;
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int capacity()>();
v = v + v;
label:
return v;
}
void release()
{
oadd.org.apache.drill.exec.rpc.InboundRpcMessage v;
oadd.io.netty.buffer.ByteBuf v, v, v, v;
v := @this: oadd.org.apache.drill.exec.rpc.InboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody>;
virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: boolean release()>();
label:
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody>;
virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: boolean release()>();
label:
return;
}
public java.lang.String toString()
{
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
int v, v;
java.lang.String v;
oadd.org.apache.drill.exec.rpc.InboundRpcMessage v;
oadd.io.netty.buffer.ByteBuf v, v;
v := @this: oadd.org.apache.drill.exec.rpc.InboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody>;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode mode>;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: int rpcType>;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: int coordinationId>;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf dBody>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.io.netty.buffer.ByteBuf,oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode,int,int,oadd.io.netty.buffer.ByteBuf)>(v, v, v, 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[])>("InboundRpcMessage [pBody=\u, mode=\u, rpcType=\u, coordinationId=\u, dBody=\u]");
return v;
}
public java.io.InputStream getProtobufBodyAsIS()
{
oadd.org.apache.drill.exec.rpc.InboundRpcMessage v;
oadd.io.netty.buffer.ByteBuf v;
oadd.io.netty.buffer.ByteBufInputStream v;
v := @this: oadd.org.apache.drill.exec.rpc.InboundRpcMessage;
v = new oadd.io.netty.buffer.ByteBufInputStream;
v = v.<oadd.org.apache.drill.exec.rpc.InboundRpcMessage: oadd.io.netty.buffer.ByteBuf pBody>;
specialinvoke v.<oadd.io.netty.buffer.ByteBufInputStream: void <init>(oadd.io.netty.buffer.ByteBuf)>(v);
return v;
}
}