package okhttp3.internal.cache; import j.h0; import j.n; import j.o0.a; import j.p0.d.j; import j.p0.d.r; import j.u0.f; import j.u0.q; import j.w; import java.io.Closeable; import java.io.EOFException; import java.io.File; import java.io.FileNotFoundException; import java.io.Flushable; import java.io.IOException; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.NoSuchElementException; import l.a0; import l.g; import l.h; import l.p; import l.y; import okhttp3.HttpUrl; import okhttp3.internal.Util; import okhttp3.internal.concurrent.Task; import okhttp3.internal.concurrent.TaskQueue; import okhttp3.internal.concurrent.TaskRunner; import okhttp3.internal.io.FileSystem; import okhttp3.internal.platform.Platform; /* JADX INFO: compiled from: DiskLruCache.kt */ /* JADX INFO: loaded from: classes.dex */ @n(bv = {1, 0, 3}, d1 = {"\u0000\u0087\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010)\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\b*\u0001<\u0018\u0000 k2\u00020\u00012\u00020\u0002:\u0004klmnB9\b\u0000\u0012\u0006\u0010J\u001a\u00020I\u0012\u0006\u0010E\u001a\u00020D\u0012\u0006\u00107\u001a\u000206\u0012\u0006\u0010d\u001a\u000206\u0012\u0006\u0010[\u001a\u00020\u0011\u0012\u0006\u0010h\u001a\u00020g¢\u0006\u0004\bi\u0010jJ\u000f\u0010\u0004\u001a\u00020\u0003H\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u000f\u0010\u0006\u001a\u00020\u0003H\u0016¢\u0006\u0004\b\u0006\u0010\u0005J#\u0010\r\u001a\u00020\u00032\n\u0010\b\u001a\u00060\u0007R\u00020\u00002\u0006\u0010\n\u001a\u00020\tH\u0000¢\u0006\u0004\b\u000b\u0010\fJ\r\u0010\u000e\u001a\u00020\u0003¢\u0006\u0004\b\u000e\u0010\u0005J'\u0010\u0013\u001a\b\u0018\u00010\u0007R\u00020\u00002\u0006\u0010\u0010\u001a\u00020\u000f2\b\b\u0002\u0010\u0012\u001a\u00020\u0011H\u0007¢\u0006\u0004\b\u0013\u0010\u0014J\r\u0010\u0015\u001a\u00020\u0003¢\u0006\u0004\b\u0015\u0010\u0005J\u000f\u0010\u0016\u001a\u00020\u0003H\u0016¢\u0006\u0004\b\u0016\u0010\u0005J\u001e\u0010\u0018\u001a\b\u0018\u00010\u0017R\u00020\u00002\u0006\u0010\u0010\u001a\u00020\u000fH\u0086\u0002¢\u0006\u0004\b\u0018\u0010\u0019J\r\u0010\u001a\u001a\u00020\u0003¢\u0006\u0004\b\u001a\u0010\u0005J\r\u0010\u001b\u001a\u00020\t¢\u0006\u0004\b\u001b\u0010\u001cJ\u000f\u0010\u001d\u001a\u00020\tH\u0002¢\u0006\u0004\b\u001d\u0010\u001cJ\u000f\u0010\u001f\u001a\u00020\u001eH\u0002¢\u0006\u0004\b\u001f\u0010 J\u000f\u0010!\u001a\u00020\u0003H\u0002¢\u0006\u0004\b!\u0010\u0005J\u000f\u0010\"\u001a\u00020\u0003H\u0002¢\u0006\u0004\b\"\u0010\u0005J\u0017\u0010$\u001a\u00020\u00032\u0006\u0010#\u001a\u00020\u000fH\u0002¢\u0006\u0004\b$\u0010%J\u000f\u0010'\u001a\u00020\u0003H\u0000¢\u0006\u0004\b&\u0010\u0005J\u0015\u0010(\u001a\u00020\t2\u0006\u0010\u0010\u001a\u00020\u000f¢\u0006\u0004\b(\u0010)J\u001b\u0010.\u001a\u00020\t2\n\u0010+\u001a\u00060*R\u00020\u0000H\u0000¢\u0006\u0004\b,\u0010-J\r\u0010/\u001a\u00020\u0011¢\u0006\u0004\b/\u00100J\u0017\u00102\u001a\f\u0012\b\u0012\u00060\u0017R\u00020\u000001¢\u0006\u0004\b2\u00103J\r\u00104\u001a\u00020\u0003¢\u0006\u0004\b4\u0010\u0005J\u0017\u00105\u001a\u00020\u00032\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b5\u0010%R\u0016\u00107\u001a\u0002068\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b7\u00108R\u0016\u0010:\u001a\u0002098\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\"\u0010?\u001a\u00020\t8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b?\u0010@\u001a\u0004\bA\u0010\u001c\"\u0004\bB\u0010CR\u0019\u0010E\u001a\u00020D8\u0006@\u0006¢\u0006\f\n\u0004\bE\u0010F\u001a\u0004\bG\u0010HR\u001c\u0010J\u001a\u00020I8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bJ\u0010K\u001a\u0004\bL\u0010MR\u0016\u0010N\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bN\u0010@R\u0016\u0010O\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bO\u0010@R\u0016\u0010P\u001a\u00020D8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bP\u0010FR\u0016\u0010Q\u001a\u00020D8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bQ\u0010FR\u0016\u0010R\u001a\u00020D8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bR\u0010FR\u0018\u0010S\u001a\u0004\u0018\u00010\u001e8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bS\u0010TR,\u0010V\u001a\u0012\u0012\u0004\u0012\u00020\u000f\u0012\b\u0012\u00060*R\u00020\u00000U8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bV\u0010W\u001a\u0004\bX\u0010YR*\u0010[\u001a\u00020\u00112\u0006\u0010Z\u001a\u00020\u00118F@FX\u0086\u000e¢\u0006\u0012\n\u0004\b[\u0010\\\u001a\u0004\b]\u00100\"\u0004\b^\u0010_R\u0016\u0010`\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b`\u0010@R\u0016\u0010a\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\ba\u0010@R\u0016\u0010b\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bb\u0010\\R\u0016\u0010c\u001a\u0002068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bc\u00108R\u0016\u0010/\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b/\u0010\\R\u001c\u0010d\u001a\u0002068\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bd\u00108\u001a\u0004\be\u0010f¨\u0006o"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache;", "Ljava/io/Closeable;", "Ljava/io/Flushable;", HttpUrl.FRAGMENT_ENCODE_SET, "checkNotClosed", "()V", "close", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "editor", HttpUrl.FRAGMENT_ENCODE_SET, "success", "completeEdit$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;Z)V", "completeEdit", "delete", HttpUrl.FRAGMENT_ENCODE_SET, "key", HttpUrl.FRAGMENT_ENCODE_SET, "expectedSequenceNumber", "edit", "(Ljava/lang/String;J)Lokhttp3/internal/cache/DiskLruCache$Editor;", "evictAll", "flush", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "get", "(Ljava/lang/String;)Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "initialize", "isClosed", "()Z", "journalRebuildRequired", "Lokio/BufferedSink;", "newJournalWriter", "()Lokio/BufferedSink;", "processJournal", "readJournal", "line", "readJournalLine", "(Ljava/lang/String;)V", "rebuildJournal$okhttp", "rebuildJournal", "remove", "(Ljava/lang/String;)Z", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "entry", "removeEntry$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Entry;)Z", "removeEntry", "size", "()J", HttpUrl.FRAGMENT_ENCODE_SET, "snapshots", "()Ljava/util/Iterator;", "trimToSize", "validateKey", HttpUrl.FRAGMENT_ENCODE_SET, "appVersion", "I", "Lokhttp3/internal/concurrent/TaskQueue;", "cleanupQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "okhttp3/internal/cache/DiskLruCache$cleanupTask$1", "cleanupTask", "Lokhttp3/internal/cache/DiskLruCache$cleanupTask$1;", "closed", "Z", "getClosed$okhttp", "setClosed$okhttp", "(Z)V", "Ljava/io/File;", "directory", "Ljava/io/File;", "getDirectory", "()Ljava/io/File;", "Lokhttp3/internal/io/FileSystem;", "fileSystem", "Lokhttp3/internal/io/FileSystem;", "getFileSystem$okhttp", "()Lokhttp3/internal/io/FileSystem;", "hasJournalErrors", "initialized", "journalFile", "journalFileBackup", "journalFileTmp", "journalWriter", "Lokio/BufferedSink;", "Ljava/util/LinkedHashMap;", "lruEntries", "Ljava/util/LinkedHashMap;", "getLruEntries$okhttp", "()Ljava/util/LinkedHashMap;", "value", "maxSize", "J", "getMaxSize", "setMaxSize", "(J)V", "mostRecentRebuildFailed", "mostRecentTrimFailed", "nextSequenceNumber", "redundantOpCount", "valueCount", "getValueCount$okhttp", "()I", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "", "(Lokhttp3/internal/io/FileSystem;Ljava/io/File;IIJLokhttp3/internal/concurrent/TaskRunner;)V", "Companion", "Editor", "Entry", "Snapshot", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class DiskLruCache implements Closeable, Flushable { private final int appVersion; private final TaskQueue cleanupQueue; private final DiskLruCache$cleanupTask$1 cleanupTask; private boolean closed; private final File directory; private final FileSystem fileSystem; private boolean hasJournalErrors; private boolean initialized; private final File journalFile; private final File journalFileBackup; private final File journalFileTmp; private g journalWriter; private final LinkedHashMap lruEntries; private long maxSize; private boolean mostRecentRebuildFailed; private boolean mostRecentTrimFailed; private long nextSequenceNumber; private int redundantOpCount; private long size; private final int valueCount; public static final Companion Companion = new Companion(null); public static final String JOURNAL_FILE = "journal"; public static final String JOURNAL_FILE_TEMP = "journal.tmp"; public static final String JOURNAL_FILE_BACKUP = "journal.bkp"; public static final String MAGIC = "libcore.io.DiskLruCache"; public static final String VERSION_1 = "1"; public static final long ANY_SEQUENCE_NUMBER = -1; public static final f LEGAL_KEY_PATTERN = new f("[a-z0-9_-]{1,120}"); public static final String CLEAN = "CLEAN"; public static final String DIRTY = "DIRTY"; public static final String REMOVE = "REMOVE"; public static final String READ = "READ"; /* JADX INFO: compiled from: DiskLruCache.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000\u001c\n\u0002\u0018\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\t\b\u0086\u0003\u0018\u0000B\t\b\u0002¢\u0006\u0004\b\u0012\u0010\u0013R\u0016\u0010\u0002\u001a\u00020\u00018\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u0002\u0010\u0003R\u0016\u0010\u0005\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u0005\u0010\u0006R\u0016\u0010\u0007\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u0007\u0010\u0006R\u0016\u0010\b\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\b\u0010\u0006R\u0016\u0010\t\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\t\u0010\u0006R\u0016\u0010\n\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\n\u0010\u0006R\u0016\u0010\f\u001a\u00020\u000b8\u0006@\u0007X\u0087\u0004¢\u0006\u0006\n\u0004\b\f\u0010\rR\u0016\u0010\u000e\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u000e\u0010\u0006R\u0016\u0010\u000f\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u000f\u0010\u0006R\u0016\u0010\u0010\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u0010\u0010\u0006R\u0016\u0010\u0011\u001a\u00020\u00048\u0006@\u0007X\u0087D¢\u0006\u0006\n\u0004\b\u0011\u0010\u0006¨\u0006\u0014"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Companion;", HttpUrl.FRAGMENT_ENCODE_SET, "ANY_SEQUENCE_NUMBER", "J", HttpUrl.FRAGMENT_ENCODE_SET, "CLEAN", "Ljava/lang/String;", "DIRTY", "JOURNAL_FILE", "JOURNAL_FILE_BACKUP", "JOURNAL_FILE_TEMP", "Lkotlin/text/Regex;", "LEGAL_KEY_PATTERN", "Lkotlin/text/Regex;", "MAGIC", "READ", "REMOVE", "VERSION_1", "", "()V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class Companion { private Companion() { } public /* synthetic */ Companion(j jVar) { this(); } } /* JADX INFO: compiled from: DiskLruCache.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000>\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0005\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u0018\n\u0002\b\u0007\b\u0086\u0004\u0018\u0000B\u0015\b\u0000\u0012\n\u0010\u0014\u001a\u00060\u0012R\u00020\u0013¢\u0006\u0004\b\u001d\u0010\u001eJ\r\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0002\u0010\u0003J\r\u0010\u0004\u001a\u00020\u0001¢\u0006\u0004\b\u0004\u0010\u0003J\u000f\u0010\u0006\u001a\u00020\u0001H\u0000¢\u0006\u0004\b\u0005\u0010\u0003J\u0015\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\n\u0010\u000bJ\u0017\u0010\r\u001a\u0004\u0018\u00010\f2\u0006\u0010\b\u001a\u00020\u0007¢\u0006\u0004\b\r\u0010\u000eR\u0016\u0010\u0010\u001a\u00020\u000f8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011R \u0010\u0014\u001a\u00060\u0012R\u00020\u00138\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0014\u0010\u0015\u001a\u0004\b\u0016\u0010\u0017R\u001e\u0010\u0019\u001a\u0004\u0018\u00010\u00188\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0019\u0010\u001a\u001a\u0004\b\u001b\u0010\u001c¨\u0006\u001f"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Editor;", HttpUrl.FRAGMENT_ENCODE_SET, "abort", "()V", "commit", "detach$okhttp", "detach", HttpUrl.FRAGMENT_ENCODE_SET, "index", "Lokio/Sink;", "newSink", "(I)Lokio/Sink;", "Lokio/Source;", "newSource", "(I)Lokio/Source;", HttpUrl.FRAGMENT_ENCODE_SET, "done", "Z", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "Lokhttp3/internal/cache/DiskLruCache;", "entry", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "getEntry$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Entry;", HttpUrl.FRAGMENT_ENCODE_SET, "written", "[Z", "getWritten$okhttp", "()[Z", "", "(Lokhttp3/internal/cache/DiskLruCache;Lokhttp3/internal/cache/DiskLruCache$Entry;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class Editor { private boolean done; private final Entry entry; final /* synthetic */ DiskLruCache this$0; private final boolean[] written; public Editor(DiskLruCache diskLruCache, Entry entry) { r.g(entry, "entry"); this.this$0 = diskLruCache; this.entry = entry; this.written = entry.getReadable$okhttp() ? null : new boolean[diskLruCache.getValueCount$okhttp()]; } public final void abort() throws IOException { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (r.a(this.entry.getCurrentEditor$okhttp(), this)) { this.this$0.completeEdit$okhttp(this, false); } this.done = true; h0 h0Var = h0.a; } } public final void commit() throws IOException { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (r.a(this.entry.getCurrentEditor$okhttp(), this)) { this.this$0.completeEdit$okhttp(this, true); } this.done = true; h0 h0Var = h0.a; } } public final void detach$okhttp() { if (r.a(this.entry.getCurrentEditor$okhttp(), this)) { int valueCount$okhttp = this.this$0.getValueCount$okhttp(); for (int i2 = 0; i2 < valueCount$okhttp; i2++) { try { this.this$0.getFileSystem$okhttp().delete(this.entry.getDirtyFiles$okhttp().get(i2)); } catch (IOException unused) { } } this.entry.setCurrentEditor$okhttp(null); } } public final Entry getEntry$okhttp() { return this.entry; } public final boolean[] getWritten$okhttp() { return this.written; } public final y newSink(int i2) { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (!r.a(this.entry.getCurrentEditor$okhttp(), this)) { return p.b(); } if (!this.entry.getReadable$okhttp()) { boolean[] zArr = this.written; if (zArr == null) { r.p(); throw null; } zArr[i2] = true; } try { return new FaultHidingSink(this.this$0.getFileSystem$okhttp().sink(this.entry.getDirtyFiles$okhttp().get(i2)), new DiskLruCache$Editor$newSink$$inlined$synchronized$lambda$1(this, i2)); } catch (FileNotFoundException unused) { return p.b(); } } } public final a0 newSource(int i2) { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } a0 a0VarSource = null; if (!this.entry.getReadable$okhttp() || (!r.a(this.entry.getCurrentEditor$okhttp(), this))) { return null; } try { a0VarSource = this.this$0.getFileSystem$okhttp().source(this.entry.getCleanFiles$okhttp().get(i2)); } catch (FileNotFoundException unused) { } return a0VarSource; } } } /* JADX INFO: compiled from: DiskLruCache.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000^\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0010\u0016\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0006\n\u0002\u0010\t\n\u0002\b\t\b\u0080\u0004\u0018\u0000B\u0011\b\u0000\u0012\u0006\u0010$\u001a\u00020\u0002¢\u0006\u0004\b;\u0010", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class Entry { private final List cleanFiles; private Editor currentEditor; private final List dirtyFiles; private final String key; private final long[] lengths; private boolean readable; private long sequenceNumber; final /* synthetic */ DiskLruCache this$0; public Entry(DiskLruCache diskLruCache, String str) { r.g(str, "key"); this.this$0 = diskLruCache; this.key = str; this.lengths = new long[diskLruCache.getValueCount$okhttp()]; this.cleanFiles = new ArrayList(); this.dirtyFiles = new ArrayList(); StringBuilder sb = new StringBuilder(this.key); sb.append('.'); int length = sb.length(); int valueCount$okhttp = diskLruCache.getValueCount$okhttp(); for (int i2 = 0; i2 < valueCount$okhttp; i2++) { sb.append(i2); this.cleanFiles.add(new File(diskLruCache.getDirectory(), sb.toString())); sb.append(".tmp"); this.dirtyFiles.add(new File(diskLruCache.getDirectory(), sb.toString())); sb.setLength(length); } } private final IOException invalidLengths(List list) throws IOException { throw new IOException("unexpected journal line: " + list); } public final List getCleanFiles$okhttp() { return this.cleanFiles; } public final Editor getCurrentEditor$okhttp() { return this.currentEditor; } public final List getDirtyFiles$okhttp() { return this.dirtyFiles; } public final String getKey$okhttp() { return this.key; } public final long[] getLengths$okhttp() { return this.lengths; } public final boolean getReadable$okhttp() { return this.readable; } public final long getSequenceNumber$okhttp() { return this.sequenceNumber; } public final void setCurrentEditor$okhttp(Editor editor) { this.currentEditor = editor; } public final void setLengths$okhttp(List list) throws IOException { r.g(list, "strings"); if (list.size() != this.this$0.getValueCount$okhttp()) { throw invalidLengths(list); } try { int size = list.size(); for (int i2 = 0; i2 < size; i2++) { this.lengths[i2] = Long.parseLong(list.get(i2)); } } catch (NumberFormatException unused) { throw invalidLengths(list); } } public final void setReadable$okhttp(boolean z) { this.readable = z; } public final void setSequenceNumber$okhttp(long j2) { this.sequenceNumber = j2; } public final Snapshot snapshot$okhttp() { DiskLruCache diskLruCache = this.this$0; if (Util.assertionsEnabled && !Thread.holdsLock(diskLruCache)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(diskLruCache); throw new AssertionError(sb.toString()); } ArrayList arrayList = new ArrayList(); long[] jArr = (long[]) this.lengths.clone(); try { int valueCount$okhttp = this.this$0.getValueCount$okhttp(); for (int i2 = 0; i2 < valueCount$okhttp; i2++) { arrayList.add(this.this$0.getFileSystem$okhttp().source(this.cleanFiles.get(i2))); } return new Snapshot(this.this$0, this.key, this.sequenceNumber, arrayList, jArr); } catch (FileNotFoundException unused) { Iterator it = arrayList.iterator(); while (it.hasNext()) { Util.closeQuietly((a0) it.next()); } try { this.this$0.removeEntry$okhttp(this); return null; } catch (IOException unused2) { return null; } } } public final void writeLengths$okhttp(g gVar) throws IOException { r.g(gVar, "writer"); for (long j2 : this.lengths) { gVar.F(32).h0(j2); } } } /* JADX INFO: compiled from: DiskLruCache.kt */ @n(bv = {1, 0, 3}, d1 = {"\u0000J\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010\u0016\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\b\u0005\b\u0086\u0004\u0018\u00002\u00020\u0001B/\b\u0000\u0012\u0006\u0010\u0012\u001a\u00020\u0011\u0012\u0006\u0010\u0018\u001a\u00020\u000b\u0012\f\u0010\u001b\u001a\b\u0012\u0004\u0012\u00020\u000e0\u001a\u0012\u0006\u0010\u0016\u001a\u00020\u0015¢\u0006\u0004\b\u001d\u0010\u001eJ\u000f\u0010\u0003\u001a\u00020\u0002H\u0016¢\u0006\u0004\b\u0003\u0010\u0004J\u0013\u0010\u0007\u001a\b\u0018\u00010\u0005R\u00020\u0006¢\u0006\u0004\b\u0007\u0010\bJ\u0015\u0010\f\u001a\u00020\u000b2\u0006\u0010\n\u001a\u00020\t¢\u0006\u0004\b\f\u0010\rJ\u0015\u0010\u000f\u001a\u00020\u000e2\u0006\u0010\n\u001a\u00020\t¢\u0006\u0004\b\u000f\u0010\u0010J\r\u0010\u0012\u001a\u00020\u0011¢\u0006\u0004\b\u0012\u0010\u0013R\u0016\u0010\u0012\u001a\u00020\u00118\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0012\u0010\u0014R\u0016\u0010\u0016\u001a\u00020\u00158\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0016\u0010\u0017R\u0016\u0010\u0018\u001a\u00020\u000b8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0018\u0010\u0019R\u001c\u0010\u001b\u001a\b\u0012\u0004\u0012\u00020\u000e0\u001a8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u001b\u0010\u001c¨\u0006\u001f"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Ljava/io/Closeable;", HttpUrl.FRAGMENT_ENCODE_SET, "close", "()V", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "edit", "()Lokhttp3/internal/cache/DiskLruCache$Editor;", HttpUrl.FRAGMENT_ENCODE_SET, "index", HttpUrl.FRAGMENT_ENCODE_SET, "getLength", "(I)J", "Lokio/Source;", "getSource", "(I)Lokio/Source;", HttpUrl.FRAGMENT_ENCODE_SET, "key", "()Ljava/lang/String;", "Ljava/lang/String;", HttpUrl.FRAGMENT_ENCODE_SET, "lengths", "[J", "sequenceNumber", "J", HttpUrl.FRAGMENT_ENCODE_SET, "sources", "Ljava/util/List;", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;JLjava/util/List;[J)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public final class Snapshot implements Closeable { private final String key; private final long[] lengths; private final long sequenceNumber; private final List sources; final /* synthetic */ DiskLruCache this$0; /* JADX WARN: Multi-variable type inference failed */ public Snapshot(DiskLruCache diskLruCache, String str, long j2, List list, long[] jArr) { r.g(str, "key"); r.g(list, "sources"); r.g(jArr, "lengths"); this.this$0 = diskLruCache; this.key = str; this.sequenceNumber = j2; this.sources = list; this.lengths = jArr; } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { Iterator it = this.sources.iterator(); while (it.hasNext()) { Util.closeQuietly(it.next()); } } public final Editor edit() throws IOException { return this.this$0.edit(this.key, this.sequenceNumber); } public final long getLength(int i2) { return this.lengths[i2]; } public final a0 getSource(int i2) { return this.sources.get(i2); } public final String key() { return this.key; } } /* JADX INFO: renamed from: okhttp3.internal.cache.DiskLruCache$snapshots$1, reason: invalid class name */ /* JADX INFO: compiled from: DiskLruCache.kt */ @n(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\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010)\n\u0002\u0018\u0002\n\u0002\b\u000e*\u0001\u0000\b\n\u0018\u00002\u00020\u00012\u00020\u0002J\u0010\u0010\u0004\u001a\u00020\u0003H\u0096\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0014\u0010\b\u001a\u00060\u0006R\u00020\u0007H\u0096\u0002¢\u0006\u0004\b\b\u0010\tJ\u000f\u0010\u000b\u001a\u00020\nH\u0016¢\u0006\u0004\b\u000b\u0010\fR/\u0010\u0010\u001a\u0018\u0012\u0014\u0012\u0012 \u000f*\b\u0018\u00010\u000eR\u00020\u00070\u000eR\u00020\u00070\r8\u0006@\u0006¢\u0006\f\n\u0004\b\u0010\u0010\u0011\u001a\u0004\b\u0012\u0010\u0013R(\u0010\u0014\u001a\b\u0018\u00010\u0006R\u00020\u00078\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0014\u0010\u0015\u001a\u0004\b\u0016\u0010\t\"\u0004\b\u0017\u0010\u0018R(\u0010\u0019\u001a\b\u0018\u00010\u0006R\u00020\u00078\u0006@\u0006X\u0086\u000e¢\u0006\u0012\n\u0004\b\u0019\u0010\u0015\u001a\u0004\b\u001a\u0010\t\"\u0004\b\u001b\u0010\u0018¨\u0006\u001c"}, d2 = {"okhttp3/internal/cache/DiskLruCache$snapshots$1", "Ljava/util/Iterator;", "Lj/p0/d/i0/a;", HttpUrl.FRAGMENT_ENCODE_SET, "hasNext", "()Z", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "next", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", HttpUrl.FRAGMENT_ENCODE_SET, "remove", "()V", HttpUrl.FRAGMENT_ENCODE_SET, "Lokhttp3/internal/cache/DiskLruCache$Entry;", "kotlin.jvm.PlatformType", "delegate", "Ljava/util/Iterator;", "getDelegate", "()Ljava/util/Iterator;", "nextSnapshot", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "getNextSnapshot", "setNextSnapshot", "(Lokhttp3/internal/cache/DiskLruCache$Snapshot;)V", "removeSnapshot", "getRemoveSnapshot", "setRemoveSnapshot", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = HttpUrl.FRAGMENT_ENCODE_SET, xi = 0, xs = HttpUrl.FRAGMENT_ENCODE_SET) public static final class AnonymousClass1 implements Iterator, Object { private final Iterator delegate; private Snapshot nextSnapshot; private Snapshot removeSnapshot; AnonymousClass1() { Iterator it = new ArrayList(DiskLruCache.this.getLruEntries$okhttp().values()).iterator(); r.b(it, "ArrayList(lruEntries.values).iterator()"); this.delegate = it; } public final Iterator getDelegate() { return this.delegate; } public final Snapshot getNextSnapshot() { return this.nextSnapshot; } public final Snapshot getRemoveSnapshot() { return this.removeSnapshot; } @Override // java.util.Iterator public boolean hasNext() { Snapshot snapshotSnapshot$okhttp; if (this.nextSnapshot != null) { return true; } synchronized (DiskLruCache.this) { if (DiskLruCache.this.getClosed$okhttp()) { return false; } while (this.delegate.hasNext()) { Entry next = this.delegate.next(); if (next != null && next.getReadable$okhttp() && (snapshotSnapshot$okhttp = next.snapshot$okhttp()) != null) { this.nextSnapshot = snapshotSnapshot$okhttp; return true; } } h0 h0Var = h0.a; return false; } } @Override // java.util.Iterator public void remove() { Snapshot snapshot = this.removeSnapshot; if (snapshot == null) { throw new IllegalStateException("remove() before next()".toString()); } try { DiskLruCache.this.remove(snapshot.key()); } catch (IOException unused) { } catch (Throwable th) { this.removeSnapshot = null; throw th; } this.removeSnapshot = null; } public final void setNextSnapshot(Snapshot snapshot) { this.nextSnapshot = snapshot; } public final void setRemoveSnapshot(Snapshot snapshot) { this.removeSnapshot = snapshot; } @Override // java.util.Iterator public Snapshot next() { if (!hasNext()) { throw new NoSuchElementException(); } Snapshot snapshot = this.nextSnapshot; this.removeSnapshot = snapshot; this.nextSnapshot = null; if (snapshot != null) { return snapshot; } r.p(); throw null; } } /* JADX WARN: Type inference failed for: r3v3, types: [okhttp3.internal.cache.DiskLruCache$cleanupTask$1] */ public DiskLruCache(FileSystem fileSystem, File file, int i2, int i3, long j2, TaskRunner taskRunner) { r.g(fileSystem, "fileSystem"); r.g(file, "directory"); r.g(taskRunner, "taskRunner"); this.fileSystem = fileSystem; this.directory = file; this.appVersion = i2; this.valueCount = i3; this.maxSize = j2; this.lruEntries = new LinkedHashMap<>(0, 0.75f, true); this.cleanupQueue = taskRunner.newQueue(); final String str = Util.okHttpName + " Cache"; this.cleanupTask = new Task(str) { // from class: okhttp3.internal.cache.DiskLruCache$cleanupTask$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { synchronized (this.this$0) { if (!this.this$0.initialized || this.this$0.getClosed$okhttp()) { return -1L; } try { this.this$0.trimToSize(); } catch (IOException unused) { this.this$0.mostRecentTrimFailed = true; } try { if (this.this$0.journalRebuildRequired()) { this.this$0.rebuildJournal$okhttp(); this.this$0.redundantOpCount = 0; } } catch (IOException unused2) { this.this$0.mostRecentRebuildFailed = true; this.this$0.journalWriter = p.c(p.b()); } return -1L; } } }; if (!(j2 > 0)) { throw new IllegalArgumentException("maxSize <= 0".toString()); } if (!(this.valueCount > 0)) { throw new IllegalArgumentException("valueCount <= 0".toString()); } this.journalFile = new File(this.directory, JOURNAL_FILE); this.journalFileTmp = new File(this.directory, JOURNAL_FILE_TEMP); this.journalFileBackup = new File(this.directory, JOURNAL_FILE_BACKUP); } private final synchronized void checkNotClosed() { if (!(!this.closed)) { throw new IllegalStateException("cache is closed".toString()); } } public static /* synthetic */ Editor edit$default(DiskLruCache diskLruCache, String str, long j2, int i2, Object obj) throws IOException { if ((i2 & 2) != 0) { j2 = ANY_SEQUENCE_NUMBER; } return diskLruCache.edit(str, j2); } /* JADX INFO: Access modifiers changed from: private */ public final boolean journalRebuildRequired() { int i2 = this.redundantOpCount; return i2 >= 2000 && i2 >= this.lruEntries.size(); } private final g newJournalWriter() throws FileNotFoundException { return p.c(new FaultHidingSink(this.fileSystem.appendingSink(this.journalFile), new DiskLruCache$newJournalWriter$faultHidingSink$1(this))); } private final void processJournal() throws IOException { this.fileSystem.delete(this.journalFileTmp); Iterator it = this.lruEntries.values().iterator(); while (it.hasNext()) { Entry next = it.next(); r.b(next, "i.next()"); Entry entry = next; int i2 = 0; if (entry.getCurrentEditor$okhttp() == null) { int i3 = this.valueCount; while (i2 < i3) { this.size += entry.getLengths$okhttp()[i2]; i2++; } } else { entry.setCurrentEditor$okhttp(null); int i4 = this.valueCount; while (i2 < i4) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i2)); this.fileSystem.delete(entry.getDirtyFiles$okhttp().get(i2)); i2++; } it.remove(); } } } private final void readJournal() throws IOException { h hVarD = p.d(this.fileSystem.source(this.journalFile)); try { String strY = hVarD.y(); String strY2 = hVarD.y(); String strY3 = hVarD.y(); String strY4 = hVarD.y(); String strY5 = hVarD.y(); if (!(!r.a(MAGIC, strY)) && !(!r.a(VERSION_1, strY2)) && !(!r.a(String.valueOf(this.appVersion), strY3)) && !(!r.a(String.valueOf(this.valueCount), strY4))) { int i2 = 0; if (!(strY5.length() > 0)) { while (true) { try { readJournalLine(hVarD.y()); i2++; } catch (EOFException unused) { this.redundantOpCount = i2 - this.lruEntries.size(); if (hVarD.E()) { this.journalWriter = newJournalWriter(); } else { rebuildJournal$okhttp(); } h0 h0Var = h0.a; a.a(hVarD, null); return; } } } } throw new IOException("unexpected journal header: [" + strY + ", " + strY2 + ", " + strY4 + ", " + strY5 + ']'); } finally { } } private final void readJournalLine(String str) throws IOException { String strSubstring; int iS = j.u0.r.S(str, ' ', 0, false, 6, null); if (iS == -1) { throw new IOException("unexpected journal line: " + str); } int i2 = iS + 1; int iS2 = j.u0.r.S(str, ' ', i2, false, 4, null); if (iS2 == -1) { if (str == null) { throw new w("null cannot be cast to non-null type java.lang.String"); } strSubstring = str.substring(i2); r.b(strSubstring, "(this as java.lang.String).substring(startIndex)"); if (iS == REMOVE.length() && q.D(str, REMOVE, false, 2, null)) { this.lruEntries.remove(strSubstring); return; } } else { if (str == null) { throw new w("null cannot be cast to non-null type java.lang.String"); } strSubstring = str.substring(i2, iS2); r.b(strSubstring, "(this as java.lang.Strin…ing(startIndex, endIndex)"); } Entry entry = this.lruEntries.get(strSubstring); if (entry == null) { entry = new Entry(this, strSubstring); this.lruEntries.put(strSubstring, entry); } if (iS2 != -1 && iS == CLEAN.length() && q.D(str, CLEAN, false, 2, null)) { int i3 = iS2 + 1; if (str == null) { throw new w("null cannot be cast to non-null type java.lang.String"); } String strSubstring2 = str.substring(i3); r.b(strSubstring2, "(this as java.lang.String).substring(startIndex)"); List listP0 = j.u0.r.p0(strSubstring2, new char[]{' '}, false, 0, 6, null); entry.setReadable$okhttp(true); entry.setCurrentEditor$okhttp(null); entry.setLengths$okhttp(listP0); return; } if (iS2 == -1 && iS == DIRTY.length() && q.D(str, DIRTY, false, 2, null)) { entry.setCurrentEditor$okhttp(new Editor(this, entry)); return; } if (iS2 == -1 && iS == READ.length() && q.D(str, READ, false, 2, null)) { return; } throw new IOException("unexpected journal line: " + str); } private final void validateKey(String str) { if (LEGAL_KEY_PATTERN.a(str)) { return; } throw new IllegalArgumentException(("keys must match regex [a-z0-9_-]{1,120}: \"" + str + '\"').toString()); } @Override // java.io.Closeable, java.lang.AutoCloseable public synchronized void close() throws IOException { if (this.initialized && !this.closed) { Collection collectionValues = this.lruEntries.values(); r.b(collectionValues, "lruEntries.values"); Object[] array = collectionValues.toArray(new Entry[0]); if (array == null) { throw new w("null cannot be cast to non-null type kotlin.Array"); } for (Entry entry : (Entry[]) array) { if (entry.getCurrentEditor$okhttp() != null) { Editor currentEditor$okhttp = entry.getCurrentEditor$okhttp(); if (currentEditor$okhttp == null) { r.p(); throw null; } currentEditor$okhttp.abort(); } } trimToSize(); g gVar = this.journalWriter; if (gVar == null) { r.p(); throw null; } gVar.close(); this.journalWriter = null; this.closed = true; return; } this.closed = true; } public final synchronized void completeEdit$okhttp(Editor editor, boolean z) throws IOException { r.g(editor, "editor"); Entry entry$okhttp = editor.getEntry$okhttp(); if (!r.a(entry$okhttp.getCurrentEditor$okhttp(), editor)) { throw new IllegalStateException("Check failed.".toString()); } if (z && !entry$okhttp.getReadable$okhttp()) { int i2 = this.valueCount; for (int i3 = 0; i3 < i2; i3++) { boolean[] written$okhttp = editor.getWritten$okhttp(); if (written$okhttp == null) { r.p(); throw null; } if (!written$okhttp[i3]) { editor.abort(); throw new IllegalStateException("Newly created entry didn't create value for index " + i3); } if (!this.fileSystem.exists(entry$okhttp.getDirtyFiles$okhttp().get(i3))) { editor.abort(); return; } } } int i4 = this.valueCount; for (int i5 = 0; i5 < i4; i5++) { File file = entry$okhttp.getDirtyFiles$okhttp().get(i5); if (!z) { this.fileSystem.delete(file); } else if (this.fileSystem.exists(file)) { File file2 = entry$okhttp.getCleanFiles$okhttp().get(i5); this.fileSystem.rename(file, file2); long j2 = entry$okhttp.getLengths$okhttp()[i5]; long size = this.fileSystem.size(file2); entry$okhttp.getLengths$okhttp()[i5] = size; this.size = (this.size - j2) + size; } } this.redundantOpCount++; entry$okhttp.setCurrentEditor$okhttp(null); g gVar = this.journalWriter; if (gVar == null) { r.p(); throw null; } if (entry$okhttp.getReadable$okhttp() || z) { entry$okhttp.setReadable$okhttp(true); gVar.f0(CLEAN).F(32); gVar.f0(entry$okhttp.getKey$okhttp()); entry$okhttp.writeLengths$okhttp(gVar); gVar.F(10); if (z) { long j3 = this.nextSequenceNumber; this.nextSequenceNumber = 1 + j3; entry$okhttp.setSequenceNumber$okhttp(j3); } } else { this.lruEntries.remove(entry$okhttp.getKey$okhttp()); gVar.f0(REMOVE).F(32); gVar.f0(entry$okhttp.getKey$okhttp()); gVar.F(10); } gVar.flush(); if (this.size > this.maxSize || journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } } public final void delete() throws IOException { close(); this.fileSystem.deleteContents(this.directory); } public final Editor edit(String str) throws IOException { return edit$default(this, str, 0L, 2, null); } public final synchronized Editor edit(String str, long j2) throws IOException { r.g(str, "key"); initialize(); checkNotClosed(); validateKey(str); Entry entry = this.lruEntries.get(str); if (j2 != ANY_SEQUENCE_NUMBER && (entry == null || entry.getSequenceNumber$okhttp() != j2)) { return null; } if ((entry != null ? entry.getCurrentEditor$okhttp() : null) != null) { return null; } if (!this.mostRecentTrimFailed && !this.mostRecentRebuildFailed) { g gVar = this.journalWriter; if (gVar == null) { r.p(); throw null; } gVar.f0(DIRTY).F(32).f0(str).F(10); gVar.flush(); if (this.hasJournalErrors) { return null; } if (entry == null) { entry = new Entry(this, str); this.lruEntries.put(str, entry); } Editor editor = new Editor(this, entry); entry.setCurrentEditor$okhttp(editor); return editor; } TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); return null; } public final synchronized void evictAll() throws IOException { initialize(); Collection collectionValues = this.lruEntries.values(); r.b(collectionValues, "lruEntries.values"); Object[] array = collectionValues.toArray(new Entry[0]); if (array == null) { throw new w("null cannot be cast to non-null type kotlin.Array"); } for (Entry entry : (Entry[]) array) { r.b(entry, "entry"); removeEntry$okhttp(entry); } this.mostRecentTrimFailed = false; } @Override // java.io.Flushable public synchronized void flush() throws IOException { if (this.initialized) { checkNotClosed(); trimToSize(); g gVar = this.journalWriter; if (gVar != null) { gVar.flush(); } else { r.p(); throw null; } } } public final synchronized Snapshot get(String str) throws IOException { r.g(str, "key"); initialize(); checkNotClosed(); validateKey(str); Entry entry = this.lruEntries.get(str); if (entry == null) { return null; } r.b(entry, "lruEntries[key] ?: return null"); if (!entry.getReadable$okhttp()) { return null; } Snapshot snapshotSnapshot$okhttp = entry.snapshot$okhttp(); if (snapshotSnapshot$okhttp == null) { return null; } this.redundantOpCount++; g gVar = this.journalWriter; if (gVar == null) { r.p(); throw null; } gVar.f0(READ).F(32).f0(str).F(10); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return snapshotSnapshot$okhttp; } public final boolean getClosed$okhttp() { return this.closed; } public final File getDirectory() { return this.directory; } public final FileSystem getFileSystem$okhttp() { return this.fileSystem; } public final LinkedHashMap getLruEntries$okhttp() { return this.lruEntries; } public final synchronized long getMaxSize() { return this.maxSize; } public final int getValueCount$okhttp() { return this.valueCount; } public final synchronized void initialize() throws IOException { if (Util.assertionsEnabled && !Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder(); sb.append("Thread "); Thread threadCurrentThread = Thread.currentThread(); r.b(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(this); throw new AssertionError(sb.toString()); } if (this.initialized) { return; } if (this.fileSystem.exists(this.journalFileBackup)) { if (this.fileSystem.exists(this.journalFile)) { this.fileSystem.delete(this.journalFileBackup); } else { this.fileSystem.rename(this.journalFileBackup, this.journalFile); } } if (this.fileSystem.exists(this.journalFile)) { try { readJournal(); processJournal(); this.initialized = true; return; } catch (IOException e) { Platform.Companion.get().log("DiskLruCache " + this.directory + " is corrupt: " + e.getMessage() + ", removing", 5, e); try { delete(); this.closed = false; rebuildJournal$okhttp(); this.initialized = true; } catch (Throwable th) { this.closed = false; throw th; } } } rebuildJournal$okhttp(); this.initialized = true; } public final synchronized boolean isClosed() { return this.closed; } public final synchronized void rebuildJournal$okhttp() throws IOException { g gVar = this.journalWriter; if (gVar != null) { gVar.close(); } g gVarC = p.c(this.fileSystem.sink(this.journalFileTmp)); try { gVarC.f0(MAGIC).F(10); gVarC.f0(VERSION_1).F(10); gVarC.h0(this.appVersion).F(10); gVarC.h0(this.valueCount).F(10); gVarC.F(10); for (Entry entry : this.lruEntries.values()) { if (entry.getCurrentEditor$okhttp() != null) { gVarC.f0(DIRTY).F(32); gVarC.f0(entry.getKey$okhttp()); gVarC.F(10); } else { gVarC.f0(CLEAN).F(32); gVarC.f0(entry.getKey$okhttp()); entry.writeLengths$okhttp(gVarC); gVarC.F(10); } } h0 h0Var = h0.a; a.a(gVarC, null); if (this.fileSystem.exists(this.journalFile)) { this.fileSystem.rename(this.journalFile, this.journalFileBackup); } this.fileSystem.rename(this.journalFileTmp, this.journalFile); this.fileSystem.delete(this.journalFileBackup); this.journalWriter = newJournalWriter(); this.hasJournalErrors = false; this.mostRecentRebuildFailed = false; } finally { } } public final synchronized boolean remove(String str) throws IOException { r.g(str, "key"); initialize(); checkNotClosed(); validateKey(str); Entry entry = this.lruEntries.get(str); if (entry == null) { return false; } r.b(entry, "lruEntries[key] ?: return false"); boolean zRemoveEntry$okhttp = removeEntry$okhttp(entry); if (zRemoveEntry$okhttp && this.size <= this.maxSize) { this.mostRecentTrimFailed = false; } return zRemoveEntry$okhttp; } public final boolean removeEntry$okhttp(Entry entry) throws IOException { r.g(entry, "entry"); Editor currentEditor$okhttp = entry.getCurrentEditor$okhttp(); if (currentEditor$okhttp != null) { currentEditor$okhttp.detach$okhttp(); } int i2 = this.valueCount; for (int i3 = 0; i3 < i2; i3++) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i3)); this.size -= entry.getLengths$okhttp()[i3]; entry.getLengths$okhttp()[i3] = 0; } this.redundantOpCount++; g gVar = this.journalWriter; if (gVar == null) { r.p(); throw null; } gVar.f0(REMOVE).F(32).f0(entry.getKey$okhttp()).F(10); this.lruEntries.remove(entry.getKey$okhttp()); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return true; } public final void setClosed$okhttp(boolean z) { this.closed = z; } public final synchronized void setMaxSize(long j2) { this.maxSize = j2; if (this.initialized) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } } public final synchronized long size() throws IOException { initialize(); return this.size; } public final synchronized Iterator snapshots() throws IOException { initialize(); return new AnonymousClass1(); } public final void trimToSize() throws IOException { while (this.size > this.maxSize) { Entry next = this.lruEntries.values().iterator().next(); r.b(next, "lruEntries.values.iterator().next()"); removeEntry$okhttp(next); } this.mostRecentTrimFailed = false; } }