public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToMessageEncoder implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrameEncoder
{
private static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger;
private static final byte OPCODE_CONT;
private static final byte OPCODE_TEXT;
private static final byte OPCODE_BINARY;
private static final byte OPCODE_CLOSE;
private static final byte OPCODE_PING;
private static final byte OPCODE_PONG;
private static final int GATHERING_WRITE_THRESHOLD;
private final boolean maskPayload;
public void <init>(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.MessageToMessageEncoder: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload> = v;
return;
}
protected void encode(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame, java.util.List) throws java.lang.Exception
{
byte[] v;
java.lang.Integer v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v, v;
byte v, v, v, v, v, v, v, v, v, v;
java.nio.ByteOrder v, v, v;
java.lang.Throwable v;
short v, v, v, v, v, v, v;
java.lang.String v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
java.lang.UnsupportedOperationException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder v;
java.nio.ByteBuffer v, v;
java.lang.Byte v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
double v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator v, v, v;
java.lang.Class v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame;
v := @parameter: java.util.List;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf content()>();
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
if v == 0 goto label;
v = 1;
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PingWebSocketFrame;
if v == 0 goto label;
v = 9;
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.PongWebSocketFrame;
if v == 0 goto label;
v = 10;
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.CloseWebSocketFrame;
if v == 0 goto label;
v = 8;
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
if v == 0 goto label;
v = 2;
goto label;
label:
v = v instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.ContinuationWebSocketFrame;
if v == 0 goto label;
v = 0;
goto label;
label:
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Cannot encode frame of type: \u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
label:
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.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Encoding WebSocket Frame opCode={} length={}", v, v);
label:
v = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame: boolean isFinalFragment()>();
if v == 0 goto label;
v = 128;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocketFrame: int rsv()>();
v = v % 8;
v = v << 4;
v = v | v;
v = v % 128;
v = v | v;
if v != 9 goto label;
if v <= 125 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("invalid payload for PING (payload length must be <= 125, was \u0001");
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.TooLongFrameException: void <init>(java.lang.String)>(v);
throw v;
label:
v = null;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v == 0 goto label;
v = 4;
goto label;
label:
v = 0;
label:
if v > 125 goto label;
v = 2 + v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v != 0 goto label;
if v > 1024 goto label;
label:
v = v + v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer(int)>(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 writeByte(int)>(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 writeByte(int)>(v);
goto label;
label:
v = (int) 65535;
if v > v goto label;
v = 4 + v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v != 0 goto label;
if v > 1024 goto label;
label:
v = v + v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer(int)>(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 writeByte(int)>(v);
v = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v == 0 goto label;
v = 254;
goto label;
label:
v = 126;
label:
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 writeByte(int)>(v);
v = v >>> 8;
v = v & 255;
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 writeByte(int)>(v);
v = v & 255;
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 writeByte(int)>(v);
goto label;
label:
v = 10 + v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v != 0 goto label;
if v > 1024 goto label;
label:
v = v + v;
label:
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator alloc()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufAllocator: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf buffer(int)>(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 writeByte(int)>(v);
v = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v == 0 goto label;
v = 255;
goto label;
label:
v = 127;
label:
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 writeByte(int)>(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 writeLong(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: boolean maskPayload>;
if v == 0 goto label;
v = staticinvoke <java.lang.Math: double random()>();
v = v * 2.147483647E9;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(4);
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
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 writeBytes(byte[])>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteOrder order()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: java.nio.ByteOrder order()>();
v = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readerIndex()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writerIndex()>();
if v != v goto label;
v = v[0];
v = v & 255;
v = v << 24;
v = v[1];
v = v & 255;
v = v << 16;
v = v | v;
v = v[2];
v = v & 255;
v = v << 8;
v = v | v;
v = v[3];
v = v & 255;
v = v | v;
v = <java.nio.ByteOrder: java.nio.ByteOrder LITTLE_ENDIAN>;
if v != v goto label;
v = staticinvoke <java.lang.Integer: int reverseBytes(int)>(v);
label:
v = v + 3;
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int getInt(int)>(v);
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 writeInt(int)>(v);
v = v + 4;
goto label;
label:
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: byte getByte(int)>(v);
v = v;
v = v + 1;
v = v % 4;
v = v[v];
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 writeByte(int)>(v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int writableBytes()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: int readableBytes()>();
if v < v goto label;
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 writeBytes(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(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 retain()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: boolean release()>();
label:
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLoggerFactory: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/shaded/io/netty/handler/codec/http/websocketx/WebSocket08FrameEncoder;");
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.websocketx.WebSocket08FrameEncoder: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}