final class org.apache.hive.kudu.org.apache.kudu.client.CallResponse extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.DefaultByteBufHolder
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buf;
private final org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header;
private final int totalResponseSize;
private org.apache.hive.kudu.org.apache.kudu.util.Slice message;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader$Builder v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.DefaultByteBufHolder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message> = null;
v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buf> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: int totalResponseSize> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: int readVarInt32(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice nextBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader$Builder newBuilder()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void readProtobuf(org.apache.hive.kudu.org.apache.kudu.util.Slice,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader$Builder: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader build()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader getHeader()
{
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header>;
return v;
}
public int getTotalResponseSize()
{
int v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: int totalResponseSize>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.util.Slice getPBMessage()
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v, v, v, v, v;
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v, v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
int v, v, v, v, v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: void cacheMessage()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: int getSidecarOffsetsCount()>();
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: int getSidecarOffsets(int)>(0);
label:
v = v;
if v < 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
if v <= v goto label;
label:
v = new java.lang.IllegalStateException;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("Main protobuf message invalid. Length is \u while the size of the message excluding the header is \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice subslice(org.apache.hive.kudu.org.apache.kudu.util.Slice,int,int)>(v, 0, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.util.Slice getSidecar(int)
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
int v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.util.Slice v, v, v, v, v;
java.lang.IllegalArgumentException v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: void cacheMessage()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader header>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.rpc.RpcHeader$ResponseHeader: java.util.List getSidecarOffsetsList()>();
if v < 0 goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= v goto label;
label:
v = new java.lang.IllegalArgumentException;
v = interfaceinvoke v.<java.util.List: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("Sidecar \u not valid, response has \u sidecars");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
goto label;
label:
v = v + 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = v - v;
if v < 0 goto label;
if v < 0 goto label;
v = v + v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
if v <= v goto label;
label:
v = new java.lang.IllegalStateException;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,int,int)>(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[])>("Sidecar \u invalid (offset = \u, length = \u). The size of the message excluding the header is \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice subslice(org.apache.hive.kudu.org.apache.kudu.util.Slice,int,int)>(v, v, v);
return v;
}
private void cacheMessage()
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v, v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message>;
if v == null goto label;
return;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buf>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: int readVarInt32(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buf>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice nextBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf,int)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice message> = v;
return;
}
private static org.apache.hive.kudu.org.apache.kudu.util.Slice subslice(org.apache.hive.kudu.org.apache.kudu.util.Slice, int, int)
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v, v;
byte[] v;
int v, v, v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.util.Slice;
v := @parameter: int;
v := @parameter: int;
v = new org.apache.hive.kudu.org.apache.kudu.util.Slice;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: byte[] getRawArray()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int getRawOffset()>();
v = v + v;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: void <init>(byte[],int,int)>(v, v, v);
return v;
}
private static org.apache.hive.kudu.org.apache.kudu.util.Slice nextBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, int)
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v;
byte[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
int v, v, v, v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: int;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte[] array()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int arrayOffset()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = v + v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf skipBytes(int)>(v);
goto label;
label:
v = newarray (byte)[v];
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf readBytes(byte[])>(v);
v = 0;
label:
v = new org.apache.hive.kudu.org.apache.kudu.util.Slice;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: void <init>(byte[],int,int)>(v, v, v);
return v;
}
public boolean equals(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v := @parameter: java.lang.Object;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.DefaultByteBufHolder: boolean equals(java.lang.Object)>(v);
return v;
}
public int hashCode()
{
int v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.DefaultByteBufHolder: int hashCode()>();
return v;
}
}