public abstract class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec extends java.lang.Object implements org.fusesource.hawtdispatch.transport.ProtocolCodec
{
protected org.fusesource.hawtdispatch.util.BufferPools bufferPools;
protected org.fusesource.hawtdispatch.util.BufferPool writeBufferPool;
protected org.fusesource.hawtdispatch.util.BufferPool readBufferPool;
protected int writeBufferSize;
protected long writeCounter;
protected java.nio.channels.GatheringByteChannel writeChannel;
protected org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer;
protected long lastWriteIoSize;
protected java.util.LinkedList writeBuffer;
private long writeBufferRemaining;
protected long readCounter;
protected int readBufferSize;
protected java.nio.channels.ReadableByteChannel readChannel;
protected java.nio.ByteBuffer readBuffer;
protected java.nio.ByteBuffer directReadBuffer;
protected int readEnd;
protected int readStart;
protected int lastReadIoSize;
protected org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction;
static final boolean $assertionsDisabled;
public void <init>()
{
java.util.LinkedList v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize> = 65536;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter> = 0L;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel> = null;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize> = 0L;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer> = v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining> = 0L;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter> = 0L;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize> = 65536;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel> = null;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer> = null;
return;
}
public void setTransport(org.fusesource.hawtdispatch.transport.Transport)
{
org.fusesource.hawtdispatch.util.BufferPools v, v, v;
org.fusesource.hawtdispatch.util.BufferPool v, v;
boolean v, v, v, v;
java.net.Socket v, v, v, v;
java.net.SocketException v;
org.fusesource.hawtdispatch.transport.Transport v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v, v, v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action v, v;
java.nio.channels.ReadableByteChannel v, v, v;
java.nio.channels.WritableByteChannel v;
java.nio.channels.GatheringByteChannel v, v, v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: org.fusesource.hawtdispatch.transport.Transport;
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: java.nio.channels.WritableByteChannel getWriteChannel()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel> = v;
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: java.nio.channels.ReadableByteChannel getReadChannel()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction>;
if v != null goto label;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action initialDecodeAction()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction> = v;
label:
v = v instanceof org.fusesource.hawtdispatch.transport.TcpTransport;
if v == 0 goto label;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.TcpTransport: int getSendBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize> = v;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.TcpTransport: int getReceiveBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize> = v;
goto label;
label:
v = v instanceof org.fusesource.hawtdispatch.transport.UdpTransport;
if v == 0 goto label;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.UdpTransport: int getSendBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize> = v;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.UdpTransport: int getReceiveBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize> = v;
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = v instanceof java.nio.channels.SocketChannel;
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = virtualinvoke v.<java.nio.channels.SocketChannel: java.net.Socket socket()>();
v = virtualinvoke v.<java.net.Socket: int getSendBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel>;
v = virtualinvoke v.<java.nio.channels.SocketChannel: java.net.Socket socket()>();
v = virtualinvoke v.<java.net.Socket: int getReceiveBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize> = v;
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = v instanceof org.fusesource.hawtdispatch.transport.SslTransport$SSLChannel;
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.SslTransport$SSLChannel: java.net.Socket socket()>();
v = virtualinvoke v.<java.net.Socket: int getSendBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.SslTransport$SSLChannel: java.net.Socket socket()>();
v = virtualinvoke v.<java.net.Socket: int getReceiveBufferSize()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize> = v;
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPools bufferPools>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPools bufferPools>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPools: org.fusesource.hawtdispatch.util.BufferPool getBufferPool(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPools bufferPools>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPools: org.fusesource.hawtdispatch.util.BufferPool getBufferPool(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool> = v;
label:
return;
catch java.net.SocketException from label to label with label;
}
public int getReadBufferSize()
{
int v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize>;
return v;
}
public int getWriteBufferSize()
{
int v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
return v;
}
public boolean full()
{
byte v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v;
long v;
boolean v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
v = v cmp v;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isEmpty()
{
byte v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v, v;
int v;
long v;
boolean v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = v cmp 0L;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: int size()>();
if v != 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long getWriteCounter()
{
long v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter>;
return v;
}
public long getLastWriteSize()
{
long v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
return v;
}
protected abstract void encode(java.lang.Object) throws java.io.IOException;
public org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState write(java.lang.Object) throws java.io.IOException
{
org.fusesource.hawtbuf.DataByteArrayOutputStream v, v, v;
org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState v, v, v;
byte v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v;
java.lang.Object v;
boolean v, v;
double v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean full()>();
if v == 0 goto label;
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState FULL>;
return v;
label:
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean isEmpty()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
if v != null goto label;
v = specialinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream allocateNextWriteBuffer()>();
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer> = v;
label:
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void encode(java.lang.Object)>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: int size()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
v = v * 0.75;
v = v cmpl v;
if v < 0 goto label;
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void flushNextWriteBuffer()>();
label:
if v == 0 goto label;
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState WAS_EMPTY>;
return v;
label:
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState NOT_EMPTY>;
return v;
}
private org.fusesource.hawtbuf.DataByteArrayOutputStream allocateNextWriteBuffer()
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
int v;
org.fusesource.hawtdispatch.util.BufferPool v, v;
java.lang.Object v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$1 v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool>;
if v == null goto label;
v = new org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$1;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: java.lang.Object checkout()>();
specialinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$1: void <init>(org.fusesource.hawtdispatch.transport.AbstractProtocolCodec,byte[])>(v, v);
return v;
label:
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(v);
return v;
}
protected void writeDirect(java.nio.ByteBuffer) throws java.io.IOException
{
byte[] v, v;
long v, v;
java.nio.ByteBuffer v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v;
java.util.LinkedList v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v, v, v, v, v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.nio.ByteBuffer;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: int position()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
v = lengthof v;
v = v - v;
if v <= v goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer get(byte[],int,int)>(v, v, v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = v + v;
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void position(int)>(v);
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: int size()>();
if v == 0 goto label;
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void flushNextWriteBuffer()>();
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining> = v;
label:
return;
}
protected void flushNextWriteBuffer()
{
org.fusesource.hawtbuf.DataByteArrayOutputStream v, v;
long v, v;
org.fusesource.hawtbuf.Buffer v;
java.nio.ByteBuffer v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v;
java.util.LinkedList v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = specialinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream allocateNextWriteBuffer()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: org.fusesource.hawtbuf.Buffer toBuffer()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.Buffer: java.nio.ByteBuffer toByteBuffer()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining> = v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer> = v;
return;
}
public org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState flush() throws java.io.IOException
{
byte[] v;
org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState v, v, v;
org.fusesource.hawtdispatch.util.BufferPool v, v;
byte v, v, v;
boolean v, v, v;
java.nio.ByteBuffer[] v;
java.lang.Object[] v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v;
java.util.LinkedList v, v, v, v, v, v, v, v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v, v, v, v;
java.lang.Object v, v, v, v;
java.nio.channels.GatheringByteChannel v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = v cmp 0L;
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v != 1 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object getFirst()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = interfaceinvoke v.<java.nio.channels.GatheringByteChannel: int write(java.nio.ByteBuffer)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v cmp 0L;
if v != 0 goto label;
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState NOT_EMPTY>;
return v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v - v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter> = v;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object removeFirst()>();
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void onBufferFlushed(java.nio.ByteBuffer)>(v);
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
v = newarray (java.nio.ByteBuffer)[v];
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.GatheringByteChannel writeChannel>;
v = lengthof v;
v = interfaceinvoke v.<java.nio.channels.GatheringByteChannel: long write(java.nio.ByteBuffer[],int,int)>(v, 0, v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v cmp 0L;
if v != 0 goto label;
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState NOT_EMPTY>;
return v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v - v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeBufferRemaining> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long lastWriteIoSize>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long writeCounter> = v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object getFirst()>();
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.util.LinkedList writeBuffer>;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object removeFirst()>();
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void onBufferFlushed(java.nio.ByteBuffer)>(v);
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: int size()>();
if v != 0 goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer>;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: void checkin(java.lang.Object)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.DataByteArrayOutputStream nextWriteBuffer> = null;
label:
v = <org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState: org.fusesource.hawtdispatch.transport.ProtocolCodec$BufferState EMPTY>;
return v;
label:
virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: void flushNextWriteBuffer()>();
goto label;
}
protected void onBufferFlushed(java.nio.ByteBuffer)
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
java.nio.ByteBuffer v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.nio.ByteBuffer;
return;
}
protected abstract org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action initialDecodeAction();
public void unread(byte[])
{
byte[] v;
long v, v, v;
java.lang.AssertionError v;
java.nio.ByteBuffer v, v;
byte v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v;
boolean v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: byte[];
v = <org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
v = v cmp 0L;
if v == 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = lengthof v;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte[])>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
v = lengthof v;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter> = v;
return;
}
public long getReadCounter()
{
long v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
return v;
}
public long getLastReadSize()
{
int v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
return v;
}
public java.lang.Object read() throws java.io.IOException
{
byte[] v, v, v, v, v, v;
org.fusesource.hawtdispatch.util.BufferPool v, v, v, v, v, v, v, v;
long v, v, v, v, v, v;
java.lang.AssertionError v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action v, v;
java.nio.ByteBuffer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v, v, v;
java.io.EOFException v, 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, v, v, v, v, v, v, v;
java.nio.channels.ReadableByteChannel v, v;
java.lang.Object v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = null;
label:
if v != null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer>;
if v == null goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer>;
v = interfaceinvoke v.<java.nio.channels.ReadableByteChannel: int read(java.nio.ByteBuffer)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
v = (int) -1;
if v != v goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>(java.lang.String)>("Peer disconnected");
throw v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
if v != 0 goto label;
return null;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction>;
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action: java.lang.Object apply()>();
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
if v < v goto label;
label:
v = 0;
v = 0;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int capacity()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: int getBufferSize()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
if v != 0 goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v - v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v - v;
if v <= v goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize>;
v = staticinvoke <java.lang.Math: int max(int,int)>(v, v);
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize>;
v = v + v;
label:
if v <= 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
staticinvoke <java.util.Arrays: byte[] copyOfRange(byte[],int,int)>(v, v, v);
goto label;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: int getBufferSize()>();
if v != v goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: java.lang.Object checkout()>();
goto label;
label:
v = newarray (byte)[v];
label:
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: void checkin(java.lang.Object)>(v);
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart> = 0;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.channels.ReadableByteChannel readChannel>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = interfaceinvoke v.<java.nio.channels.ReadableByteChannel: int read(java.nio.ByteBuffer)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
v = (int) -1;
if v != v goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter>;
v = v + 1L;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: long readCounter> = v;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>(java.lang.String)>("Peer disconnected");
throw v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int lastReadIoSize>;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
if v != v goto label;
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: void checkin(java.lang.Object)>(v);
label:
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart> = 0;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = 0;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer> = null;
label:
return null;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
if v > v goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = staticinvoke <java.util.Arrays: byte[] copyOfRange(byte[],int,int)>(v, 0, v);
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPool: void checkin(java.lang.Object)>(v);
label:
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer> = v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action nextDecodeAction>;
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec$Action: java.lang.Object apply()>();
v = <org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
if v <= v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
return v;
}
protected org.fusesource.hawtbuf.Buffer readUntil(java.lang.Byte) throws java.net.ProtocolException
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v;
java.lang.Byte v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.lang.Byte;
v = (int) -1;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.Buffer readUntil(java.lang.Byte,int)>(v, v);
return v;
}
protected org.fusesource.hawtbuf.Buffer readUntil(java.lang.Byte, int) throws java.net.ProtocolException
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v;
java.lang.Byte v;
org.fusesource.hawtbuf.Buffer v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.lang.Byte;
v := @parameter: int;
v = virtualinvoke v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtbuf.Buffer readUntil(java.lang.Byte,int,java.lang.String)>(v, v, "Maximum protocol buffer length exeeded");
return v;
}
protected org.fusesource.hawtbuf.Buffer readUntil(java.lang.Byte, int, java.lang.String) throws java.net.ProtocolException
{
byte[] v;
org.fusesource.hawtbuf.Buffer v, v;
java.nio.ByteBuffer v, v;
byte v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
java.lang.Byte v;
java.net.ProtocolException v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.lang.Byte;
v := @parameter: int;
v := @parameter: java.lang.String;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = new org.fusesource.hawtbuf.Buffer;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v - v;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
v = virtualinvoke v.<java.lang.Byte: byte byteValue()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.Buffer: int indexOf(byte)>(v);
if v < 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v + 1;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v - v;
if v < 0 goto label;
if v <= v goto label;
v = new java.net.ProtocolException;
specialinvoke v.<java.net.ProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.fusesource.hawtbuf.Buffer;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
return v;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtbuf.Buffer: int length>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
if v < 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v - v;
if v <= v goto label;
v = new java.net.ProtocolException;
specialinvoke v.<java.net.ProtocolException: void <init>(java.lang.String)>(v);
throw v;
label:
return null;
}
protected org.fusesource.hawtbuf.Buffer readBytes(int)
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
java.nio.ByteBuffer v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: int;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
if v >= v goto label;
return null;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart> = v;
v = new org.fusesource.hawtbuf.Buffer;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
return v;
}
protected org.fusesource.hawtbuf.Buffer peekBytes(int)
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
java.nio.ByteBuffer v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: int;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd>;
if v >= v goto label;
return null;
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readEnd> = v;
v = new org.fusesource.hawtbuf.Buffer;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
return v;
}
protected java.lang.Boolean readDirect(java.nio.ByteBuffer)
{
byte[] v;
java.lang.AssertionError v;
java.nio.ByteBuffer v, v, v, v, v, v;
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Boolean v, v;
boolean v, v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: java.nio.ByteBuffer;
v = <org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer>;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer>;
if v == v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v - v;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte[],int,int)>(v, v, v);
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
v = v - v;
if v <= 0 goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, v, v);
label:
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer readBuffer>;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readStart>;
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
label:
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer> = v;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(0);
return v;
label:
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: java.nio.ByteBuffer directReadBuffer> = null;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer flip()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
return v;
}
public org.fusesource.hawtdispatch.util.BufferPools getBufferPools()
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
org.fusesource.hawtdispatch.util.BufferPools v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPools bufferPools>;
return v;
}
public void setBufferPools(org.fusesource.hawtdispatch.util.BufferPools)
{
org.fusesource.hawtdispatch.transport.AbstractProtocolCodec v;
org.fusesource.hawtdispatch.util.BufferPools v;
int v, v;
org.fusesource.hawtdispatch.util.BufferPool v, v;
v := @this: org.fusesource.hawtdispatch.transport.AbstractProtocolCodec;
v := @parameter: org.fusesource.hawtdispatch.util.BufferPools;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPools bufferPools> = v;
if v == null goto label;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int readBufferSize>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPools: org.fusesource.hawtdispatch.util.BufferPool getBufferPool(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool> = v;
v = v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: int writeBufferSize>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.util.BufferPools: org.fusesource.hawtdispatch.util.BufferPool getBufferPool(int)>(v);
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool> = v;
goto label;
label:
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool readBufferPool> = null;
v.<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: org.fusesource.hawtdispatch.util.BufferPool writeBufferPool> = null;
label:
return;
}
static void <clinit>()
{
java.lang.Class v;
boolean v, v;
v = class "Lorg/fusesource/hawtdispatch/transport/AbstractProtocolCodec;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.fusesource.hawtdispatch.transport.AbstractProtocolCodec: boolean $assertionsDisabled> = v;
return;
}
}