public class org.apache.http.conn.BasicEofSensorWatcher extends java.lang.Object implements org.apache.http.conn.EofSensorWatcher
{
protected final org.apache.http.conn.ManagedClientConnection managedConn;
protected final boolean attemptReuse;
public void <init>(org.apache.http.conn.ManagedClientConnection, boolean)
{
org.apache.http.conn.ManagedClientConnection v;
org.apache.http.conn.BasicEofSensorWatcher v;
boolean v;
v := @this: org.apache.http.conn.BasicEofSensorWatcher;
v := @parameter: org.apache.http.conn.ManagedClientConnection;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
staticinvoke <org.apache.http.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "Connection");
v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn> = v;
v.<org.apache.http.conn.BasicEofSensorWatcher: boolean attemptReuse> = v;
return;
}
public boolean eofDetected(java.io.InputStream) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.http.conn.BasicEofSensorWatcher v;
org.apache.http.conn.ManagedClientConnection v, v, v;
boolean v;
java.io.InputStream v;
v := @this: org.apache.http.conn.BasicEofSensorWatcher;
v := @parameter: java.io.InputStream;
label:
v = v.<org.apache.http.conn.BasicEofSensorWatcher: boolean attemptReuse>;
if v == 0 goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void markReusable()>();
label:
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void releaseConnection()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void releaseConnection()>();
throw v;
label:
return 0;
catch java.lang.Throwable from label to label with label;
}
public boolean streamClosed(java.io.InputStream) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.http.conn.BasicEofSensorWatcher v;
org.apache.http.conn.ManagedClientConnection v, v, v;
boolean v;
java.io.InputStream v;
v := @this: org.apache.http.conn.BasicEofSensorWatcher;
v := @parameter: java.io.InputStream;
label:
v = v.<org.apache.http.conn.BasicEofSensorWatcher: boolean attemptReuse>;
if v == 0 goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void markReusable()>();
label:
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void releaseConnection()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void releaseConnection()>();
throw v;
label:
return 0;
catch java.lang.Throwable from label to label with label;
}
public boolean streamAbort(java.io.InputStream) throws java.io.IOException
{
org.apache.http.conn.ManagedClientConnection v;
org.apache.http.conn.BasicEofSensorWatcher v;
java.io.InputStream v;
v := @this: org.apache.http.conn.BasicEofSensorWatcher;
v := @parameter: java.io.InputStream;
v = v.<org.apache.http.conn.BasicEofSensorWatcher: org.apache.http.conn.ManagedClientConnection managedConn>;
interfaceinvoke v.<org.apache.http.conn.ManagedClientConnection: void abortConnection()>();
return 0;
}
}