package okhttp3; import com.ifpdos.sdk.httpd.binder.aidl.RequestLine; import h.c0.p; import h.i; import h.r; import h.s.i0; import h.s.m; import h.w.a; import h.x.d.k; import h.x.d.x; import i.b0; import i.d0; import i.f; import i.g; import i.h; import i.i; import i.l; import i.q; import io.netty.util.internal.StringUtil; import java.io.Closeable; import java.io.File; import java.io.Flushable; import java.io.IOException; import java.security.cert.Certificate; import java.security.cert.CertificateEncodingException; import java.security.cert.CertificateException; import java.security.cert.CertificateFactory; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.Set; import java.util.TreeSet; import okhttp3.Headers; import okhttp3.Request; import okhttp3.Response; import okhttp3.internal.Util; import okhttp3.internal.cache.CacheRequest; import okhttp3.internal.cache.CacheStrategy; import okhttp3.internal.cache.DiskLruCache; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.http.HttpMethod; import okhttp3.internal.http.StatusLine; import okhttp3.internal.io.FileSystem; import okhttp3.internal.platform.Platform; import org.snmp4j.mp.MPv3; /* JADX INFO: compiled from: Cache.kt */ /* JADX INFO: loaded from: classes.dex */ @i(bv = {1, 0, 3}, d1 = {"\u0000p\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0010)\n\u0002\u0010\u000e\n\u0002\b\t\n\u0002\u0010\u000b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u0007\u0018\u0000 N2\u00020\u00012\u00020\u0002:\u0004ONPQB\u0019\b\u0016\u0012\u0006\u0010\u000f\u001a\u00020\f\u0012\u0006\u0010\u001d\u001a\u00020\u001c¢\u0006\u0004\bI\u0010JB!\b\u0000\u0012\u0006\u0010\u000f\u001a\u00020\f\u0012\u0006\u0010\u001d\u001a\u00020\u001c\u0012\u0006\u0010L\u001a\u00020K¢\u0006\u0004\bI\u0010MJ\u001d\u0010\u0007\u001a\u00020\u00062\f\u0010\u0005\u001a\b\u0018\u00010\u0003R\u00020\u0004H\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\t\u001a\u00020\u0006H\u0016¢\u0006\u0004\b\t\u0010\nJ\r\u0010\u000b\u001a\u00020\u0006¢\u0006\u0004\b\u000b\u0010\nJ\u000f\u0010\u000f\u001a\u00020\fH\u0007¢\u0006\u0004\b\r\u0010\u000eJ\r\u0010\u0010\u001a\u00020\u0006¢\u0006\u0004\b\u0010\u0010\nJ\u000f\u0010\u0011\u001a\u00020\u0006H\u0016¢\u0006\u0004\b\u0011\u0010\nJ\u0019\u0010\u0017\u001a\u0004\u0018\u00010\u00142\u0006\u0010\u0013\u001a\u00020\u0012H\u0000¢\u0006\u0004\b\u0015\u0010\u0016J\r\u0010\u0019\u001a\u00020\u0018¢\u0006\u0004\b\u0019\u0010\u001aJ\r\u0010\u001b\u001a\u00020\u0006¢\u0006\u0004\b\u001b\u0010\nJ\r\u0010\u001d\u001a\u00020\u001c¢\u0006\u0004\b\u001d\u0010\u001eJ\r\u0010\u001f\u001a\u00020\u0018¢\u0006\u0004\b\u001f\u0010\u001aJ\u0019\u0010$\u001a\u0004\u0018\u00010!2\u0006\u0010 \u001a\u00020\u0014H\u0000¢\u0006\u0004\b\"\u0010#J\u0017\u0010'\u001a\u00020\u00062\u0006\u0010\u0013\u001a\u00020\u0012H\u0000¢\u0006\u0004\b%\u0010&J\r\u0010(\u001a\u00020\u0018¢\u0006\u0004\b(\u0010\u001aJ\r\u0010)\u001a\u00020\u001c¢\u0006\u0004\b)\u0010\u001eJ\u000f\u0010+\u001a\u00020\u0006H\u0000¢\u0006\u0004\b*\u0010\nJ\u0017\u00100\u001a\u00020\u00062\u0006\u0010-\u001a\u00020,H\u0000¢\u0006\u0004\b.\u0010/J\u001f\u00105\u001a\u00020\u00062\u0006\u00101\u001a\u00020\u00142\u0006\u00102\u001a\u00020\u0014H\u0000¢\u0006\u0004\b3\u00104J\u0013\u00108\u001a\b\u0012\u0004\u0012\u00020706¢\u0006\u0004\b8\u00109J\r\u0010:\u001a\u00020\u0018¢\u0006\u0004\b:\u0010\u001aJ\r\u0010;\u001a\u00020\u0018¢\u0006\u0004\b;\u0010\u001aR\u001c\u0010<\u001a\u00020\u00048\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b<\u0010=\u001a\u0004\b>\u0010?R\u0013\u0010\u000f\u001a\u00020\f8G@\u0006¢\u0006\u0006\u001a\u0004\b\u000f\u0010\u000eR\u0016\u0010\u0019\u001a\u00020\u00188\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0019\u0010@R\u0013\u0010B\u001a\u00020A8F@\u0006¢\u0006\u0006\u001a\u0004\bB\u0010CR\u0016\u0010\u001f\u001a\u00020\u00188\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u001f\u0010@R\u0016\u0010(\u001a\u00020\u00188\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b(\u0010@R\"\u0010:\u001a\u00020\u00188\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b:\u0010@\u001a\u0004\bD\u0010\u001a\"\u0004\bE\u0010FR\"\u0010;\u001a\u00020\u00188\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b;\u0010@\u001a\u0004\bG\u0010\u001a\"\u0004\bH\u0010F¨\u0006R"}, d2 = {"Lokhttp3/Cache;", "Ljava/io/Closeable;", "Ljava/io/Flushable;", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "editor", "", "abortQuietly", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "close", "()V", "delete", "Ljava/io/File;", "-deprecated_directory", "()Ljava/io/File;", "directory", "evictAll", "flush", "Lokhttp3/Request;", "request", "Lokhttp3/Response;", "get$okhttp", "(Lokhttp3/Request;)Lokhttp3/Response;", "get", "", "hitCount", "()I", "initialize", "", "maxSize", "()J", "networkCount", "response", "Lokhttp3/internal/cache/CacheRequest;", "put$okhttp", "(Lokhttp3/Response;)Lokhttp3/internal/cache/CacheRequest;", "put", "remove$okhttp", "(Lokhttp3/Request;)V", "remove", "requestCount", "size", "trackConditionalCacheHit$okhttp", "trackConditionalCacheHit", "Lokhttp3/internal/cache/CacheStrategy;", "cacheStrategy", "trackResponse$okhttp", "(Lokhttp3/internal/cache/CacheStrategy;)V", "trackResponse", "cached", "network", "update$okhttp", "(Lokhttp3/Response;Lokhttp3/Response;)V", "update", "", "", "urls", "()Ljava/util/Iterator;", "writeAbortCount", "writeSuccessCount", "cache", "Lokhttp3/internal/cache/DiskLruCache;", "getCache$okhttp", "()Lokhttp3/internal/cache/DiskLruCache;", "I", "", "isClosed", "()Z", "getWriteAbortCount$okhttp", "setWriteAbortCount$okhttp", "(I)V", "getWriteSuccessCount$okhttp", "setWriteSuccessCount$okhttp", "", "(Ljava/io/File;J)V", "Lokhttp3/internal/io/FileSystem;", "fileSystem", "(Ljava/io/File;JLokhttp3/internal/io/FileSystem;)V", "Companion", "CacheResponseBody", "Entry", "RealCacheRequest", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class Cache implements Closeable, Flushable { public static final Companion Companion = new Companion(null); private static final int ENTRY_BODY = 1; private static final int ENTRY_COUNT = 2; private static final int ENTRY_METADATA = 0; private static final int VERSION = 201105; private final DiskLruCache cache; private int hitCount; private int networkCount; private int requestCount; private int writeAbortCount; private int writeSuccessCount; /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u00002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0002\u0018\u00002\u00020\u0001B'\u0012\n\u0010\u0011\u001a\u00060\u000fR\u00020\u0010\u0012\b\u0010\u0006\u001a\u0004\u0018\u00010\r\u0012\b\u0010\u0003\u001a\u0004\u0018\u00010\r¢\u0006\u0004\b\u0015\u0010\u0016J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u0011\u0010\u0006\u001a\u0004\u0018\u00010\u0005H\u0016¢\u0006\u0004\b\u0006\u0010\u0007J\u000f\u0010\t\u001a\u00020\bH\u0016¢\u0006\u0004\b\t\u0010\nR\u0016\u0010\u000b\u001a\u00020\b8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010\fR\u0018\u0010\u0003\u001a\u0004\u0018\u00010\r8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u000eR\u0018\u0010\u0006\u001a\u0004\u0018\u00010\r8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0006\u0010\u000eR\u001d\u0010\u0011\u001a\u00060\u000fR\u00020\u00108\u0006@\u0006¢\u0006\f\n\u0004\b\u0011\u0010\u0012\u001a\u0004\b\u0013\u0010\u0014¨\u0006\u0017"}, d2 = {"Lokhttp3/Cache$CacheResponseBody;", "Lokhttp3/ResponseBody;", "", "contentLength", "()J", "Lokhttp3/MediaType;", "contentType", "()Lokhttp3/MediaType;", "Lokio/BufferedSource;", "source", "()Lokio/BufferedSource;", "bodySource", "Lokio/BufferedSource;", "", "Ljava/lang/String;", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "getSnapshot", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "", "(Lokhttp3/internal/cache/DiskLruCache$Snapshot;Ljava/lang/String;Ljava/lang/String;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") private static final class CacheResponseBody extends ResponseBody { private final h bodySource; private final String contentLength; private final String contentType; private final DiskLruCache.Snapshot snapshot; public CacheResponseBody(DiskLruCache.Snapshot snapshot, String str, String str2) { k.d(snapshot, "snapshot"); this.snapshot = snapshot; this.contentType = str; this.contentLength = str2; final d0 source = snapshot.getSource(1); this.bodySource = q.d(new l(source) { // from class: okhttp3.Cache.CacheResponseBody.1 @Override // i.l, i.d0, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { CacheResponseBody.this.getSnapshot().close(); super.close(); } }); } @Override // okhttp3.ResponseBody public long contentLength() { String str = this.contentLength; if (str != null) { return Util.toLongOrDefault(str, -1L); } return -1L; } @Override // okhttp3.ResponseBody public MediaType contentType() { String str = this.contentType; if (str != null) { return MediaType.Companion.parse(str); } return null; } public final DiskLruCache.Snapshot getSnapshot() { return this.snapshot; } @Override // okhttp3.ResponseBody public h source() { return this.bodySource; } } /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000F\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0010\"\n\u0002\b\u000b\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b$\u0010%J\u0017\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0002\u001a\u00020\u0001H\u0007¢\u0006\u0004\b\u0004\u0010\u0005J\u0017\u0010\u000b\u001a\u00020\b2\u0006\u0010\u0007\u001a\u00020\u0006H\u0000¢\u0006\u0004\b\t\u0010\nJ\u001f\u0010\u000f\u001a\u00020\f2\u0006\u0010\r\u001a\u00020\f2\u0006\u0010\u000e\u001a\u00020\fH\u0002¢\u0006\u0004\b\u000f\u0010\u0010J%\u0010\u0017\u001a\u00020\u00162\u0006\u0010\u0012\u001a\u00020\u00112\u0006\u0010\u0013\u001a\u00020\f2\u0006\u0010\u0015\u001a\u00020\u0014¢\u0006\u0004\b\u0017\u0010\u0018J\u0011\u0010\u0019\u001a\u00020\u0016*\u00020\u0011¢\u0006\u0004\b\u0019\u0010\u001aJ\u0019\u0010\u001c\u001a\b\u0012\u0004\u0012\u00020\u00030\u001b*\u00020\fH\u0002¢\u0006\u0004\b\u001c\u0010\u001dJ\u0011\u0010\u000f\u001a\u00020\f*\u00020\u0011¢\u0006\u0004\b\u000f\u0010\u001eR\u0016\u0010\u001f\u001a\u00020\b8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u001f\u0010 R\u0016\u0010!\u001a\u00020\b8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b!\u0010 R\u0016\u0010\"\u001a\u00020\b8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b\"\u0010 R\u0016\u0010#\u001a\u00020\b8\u0002@\u0002X\u0082T¢\u0006\u0006\n\u0004\b#\u0010 ¨\u0006&"}, d2 = {"Lokhttp3/Cache$Companion;", "Lokhttp3/HttpUrl;", "url", "", "key", "(Lokhttp3/HttpUrl;)Ljava/lang/String;", "Lokio/BufferedSource;", "source", "", "readInt$okhttp", "(Lokio/BufferedSource;)I", "readInt", "Lokhttp3/Headers;", "requestHeaders", "responseHeaders", "varyHeaders", "(Lokhttp3/Headers;Lokhttp3/Headers;)Lokhttp3/Headers;", "Lokhttp3/Response;", "cachedResponse", "cachedRequest", "Lokhttp3/Request;", "newRequest", "", "varyMatches", "(Lokhttp3/Response;Lokhttp3/Headers;Lokhttp3/Request;)Z", "hasVaryAll", "(Lokhttp3/Response;)Z", "", "varyFields", "(Lokhttp3/Headers;)Ljava/util/Set;", "(Lokhttp3/Response;)Lokhttp3/Headers;", "ENTRY_BODY", "I", "ENTRY_COUNT", "ENTRY_METADATA", "VERSION", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Companion { private Companion() { } private final Set varyFields(Headers headers) { int size = headers.size(); TreeSet treeSet = null; for (int i2 = 0; i2 < size; i2++) { if (p.m("Vary", headers.name(i2), true)) { String strValue = headers.value(i2); if (treeSet == null) { treeSet = new TreeSet(p.n(x.a)); } for (String str : h.c0.q.l0(strValue, new char[]{StringUtil.COMMA}, false, 0, 6, null)) { if (str == null) { throw new NullPointerException("null cannot be cast to non-null type kotlin.CharSequence"); } treeSet.add(h.c0.q.u0(str).toString()); } } } return treeSet != null ? treeSet : i0.b(); } public final boolean hasVaryAll(Response response) { k.d(response, "$this$hasVaryAll"); return varyFields(response.headers()).contains("*"); } public final String key(HttpUrl httpUrl) { k.d(httpUrl, "url"); return i.i.f1027h.d(httpUrl.toString()).l().i(); } public final int readInt$okhttp(h hVar) throws IOException { k.d(hVar, "source"); try { long jM = hVar.M(); String strV = hVar.v(); if (jM >= 0 && jM <= MPv3.MAX_MESSAGE_ID) { if (!(strV.length() > 0)) { return (int) jM; } } throw new IOException("expected an int but was \"" + jM + strV + StringUtil.DOUBLE_QUOTE); } catch (NumberFormatException e2) { throw new IOException(e2.getMessage()); } } public final Headers varyHeaders(Response response) { k.d(response, "$this$varyHeaders"); Response responseNetworkResponse = response.networkResponse(); k.b(responseNetworkResponse); return varyHeaders(responseNetworkResponse.request().headers(), response.headers()); } public final boolean varyMatches(Response response, Headers headers, Request request) { k.d(response, "cachedResponse"); k.d(headers, "cachedRequest"); k.d(request, "newRequest"); Set setVaryFields = varyFields(response.headers()); if ((setVaryFields instanceof Collection) && setVaryFields.isEmpty()) { return true; } for (String str : setVaryFields) { if (!k.a(headers.values(str), request.headers(str))) { return false; } } return true; } public /* synthetic */ Companion(h.x.d.h hVar) { this(); } private final Headers varyHeaders(Headers headers, Headers headers2) { Set setVaryFields = varyFields(headers2); if (setVaryFields.isEmpty()) { return Util.EMPTY_HEADERS; } Headers.Builder builder = new Headers.Builder(); int size = headers.size(); for (int i2 = 0; i2 < size; i2++) { String strName = headers.name(i2); if (setVaryFields.contains(strName)) { builder.add(strName, headers.value(i2)); } } return builder.build(); } } /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000,\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0082\u0004\u0018\u00002\u00020\u0001B\u0013\u0012\n\u0010\u0013\u001a\u00060\u0011R\u00020\u0012¢\u0006\u0004\b\u0015\u0010\u0016J\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u000f\u0010\u0006\u001a\u00020\u0005H\u0016¢\u0006\u0004\b\u0006\u0010\u0007R\u0016\u0010\u0006\u001a\u00020\u00058\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0006\u0010\bR\u0016\u0010\t\u001a\u00020\u00058\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\t\u0010\bR\"\u0010\u000b\u001a\u00020\n8\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u000b\u0010\f\u001a\u0004\b\r\u0010\u000e\"\u0004\b\u000f\u0010\u0010R\u001a\u0010\u0013\u001a\u00060\u0011R\u00020\u00128\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014¨\u0006\u0017"}, d2 = {"Lokhttp3/Cache$RealCacheRequest;", "Lokhttp3/internal/cache/CacheRequest;", "", "abort", "()V", "Lokio/Sink;", "body", "()Lokio/Sink;", "Lokio/Sink;", "cacheOut", "", "done", "Z", "getDone", "()Z", "setDone", "(Z)V", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "editor", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "(Lokhttp3/Cache;Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") private final class RealCacheRequest implements CacheRequest { private final b0 body; private final b0 cacheOut; private boolean done; private final DiskLruCache.Editor editor; final /* synthetic */ Cache this$0; public RealCacheRequest(Cache cache, DiskLruCache.Editor editor) { k.d(editor, "editor"); this.this$0 = cache; this.editor = editor; b0 b0VarNewSink = editor.newSink(1); this.cacheOut = b0VarNewSink; this.body = new i.k(b0VarNewSink) { // from class: okhttp3.Cache.RealCacheRequest.1 @Override // i.k, i.b0, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel public void close() throws IOException { synchronized (RealCacheRequest.this.this$0) { if (RealCacheRequest.this.getDone()) { return; } RealCacheRequest.this.setDone(true); Cache cache2 = RealCacheRequest.this.this$0; cache2.setWriteSuccessCount$okhttp(cache2.getWriteSuccessCount$okhttp() + 1); super.close(); RealCacheRequest.this.editor.commit(); } } }; } @Override // okhttp3.internal.cache.CacheRequest public void abort() { synchronized (this.this$0) { if (this.done) { return; } this.done = true; Cache cache = this.this$0; cache.setWriteAbortCount$okhttp(cache.getWriteAbortCount$okhttp() + 1); Util.closeQuietly(this.cacheOut); try { this.editor.abort(); } catch (IOException unused) { } } } @Override // okhttp3.internal.cache.CacheRequest public b0 body() { return this.body; } public final boolean getDone() { return this.done; } public final void setDone(boolean z) { this.done = z; } } /* JADX INFO: renamed from: okhttp3.Cache$urls$1, reason: invalid class name */ /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u00005\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0010)\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005*\u0001\u0000\b\n\u0018\u00002\u00020\u00012\u00020\u0002J\u0010\u0010\u0004\u001a\u00020\u0003H\u0096\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0010\u0010\u0007\u001a\u00020\u0006H\u0096\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\n\u001a\u00020\tH\u0016¢\u0006\u0004\b\n\u0010\u000bR\u0016\u0010\f\u001a\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\f\u0010\rR \u0010\u0011\u001a\f\u0012\b\u0012\u00060\u000fR\u00020\u00100\u000e8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0011\u0010\u0012R\u0018\u0010\u0013\u001a\u0004\u0018\u00010\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014¨\u0006\u0015"}, d2 = {"okhttp3/Cache$urls$1", "Ljava/util/Iterator;", "Lh/x/d/z/a;", "", "hasNext", "()Z", "", "next", "()Ljava/lang/String;", "", "remove", "()V", "canRemove", "Z", "", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "delegate", "Ljava/util/Iterator;", "nextUrl", "Ljava/lang/String;", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class AnonymousClass1 implements Iterator, Object { private boolean canRemove; private final Iterator delegate; private String nextUrl; AnonymousClass1() { this.delegate = Cache.this.getCache$okhttp().snapshots(); } @Override // java.util.Iterator public boolean hasNext() { if (this.nextUrl != null) { return true; } this.canRemove = false; while (this.delegate.hasNext()) { try { DiskLruCache.Snapshot next = this.delegate.next(); try { continue; this.nextUrl = q.d(next.getSource(0)).v(); a.a(next, null); return true; } finally { try { continue; } catch (Throwable th) { } } } catch (IOException unused) { } } return false; } @Override // java.util.Iterator public void remove() { if (!this.canRemove) { throw new IllegalStateException("remove() before next()".toString()); } this.delegate.remove(); } @Override // java.util.Iterator public String next() { if (!hasNext()) { throw new NoSuchElementException(); } String str = this.nextUrl; k.b(str); this.nextUrl = null; this.canRemove = true; return str; } } public Cache(File file, long j2, FileSystem fileSystem) { k.d(file, "directory"); k.d(fileSystem, "fileSystem"); this.cache = new DiskLruCache(fileSystem, file, VERSION, 2, j2, TaskRunner.INSTANCE); } private final void abortQuietly(DiskLruCache.Editor editor) { if (editor != null) { try { editor.abort(); } catch (IOException unused) { } } } public static final String key(HttpUrl httpUrl) { return Companion.key(httpUrl); } /* JADX INFO: renamed from: -deprecated_directory, reason: not valid java name */ public final File m19deprecated_directory() { return this.cache.getDirectory(); } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { this.cache.close(); } public final void delete() throws IOException { this.cache.delete(); } public final File directory() { return this.cache.getDirectory(); } public final void evictAll() throws IOException { this.cache.evictAll(); } @Override // java.io.Flushable public void flush() throws IOException { this.cache.flush(); } public final Response get$okhttp(Request request) { k.d(request, "request"); try { DiskLruCache.Snapshot snapshot = this.cache.get(Companion.key(request.url())); if (snapshot != null) { try { Entry entry = new Entry(snapshot.getSource(0)); Response response = entry.response(snapshot); if (entry.matches(request, response)) { return response; } ResponseBody responseBodyBody = response.body(); if (responseBodyBody != null) { Util.closeQuietly(responseBodyBody); } return null; } catch (IOException unused) { Util.closeQuietly(snapshot); } } } catch (IOException unused2) { } return null; } public final DiskLruCache getCache$okhttp() { return this.cache; } public final int getWriteAbortCount$okhttp() { return this.writeAbortCount; } public final int getWriteSuccessCount$okhttp() { return this.writeSuccessCount; } public final synchronized int hitCount() { return this.hitCount; } public final void initialize() throws IOException { this.cache.initialize(); } public final boolean isClosed() { return this.cache.isClosed(); } public final long maxSize() { return this.cache.getMaxSize(); } public final synchronized int networkCount() { return this.networkCount; } public final CacheRequest put$okhttp(Response response) { DiskLruCache.Editor editorEdit$default; k.d(response, "response"); String strMethod = response.request().method(); if (HttpMethod.INSTANCE.invalidatesCache(response.request().method())) { try { remove$okhttp(response.request()); } catch (IOException unused) { } return null; } if ((!k.a(strMethod, RequestLine.METHOD_GET)) || Companion.hasVaryAll(response)) { return null; } Entry entry = new Entry(response); try { editorEdit$default = DiskLruCache.edit$default(this.cache, Companion.key(response.request().url()), 0L, 2, null); if (editorEdit$default == null) { return null; } try { entry.writeTo(editorEdit$default); return new RealCacheRequest(this, editorEdit$default); } catch (IOException unused2) { abortQuietly(editorEdit$default); return null; } } catch (IOException unused3) { editorEdit$default = null; } } public final void remove$okhttp(Request request) throws IOException { k.d(request, "request"); this.cache.remove(Companion.key(request.url())); } public final synchronized int requestCount() { return this.requestCount; } public final void setWriteAbortCount$okhttp(int i2) { this.writeAbortCount = i2; } public final void setWriteSuccessCount$okhttp(int i2) { this.writeSuccessCount = i2; } public final long size() throws IOException { return this.cache.size(); } public final synchronized void trackConditionalCacheHit$okhttp() { this.hitCount++; } public final synchronized void trackResponse$okhttp(CacheStrategy cacheStrategy) { k.d(cacheStrategy, "cacheStrategy"); this.requestCount++; if (cacheStrategy.getNetworkRequest() != null) { this.networkCount++; } else if (cacheStrategy.getCacheResponse() != null) { this.hitCount++; } } public final void update$okhttp(Response response, Response response2) { k.d(response, "cached"); k.d(response2, "network"); Entry entry = new Entry(response2); ResponseBody responseBodyBody = response.body(); if (responseBodyBody == null) { throw new NullPointerException("null cannot be cast to non-null type okhttp3.Cache.CacheResponseBody"); } DiskLruCache.Editor editorEdit = null; try { editorEdit = ((CacheResponseBody) responseBodyBody).getSnapshot().edit(); if (editorEdit != null) { entry.writeTo(editorEdit); editorEdit.commit(); } } catch (IOException unused) { abortQuietly(editorEdit); } } public final Iterator urls() throws IOException { return new AnonymousClass1(); } public final synchronized int writeAbortCount() { return this.writeAbortCount; } public final synchronized int writeSuccessCount() { return this.writeSuccessCount; } /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */ public Cache(File file, long j2) { this(file, j2, FileSystem.SYSTEM); k.d(file, "directory"); } /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\u0086\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0002\u0018\u0000 9:\u00019B\u0011\b\u0016\u0012\u0006\u00105\u001a\u000204¢\u0006\u0004\b6\u00107B\u0011\b\u0016\u0012\u0006\u0010\u0004\u001a\u00020\u0003¢\u0006\u0004\b6\u00108J\u001d\u0010\u0006\u001a\u00020\u00052\u0006\u0010\u0002\u001a\u00020\u00012\u0006\u0010\u0004\u001a\u00020\u0003¢\u0006\u0004\b\u0006\u0010\u0007J\u001d\u0010\f\u001a\b\u0012\u0004\u0012\u00020\u000b0\n2\u0006\u0010\t\u001a\u00020\bH\u0002¢\u0006\u0004\b\f\u0010\rJ\u0019\u0010\u0004\u001a\u00020\u00032\n\u0010\u0010\u001a\u00060\u000eR\u00020\u000f¢\u0006\u0004\b\u0004\u0010\u0011J%\u0010\u0016\u001a\u00020\u00152\u0006\u0010\u0013\u001a\u00020\u00122\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u000b0\nH\u0002¢\u0006\u0004\b\u0016\u0010\u0017J\u0019\u0010\u001a\u001a\u00020\u00152\n\u0010\u0019\u001a\u00060\u0018R\u00020\u000f¢\u0006\u0004\b\u001a\u0010\u001bR\u0016\u0010\u001d\u001a\u00020\u001c8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001d\u0010\u001eR\u0018\u0010 \u001a\u0004\u0018\u00010\u001f8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b \u0010!R\u0016\u0010\"\u001a\u00020\u00058B@\u0002X\u0082\u0004¢\u0006\u0006\u001a\u0004\b\"\u0010#R\u0016\u0010%\u001a\u00020$8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b%\u0010&R\u0016\u0010(\u001a\u00020'8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b(\u0010)R\u0016\u0010+\u001a\u00020*8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b+\u0010,R\u0016\u0010-\u001a\u00020$8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b-\u0010&R\u0016\u0010/\u001a\u00020.8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b/\u00100R\u0016\u00101\u001a\u00020*8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b1\u0010,R\u0016\u00102\u001a\u00020$8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b2\u0010&R\u0016\u00103\u001a\u00020.8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b3\u00100¨\u0006:"}, d2 = {"Lokhttp3/Cache$Entry;", "Lokhttp3/Request;", "request", "Lokhttp3/Response;", "response", "", "matches", "(Lokhttp3/Request;Lokhttp3/Response;)Z", "Lokio/BufferedSource;", "source", "", "Ljava/security/cert/Certificate;", "readCertificateList", "(Lokio/BufferedSource;)Ljava/util/List;", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot", "(Lokhttp3/internal/cache/DiskLruCache$Snapshot;)Lokhttp3/Response;", "Lokio/BufferedSink;", "sink", "certificates", "", "writeCertList", "(Lokio/BufferedSink;Ljava/util/List;)V", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "editor", "writeTo", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "", "code", "I", "Lokhttp3/Handshake;", "handshake", "Lokhttp3/Handshake;", "isHttps", "()Z", "", "message", "Ljava/lang/String;", "Lokhttp3/Protocol;", "protocol", "Lokhttp3/Protocol;", "", "receivedResponseMillis", "J", "requestMethod", "Lokhttp3/Headers;", "responseHeaders", "Lokhttp3/Headers;", "sentRequestMillis", "url", "varyHeaders", "Lokio/Source;", "rawSource", "", "(Lokio/Source;)V", "(Lokhttp3/Response;)V", "Companion", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") private static final class Entry { private final int code; private final Handshake handshake; private final String message; private final Protocol protocol; private final long receivedResponseMillis; private final String requestMethod; private final Headers responseHeaders; private final long sentRequestMillis; private final String url; private final Headers varyHeaders; public static final Companion Companion = new Companion(null); private static final String SENT_MILLIS = Platform.Companion.get().getPrefix() + "-Sent-Millis"; private static final String RECEIVED_MILLIS = Platform.Companion.get().getPrefix() + "-Received-Millis"; /* JADX INFO: compiled from: Cache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\b\u0006\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u0005\u0010\u0006R\u0016\u0010\u0002\u001a\u00020\u00018\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003R\u0016\u0010\u0004\u001a\u00020\u00018\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0004\u0010\u0003¨\u0006\u0007"}, d2 = {"Lokhttp3/Cache$Entry$Companion;", "", "RECEIVED_MILLIS", "Ljava/lang/String;", "SENT_MILLIS", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public static final class Companion { private Companion() { } public /* synthetic */ Companion(h.x.d.h hVar) { this(); } } public Entry(d0 d0Var) throws IOException { k.d(d0Var, "rawSource"); try { h hVarD = q.d(d0Var); this.url = hVarD.v(); this.requestMethod = hVarD.v(); Headers.Builder builder = new Headers.Builder(); int int$okhttp = Cache.Companion.readInt$okhttp(hVarD); for (int i2 = 0; i2 < int$okhttp; i2++) { builder.addLenient$okhttp(hVarD.v()); } this.varyHeaders = builder.build(); StatusLine statusLine = StatusLine.Companion.parse(hVarD.v()); this.protocol = statusLine.protocol; this.code = statusLine.code; this.message = statusLine.message; Headers.Builder builder2 = new Headers.Builder(); int int$okhttp2 = Cache.Companion.readInt$okhttp(hVarD); for (int i3 = 0; i3 < int$okhttp2; i3++) { builder2.addLenient$okhttp(hVarD.v()); } String str = builder2.get(SENT_MILLIS); String str2 = builder2.get(RECEIVED_MILLIS); builder2.removeAll(SENT_MILLIS); builder2.removeAll(RECEIVED_MILLIS); this.sentRequestMillis = str != null ? Long.parseLong(str) : 0L; this.receivedResponseMillis = str2 != null ? Long.parseLong(str2) : 0L; this.responseHeaders = builder2.build(); if (isHttps()) { String strV = hVarD.v(); if (strV.length() > 0) { throw new IOException("expected \"\" but was \"" + strV + StringUtil.DOUBLE_QUOTE); } this.handshake = Handshake.Companion.get(!hVarD.B() ? TlsVersion.Companion.forJavaName(hVarD.v()) : TlsVersion.SSL_3_0, CipherSuite.Companion.forJavaName(hVarD.v()), readCertificateList(hVarD), readCertificateList(hVarD)); } else { this.handshake = null; } } finally { d0Var.close(); } } private final boolean isHttps() { return p.z(this.url, "https://", false, 2, null); } private final List readCertificateList(h hVar) throws IOException { int int$okhttp = Cache.Companion.readInt$okhttp(hVar); if (int$okhttp == -1) { return m.f(); } try { CertificateFactory certificateFactory = CertificateFactory.getInstance("X.509"); ArrayList arrayList = new ArrayList(int$okhttp); for (int i2 = 0; i2 < int$okhttp; i2++) { String strV = hVar.v(); f fVar = new f(); i.i iVarA = i.i.f1027h.a(strV); k.b(iVarA); fVar.Q(iVarA); arrayList.add(certificateFactory.generateCertificate(fVar.k0())); } return arrayList; } catch (CertificateException e2) { throw new IOException(e2.getMessage()); } } private final void writeCertList(g gVar, List list) throws IOException { try { gVar.b0(list.size()).writeByte(10); int size = list.size(); for (int i2 = 0; i2 < size; i2++) { byte[] encoded = list.get(i2).getEncoded(); i.a aVar = i.i.f1027h; k.c(encoded, "bytes"); gVar.Z(i.a.f(aVar, encoded, 0, 0, 3, null).a()).writeByte(10); } } catch (CertificateEncodingException e2) { throw new IOException(e2.getMessage()); } } public final boolean matches(Request request, Response response) { k.d(request, "request"); k.d(response, "response"); return k.a(this.url, request.url().toString()) && k.a(this.requestMethod, request.method()) && Cache.Companion.varyMatches(response, this.varyHeaders, request); } public final Response response(DiskLruCache.Snapshot snapshot) { k.d(snapshot, "snapshot"); String str = this.responseHeaders.get("Content-Type"); String str2 = this.responseHeaders.get(com.ifpdos.sdk.httpd.binder.aidl.Headers.KEY_CONTENT_LENGTH); return new Response.Builder().request(new Request.Builder().url(this.url).method(this.requestMethod, null).headers(this.varyHeaders).build()).protocol(this.protocol).code(this.code).message(this.message).headers(this.responseHeaders).body(new CacheResponseBody(snapshot, str, str2)).handshake(this.handshake).sentRequestAtMillis(this.sentRequestMillis).receivedResponseAtMillis(this.receivedResponseMillis).build(); } public final void writeTo(DiskLruCache.Editor editor) throws IOException { k.d(editor, "editor"); g gVarC = q.c(editor.newSink(0)); try { gVarC.Z(this.url).writeByte(10); gVarC.Z(this.requestMethod).writeByte(10); gVarC.b0(this.varyHeaders.size()).writeByte(10); int size = this.varyHeaders.size(); for (int i2 = 0; i2 < size; i2++) { gVarC.Z(this.varyHeaders.name(i2)).Z(": ").Z(this.varyHeaders.value(i2)).writeByte(10); } gVarC.Z(new StatusLine(this.protocol, this.code, this.message).toString()).writeByte(10); gVarC.b0(this.responseHeaders.size() + 2).writeByte(10); int size2 = this.responseHeaders.size(); for (int i3 = 0; i3 < size2; i3++) { gVarC.Z(this.responseHeaders.name(i3)).Z(": ").Z(this.responseHeaders.value(i3)).writeByte(10); } gVarC.Z(SENT_MILLIS).Z(": ").b0(this.sentRequestMillis).writeByte(10); gVarC.Z(RECEIVED_MILLIS).Z(": ").b0(this.receivedResponseMillis).writeByte(10); if (isHttps()) { gVarC.writeByte(10); Handshake handshake = this.handshake; k.b(handshake); gVarC.Z(handshake.cipherSuite().javaName()).writeByte(10); writeCertList(gVarC, this.handshake.peerCertificates()); writeCertList(gVarC, this.handshake.localCertificates()); gVarC.Z(this.handshake.tlsVersion().javaName()).writeByte(10); } r rVar = r.a; a.a(gVarC, null); } finally { } } public Entry(Response response) { k.d(response, "response"); this.url = response.request().url().toString(); this.varyHeaders = Cache.Companion.varyHeaders(response); this.requestMethod = response.request().method(); this.protocol = response.protocol(); this.code = response.code(); this.message = response.message(); this.responseHeaders = response.headers(); this.handshake = response.handshake(); this.sentRequestMillis = response.sentRequestAtMillis(); this.receivedResponseMillis = response.receivedResponseAtMillis(); } } }