public abstract class org.glassfish.grizzly.streams.AbstractStreamReader extends java.lang.Object implements org.glassfish.grizzly.streams.StreamReader
{
private static final boolean DEBUG;
private static final java.util.logging.Logger LOGGER;
protected final org.glassfish.grizzly.Connection connection;
protected final org.glassfish.grizzly.streams.Input input;
protected final java.util.concurrent.atomic.AtomicBoolean isClosed;
protected void <init>(org.glassfish.grizzly.Connection, org.glassfish.grizzly.streams.Input)
{
org.glassfish.grizzly.Connection v;
java.util.concurrent.atomic.AtomicBoolean v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.streams.Input;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.glassfish.grizzly.streams.AbstractStreamReader: java.util.concurrent.atomic.AtomicBoolean isClosed> = v;
v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input> = v;
v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.Connection connection> = v;
return;
}
public boolean readBoolean() throws java.io.IOException
{
org.glassfish.grizzly.streams.AbstractStreamReader v;
byte v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: byte readByte()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public byte readByte() throws java.io.IOException
{
org.glassfish.grizzly.streams.AbstractStreamReader v;
byte v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: byte read()>();
return v;
}
public char readChar() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
char v;
org.glassfish.grizzly.streams.Input v, v;
short v, v;
byte v, v;
int v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 2 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: char getChar()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: byte readByte()>();
v = v & 255;
v = v << 8;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: byte readByte()>();
v = v & 255;
v = v | v;
return v;
}
public short readShort() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.Input v, v;
short v, v, v;
byte v, v;
int v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 2 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: short getShort()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: byte readByte()>();
v = v & 255;
v = v << 8;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: byte readByte()>();
v = v & 255;
v = v | v;
return v;
}
public int readInt() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.Input v, v;
short v, v;
int v, v, v, v, v, v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 4 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int getInt()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: short readShort()>();
v = (int) 65535;
v = v & v;
v = v << 16;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: short readShort()>();
v = (int) 65535;
v = v & v;
v = v | v;
return v;
}
public long readLong() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
long v, v, v, v, v;
org.glassfish.grizzly.streams.Input v, v;
int v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 8 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: long getLong()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int readInt()>();
v = v & 4294967295L;
v = v << 32;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int readInt()>();
v = v & 4294967295L;
v = v | v;
return v;
}
public final float readFloat() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.Input v, v;
int v, v;
float v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 4 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: float getFloat()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int readInt()>();
v = staticinvoke <java.lang.Float: float intBitsToFloat(int)>(v);
return v;
}
public final double readDouble() throws java.io.IOException
{
org.glassfish.grizzly.Buffer v;
long v;
org.glassfish.grizzly.streams.Input v, v;
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
double v, v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
if v < 8 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: double getDouble()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: long readLong()>();
v = staticinvoke <java.lang.Double: double longBitsToDouble(long)>(v);
return v;
}
private void arraySizeCheck(int)
{
int v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
java.nio.BufferUnderflowException v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: int;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int available()>();
if v <= v goto label;
v = new java.nio.BufferUnderflowException;
specialinvoke v.<java.nio.BufferUnderflowException: void <init>()>();
throw v;
label:
return;
}
public void readBooleanArray(boolean[]) throws java.io.IOException
{
boolean[] v;
int v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: boolean[];
v = lengthof v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: boolean readBoolean()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readByteArray(byte[]) throws java.io.IOException
{
int v;
byte[] v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: byte[];
v = lengthof v;
virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void readByteArray(byte[],int,int)>(v, 0, v);
return;
}
public void readByteArray(byte[], int, int) throws java.io.IOException
{
byte[] v;
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.Input v, v, v;
byte v;
int v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer get(byte[],int,int)>(v, v, v);
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
goto label;
label:
v = v;
label:
if v >= v goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: byte read()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readBytes(org.glassfish.grizzly.Buffer) throws java.io.IOException
{
byte v;
int v, v, v, v, v, v;
boolean v, v, v;
org.glassfish.grizzly.Buffer v, v;
org.glassfish.grizzly.streams.Input v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.Buffer;
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: boolean hasRemaining()>();
if v != 0 goto label;
return;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int remaining()>();
v = v - v;
if v < 0 goto label;
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer put(org.glassfish.grizzly.Buffer)>(v);
goto label;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int limit()>();
v = v + v;
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer limit(int)>(v);
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer put(org.glassfish.grizzly.Buffer)>(v);
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer limit(int)>(v);
label:
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void shrink()>();
goto label;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: byte read()>();
interfaceinvoke v.<org.glassfish.grizzly.Buffer: org.glassfish.grizzly.Buffer put(byte)>(v);
goto label;
label:
return;
}
public void readCharArray(char[]) throws java.io.IOException
{
int v, v, v, v;
char[] v;
char v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: char[];
v = lengthof v;
v = 2 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: char readChar()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readShortArray(short[]) throws java.io.IOException
{
short v;
int v, v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
short[] v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: short[];
v = lengthof v;
v = 2 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: short readShort()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readIntArray(int[]) throws java.io.IOException
{
int[] v;
int v, v, v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: int[];
v = lengthof v;
v = 4 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int readInt()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readLongArray(long[]) throws java.io.IOException
{
long[] v;
int v, v, v, v;
long v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: long[];
v = lengthof v;
v = 8 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: long readLong()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readFloatArray(float[]) throws java.io.IOException
{
int v, v, v, v;
float v;
float[] v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: float[];
v = lengthof v;
v = 4 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: float readFloat()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void readDoubleArray(double[]) throws java.io.IOException
{
double[] v;
int v, v, v, v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
double v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: double[];
v = lengthof v;
v = 8 * v;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: void arraySizeCheck(int)>(v);
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: double readDouble()>();
v[v] = v;
v = v + 1;
goto label;
label:
return;
}
public void skip(int)
{
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: int;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
interfaceinvoke v.<org.glassfish.grizzly.streams.Input: void skip(int)>(v);
return;
}
public org.glassfish.grizzly.GrizzlyFuture decode(org.glassfish.grizzly.Transformer)
{
org.glassfish.grizzly.Transformer v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.GrizzlyFuture v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.Transformer;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.GrizzlyFuture decode(org.glassfish.grizzly.Transformer,org.glassfish.grizzly.CompletionHandler)>(v, null);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture decode(org.glassfish.grizzly.Transformer, org.glassfish.grizzly.CompletionHandler)
{
org.glassfish.grizzly.Transformer v;
org.glassfish.grizzly.streams.AbstractStreamReader$DecodeCompletionHandler v;
org.glassfish.grizzly.impl.SafeFutureImpl v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.StreamDecodeCondition v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.Transformer;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v = staticinvoke <org.glassfish.grizzly.impl.SafeFutureImpl: org.glassfish.grizzly.impl.SafeFutureImpl create()>();
v = new org.glassfish.grizzly.streams.AbstractStreamReader$DecodeCompletionHandler;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader$DecodeCompletionHandler: void <init>(org.glassfish.grizzly.impl.FutureImpl,org.glassfish.grizzly.CompletionHandler)>(v, v);
v = new org.glassfish.grizzly.streams.StreamDecodeCondition;
specialinvoke v.<org.glassfish.grizzly.streams.StreamDecodeCondition: void <init>(org.glassfish.grizzly.streams.StreamReader,org.glassfish.grizzly.Transformer,org.glassfish.grizzly.utils.ResultAware)>(v, v, v);
virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition,org.glassfish.grizzly.CompletionHandler)>(v, v);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture notifyAvailable(int)
{
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.GrizzlyFuture v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: int;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.GrizzlyFuture notifyAvailable(int,org.glassfish.grizzly.CompletionHandler)>(v, null);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture notifyAvailable(int, org.glassfish.grizzly.CompletionHandler)
{
org.glassfish.grizzly.GrizzlyFuture v;
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.AbstractStreamReader$1 v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: int;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v = new org.glassfish.grizzly.streams.AbstractStreamReader$1;
specialinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader$1: void <init>(org.glassfish.grizzly.streams.AbstractStreamReader,int)>(v, v);
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition,org.glassfish.grizzly.CompletionHandler)>(v, v);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition)
{
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.utils.conditions.Condition v;
org.glassfish.grizzly.GrizzlyFuture v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.utils.conditions.Condition;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition,org.glassfish.grizzly.CompletionHandler)>(v, null);
return v;
}
public synchronized org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition, org.glassfish.grizzly.CompletionHandler)
{
org.glassfish.grizzly.impl.ReadyFutureImpl v;
org.glassfish.grizzly.utils.conditions.Condition v;
java.io.EOFException v;
org.glassfish.grizzly.streams.Input v;
org.glassfish.grizzly.GrizzlyFuture v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v := @parameter: org.glassfish.grizzly.utils.conditions.Condition;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: boolean isClosed()>();
if v == 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
if v == null goto label;
interfaceinvoke v.<org.glassfish.grizzly.CompletionHandler: void failed(java.lang.Throwable)>(v);
label:
v = staticinvoke <org.glassfish.grizzly.impl.ReadyFutureImpl: org.glassfish.grizzly.impl.ReadyFutureImpl create(java.lang.Throwable)>(v);
return v;
label:
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.GrizzlyFuture notifyCondition(org.glassfish.grizzly.utils.conditions.Condition,org.glassfish.grizzly.CompletionHandler)>(v, v);
return v;
}
public void close()
{
java.util.concurrent.atomic.AtomicBoolean v;
java.io.IOException v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v, v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: java.util.concurrent.atomic.AtomicBoolean isClosed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
if v == null goto label;
label:
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
interfaceinvoke v.<org.glassfish.grizzly.streams.Input: void close()>();
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.io.IOException from label to label with label;
}
public boolean isClosed()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: java.util.concurrent.atomic.AtomicBoolean isClosed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public final boolean hasAvailable()
{
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = virtualinvoke v.<org.glassfish.grizzly.streams.AbstractStreamReader: int available()>();
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int available()
{
int v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: int size()>();
return v;
}
public boolean isSupportBufferWindow()
{
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
boolean v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: boolean isBuffered()>();
return v;
}
public org.glassfish.grizzly.Buffer getBufferWindow()
{
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer getBuffer()>();
return v;
}
public org.glassfish.grizzly.Buffer takeBufferWindow()
{
org.glassfish.grizzly.Buffer v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
org.glassfish.grizzly.streams.Input v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.streams.Input input>;
v = interfaceinvoke v.<org.glassfish.grizzly.streams.Input: org.glassfish.grizzly.Buffer takeBuffer()>();
return v;
}
public org.glassfish.grizzly.Connection getConnection()
{
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.streams.AbstractStreamReader v;
v := @this: org.glassfish.grizzly.streams.AbstractStreamReader;
v = v.<org.glassfish.grizzly.streams.AbstractStreamReader: org.glassfish.grizzly.Connection connection>;
return v;
}
static void <clinit>()
{
java.util.logging.Logger v;
v = staticinvoke <org.glassfish.grizzly.Grizzly: java.util.logging.Logger logger(java.lang.Class)>(class "Lorg/glassfish/grizzly/streams/AbstractStreamReader;");
<org.glassfish.grizzly.streams.AbstractStreamReader: java.util.logging.Logger LOGGER> = v;
return;
}
}