package okhttp3.internal.cache; import h.c0.f; import h.c0.p; import h.d; import h.i; import h.r; import h.w.a; import h.x.d.h; import h.x.d.k; import i.b0; import i.d0; import i.g; import i.l; import i.q; import io.netty.util.internal.StringUtil; 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 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 */ @i(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\u0007\n\u0002\u0010)\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\b\u0007\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 m2\u00020\u00012\u00020\u0002:\u0004mnopB9\b\u0000\u0012\u0006\u0010L\u001a\u00020K\u0012\u0006\u0010G\u001a\u00020F\u0012\u0006\u00108\u001a\u000207\u0012\u0006\u0010f\u001a\u000207\u0012\u0006\u0010]\u001a\u00020\u0011\u0012\u0006\u0010j\u001a\u00020i¢\u0006\u0004\bk\u0010lJ\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\u000f\u0010/\u001a\u00020\tH\u0002¢\u0006\u0004\b/\u0010\u001cJ\r\u00100\u001a\u00020\u0011¢\u0006\u0004\b0\u00101J\u0017\u00103\u001a\f\u0012\b\u0012\u00060\u0017R\u00020\u000002¢\u0006\u0004\b3\u00104J\r\u00105\u001a\u00020\u0003¢\u0006\u0004\b5\u0010\u0005J\u0017\u00106\u001a\u00020\u00032\u0006\u0010\u0010\u001a\u00020\u000fH\u0002¢\u0006\u0004\b6\u0010%R\u0016\u00108\u001a\u0002078\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b8\u00109R\u0016\u0010:\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\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@\u0010AR\"\u0010B\u001a\u00020\t8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bB\u0010;\u001a\u0004\bC\u0010\u001c\"\u0004\bD\u0010ER\u0019\u0010G\u001a\u00020F8\u0006@\u0006¢\u0006\f\n\u0004\bG\u0010H\u001a\u0004\bI\u0010JR\u001c\u0010L\u001a\u00020K8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bL\u0010M\u001a\u0004\bN\u0010OR\u0016\u0010P\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bP\u0010;R\u0016\u0010Q\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bQ\u0010;R\u0016\u0010R\u001a\u00020F8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bR\u0010HR\u0016\u0010S\u001a\u00020F8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bS\u0010HR\u0016\u0010T\u001a\u00020F8\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bT\u0010HR\u0018\u0010U\u001a\u0004\u0018\u00010\u001e8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bU\u0010VR,\u0010X\u001a\u0012\u0012\u0004\u0012\u00020\u000f\u0012\b\u0012\u00060*R\u00020\u00000W8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bX\u0010Y\u001a\u0004\bZ\u0010[R*\u0010]\u001a\u00020\u00112\u0006\u0010\\\u001a\u00020\u00118F@FX\u0086\u000e¢\u0006\u0012\n\u0004\b]\u0010^\u001a\u0004\b_\u00101\"\u0004\b`\u0010aR\u0016\u0010b\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bb\u0010;R\u0016\u0010c\u001a\u00020\t8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bc\u0010;R\u0016\u0010d\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bd\u0010^R\u0016\u0010e\u001a\u0002078\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\be\u00109R\u0016\u00100\u001a\u00020\u00118\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b0\u0010^R\u001c\u0010f\u001a\u0002078\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\bf\u00109\u001a\u0004\bg\u0010h¨\u0006q"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache;", "Ljava/io/Closeable;", "Ljava/io/Flushable;", "", "checkNotClosed", "()V", "close", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "editor", "", "success", "completeEdit$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;Z)V", "completeEdit", "delete", "", "key", "", "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", "removeOldestEntry", "size", "()J", "", "snapshots", "()Ljava/util/Iterator;", "trimToSize", "validateKey", "", "appVersion", "I", "civilizedFileSystem", "Z", "Lokhttp3/internal/concurrent/TaskQueue;", "cleanupQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "okhttp3/internal/cache/DiskLruCache$cleanupTask$1", "cleanupTask", "Lokhttp3/internal/cache/DiskLruCache$cleanupTask$1;", "closed", "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 = "", xi = 0, xs = "") public final class DiskLruCache implements Closeable, Flushable { private final int appVersion; private boolean civilizedFileSystem; 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 */ @i(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;", "", "ANY_SEQUENCE_NUMBER", "J", "", "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 = "", xi = 0, xs = "") public static final class Companion { private Companion() { } public /* synthetic */ Companion(h hVar) { this(); } } /* JADX INFO: compiled from: DiskLruCache.kt */ @i(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;", "", "abort", "()V", "commit", "detach$okhttp", "detach", "", "index", "Lokio/Sink;", "newSink", "(I)Lokio/Sink;", "Lokio/Source;", "newSource", "(I)Lokio/Source;", "", "done", "Z", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "Lokhttp3/internal/cache/DiskLruCache;", "entry", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "getEntry$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "written", "[Z", "getWritten$okhttp", "()[Z", "", "(Lokhttp3/internal/cache/DiskLruCache;Lokhttp3/internal/cache/DiskLruCache$Entry;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") 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) { k.d(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 (k.a(this.entry.getCurrentEditor$okhttp(), this)) { this.this$0.completeEdit$okhttp(this, false); } this.done = true; r rVar = r.a; } } public final void commit() throws IOException { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (k.a(this.entry.getCurrentEditor$okhttp(), this)) { this.this$0.completeEdit$okhttp(this, true); } this.done = true; r rVar = r.a; } } public final void detach$okhttp() throws IOException { if (k.a(this.entry.getCurrentEditor$okhttp(), this)) { if (this.this$0.civilizedFileSystem) { this.this$0.completeEdit$okhttp(this, false); } else { this.entry.setZombie$okhttp(true); } } } public final Entry getEntry$okhttp() { return this.entry; } public final boolean[] getWritten$okhttp() { return this.written; } public final b0 newSink(int i2) { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (!k.a(this.entry.getCurrentEditor$okhttp(), this)) { return q.b(); } if (!this.entry.getReadable$okhttp()) { boolean[] zArr = this.written; k.b(zArr); 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 q.b(); } } } public final d0 newSource(int i2) { synchronized (this.this$0) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } d0 d0VarSource = null; if (!this.entry.getReadable$okhttp() || (!k.a(this.entry.getCurrentEditor$okhttp(), this)) || this.entry.getZombie$okhttp()) { return null; } try { d0VarSource = this.this$0.getFileSystem$okhttp().source(this.entry.getCleanFiles$okhttp().get(i2)); } catch (FileNotFoundException unused) { } return d0VarSource; } } } /* JADX INFO: compiled from: DiskLruCache.kt */ @i(bv = {1, 0, 3}, d1 = {"\u0000l\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\u0001\n\u0002\b\u0002\n\u0002\u0010\b\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\n\n\u0002\u0010\u000b\n\u0002\b\u0006\n\u0002\u0010\t\n\u0002\b\f\b\u0080\u0004\u0018\u0000B\u0011\b\u0000\u0012\u0006\u0010)\u001a\u00020\u0002¢\u0006\u0004\bI\u0010JJ\u001d\u0010\u0005\u001a\u00020\u00042\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001H\u0002¢\u0006\u0004\b\u0005\u0010\u0006J\u0017\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0007H\u0002¢\u0006\u0004\b\n\u0010\u000bJ\u001d\u0010\u000f\u001a\u00020\f2\f\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001H\u0000¢\u0006\u0004\b\r\u0010\u000eJ\u0015\u0010\u0014\u001a\b\u0018\u00010\u0010R\u00020\u0011H\u0000¢\u0006\u0004\b\u0012\u0010\u0013J\u0017\u0010\u0019\u001a\u00020\f2\u0006\u0010\u0016\u001a\u00020\u0015H\u0000¢\u0006\u0004\b\u0017\u0010\u0018R\"\u0010\u001c\u001a\b\u0012\u0004\u0012\u00020\u001b0\u001a8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u001c\u0010\u001d\u001a\u0004\b\u001e\u0010\u001fR(\u0010!\u001a\b\u0018\u00010 R\u00020\u00118\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b!\u0010\"\u001a\u0004\b#\u0010$\"\u0004\b%\u0010&R\"\u0010'\u001a\b\u0012\u0004\u0012\u00020\u001b0\u001a8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b'\u0010\u001d\u001a\u0004\b(\u0010\u001fR\u001c\u0010)\u001a\u00020\u00028\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b)\u0010*\u001a\u0004\b+\u0010,R\u001c\u0010.\u001a\u00020-8\u0000@\u0000X\u0080\u0004¢\u0006\f\n\u0004\b.\u0010/\u001a\u0004\b0\u00101R\"\u00102\u001a\u00020\u00078\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b2\u00103\u001a\u0004\b4\u00105\"\u0004\b6\u00107R\"\u00109\u001a\u0002088\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b9\u0010:\u001a\u0004\b;\u0010<\"\u0004\b=\u0010>R\"\u0010@\u001a\u00020?8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b@\u0010A\u001a\u0004\bB\u0010C\"\u0004\bD\u0010ER\"\u0010F\u001a\u0002088\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bF\u0010:\u001a\u0004\bG\u0010<\"\u0004\bH\u0010>¨\u0006K"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "", "strings", "", "invalidLengths", "(Ljava/util/List;)Ljava/lang/Void;", "", "index", "Lokio/Source;", "newSource", "(I)Lokio/Source;", "", "setLengths$okhttp", "(Ljava/util/List;)V", "setLengths", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "snapshot", "Lokio/BufferedSink;", "writer", "writeLengths$okhttp", "(Lokio/BufferedSink;)V", "writeLengths", "", "Ljava/io/File;", "cleanFiles", "Ljava/util/List;", "getCleanFiles$okhttp", "()Ljava/util/List;", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "currentEditor", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "getCurrentEditor$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Editor;", "setCurrentEditor$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "dirtyFiles", "getDirtyFiles$okhttp", "key", "Ljava/lang/String;", "getKey$okhttp", "()Ljava/lang/String;", "", "lengths", "[J", "getLengths$okhttp", "()[J", "lockingSourceCount", "I", "getLockingSourceCount$okhttp", "()I", "setLockingSourceCount$okhttp", "(I)V", "", "readable", "Z", "getReadable$okhttp", "()Z", "setReadable$okhttp", "(Z)V", "", "sequenceNumber", "J", "getSequenceNumber$okhttp", "()J", "setSequenceNumber$okhttp", "(J)V", "zombie", "getZombie$okhttp", "setZombie$okhttp", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") public final class Entry { private final List cleanFiles; private Editor currentEditor; private final List dirtyFiles; private final String key; private final long[] lengths; private int lockingSourceCount; private boolean readable; private long sequenceNumber; final /* synthetic */ DiskLruCache this$0; private boolean zombie; public Entry(DiskLruCache diskLruCache, String str) { k.d(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 Void invalidLengths(List list) throws IOException { throw new IOException("unexpected journal line: " + list); } private final d0 newSource(int i2) throws FileNotFoundException { final d0 d0VarSource = this.this$0.getFileSystem$okhttp().source(this.cleanFiles.get(i2)); if (this.this$0.civilizedFileSystem) { return d0VarSource; } this.lockingSourceCount++; return new l(d0VarSource) { // from class: okhttp3.internal.cache.DiskLruCache$Entry$newSource$1 private boolean closed; @Override // i.l, i.d0, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { super.close(); if (this.closed) { return; } this.closed = true; synchronized (this.this$0.this$0) { this.this$0.setLockingSourceCount$okhttp(r1.getLockingSourceCount$okhttp() - 1); if (this.this$0.getLockingSourceCount$okhttp() == 0 && this.this$0.getZombie$okhttp()) { this.this$0.this$0.removeEntry$okhttp(this.this$0); } r rVar = r.a; } } }; } 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 int getLockingSourceCount$okhttp() { return this.lockingSourceCount; } public final boolean getReadable$okhttp() { return this.readable; } public final long getSequenceNumber$okhttp() { return this.sequenceNumber; } public final boolean getZombie$okhttp() { return this.zombie; } public final void setCurrentEditor$okhttp(Editor editor) { this.currentEditor = editor; } public final void setLengths$okhttp(List list) throws IOException { k.d(list, "strings"); if (list.size() != this.this$0.getValueCount$okhttp()) { invalidLengths(list); throw new d(); } try { int size = list.size(); for (int i2 = 0; i2 < size; i2++) { this.lengths[i2] = Long.parseLong(list.get(i2)); } } catch (NumberFormatException unused) { invalidLengths(list); throw new d(); } } public final void setLockingSourceCount$okhttp(int i2) { this.lockingSourceCount = i2; } public final void setReadable$okhttp(boolean z) { this.readable = z; } public final void setSequenceNumber$okhttp(long j2) { this.sequenceNumber = j2; } public final void setZombie$okhttp(boolean z) { this.zombie = z; } 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(); k.c(threadCurrentThread, "Thread.currentThread()"); sb.append(threadCurrentThread.getName()); sb.append(" MUST hold lock on "); sb.append(diskLruCache); throw new AssertionError(sb.toString()); } if (!this.readable) { return null; } if (!this.this$0.civilizedFileSystem && (this.currentEditor != null || this.zombie)) { return null; } 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(newSource(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((d0) it.next()); } try { this.this$0.removeEntry$okhttp(this); } catch (IOException unused2) { } return null; } } public final void writeLengths$okhttp(g gVar) throws IOException { k.d(gVar, "writer"); for (long j2 : this.lengths) { gVar.writeByte(32).b0(j2); } } } /* JADX INFO: compiled from: DiskLruCache.kt */ @i(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;", "", "close", "()V", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "edit", "()Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "index", "", "getLength", "(I)J", "Lokio/Source;", "getSource", "(I)Lokio/Source;", "", "key", "()Ljava/lang/String;", "Ljava/lang/String;", "", "lengths", "[J", "sequenceNumber", "J", "", "sources", "Ljava/util/List;", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;JLjava/util/List;[J)V", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") 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) { k.d(str, "key"); k.d(list, "sources"); k.d(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 d0 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 */ @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\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\u0007*\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\u0002@\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011R\u001c\u0010\u0012\u001a\b\u0018\u00010\u0006R\u00020\u00078\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0012\u0010\u0013R\u001c\u0010\u0014\u001a\b\u0018\u00010\u0006R\u00020\u00078\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0014\u0010\u0013¨\u0006\u0015"}, d2 = {"okhttp3/internal/cache/DiskLruCache$snapshots$1", "Ljava/util/Iterator;", "Lh/x/d/z/a;", "", "hasNext", "()Z", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "next", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "", "remove", "()V", "", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "kotlin.jvm.PlatformType", "delegate", "Ljava/util/Iterator;", "nextSnapshot", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "removeSnapshot", "okhttp"}, k = 1, mv = {1, 1, 15}, pn = "", xi = 0, xs = "") 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(); k.c(it, "ArrayList(lruEntries.values).iterator()"); this.delegate = it; } @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 && (snapshotSnapshot$okhttp = next.snapshot$okhttp()) != null) { this.nextSnapshot = snapshotSnapshot$okhttp; return true; } } r rVar = r.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; } @Override // java.util.Iterator public Snapshot next() { if (!hasNext()) { throw new NoSuchElementException(); } Snapshot snapshot = this.nextSnapshot; this.removeSnapshot = snapshot; this.nextSnapshot = null; k.b(snapshot); return snapshot; } } /* 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) { k.d(fileSystem, "fileSystem"); k.d(file, "directory"); k.d(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 = q.c(q.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 q.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(); k.c(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 { i.h hVarD = q.d(this.fileSystem.source(this.journalFile)); try { String strV = hVarD.v(); String strV2 = hVarD.v(); String strV3 = hVarD.v(); String strV4 = hVarD.v(); String strV5 = hVarD.v(); if (!(!k.a(MAGIC, strV)) && !(!k.a(VERSION_1, strV2)) && !(!k.a(String.valueOf(this.appVersion), strV3)) && !(!k.a(String.valueOf(this.valueCount), strV4))) { int i2 = 0; if (!(strV5.length() > 0)) { while (true) { try { readJournalLine(hVarD.v()); i2++; } catch (EOFException unused) { this.redundantOpCount = i2 - this.lruEntries.size(); if (hVarD.B()) { this.journalWriter = newJournalWriter(); } else { rebuildJournal$okhttp(); } r rVar = r.a; a.a(hVarD, null); return; } } } } throw new IOException("unexpected journal header: [" + strV + ", " + strV2 + ", " + strV4 + ", " + strV5 + ']'); } finally { } } private final void readJournalLine(String str) throws IOException { String strSubstring; int iO = h.c0.q.O(str, ' ', 0, false, 6, null); if (iO == -1) { throw new IOException("unexpected journal line: " + str); } int i2 = iO + 1; int iO2 = h.c0.q.O(str, ' ', i2, false, 4, null); if (iO2 == -1) { if (str == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.String"); } strSubstring = str.substring(i2); k.c(strSubstring, "(this as java.lang.String).substring(startIndex)"); if (iO == REMOVE.length() && p.z(str, REMOVE, false, 2, null)) { this.lruEntries.remove(strSubstring); return; } } else { if (str == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.String"); } strSubstring = str.substring(i2, iO2); k.c(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 (iO2 != -1 && iO == CLEAN.length() && p.z(str, CLEAN, false, 2, null)) { int i3 = iO2 + 1; if (str == null) { throw new NullPointerException("null cannot be cast to non-null type java.lang.String"); } String strSubstring2 = str.substring(i3); k.c(strSubstring2, "(this as java.lang.String).substring(startIndex)"); List listL0 = h.c0.q.l0(strSubstring2, new char[]{' '}, false, 0, 6, null); entry.setReadable$okhttp(true); entry.setCurrentEditor$okhttp(null); entry.setLengths$okhttp(listL0); return; } if (iO2 == -1 && iO == DIRTY.length() && p.z(str, DIRTY, false, 2, null)) { entry.setCurrentEditor$okhttp(new Editor(this, entry)); return; } if (iO2 == -1 && iO == READ.length() && p.z(str, READ, false, 2, null)) { return; } throw new IOException("unexpected journal line: " + str); } private final boolean removeOldestEntry() throws IOException { for (Entry entry : this.lruEntries.values()) { if (!entry.getZombie$okhttp()) { k.c(entry, "toEvict"); removeEntry$okhttp(entry); return true; } } return false; } 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 + StringUtil.DOUBLE_QUOTE).toString()); } @Override // java.io.Closeable, java.lang.AutoCloseable public synchronized void close() throws IOException { Editor currentEditor$okhttp; if (this.initialized && !this.closed) { Collection collectionValues = this.lruEntries.values(); k.c(collectionValues, "lruEntries.values"); Object[] array = collectionValues.toArray(new Entry[0]); if (array == null) { throw new NullPointerException("null cannot be cast to non-null type kotlin.Array"); } for (Entry entry : (Entry[]) array) { if (entry.getCurrentEditor$okhttp() != null && (currentEditor$okhttp = entry.getCurrentEditor$okhttp()) != null) { currentEditor$okhttp.detach$okhttp(); } } trimToSize(); g gVar = this.journalWriter; k.b(gVar); gVar.close(); this.journalWriter = null; this.closed = true; return; } this.closed = true; } public final synchronized void completeEdit$okhttp(Editor editor, boolean z) throws IOException { k.d(editor, "editor"); Entry entry$okhttp = editor.getEntry$okhttp(); if (!k.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(); k.b(written$okhttp); 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 || entry$okhttp.getZombie$okhttp()) { 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; } } entry$okhttp.setCurrentEditor$okhttp(null); if (entry$okhttp.getZombie$okhttp()) { removeEntry$okhttp(entry$okhttp); return; } this.redundantOpCount++; g gVar = this.journalWriter; k.b(gVar); if (entry$okhttp.getReadable$okhttp() || z) { entry$okhttp.setReadable$okhttp(true); gVar.Z(CLEAN).writeByte(32); gVar.Z(entry$okhttp.getKey$okhttp()); entry$okhttp.writeLengths$okhttp(gVar); gVar.writeByte(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.Z(REMOVE).writeByte(32); gVar.Z(entry$okhttp.getKey$okhttp()); gVar.writeByte(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 { k.d(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 (entry != null && entry.getLockingSourceCount$okhttp() != 0) { return null; } if (!this.mostRecentTrimFailed && !this.mostRecentRebuildFailed) { g gVar = this.journalWriter; k.b(gVar); gVar.Z(DIRTY).writeByte(32).Z(str).writeByte(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(); k.c(collectionValues, "lruEntries.values"); Object[] array = collectionValues.toArray(new Entry[0]); if (array == null) { throw new NullPointerException("null cannot be cast to non-null type kotlin.Array"); } for (Entry entry : (Entry[]) array) { k.c(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; k.b(gVar); gVar.flush(); } } public final synchronized Snapshot get(String str) throws IOException { k.d(str, "key"); initialize(); checkNotClosed(); validateKey(str); Entry entry = this.lruEntries.get(str); if (entry == null) { return null; } k.c(entry, "lruEntries[key] ?: return null"); Snapshot snapshotSnapshot$okhttp = entry.snapshot$okhttp(); if (snapshotSnapshot$okhttp == null) { return null; } this.redundantOpCount++; g gVar = this.journalWriter; k.b(gVar); gVar.Z(READ).writeByte(32).Z(str).writeByte(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(); k.c(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); } } this.civilizedFileSystem = Util.isCivilized(this.fileSystem, this.journalFileBackup); if (this.fileSystem.exists(this.journalFile)) { try { readJournal(); processJournal(); this.initialized = true; return; } catch (IOException e2) { Platform.Companion.get().log("DiskLruCache " + this.directory + " is corrupt: " + e2.getMessage() + ", removing", 5, e2); 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 = q.c(this.fileSystem.sink(this.journalFileTmp)); try { gVarC.Z(MAGIC).writeByte(10); gVarC.Z(VERSION_1).writeByte(10); gVarC.b0(this.appVersion).writeByte(10); gVarC.b0(this.valueCount).writeByte(10); gVarC.writeByte(10); for (Entry entry : this.lruEntries.values()) { if (entry.getCurrentEditor$okhttp() != null) { gVarC.Z(DIRTY).writeByte(32); gVarC.Z(entry.getKey$okhttp()); gVarC.writeByte(10); } else { gVarC.Z(CLEAN).writeByte(32); gVarC.Z(entry.getKey$okhttp()); entry.writeLengths$okhttp(gVarC); gVarC.writeByte(10); } } r rVar = r.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 { k.d(str, "key"); initialize(); checkNotClosed(); validateKey(str); Entry entry = this.lruEntries.get(str); if (entry == null) { return false; } k.c(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 { g gVar; k.d(entry, "entry"); if (!this.civilizedFileSystem) { if (entry.getLockingSourceCount$okhttp() > 0 && (gVar = this.journalWriter) != null) { gVar.Z(DIRTY); gVar.writeByte(32); gVar.Z(entry.getKey$okhttp()); gVar.writeByte(10); gVar.flush(); } if (entry.getLockingSourceCount$okhttp() > 0 || entry.getCurrentEditor$okhttp() != null) { entry.setZombie$okhttp(true); return true; } } 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 gVar2 = this.journalWriter; if (gVar2 != null) { gVar2.Z(REMOVE); gVar2.writeByte(32); gVar2.Z(entry.getKey$okhttp()); gVar2.writeByte(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) { if (!removeOldestEntry()) { return; } } this.mostRecentTrimFailed = false; } }