class org.fusesource.mqtt.codec.MQTTProtocolCodec$2 extends java.lang.Object implements org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action
{
final int val$length;
final byte val$header;
final org.fusesource.mqtt.codec.MQTTProtocolCodec this$0;
void <init>(org.fusesource.mqtt.codec.MQTTProtocolCodec, int, byte)
{
byte v;
org.fusesource.mqtt.codec.MQTTProtocolCodec v;
int v;
org.fusesource.mqtt.codec.MQTTProtocolCodec$2 v;
v := @this: org.fusesource.mqtt.codec.MQTTProtocolCodec$2;
v := @parameter: org.fusesource.mqtt.codec.MQTTProtocolCodec;
v := @parameter: int;
v := @parameter: byte;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0> = v;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: int val$length> = v;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: byte val$header> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.fusesource.mqtt.codec.MQTTFrame apply() throws java.io.IOException
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
java.nio.ByteBuffer v, v;
byte v;
int v, v, v, v, v, v, v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action v;
org.fusesource.mqtt.codec.MQTTFrame v, v;
org.fusesource.mqtt.codec.MQTTProtocolCodec v, v, v, v, v, v, v, v, v, v;
org.fusesource.mqtt.codec.MQTTProtocolCodec$2 v;
v := @this: org.fusesource.mqtt.codec.MQTTProtocolCodec$2;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readStart>;
v = v - v;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: int val$length>;
if v >= v goto label;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readEnd> = v;
return null;
label:
v = new org.fusesource.hawtbuf.Buffer;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readStart>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: int val$length>;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readStart>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readStart>;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: int readEnd> = v;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: org.fusesource.mqtt.codec.MQTTProtocolCodec this$0>;
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action readHeader>;
v.<org.fusesource.mqtt.codec.MQTTProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction> = v;
v = new org.fusesource.mqtt.codec.MQTTFrame;
specialinvoke v.<org.fusesource.mqtt.codec.MQTTFrame: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
v = v.<org.fusesource.mqtt.codec.MQTTProtocolCodec$2: byte val$header>;
v = virtualinvoke v.<org.fusesource.mqtt.codec.MQTTFrame: org.fusesource.mqtt.codec.MQTTFrame header(byte)>(v);
return v;
}
}