class oadd.org.apache.commons.net.ftp.FTPClient$CSL extends java.lang.Object implements oadd.org.apache.commons.net.io.CopyStreamListener
{
private final oadd.org.apache.commons.net.ftp.FTPClient parent;
private final long idleMillis;
private final int currentSoTimeoutMillis;
private long lastIdleTimeMillis;
private int notAcked;
private int acksAcked;
private int ioErrors;
void <init>(oadd.org.apache.commons.net.ftp.FTPClient, java.time.Duration, java.time.Duration) throws java.net.SocketException
{
long v, v;
java.time.Duration v, v;
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v;
oadd.org.apache.commons.net.ftp.FTPClient$CSL v;
v := @this: oadd.org.apache.commons.net.ftp.FTPClient$CSL;
v := @parameter: oadd.org.apache.commons.net.ftp.FTPClient;
v := @parameter: java.time.Duration;
v := @parameter: java.time.Duration;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: long lastIdleTimeMillis> = v;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: long idleMillis> = v;
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent> = v;
v = virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getSoTimeout()>();
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int currentSoTimeoutMillis> = v;
v = staticinvoke <oadd.org.apache.commons.net.ftp.DurationUtils: int toMillisInt(java.time.Duration)>(v);
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void setSoTimeout(int)>(v);
return;
}
public void bytesTransferred(oadd.org.apache.commons.net.io.CopyStreamEvent)
{
int v;
long v, v;
oadd.org.apache.commons.net.ftp.FTPClient$CSL v;
oadd.org.apache.commons.net.io.CopyStreamEvent v;
v := @this: oadd.org.apache.commons.net.ftp.FTPClient$CSL;
v := @parameter: oadd.org.apache.commons.net.io.CopyStreamEvent;
v = virtualinvoke v.<oadd.org.apache.commons.net.io.CopyStreamEvent: long getTotalBytesTransferred()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.io.CopyStreamEvent: int getBytesTransferred()>();
v = virtualinvoke v.<oadd.org.apache.commons.net.io.CopyStreamEvent: long getStreamSize()>();
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: void bytesTransferred(long,int,long)>(v, v, v);
return;
}
public void bytesTransferred(long, int, long)
{
long v, v, v, v, v, v;
byte v;
java.net.SocketTimeoutException v;
oadd.org.apache.commons.net.ftp.FTPClient v;
int v, v, v, v, v, v, v;
oadd.org.apache.commons.net.ftp.FTPClient$CSL v;
java.io.IOException v;
v := @this: oadd.org.apache.commons.net.ftp.FTPClient$CSL;
v := @parameter: long;
v := @parameter: int;
v := @parameter: long;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: long lastIdleTimeMillis>;
v = v - v;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: long idleMillis>;
v = v cmp v;
if v <= 0 goto label;
label:
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent>;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void __noop()>();
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int acksAcked>;
v = v + 1;
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int acksAcked> = v;
label:
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked>;
v = v + 1;
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked> = v;
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int ioErrors>;
v = v + 1;
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int ioErrors> = v;
label:
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: long lastIdleTimeMillis> = v;
label:
return;
catch java.net.SocketTimeoutException from label to label with label;
catch java.io.IOException from label to label with label;
}
int[] cleanUp() throws java.io.IOException
{
java.lang.Throwable v;
int[] v;
java.net.SocketTimeoutException v;
oadd.org.apache.commons.net.ftp.FTPClient v, v, v, v;
int v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.commons.net.ftp.FTPClient$CSL v;
v := @this: oadd.org.apache.commons.net.ftp.FTPClient$CSL;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked>;
label:
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked>;
if v <= 0 goto label;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent>;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: int getReply()>();
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked>;
v = v - 1;
v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked> = v;
goto label;
label:
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent>;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int currentSoTimeoutMillis>;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void setSoTimeout(int)>(v);
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent>;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int currentSoTimeoutMillis>;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void setSoTimeout(int)>(v);
goto label;
label:
v := @caughtexception;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: oadd.org.apache.commons.net.ftp.FTPClient parent>;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int currentSoTimeoutMillis>;
virtualinvoke v.<oadd.org.apache.commons.net.ftp.FTPClient: void setSoTimeout(int)>(v);
throw v;
label:
v = newarray (int)[4];
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int acksAcked>;
v[0] = v;
v[1] = v;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int notAcked>;
v[2] = v;
v = v.<oadd.org.apache.commons.net.ftp.FTPClient$CSL: int ioErrors>;
v[3] = v;
return v;
catch java.net.SocketTimeoutException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}