public class org.apache.zookeeper.server.admin.ReadAheadEndpoint extends java.lang.Object implements org.eclipse.jetty.io.EndPoint
{
private final org.eclipse.jetty.io.EndPoint endPoint;
private final java.nio.ByteBuffer start;
private final byte[] bytes;
private int leftToRead;
private java.io.IOException pendingException;
public java.net.InetSocketAddress getLocalAddress()
{
org.eclipse.jetty.io.EndPoint v;
java.net.InetSocketAddress v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: java.net.InetSocketAddress getLocalAddress()>();
return v;
}
public java.net.InetSocketAddress getRemoteAddress()
{
org.eclipse.jetty.io.EndPoint v;
java.net.InetSocketAddress v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: java.net.InetSocketAddress getRemoteAddress()>();
return v;
}
public boolean isOpen()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isOpen()>();
return v;
}
public long getCreatedTimeStamp()
{
long v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: long getCreatedTimeStamp()>();
return v;
}
public boolean isOutputShutdown()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isOutputShutdown()>();
return v;
}
public boolean isInputShutdown()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isInputShutdown()>();
return v;
}
public void shutdownOutput()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void shutdownOutput()>();
return;
}
public void close()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void close()>();
return;
}
public java.lang.Object getTransport()
{
java.lang.Object v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: java.lang.Object getTransport()>();
return v;
}
public long getIdleTimeout()
{
long v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: long getIdleTimeout()>();
return v;
}
public org.eclipse.jetty.io.Connection getConnection()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
org.eclipse.jetty.io.Connection v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: org.eclipse.jetty.io.Connection getConnection()>();
return v;
}
public void onOpen()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void onOpen()>();
return;
}
public void onClose()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void onClose()>();
return;
}
public boolean isOptimizedForDirectBuffers()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isOptimizedForDirectBuffers()>();
return v;
}
public boolean isFillInterested()
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isFillInterested()>();
return v;
}
public boolean tryFillInterested(org.eclipse.jetty.util.Callback)
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
org.eclipse.jetty.util.Callback v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.util.Callback;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean tryFillInterested(org.eclipse.jetty.util.Callback)>(v);
return v;
}
public transient boolean flush(java.nio.ByteBuffer[]) throws java.io.IOException
{
java.nio.ByteBuffer[] v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
boolean v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: java.nio.ByteBuffer[];
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean flush(java.nio.ByteBuffer[])>(v);
return v;
}
public void setIdleTimeout(long)
{
long v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: long;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void setIdleTimeout(long)>(v);
return;
}
public transient void write(org.eclipse.jetty.util.Callback, java.nio.ByteBuffer[]) throws java.nio.channels.WritePendingException
{
java.nio.ByteBuffer[] v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
org.eclipse.jetty.util.Callback v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.util.Callback;
v := @parameter: java.nio.ByteBuffer[];
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void write(org.eclipse.jetty.util.Callback,java.nio.ByteBuffer[])>(v, v);
return;
}
public void setConnection(org.eclipse.jetty.io.Connection)
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
org.eclipse.jetty.io.Connection v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.io.Connection;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void setConnection(org.eclipse.jetty.io.Connection)>(v);
return;
}
public void upgrade(org.eclipse.jetty.io.Connection)
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
org.eclipse.jetty.io.Connection v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.io.Connection;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void upgrade(org.eclipse.jetty.io.Connection)>(v);
return;
}
public void fillInterested(org.eclipse.jetty.util.Callback) throws java.nio.channels.ReadPendingException
{
org.eclipse.jetty.io.EndPoint v;
org.eclipse.jetty.util.Callback v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.util.Callback;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: void fillInterested(org.eclipse.jetty.util.Callback)>(v);
return;
}
public void <init>(org.eclipse.jetty.io.EndPoint, int)
{
byte[] v;
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
int v;
java.lang.IllegalArgumentException v;
java.nio.ByteBuffer v, v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: org.eclipse.jetty.io.EndPoint;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException> = null;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("channel cannot be null");
throw v;
label:
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint> = v;
v = newarray (byte)[v];
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: byte[] bytes> = v;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start> = v;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer flip()>();
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead> = v;
return;
}
private synchronized void readAhead() throws java.io.IOException
{
org.eclipse.jetty.io.EndPoint v, v, v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
java.nio.ByteBuffer v, v;
int v, v, v, v, v, v, v;
boolean v, v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead>;
if v <= 0 goto label;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: int fill(java.nio.ByteBuffer)>(v);
if v != 0 goto label;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isOpen()>();
if v == 0 goto label;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: boolean isInputShutdown()>();
if v == 0 goto label;
label:
v = (int) -1;
if v != v goto label;
v = (int) -1;
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead> = v;
goto label;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead>;
v = v - v;
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead> = v;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead>;
if v > 0 goto label;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
label:
return;
}
private int readFromStart(java.nio.ByteBuffer) throws java.io.IOException
{
byte[] v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
java.nio.ByteBuffer v, v, v, v, v;
int v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: java.nio.ByteBuffer;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
if v <= 0 goto label;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: byte[] bytes>;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte[],int,int)>(v, v, v);
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer flip()>();
label:
return v;
}
public synchronized int fill(java.nio.ByteBuffer) throws java.io.IOException
{
org.eclipse.jetty.io.EndPoint v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
java.nio.ByteBuffer v, v;
int v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v := @parameter: java.nio.ByteBuffer;
specialinvoke v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: void throwPendingException()>();
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead>;
if v <= 0 goto label;
specialinvoke v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: void readAhead()>();
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int leftToRead>;
if v <= 0 goto label;
return 0;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.nio.ByteBuffer start>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
if v <= 0 goto label;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer compact()>();
v = specialinvoke v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: int readFromStart(java.nio.ByteBuffer)>(v);
if v >= v goto label;
return v;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: org.eclipse.jetty.io.EndPoint endPoint>;
v = interfaceinvoke v.<org.eclipse.jetty.io.EndPoint: int fill(java.nio.ByteBuffer)>(v);
v = v + v;
return v;
}
public byte[] getBytes()
{
byte[] v, v, v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
java.io.IOException v, v;
int v, v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException>;
if v != null goto label;
label:
specialinvoke v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: void readAhead()>();
label:
goto label;
label:
v := @caughtexception;
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException> = v;
label:
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: byte[] bytes>;
v = lengthof v;
v = newarray (byte)[v];
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: byte[] bytes>;
v = lengthof v;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, 0, v, 0, v);
return v;
catch java.io.IOException from label to label with label;
}
private void throwPendingException() throws java.io.IOException
{
java.io.IOException v, v;
org.apache.zookeeper.server.admin.ReadAheadEndpoint v;
v := @this: org.apache.zookeeper.server.admin.ReadAheadEndpoint;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException>;
v.<org.apache.zookeeper.server.admin.ReadAheadEndpoint: java.io.IOException pendingException> = null;
throw v;
label:
return;
}
}