package okhttp3; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.rtsp.RtspHeaders; import androidx.media3.extractor.text.ttml.TtmlNode; import com.google.android.gms.common.internal.ImagesContract; import defpackage.cr4; import defpackage.e52; import defpackage.eu6; import defpackage.f21; import defpackage.i25; import defpackage.ik2; import defpackage.jg0; import defpackage.kp6; import defpackage.lg0; import defpackage.mv8; import defpackage.n89; import defpackage.ok3; import defpackage.pk2; import defpackage.pq6; import defpackage.px8; import defpackage.r15; import defpackage.rh0; import defpackage.sh0; import defpackage.su7; import defpackage.tk3; import defpackage.uu7; import defpackage.uz1; import defpackage.vx8; import defpackage.x15; import defpackage.zo0; 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.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.Set; import java.util.TreeSet; import kotlin.Metadata; 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; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0010)\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\r\n\u0002\u0010\u000b\n\u0002\b\u0007\u0018\u0000 N2\u00020\u00012\u00020\u0002:\u0004ONPQB!\b\u0000\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\u0006\u0010\u0006\u001a\u00020\u0005\u0012\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\t\u0010\nB\u0019\b\u0016\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\u0006\u0010\u0006\u001a\u00020\u0005¢\u0006\u0004\b\t\u0010\u000bJ\u0019\u0010\u0011\u001a\u0004\u0018\u00010\u000e2\u0006\u0010\r\u001a\u00020\fH\u0000¢\u0006\u0004\b\u000f\u0010\u0010J\u0019\u0010\u0016\u001a\u0004\u0018\u00010\u00132\u0006\u0010\u0012\u001a\u00020\u000eH\u0000¢\u0006\u0004\b\u0014\u0010\u0015J\u0017\u0010\u001a\u001a\u00020\u00172\u0006\u0010\r\u001a\u00020\fH\u0000¢\u0006\u0004\b\u0018\u0010\u0019J\u001f\u0010\u001f\u001a\u00020\u00172\u0006\u0010\u001b\u001a\u00020\u000e2\u0006\u0010\u001c\u001a\u00020\u000eH\u0000¢\u0006\u0004\b\u001d\u0010\u001eJ\r\u0010 \u001a\u00020\u0017¢\u0006\u0004\b \u0010!J\r\u0010\"\u001a\u00020\u0017¢\u0006\u0004\b\"\u0010!J\r\u0010#\u001a\u00020\u0017¢\u0006\u0004\b#\u0010!J\u0013\u0010&\u001a\b\u0012\u0004\u0012\u00020%0$¢\u0006\u0004\b&\u0010'J\r\u0010)\u001a\u00020(¢\u0006\u0004\b)\u0010*J\r\u0010+\u001a\u00020(¢\u0006\u0004\b+\u0010*J\r\u0010,\u001a\u00020\u0005¢\u0006\u0004\b,\u0010-J\r\u0010\u0006\u001a\u00020\u0005¢\u0006\u0004\b\u0006\u0010-J\u000f\u0010.\u001a\u00020\u0017H\u0016¢\u0006\u0004\b.\u0010!J\u000f\u0010/\u001a\u00020\u0017H\u0016¢\u0006\u0004\b/\u0010!J\u000f\u0010\u0004\u001a\u00020\u0003H\u0007¢\u0006\u0004\b0\u00101J\u0017\u00106\u001a\u00020\u00172\u0006\u00103\u001a\u000202H\u0000¢\u0006\u0004\b4\u00105J\u000f\u00108\u001a\u00020\u0017H\u0000¢\u0006\u0004\b7\u0010!J\r\u00109\u001a\u00020(¢\u0006\u0004\b9\u0010*J\r\u0010:\u001a\u00020(¢\u0006\u0004\b:\u0010*J\r\u0010;\u001a\u00020(¢\u0006\u0004\b;\u0010*J\u001d\u0010?\u001a\u00020\u00172\f\u0010>\u001a\b\u0018\u00010", "(Ljava/io/File;JLokhttp3/internal/io/FileSystem;)V", "(Ljava/io/File;J)V", "Lokhttp3/Request;", "request", "Lokhttp3/Response;", "get$okhttp", "(Lokhttp3/Request;)Lokhttp3/Response;", "get", "response", "Lokhttp3/internal/cache/CacheRequest;", "put$okhttp", "(Lokhttp3/Response;)Lokhttp3/internal/cache/CacheRequest;", "put", "Le6a;", "remove$okhttp", "(Lokhttp3/Request;)V", "remove", "cached", "network", "update$okhttp", "(Lokhttp3/Response;Lokhttp3/Response;)V", "update", "initialize", "()V", "delete", "evictAll", "", "", "urls", "()Ljava/util/Iterator;", "", "writeAbortCount", "()I", "writeSuccessCount", "size", "()J", "flush", "close", "-deprecated_directory", "()Ljava/io/File;", "Lokhttp3/internal/cache/CacheStrategy;", "cacheStrategy", "trackResponse$okhttp", "(Lokhttp3/internal/cache/CacheStrategy;)V", "trackResponse", "trackConditionalCacheHit$okhttp", "trackConditionalCacheHit", "networkCount", "hitCount", "requestCount", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "editor", "abortQuietly", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "cache", "Lokhttp3/internal/cache/DiskLruCache;", "getCache$okhttp", "()Lokhttp3/internal/cache/DiskLruCache;", "I", "getWriteSuccessCount$okhttp", "setWriteSuccessCount$okhttp", "(I)V", "getWriteAbortCount$okhttp", "setWriteAbortCount$okhttp", "", "isClosed", "()Z", "Companion", "CacheResponseBody", "Entry", "RealCacheRequest", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class Cache implements Closeable, Flushable { /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */ @kp6 public static final Companion INSTANCE = 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; @kp6 private final DiskLruCache cache; private int hitCount; private int networkCount; private int requestCount; private int writeAbortCount; private int writeSuccessCount; @Metadata(d1 = {"\u0000.\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\t\b\u0002\u0018\u00002\u00020\u0001B'\u0012\n\u0010\u0004\u001a\u00060\u0002R\u00020\u0003\u0012\b\u0010\u0006\u001a\u0004\u0018\u00010\u0005\u0012\b\u0010\u0007\u001a\u0004\u0018\u00010\u0005¢\u0006\u0004\b\b\u0010\tJ\u0011\u0010\u0006\u001a\u0004\u0018\u00010\nH\u0016¢\u0006\u0004\b\u0006\u0010\u000bJ\u000f\u0010\u0007\u001a\u00020\fH\u0016¢\u0006\u0004\b\u0007\u0010\rJ\u000f\u0010\u000f\u001a\u00020\u000eH\u0016¢\u0006\u0004\b\u000f\u0010\u0010R\u001b\u0010\u0004\u001a\u00060\u0002R\u00020\u00038\u0006¢\u0006\f\n\u0004\b\u0004\u0010\u0011\u001a\u0004\b\u0012\u0010\u0013R\u0016\u0010\u0006\u001a\u0004\u0018\u00010\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0006\u0010\u0014R\u0016\u0010\u0007\u001a\u0004\u0018\u00010\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0007\u0010\u0014R\u0014\u0010\u0015\u001a\u00020\u000e8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0015\u0010\u0016¨\u0006\u0017"}, d2 = {"Lokhttp3/Cache$CacheResponseBody;", "Lokhttp3/ResponseBody;", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot", "", "contentType", "contentLength", "", "(Lokhttp3/internal/cache/DiskLruCache$Snapshot;Ljava/lang/String;Ljava/lang/String;)V", "Lokhttp3/MediaType;", "()Lokhttp3/MediaType;", "", "()J", "Lsh0;", "source", "()Lsh0;", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "getSnapshot", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Ljava/lang/String;", "bodySource", "Lsh0;", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class CacheResponseBody extends ResponseBody { @kp6 private final sh0 bodySource; @pq6 private final String contentLength; @pq6 private final String contentType; @kp6 private final DiskLruCache.Snapshot snapshot; public CacheResponseBody(@kp6 DiskLruCache.Snapshot snapshot, @pq6 String str, @pq6 String str2) { cr4.g(snapshot, "snapshot"); this.snapshot = snapshot; this.contentType = str; this.contentLength = str2; this.bodySource = eu6.d(new tk3(snapshot.getSource(1)) { // from class: okhttp3.Cache.CacheResponseBody.1 @Override // defpackage.tk3, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { this.getSnapshot().close(); super.close(); } }); } @Override // okhttp3.ResponseBody /* JADX INFO: renamed from: contentLength */ public long getContentLength() { String str = this.contentLength; if (str != null) { return Util.toLongOrDefault(str, -1L); } return -1L; } @Override // okhttp3.ResponseBody @pq6 /* JADX INFO: renamed from: contentType */ public MediaType get$contentType() { String str = this.contentType; if (str != null) { return MediaType.INSTANCE.parse(str); } return null; } @kp6 public final DiskLruCache.Snapshot getSnapshot() { return this.snapshot; } @Override // okhttp3.ResponseBody @kp6 /* JADX INFO: renamed from: source, reason: from getter */ public sh0 getSource() { return this.bodySource; } } @Metadata(d1 = {"\u0000H\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0010\"\n\u0002\u0010\u000e\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u000b\b\u0086\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003J\u0019\u0010\u0007\u001a\b\u0012\u0004\u0012\u00020\u00060\u0005*\u00020\u0004H\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u001f\u0010\u000b\u001a\u00020\u00042\u0006\u0010\t\u001a\u00020\u00042\u0006\u0010\n\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\u000b\u0010\fJ\u0017\u0010\u000f\u001a\u00020\u00062\u0006\u0010\u000e\u001a\u00020\rH\u0007¢\u0006\u0004\b\u000f\u0010\u0010J\u0017\u0010\u0016\u001a\u00020\u00132\u0006\u0010\u0012\u001a\u00020\u0011H\u0000¢\u0006\u0004\b\u0014\u0010\u0015J%\u0010\u001d\u001a\u00020\u001c2\u0006\u0010\u0018\u001a\u00020\u00172\u0006\u0010\u0019\u001a\u00020\u00042\u0006\u0010\u001b\u001a\u00020\u001a¢\u0006\u0004\b\u001d\u0010\u001eJ\u0011\u0010\u001f\u001a\u00020\u001c*\u00020\u0017¢\u0006\u0004\b\u001f\u0010 J\u0011\u0010\u000b\u001a\u00020\u0004*\u00020\u0017¢\u0006\u0004\b\u000b\u0010!R\u0014\u0010\"\u001a\u00020\u00138\u0002X\u0082T¢\u0006\u0006\n\u0004\b\"\u0010#R\u0014\u0010$\u001a\u00020\u00138\u0002X\u0082T¢\u0006\u0006\n\u0004\b$\u0010#R\u0014\u0010%\u001a\u00020\u00138\u0002X\u0082T¢\u0006\u0006\n\u0004\b%\u0010#R\u0014\u0010&\u001a\u00020\u00138\u0002X\u0082T¢\u0006\u0006\n\u0004\b&\u0010#¨\u0006'"}, d2 = {"Lokhttp3/Cache$Companion;", "", "", "()V", "Lokhttp3/Headers;", "", "", "varyFields", "(Lokhttp3/Headers;)Ljava/util/Set;", "requestHeaders", "responseHeaders", "varyHeaders", "(Lokhttp3/Headers;Lokhttp3/Headers;)Lokhttp3/Headers;", "Lokhttp3/HttpUrl;", ImagesContract.URL, "key", "(Lokhttp3/HttpUrl;)Ljava/lang/String;", "Lsh0;", "source", "", "readInt$okhttp", "(Lsh0;)I", "readInt", "Lokhttp3/Response;", "cachedResponse", "cachedRequest", "Lokhttp3/Request;", "newRequest", "", "varyMatches", "(Lokhttp3/Response;Lokhttp3/Headers;Lokhttp3/Request;)Z", "hasVaryAll", "(Lokhttp3/Response;)Z", "(Lokhttp3/Response;)Lokhttp3/Headers;", "ENTRY_BODY", "I", "ENTRY_COUNT", "ENTRY_METADATA", "VERSION", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class Companion { public /* synthetic */ Companion(uz1 uz1Var) { this(); } private final Set varyFields(Headers headers) { int size = headers.size(); TreeSet treeSet = null; for (int i = 0; i < size; i++) { if ("Vary".equalsIgnoreCase(headers.name(i))) { String strValue = headers.value(i); if (treeSet == null) { n89.w(); treeSet = new TreeSet(String.CASE_INSENSITIVE_ORDER); } Iterator it = n89.ap(strValue, new char[]{','}).iterator(); while (it.hasNext()) { treeSet.add(n89.bg((String) it.next()).toString()); } } } return treeSet == null ? pk2.a : treeSet; } public final boolean hasVaryAll(@kp6 Response response) { cr4.g(response, ""); return varyFields(response.headers()).contains("*"); } @x15 @kp6 public final String key(@kp6 HttpUrl url) { cr4.g(url, ImagesContract.URL); zo0 zo0Var = zo0.d; return zo0.a.c(url.getUrl()).d("MD5").f(); } public final int readInt$okhttp(@kp6 sh0 source) throws IOException { cr4.g(source, "source"); try { long jBl = source.bl(); String strAj = source.aj(); if (jBl >= 0 && jBl <= 2147483647L && strAj.length() <= 0) { return (int) jBl; } throw new IOException("expected an int but was \"" + jBl + strAj + '\"'); } catch (NumberFormatException e) { throw new IOException(e.getMessage()); } } @kp6 public final Headers varyHeaders(@kp6 Response response) { cr4.g(response, ""); Response responseNetworkResponse = response.networkResponse(); cr4.d(responseNetworkResponse); return varyHeaders(responseNetworkResponse.request().headers(), response.headers()); } public final boolean varyMatches(@kp6 Response cachedResponse, @kp6 Headers cachedRequest, @kp6 Request newRequest) { cr4.g(cachedResponse, "cachedResponse"); cr4.g(cachedRequest, "cachedRequest"); cr4.g(newRequest, "newRequest"); Set setVaryFields = varyFields(cachedResponse.headers()); if (setVaryFields != null && setVaryFields.isEmpty()) { return true; } for (String str : setVaryFields) { if (!cr4.b(cachedRequest.values(str), newRequest.headers(str))) { return false; } } return true; } private Companion() { } private final Headers varyHeaders(Headers requestHeaders, Headers responseHeaders) { Set setVaryFields = varyFields(responseHeaders); if (setVaryFields.isEmpty()) { return Util.EMPTY_HEADERS; } Headers.Builder builder = new Headers.Builder(); int size = requestHeaders.size(); for (int i = 0; i < size; i++) { String strName = requestHeaders.name(i); if (setVaryFields.contains(strName)) { builder.add(strName, requestHeaders.value(i)); } } return builder.build(); } } @Metadata(d1 = {"\u0000,\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\u0007\b\u0082\u0004\u0018\u00002\u00020\u0001B\u0013\u0012\n\u0010\u0004\u001a\u00060\u0002R\u00020\u0003¢\u0006\u0004\b\u0005\u0010\u0006J\u000f\u0010\b\u001a\u00020\u0007H\u0016¢\u0006\u0004\b\b\u0010\tJ\u000f\u0010\u000b\u001a\u00020\nH\u0016¢\u0006\u0004\b\u000b\u0010\fR\u0018\u0010\u0004\u001a\u00060\u0002R\u00020\u00038\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0004\u0010\rR\u0014\u0010\u000e\u001a\u00020\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000e\u0010\u000fR\u0014\u0010\u000b\u001a\u00020\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010\u000fR\"\u0010\u0011\u001a\u00020\u00108\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0011\u0010\u0012\u001a\u0004\b\u0013\u0010\u0014\"\u0004\b\u0015\u0010\u0016¨\u0006\u0017"}, d2 = {"Lokhttp3/Cache$RealCacheRequest;", "Lokhttp3/internal/cache/CacheRequest;", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "editor", "", "(Lokhttp3/Cache;Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "Le6a;", "abort", "()V", "Lmv8;", TtmlNode.TAG_BODY, "()Lmv8;", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "cacheOut", "Lmv8;", "", "done", "Z", "getDone", "()Z", "setDone", "(Z)V", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class RealCacheRequest implements CacheRequest { @kp6 private final mv8 body; @kp6 private final mv8 cacheOut; private boolean done; @kp6 private final DiskLruCache.Editor editor; final /* synthetic */ Cache this$0; public RealCacheRequest(@kp6 final Cache cache, DiskLruCache.Editor editor) { cr4.g(editor, "editor"); this.this$0 = cache; this.editor = editor; mv8 mv8VarNewSink = editor.newSink(1); this.cacheOut = mv8VarNewSink; this.body = new ok3(mv8VarNewSink) { // from class: okhttp3.Cache.RealCacheRequest.1 @Override // defpackage.ok3, defpackage.mv8, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { Cache cache2 = cache; RealCacheRequest realCacheRequest = this; synchronized (cache2) { if (realCacheRequest.getDone()) { return; } realCacheRequest.setDone(true); cache2.setWriteSuccessCount$okhttp(cache2.getWriteSuccessCount() + 1); super.close(); this.editor.commit(); } } }; } @Override // okhttp3.internal.cache.CacheRequest public void abort() { Cache cache = this.this$0; synchronized (cache) { if (this.done) { return; } this.done = true; cache.setWriteAbortCount$okhttp(cache.getWriteAbortCount() + 1); Util.closeQuietly(this.cacheOut); try { this.editor.abort(); } catch (IOException unused) { } } } @Override // okhttp3.internal.cache.CacheRequest @kp6 /* JADX INFO: renamed from: body, reason: from getter */ public mv8 getBody() { 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 */ @Metadata(d1 = {"\u0000)\n\u0000\n\u0002\u0010)\n\u0002\u0010\u000e\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007*\u0001\u0000\b\n\u0018\u00002\b\u0012\u0004\u0012\u00020\u00020\u0001J\u0010\u0010\u0004\u001a\u00020\u0003H\u0096\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0010\u0010\u0006\u001a\u00020\u0002H\u0096\u0002¢\u0006\u0004\b\u0006\u0010\u0007J\u000f\u0010\t\u001a\u00020\bH\u0016¢\u0006\u0004\b\t\u0010\nR\u001e\u0010\r\u001a\f\u0012\b\u0012\u00060\u000bR\u00020\f0\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\r\u0010\u000eR\u0018\u0010\u000f\u001a\u0004\u0018\u00010\u00028\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u000f\u0010\u0010R\u0016\u0010\u0011\u001a\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0011\u0010\u0012¨\u0006\u0013"}, d2 = {"okhttp3/Cache$urls$1", "", "", "", "hasNext", "()Z", "next", "()Ljava/lang/String;", "Le6a;", "remove", "()V", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "delegate", "Ljava/util/Iterator;", "nextUrl", "Ljava/lang/String;", "canRemove", "Z", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class AnonymousClass1 implements Iterator, i25 { private boolean canRemove; @kp6 private final Iterator delegate; @pq6 private String nextUrl; public AnonymousClass1(Cache cache) { this.delegate = cache.getCache().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 = eu6.d(next.getSource(0)).x(Long.MAX_VALUE); f21.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()"); } this.delegate.remove(); } @Override // java.util.Iterator @kp6 public String next() { if (!hasNext()) { throw new NoSuchElementException(); } String str = this.nextUrl; cr4.d(str); this.nextUrl = null; this.canRemove = true; return str; } } public Cache(@kp6 File file, long j, @kp6 FileSystem fileSystem) { cr4.g(file, "directory"); cr4.g(fileSystem, "fileSystem"); this.cache = new DiskLruCache(fileSystem, file, VERSION, 2, j, TaskRunner.INSTANCE); } private final void abortQuietly(DiskLruCache.Editor editor) { if (editor != null) { try { editor.abort(); } catch (IOException unused) { } } } @x15 @kp6 public static final String key(@kp6 HttpUrl httpUrl) { return INSTANCE.key(httpUrl); } @e52 @r15 @kp6 /* JADX INFO: renamed from: -deprecated_directory, reason: not valid java name */ public final File m192deprecated_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(); } @r15 @kp6 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(); } @pq6 public final Response get$okhttp(@kp6 Request request) { cr4.g(request, "request"); try { DiskLruCache.Snapshot snapshot = this.cache.get(INSTANCE.key(request.url())); if (snapshot == null) { return 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); return null; } } catch (IOException unused2) { } } @kp6 /* JADX INFO: renamed from: getCache$okhttp, reason: from getter */ public final DiskLruCache getCache() { return this.cache; } /* JADX INFO: renamed from: getWriteAbortCount$okhttp, reason: from getter */ public final int getWriteAbortCount() { return this.writeAbortCount; } /* JADX INFO: renamed from: getWriteSuccessCount$okhttp, reason: from getter */ public final int getWriteSuccessCount() { 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; } @pq6 public final CacheRequest put$okhttp(@kp6 Response response) throws Throwable { DiskLruCache.Editor editorEdit$default; cr4.g(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 (!cr4.b(strMethod, "GET")) { return null; } Companion companion = INSTANCE; if (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(@kp6 Request request) throws IOException { cr4.g(request, "request"); this.cache.remove(INSTANCE.key(request.url())); } public final synchronized int requestCount() { return this.requestCount; } public final void setWriteAbortCount$okhttp(int i) { this.writeAbortCount = i; } public final void setWriteSuccessCount$okhttp(int i) { this.writeSuccessCount = i; } public final long size() throws IOException { return this.cache.size(); } public final synchronized void trackConditionalCacheHit$okhttp() { this.hitCount++; } public final synchronized void trackResponse$okhttp(@kp6 CacheStrategy cacheStrategy) { try { cr4.g(cacheStrategy, "cacheStrategy"); this.requestCount++; if (cacheStrategy.getNetworkRequest() != null) { this.networkCount++; } else if (cacheStrategy.getCacheResponse() != null) { this.hitCount++; } } catch (Throwable th) { throw th; } } public final void update$okhttp(@kp6 Response cached, @kp6 Response network) throws Throwable { DiskLruCache.Editor editorEdit; cr4.g(cached, "cached"); cr4.g(network, "network"); Entry entry = new Entry(network); ResponseBody responseBodyBody = cached.body(); cr4.e(responseBodyBody, "null cannot be cast to non-null type okhttp3.Cache.CacheResponseBody"); try { editorEdit = ((CacheResponseBody) responseBodyBody).getSnapshot().edit(); if (editorEdit == null) { return; } try { entry.writeTo(editorEdit); editorEdit.commit(); } catch (IOException unused) { abortQuietly(editorEdit); } } catch (IOException unused2) { editorEdit = null; } } @kp6 public final Iterator urls() throws IOException { return new AnonymousClass1(this); } 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(@kp6 File file, long j) { this(file, j, FileSystem.SYSTEM); cr4.g(file, "directory"); } @Metadata(d1 = {"\u0000\u0094\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\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\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0007\b\u0002\u0018\u0000 <2\u00020\u0001:\u0001", "(Lpx8;)V", "Lokhttp3/Response;", "response", "(Lokhttp3/Response;)V", "Lsh0;", "source", "", "Ljava/security/cert/Certificate;", "readCertificateList", "(Lsh0;)Ljava/util/List;", "Lrh0;", "sink", "certificates", "Le6a;", "writeCertList", "(Lrh0;Ljava/util/List;)V", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "editor", "writeTo", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "Lokhttp3/Request;", "request", "", "matches", "(Lokhttp3/Request;Lokhttp3/Response;)Z", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "snapshot", "(Lokhttp3/internal/cache/DiskLruCache$Snapshot;)Lokhttp3/Response;", "Lokhttp3/HttpUrl;", ImagesContract.URL, "Lokhttp3/HttpUrl;", "Lokhttp3/Headers;", "varyHeaders", "Lokhttp3/Headers;", "", "requestMethod", "Ljava/lang/String;", "Lokhttp3/Protocol;", "protocol", "Lokhttp3/Protocol;", "", "code", "I", "message", "responseHeaders", "Lokhttp3/Handshake;", "handshake", "Lokhttp3/Handshake;", "", "sentRequestMillis", "J", "receivedResponseMillis", "isHttps", "()Z", "Companion", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class Entry { @kp6 private static final String RECEIVED_MILLIS; @kp6 private static final String SENT_MILLIS; private final int code; @pq6 private final Handshake handshake; @kp6 private final String message; @kp6 private final Protocol protocol; private final long receivedResponseMillis; @kp6 private final String requestMethod; @kp6 private final Headers responseHeaders; private final long sentRequestMillis; @kp6 private final HttpUrl url; @kp6 private final Headers varyHeaders; static { StringBuilder sb = new StringBuilder(); Platform.Companion companion = Platform.INSTANCE; sb.append(companion.get().getPrefix()); sb.append("-Sent-Millis"); SENT_MILLIS = sb.toString(); RECEIVED_MILLIS = companion.get().getPrefix() + "-Received-Millis"; } public Entry(@kp6 px8 px8Var) throws IOException { cr4.g(px8Var, "rawSource"); try { uu7 uu7VarD = eu6.d(px8Var); String strX = uu7VarD.x(Long.MAX_VALUE); HttpUrl httpUrl = HttpUrl.INSTANCE.parse(strX); if (httpUrl == null) { IOException iOException = new IOException("Cache corruption for ".concat(strX)); Platform.INSTANCE.get().log("cache corruption", 5, iOException); throw iOException; } this.url = httpUrl; this.requestMethod = uu7VarD.x(Long.MAX_VALUE); Headers.Builder builder = new Headers.Builder(); int int$okhttp = Cache.INSTANCE.readInt$okhttp(uu7VarD); for (int i = 0; i < int$okhttp; i++) { builder.addLenient$okhttp(uu7VarD.x(Long.MAX_VALUE)); } this.varyHeaders = builder.build(); StatusLine statusLine = StatusLine.INSTANCE.parse(uu7VarD.x(Long.MAX_VALUE)); this.protocol = statusLine.protocol; this.code = statusLine.code; this.message = statusLine.message; Headers.Builder builder2 = new Headers.Builder(); int int$okhttp2 = Cache.INSTANCE.readInt$okhttp(uu7VarD); for (int i2 = 0; i2 < int$okhttp2; i2++) { builder2.addLenient$okhttp(uu7VarD.x(Long.MAX_VALUE)); } String str = SENT_MILLIS; String str2 = builder2.get(str); String str3 = RECEIVED_MILLIS; String str4 = builder2.get(str3); builder2.removeAll(str); builder2.removeAll(str3); this.sentRequestMillis = str2 != null ? Long.parseLong(str2) : 0L; this.receivedResponseMillis = str4 != null ? Long.parseLong(str4) : 0L; this.responseHeaders = builder2.build(); if (isHttps()) { String strX2 = uu7VarD.x(Long.MAX_VALUE); if (strX2.length() > 0) { throw new IOException("expected \"\" but was \"" + strX2 + '\"'); } this.handshake = Handshake.INSTANCE.get(!uu7VarD.j() ? TlsVersion.INSTANCE.forJavaName(uu7VarD.x(Long.MAX_VALUE)) : TlsVersion.SSL_3_0, CipherSuite.INSTANCE.forJavaName(uu7VarD.x(Long.MAX_VALUE)), readCertificateList(uu7VarD), readCertificateList(uu7VarD)); } else { this.handshake = null; } px8Var.close(); } catch (Throwable th) { try { throw th; } catch (Throwable th2) { f21.a(px8Var, th); throw th2; } } } private final boolean isHttps() { return cr4.b(this.url.scheme(), "https"); } private final List readCertificateList(sh0 source) throws IOException { int int$okhttp = Cache.INSTANCE.readInt$okhttp(source); if (int$okhttp == -1) { return ik2.a; } try { CertificateFactory certificateFactory = CertificateFactory.getInstance("X.509"); ArrayList arrayList = new ArrayList(int$okhttp); for (int i = 0; i < int$okhttp; i++) { String strAj = source.aj(); lg0 lg0Var = new lg0(); zo0 zo0Var = zo0.d; zo0 zo0VarA = zo0.a.a(strAj); if (zo0VarA == null) { throw new IOException("Corrupt certificate in cache entry"); } lg0Var.ah(zo0VarA); arrayList.add(certificateFactory.generateCertificate(new jg0(lg0Var))); } return arrayList; } catch (CertificateException e) { throw new IOException(e.getMessage()); } } private final void writeCertList(rh0 sink, List certificates) throws IOException { try { sink.ay(certificates.size()).writeByte(10); Iterator it = certificates.iterator(); while (it.hasNext()) { byte[] encoded = it.next().getEncoded(); zo0 zo0Var = zo0.d; cr4.f(encoded, "bytes"); sink.ac(zo0.a.d(-1234567890, encoded).a()).writeByte(10); } } catch (CertificateEncodingException e) { throw new IOException(e.getMessage()); } } public final boolean matches(@kp6 Request request, @kp6 Response response) { cr4.g(request, "request"); cr4.g(response, "response"); return cr4.b(this.url, request.url()) && cr4.b(this.requestMethod, request.method()) && Cache.INSTANCE.varyMatches(response, this.varyHeaders, request); } @kp6 public final Response response(@kp6 DiskLruCache.Snapshot snapshot) { cr4.g(snapshot, "snapshot"); String str = this.responseHeaders.get(RtspHeaders.CONTENT_TYPE); String str2 = this.responseHeaders.get(RtspHeaders.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(@kp6 DiskLruCache.Editor editor) throws Throwable { cr4.g(editor, "editor"); su7 su7VarC = eu6.c(editor.newSink(0)); try { su7VarC.ac(this.url.getUrl()); su7VarC.writeByte(10); su7VarC.ac(this.requestMethod); su7VarC.writeByte(10); su7VarC.ay(this.varyHeaders.size()); su7VarC.writeByte(10); int size = this.varyHeaders.size(); for (int i = 0; i < size; i++) { su7VarC.ac(this.varyHeaders.name(i)); su7VarC.ac(": "); su7VarC.ac(this.varyHeaders.value(i)); su7VarC.writeByte(10); } su7VarC.ac(new StatusLine(this.protocol, this.code, this.message).toString()); su7VarC.writeByte(10); su7VarC.ay(this.responseHeaders.size() + 2); su7VarC.writeByte(10); int size2 = this.responseHeaders.size(); for (int i2 = 0; i2 < size2; i2++) { su7VarC.ac(this.responseHeaders.name(i2)); su7VarC.ac(": "); su7VarC.ac(this.responseHeaders.value(i2)); su7VarC.writeByte(10); } su7VarC.ac(SENT_MILLIS); su7VarC.ac(": "); su7VarC.ay(this.sentRequestMillis); su7VarC.writeByte(10); su7VarC.ac(RECEIVED_MILLIS); su7VarC.ac(": "); su7VarC.ay(this.receivedResponseMillis); su7VarC.writeByte(10); if (isHttps()) { su7VarC.writeByte(10); Handshake handshake = this.handshake; cr4.d(handshake); su7VarC.ac(handshake.cipherSuite().javaName()); su7VarC.writeByte(10); writeCertList(su7VarC, this.handshake.peerCertificates()); writeCertList(su7VarC, this.handshake.localCertificates()); su7VarC.ac(this.handshake.tlsVersion().javaName()); su7VarC.writeByte(10); } su7VarC.close(); } finally { } } public Entry(@kp6 Response response) { cr4.g(response, "response"); this.url = response.request().url(); this.varyHeaders = Cache.INSTANCE.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(); } } }