class okhttp.internal.cache.Relay$RelaySource extends java.lang.Object implements okio.Source
{
private final okio.Timeout timeout;
private okhttp.internal.cache.FileOperator fileOperator;
private long sourcePos;
final okhttp.internal.cache.Relay this$0;
void <init>(okhttp.internal.cache.Relay)
{
java.io.RandomAccessFile v;
okhttp.internal.cache.FileOperator v;
okio.Timeout v;
okhttp.internal.cache.Relay v, v;
java.nio.channels.FileChannel v;
okhttp.internal.cache.Relay$RelaySource v;
v := @this: okhttp.internal.cache.Relay$RelaySource;
v := @parameter: okhttp.internal.cache.Relay;
v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new okio.Timeout;
specialinvoke v.<okio.Timeout: void <init>()>();
v.<okhttp.internal.cache.Relay$RelaySource: okio.Timeout timeout> = v;
v = new okhttp.internal.cache.FileOperator;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: java.io.RandomAccessFile file>;
v = virtualinvoke v.<java.io.RandomAccessFile: java.nio.channels.FileChannel getChannel()>();
specialinvoke v.<okhttp.internal.cache.FileOperator: void <init>(java.nio.channels.FileChannel)>(v);
v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator> = v;
return;
}
public long read(okio.Buffer, long) throws java.io.IOException
{
byte v, v, v, v, v;
java.lang.Thread v, v;
okhttp.internal.cache.Relay$RelaySource v;
okhttp.internal.cache.Relay 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.lang.Throwable v, v, v, v, v, v;
okhttp.internal.cache.FileOperator v, v, v;
okio.Source v;
long 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.lang.IllegalStateException v;
okio.Timeout v;
boolean v;
okio.Buffer v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: okhttp.internal.cache.Relay$RelaySource;
v := @parameter: okio.Buffer;
v := @parameter: long;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("closed");
throw v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: long upstreamPos>;
v = v cmp v;
if v != 0 goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: boolean complete>;
if v == 0 goto label;
exitmonitor v;
label:
return -1L;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: java.lang.Thread upstreamReader>;
if v == null goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: okio.Timeout timeout>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
virtualinvoke v.<okio.Timeout: void waitUntilNotified(java.lang.Object)>(v);
goto label;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v.<okhttp.internal.cache.Relay: java.lang.Thread upstreamReader> = v;
v = 1;
exitmonitor v;
label:
goto label;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = virtualinvoke v.<okio.Buffer: long size()>();
v = v - v;
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v cmp v;
if v >= 0 goto label;
v = 2;
exitmonitor v;
label:
goto label;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v - v;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v - v;
virtualinvoke v.<okio.Buffer: okio.Buffer copyTo(okio.Buffer,long,long)>(v, v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v + v;
v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos> = v;
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v != 2 goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v - v;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator>;
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = 32L + v;
virtualinvoke v.<okhttp.internal.cache.FileOperator: void read(long,okio.Buffer,long)>(v, v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v + v;
v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos> = v;
return v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Source upstream>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer upstreamBuffer>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: long bufferMaxSize>;
v = interfaceinvoke v.<okio.Source: long read(okio.Buffer,long)>(v, v);
v = v cmp -1L;
if v != 0 goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
virtualinvoke v.<okhttp.internal.cache.Relay: void commit(long)>(v);
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v.<okhttp.internal.cache.Relay: java.lang.Thread upstreamReader> = null;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return -1L;
label:
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer upstreamBuffer>;
virtualinvoke v.<okio.Buffer: okio.Buffer copyTo(okio.Buffer,long,long)>(v, 0L, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos>;
v = v + v;
v.<okhttp.internal.cache.Relay$RelaySource: long sourcePos> = v;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator>;
v = 32L + v;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer upstreamBuffer>;
v = virtualinvoke v.<okio.Buffer: okio.Buffer clone()>();
virtualinvoke v.<okhttp.internal.cache.FileOperator: void write(long,okio.Buffer,long)>(v, v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer upstreamBuffer>;
virtualinvoke v.<okio.Buffer: void write(okio.Buffer,long)>(v, v);
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = virtualinvoke v.<okio.Buffer: long size()>();
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: long bufferMaxSize>;
v = v cmp v;
if v <= 0 goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: okio.Buffer buffer>;
v = virtualinvoke v.<okio.Buffer: long size()>();
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: long bufferMaxSize>;
v = v - v;
virtualinvoke v.<okio.Buffer: void skip(long)>(v);
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: long upstreamPos>;
v = v + v;
v.<okhttp.internal.cache.Relay: long upstreamPos> = v;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v.<okhttp.internal.cache.Relay: java.lang.Thread upstreamReader> = null;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
label:
v := @caughtexception;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v.<okhttp.internal.cache.Relay: java.lang.Thread upstreamReader> = null;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
virtualinvoke v.<java.lang.Object: void notifyAll()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public okio.Timeout timeout()
{
okio.Timeout v;
okhttp.internal.cache.Relay$RelaySource v;
v := @this: okhttp.internal.cache.Relay$RelaySource;
v = v.<okhttp.internal.cache.Relay$RelaySource: okio.Timeout timeout>;
return v;
}
public void close() throws java.io.IOException
{
java.lang.Throwable v;
java.io.RandomAccessFile v;
okhttp.internal.cache.FileOperator v;
okhttp.internal.cache.Relay v, v, v, v, v;
int v, v, v;
okhttp.internal.cache.Relay$RelaySource v;
v := @this: okhttp.internal.cache.Relay$RelaySource;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator>;
if v != null goto label;
return;
label:
v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.FileOperator fileOperator> = null;
v = null;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
entermonitor v;
label:
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: int sourceCount>;
v = v - 1;
v.<okhttp.internal.cache.Relay: int sourceCount> = v;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: int sourceCount>;
if v != 0 goto label;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v = v.<okhttp.internal.cache.Relay: java.io.RandomAccessFile file>;
v = v.<okhttp.internal.cache.Relay$RelaySource: okhttp.internal.cache.Relay this$0>;
v.<okhttp.internal.cache.Relay: java.io.RandomAccessFile file> = null;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
staticinvoke <okhttp.internal.Util: void closeQuietly(java.io.Closeable)>(v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
}