public class oadd.org.apache.drill.exec.rpc.OutboundRpcMessage extends oadd.org.apache.drill.exec.rpc.RpcMessage
{
static final org.slf4j.Logger logger;
final oadd.com.google.protobuf.MessageLite pBody;
public oadd.io.netty.buffer.ByteBuf[] dBodies;
public transient void <init>(oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode, oadd.com.google.protobuf.Internal$EnumLite, int, oadd.com.google.protobuf.MessageLite, oadd.io.netty.buffer.ByteBuf[])
{
oadd.com.google.protobuf.MessageLite v;
oadd.io.netty.buffer.ByteBuf[] v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
int v, v;
oadd.com.google.protobuf.Internal$EnumLite v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v := @parameter: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode;
v := @parameter: oadd.com.google.protobuf.Internal$EnumLite;
v := @parameter: int;
v := @parameter: oadd.com.google.protobuf.MessageLite;
v := @parameter: oadd.io.netty.buffer.ByteBuf[];
v = interfaceinvoke v.<oadd.com.google.protobuf.Internal$EnumLite: int getNumber()>();
specialinvoke v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: void <init>(oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode,int,int,oadd.com.google.protobuf.MessageLite,oadd.io.netty.buffer.ByteBuf[])>(v, v, v, v, v);
return;
}
transient void <init>(oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode, int, int, oadd.com.google.protobuf.MessageLite, oadd.io.netty.buffer.ByteBuf[])
{
oadd.io.netty.buffer.ByteBuf[] v, v;
java.lang.Object[] v;
java.util.ArrayList v;
oadd.com.google.protobuf.MessageLite v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
int v, v, v, v, v, v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v := @parameter: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode;
v := @parameter: int;
v := @parameter: int;
v := @parameter: oadd.com.google.protobuf.MessageLite;
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.OutboundRpcMessage: oadd.com.google.protobuf.MessageLite pBody> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int readableBytes()>();
if v != 0 goto label;
virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: boolean release()>();
goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (oadd.io.netty.buffer.ByteBuf)[v];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies> = v;
return;
}
public int getBodySize()
{
oadd.com.google.protobuf.MessageLite v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
int v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.com.google.protobuf.MessageLite pBody>;
v = interfaceinvoke v.<oadd.com.google.protobuf.MessageLite: int getSerializedSize()>();
v = staticinvoke <oadd.org.apache.drill.exec.rpc.RpcEncoder: int getRawVarintSize(int)>(v);
v = v + v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: int getRawBodySize()>();
v = v + v;
return v;
}
public int getRawBodySize()
{
oadd.io.netty.buffer.ByteBuf[] v, v, v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
int v, v, v, v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
if v != null goto label;
return 0;
label:
v = 0;
v = 0;
label:
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
v = lengthof v;
if v >= v goto label;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
v = v[v];
v = virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: int readableBytes()>();
v = v + v;
v = v + 1;
goto label;
label:
return v;
}
public java.lang.String toString()
{
oadd.io.netty.buffer.ByteBuf[] v;
oadd.com.google.protobuf.MessageLite v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode v;
int v, v;
java.lang.String v, v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.com.google.protobuf.MessageLite pBody>;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode mode>;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: int rpcType>;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: int coordinationId>;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
v = staticinvoke <java.util.Arrays: java.lang.String toString(java.lang.Object[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.com.google.protobuf.MessageLite,oadd.org.apache.drill.exec.proto.GeneralRPCProtos$RpcMode,int,int,java.lang.String)>(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[])>("OutboundRpcMessage [pBody=\u, mode=\u, rpcType=\u, coordinationId=\u, dBodies=\u]");
return v;
}
void release()
{
oadd.io.netty.buffer.ByteBuf[] v, v;
oadd.org.apache.drill.exec.rpc.OutboundRpcMessage v;
int v, v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.org.apache.drill.exec.rpc.OutboundRpcMessage;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: oadd.io.netty.buffer.ByteBuf[] dBodies>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.io.netty.buffer.ByteBuf: boolean release()>();
v = v + 1;
goto label;
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/rpc/OutboundRpcMessage;");
<oadd.org.apache.drill.exec.rpc.OutboundRpcMessage: org.slf4j.Logger logger> = v;
return;
}
}