package okhttp3.internal.cache; 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 kd.e; import kotlin.KotlinNothingValueException; import kotlin.Metadata; import kotlin.jvm.JvmField; import kotlin.jvm.JvmOverloads; import kotlin.jvm.internal.SourceDebugExtension; import kotlin.text.Regex; import kotlin.text.h; import kotlin.text.i; import nb.g; import okhttp3.internal.Util; import okhttp3.internal.cache.DiskLruCache; 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; import okio.BufferedSink; import okio.BufferedSource; import okio.ForwardingSource; import okio.Okio; import okio.Sink; import okio.Source; import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.Nullable; import sd.l; import td.a; import ua.b; import xyz.stream.download.config.InnerConstant; /* JADX INFO: loaded from: classes.dex */ @Metadata(d1 = {"\u0000\u0085\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010)\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\b*\u0001`\u0018\u0000 g2\u00020\u00012\u00020\u0002:\u0004ghijB9\b\u0000\u0012\u0006\u00100\u001a\u00020/\u0012\u0006\u00105\u001a\u000204\u0012\u0006\u0010:\u001a\u000209\u0012\u0006\u0010<\u001a\u000209\u0012\u0006\u0010@\u001a\u00020\f\u0012\u0006\u0010d\u001a\u00020c¢\u0006\u0004\be\u0010fJ\u0006\u0010\u0004\u001a\u00020\u0003J\u000f\u0010\u0007\u001a\u00020\u0003H\u0000¢\u0006\u0004\b\u0005\u0010\u0006J\u0017\u0010\u000b\u001a\b\u0018\u00010\nR\u00020\u00002\u0006\u0010\t\u001a\u00020\bH\u0086\u0002J \u0010\u000f\u001a\b\u0018\u00010\u000eR\u00020\u00002\u0006\u0010\t\u001a\u00020\b2\b\b\u0002\u0010\r\u001a\u00020\fH\u0007J\u0006\u0010\u0010\u001a\u00020\fJ#\u0010\u0016\u001a\u00020\u00032\n\u0010\u0011\u001a\u00060\u000eR\u00020\u00002\u0006\u0010\u0013\u001a\u00020\u0012H\u0000¢\u0006\u0004\b\u0014\u0010\u0015J\u000e\u0010\u0017\u001a\u00020\u00122\u0006\u0010\t\u001a\u00020\bJ\u001b\u0010\u001c\u001a\u00020\u00122\n\u0010\u0019\u001a\u00060\u0018R\u00020\u0000H\u0000¢\u0006\u0004\b\u001a\u0010\u001bJ\b\u0010\u001d\u001a\u00020\u0003H\u0016J\u0006\u0010\u001e\u001a\u00020\u0012J\b\u0010\u001f\u001a\u00020\u0003H\u0016J\u0006\u0010 \u001a\u00020\u0003J\u0006\u0010!\u001a\u00020\u0003J\u0006\u0010\"\u001a\u00020\u0003J\u0010\u0010$\u001a\f\u0012\b\u0012\u00060\nR\u00020\u00000#J\b\u0010%\u001a\u00020\u0003H\u0002J\b\u0010'\u001a\u00020&H\u0002J\u0010\u0010)\u001a\u00020\u00032\u0006\u0010(\u001a\u00020\bH\u0002J\b\u0010*\u001a\u00020\u0003H\u0002J\b\u0010+\u001a\u00020\u0012H\u0002J\b\u0010,\u001a\u00020\u0003H\u0002J\b\u0010-\u001a\u00020\u0012H\u0002J\u0010\u0010.\u001a\u00020\u00032\u0006\u0010\t\u001a\u00020\bH\u0002R\u001a\u00100\u001a\u00020/8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b0\u00101\u001a\u0004\b2\u00103R\u0017\u00105\u001a\u0002048\u0006¢\u0006\f\n\u0004\b5\u00106\u001a\u0004\b7\u00108R\u0014\u0010:\u001a\u0002098\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b:\u0010;R\u001a\u0010<\u001a\u0002098\u0000X\u0080\u0004¢\u0006\f\n\u0004\b<\u0010;\u001a\u0004\b=\u0010>R*\u0010@\u001a\u00020\f2\u0006\u0010?\u001a\u00020\f8F@FX\u0086\u000e¢\u0006\u0012\n\u0004\b@\u0010A\u001a\u0004\bB\u0010C\"\u0004\bD\u0010ER\u0014\u0010F\u001a\u0002048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bF\u00106R\u0014\u0010G\u001a\u0002048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bG\u00106R\u0014\u0010H\u001a\u0002048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bH\u00106R\u0016\u0010\u0010\u001a\u00020\f8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0010\u0010AR\u0018\u0010I\u001a\u0004\u0018\u00010&8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bI\u0010JR*\u0010L\u001a\u0012\u0012\u0004\u0012\u00020\b\u0012\b\u0012\u00060\u0018R\u00020\u00000K8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bL\u0010M\u001a\u0004\bN\u0010OR\u0016\u0010P\u001a\u0002098\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bP\u0010;R\u0016\u0010Q\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bQ\u0010RR\u0016\u0010S\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bS\u0010RR\u0016\u0010T\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bT\u0010RR\"\u0010U\u001a\u00020\u00128\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bU\u0010R\u001a\u0004\bV\u0010W\"\u0004\bX\u0010YR\u0016\u0010Z\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bZ\u0010RR\u0016\u0010[\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b[\u0010RR\u0016\u0010\\\u001a\u00020\f8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\\\u0010AR\u0014\u0010^\u001a\u00020]8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b^\u0010_R\u0014\u0010a\u001a\u00020`8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\ba\u0010b¨\u0006k"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache;", "Ljava/io/Closeable;", "Ljava/io/Flushable;", "Lkd/e;", "initialize", "rebuildJournal$okhttp", "()V", "rebuildJournal", "", "key", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "get", "", "expectedSequenceNumber", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "edit", InnerConstant.Db.size, "editor", "", "success", "completeEdit$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;Z)V", "completeEdit", "remove", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "entry", "removeEntry$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Entry;)Z", "removeEntry", "flush", "isClosed", "close", "trimToSize", "delete", "evictAll", "", "snapshots", "readJournal", "Lokio/BufferedSink;", "newJournalWriter", "line", "readJournalLine", "processJournal", "journalRebuildRequired", "checkNotClosed", "removeOldestEntry", "validateKey", "Lokhttp3/internal/io/FileSystem;", "fileSystem", "Lokhttp3/internal/io/FileSystem;", "getFileSystem$okhttp", "()Lokhttp3/internal/io/FileSystem;", "Ljava/io/File;", "directory", "Ljava/io/File;", "getDirectory", "()Ljava/io/File;", "", "appVersion", "I", "valueCount", "getValueCount$okhttp", "()I", "value", "maxSize", "J", "getMaxSize", "()J", "setMaxSize", "(J)V", "journalFile", "journalFileTmp", "journalFileBackup", "journalWriter", "Lokio/BufferedSink;", "Ljava/util/LinkedHashMap;", "lruEntries", "Ljava/util/LinkedHashMap;", "getLruEntries$okhttp", "()Ljava/util/LinkedHashMap;", "redundantOpCount", "hasJournalErrors", "Z", "civilizedFileSystem", "initialized", "closed", "getClosed$okhttp", "()Z", "setClosed$okhttp", "(Z)V", "mostRecentTrimFailed", "mostRecentRebuildFailed", "nextSequenceNumber", "Lokhttp3/internal/concurrent/TaskQueue;", "cleanupQueue", "Lokhttp3/internal/concurrent/TaskQueue;", "okhttp3/internal/cache/DiskLruCache$cleanupTask$1", "cleanupTask", "Lokhttp3/internal/cache/DiskLruCache$cleanupTask$1;", "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, 8, 0}) @SourceDebugExtension({"SMAP\nDiskLruCache.kt\nKotlin\n*S Kotlin\n*F\n+ 1 DiskLruCache.kt\nokhttp3/internal/cache/DiskLruCache\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n+ 3 Util.kt\nokhttp3/internal/Util\n+ 4 ArraysJVM.kt\nkotlin/collections/ArraysKt__ArraysJVMKt\n*L\n1#1,1065:1\n1#2:1066\n608#3,4:1067\n37#4,2:1071\n37#4,2:1073\n*S KotlinDebug\n*F\n+ 1 DiskLruCache.kt\nokhttp3/internal/cache/DiskLruCache\n*L\n215#1:1067,4\n672#1:1071,2\n721#1:1073,2\n*E\n"}) public final class DiskLruCache implements Closeable, Flushable { private final int appVersion; private boolean civilizedFileSystem; @NotNull private final TaskQueue cleanupQueue; @NotNull private final DiskLruCache$cleanupTask$1 cleanupTask; private boolean closed; @NotNull private final File directory; @NotNull private final FileSystem fileSystem; private boolean hasJournalErrors; private boolean initialized; @NotNull private final File journalFile; @NotNull private final File journalFileBackup; @NotNull private final File journalFileTmp; @Nullable private BufferedSink journalWriter; @NotNull 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; @JvmField @NotNull public static final String JOURNAL_FILE = "journal"; @JvmField @NotNull public static final String JOURNAL_FILE_TEMP = "journal.tmp"; @JvmField @NotNull public static final String JOURNAL_FILE_BACKUP = "journal.bkp"; @JvmField @NotNull public static final String MAGIC = "libcore.io.DiskLruCache"; @JvmField @NotNull public static final String VERSION_1 = "1"; @JvmField public static final long ANY_SEQUENCE_NUMBER = -1; @JvmField @NotNull public static final Regex LEGAL_KEY_PATTERN = new Regex("[a-z0-9_-]{1,120}"); @JvmField @NotNull public static final String CLEAN = "CLEAN"; @JvmField @NotNull public static final String DIRTY = "DIRTY"; @JvmField @NotNull public static final String REMOVE = "REMOVE"; @JvmField @NotNull public static final String READ = "READ"; @Metadata(d1 = {"\u0000@\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u0018\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0005\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0015\b\u0000\u0012\n\u0010\u0010\u001a\u00060\u000eR\u00020\u000f¢\u0006\u0004\b\u001c\u0010\u001dJ\u000f\u0010\u0005\u001a\u00020\u0002H\u0000¢\u0006\u0004\b\u0003\u0010\u0004J\u0010\u0010\t\u001a\u0004\u0018\u00010\b2\u0006\u0010\u0007\u001a\u00020\u0006J\u000e\u0010\u000b\u001a\u00020\n2\u0006\u0010\u0007\u001a\u00020\u0006J\u0006\u0010\f\u001a\u00020\u0002J\u0006\u0010\r\u001a\u00020\u0002R\u001e\u0010\u0010\u001a\u00060\u000eR\u00020\u000f8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0010\u0010\u0011\u001a\u0004\b\u0012\u0010\u0013R\u001c\u0010\u0015\u001a\u0004\u0018\u00010\u00148\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0015\u0010\u0016\u001a\u0004\b\u0017\u0010\u0018R\u0016\u0010\u001a\u001a\u00020\u00198\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u001a\u0010\u001b¨\u0006\u001e"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "Lkd/e;", "detach$okhttp", "()V", "detach", "", "index", "Lokio/Source;", "newSource", "Lokio/Sink;", "newSink", "commit", "abort", "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", "", "done", "Z", "", "(Lokhttp3/internal/cache/DiskLruCache;Lokhttp3/internal/cache/DiskLruCache$Entry;)V", "okhttp"}, k = 1, mv = {1, 8, 0}) public final class Editor { private boolean done; @NotNull private final Entry entry; final /* synthetic */ DiskLruCache this$0; @Nullable private final boolean[] written; public Editor(@NotNull DiskLruCache diskLruCache, Entry entry) { g.i(entry, "entry"); this.this$0 = diskLruCache; this.entry = entry; this.written = entry.getReadable() ? null : new boolean[diskLruCache.getValueCount()]; } public final void abort() throws IOException { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { try { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (g.c(this.entry.getCurrentEditor(), this)) { diskLruCache.completeEdit$okhttp(this, false); } this.done = true; } catch (Throwable th) { throw th; } } } public final void commit() throws IOException { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { try { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (g.c(this.entry.getCurrentEditor(), this)) { diskLruCache.completeEdit$okhttp(this, true); } this.done = true; } catch (Throwable th) { throw th; } } } public final void detach$okhttp() throws IOException { if (g.c(this.entry.getCurrentEditor(), this)) { if (this.this$0.civilizedFileSystem) { this.this$0.completeEdit$okhttp(this, false); } else { this.entry.setZombie$okhttp(true); } } } @NotNull /* JADX INFO: renamed from: getEntry$okhttp, reason: from getter */ public final Entry getEntry() { return this.entry; } @Nullable /* JADX INFO: renamed from: getWritten$okhttp, reason: from getter */ public final boolean[] getWritten() { return this.written; } @NotNull public final Sink newSink(int index) { final DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } if (!g.c(this.entry.getCurrentEditor(), this)) { return Okio.blackhole(); } if (!this.entry.getReadable()) { boolean[] zArr = this.written; g.f(zArr); zArr[index] = true; } try { return new FaultHidingSink(diskLruCache.getFileSystem().sink(this.entry.getDirtyFiles$okhttp().get(index)), new l() { // from class: okhttp3.internal.cache.DiskLruCache$Editor$newSink$1$1 /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(1); } @Override // sd.l public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((IOException) obj); return e.f29109a; } public final void invoke(@NotNull IOException iOException) { g.i(iOException, "it"); DiskLruCache diskLruCache2 = diskLruCache; DiskLruCache.Editor editor = this; synchronized (diskLruCache2) { editor.detach$okhttp(); } } }); } catch (FileNotFoundException unused) { return Okio.blackhole(); } } } @Nullable public final Source newSource(int index) { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { if (!(!this.done)) { throw new IllegalStateException("Check failed.".toString()); } Source source = null; if (!this.entry.getReadable() || !g.c(this.entry.getCurrentEditor(), this) || this.entry.getZombie()) { return null; } try { source = diskLruCache.getFileSystem().source(this.entry.getCleanFiles$okhttp().get(index)); } catch (FileNotFoundException unused) { } return source; } } } @Metadata(d1 = {"\u0000l\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010 \n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\u0001\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\u0016\n\u0002\b\u0004\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\u000b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0010\t\n\u0002\b\t\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0011\b\u0000\u0012\u0006\u0010\u0019\u001a\u00020\u0003¢\u0006\u0004\bH\u0010IJ\u0016\u0010\u0006\u001a\u00020\u00052\f\u0010\u0004\u001a\b\u0012\u0004\u0012\u00020\u00030\u0002H\u0002J\u0010\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0007H\u0002J\u001d\u0010\u000e\u001a\u00020\u000b2\f\u0010\u0004\u001a\b\u0012\u0004\u0012\u00020\u00030\u0002H\u0000¢\u0006\u0004\b\f\u0010\rJ\u0017\u0010\u0013\u001a\u00020\u000b2\u0006\u0010\u0010\u001a\u00020\u000fH\u0000¢\u0006\u0004\b\u0011\u0010\u0012J\u0015\u0010\u0018\u001a\b\u0018\u00010\u0014R\u00020\u0015H\u0000¢\u0006\u0004\b\u0016\u0010\u0017R\u001a\u0010\u0019\u001a\u00020\u00038\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0019\u0010\u001a\u001a\u0004\b\u001b\u0010\u001cR\u001a\u0010\u001e\u001a\u00020\u001d8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u001e\u0010\u001f\u001a\u0004\b \u0010!R \u0010$\u001a\b\u0012\u0004\u0012\u00020#0\"8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b$\u0010%\u001a\u0004\b&\u0010'R \u0010(\u001a\b\u0012\u0004\u0012\u00020#0\"8\u0000X\u0080\u0004¢\u0006\f\n\u0004\b(\u0010%\u001a\u0004\b)\u0010'R\"\u0010+\u001a\u00020*8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b+\u0010,\u001a\u0004\b-\u0010.\"\u0004\b/\u00100R\"\u00101\u001a\u00020*8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b1\u0010,\u001a\u0004\b2\u0010.\"\u0004\b3\u00100R(\u00105\u001a\b\u0018\u000104R\u00020\u00158\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b5\u00106\u001a\u0004\b7\u00108\"\u0004\b9\u0010:R\"\u0010;\u001a\u00020\u00078\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b;\u0010<\u001a\u0004\b=\u0010>\"\u0004\b?\u0010@R\"\u0010B\u001a\u00020A8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bB\u0010C\u001a\u0004\bD\u0010E\"\u0004\bF\u0010G¨\u0006J"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "", "", "strings", "", "invalidLengths", "", "index", "Lokio/Source;", "newSource", "Lkd/e;", "setLengths$okhttp", "(Ljava/util/List;)V", "setLengths", "Lokio/BufferedSink;", "writer", "writeLengths$okhttp", "(Lokio/BufferedSink;)V", "writeLengths", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "snapshot", "key", "Ljava/lang/String;", "getKey$okhttp", "()Ljava/lang/String;", "", "lengths", "[J", "getLengths$okhttp", "()[J", "", "Ljava/io/File;", "cleanFiles", "Ljava/util/List;", "getCleanFiles$okhttp", "()Ljava/util/List;", "dirtyFiles", "getDirtyFiles$okhttp", "", "readable", "Z", "getReadable$okhttp", "()Z", "setReadable$okhttp", "(Z)V", "zombie", "getZombie$okhttp", "setZombie$okhttp", "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", "lockingSourceCount", "I", "getLockingSourceCount$okhttp", "()I", "setLockingSourceCount$okhttp", "(I)V", "", "sequenceNumber", "J", "getSequenceNumber$okhttp", "()J", "setSequenceNumber$okhttp", "(J)V", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;)V", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nDiskLruCache.kt\nKotlin\n*S Kotlin\n*F\n+ 1 DiskLruCache.kt\nokhttp3/internal/cache/DiskLruCache$Entry\n+ 2 Util.kt\nokhttp3/internal/Util\n*L\n1#1,1065:1\n608#2,4:1066\n*S KotlinDebug\n*F\n+ 1 DiskLruCache.kt\nokhttp3/internal/cache/DiskLruCache$Entry\n*L\n1001#1:1066,4\n*E\n"}) public final class Entry { @NotNull private final List cleanFiles; @Nullable private Editor currentEditor; @NotNull private final List dirtyFiles; @NotNull private final String key; @NotNull private final long[] lengths; private int lockingSourceCount; private boolean readable; private long sequenceNumber; final /* synthetic */ DiskLruCache this$0; private boolean zombie; public Entry(@NotNull DiskLruCache diskLruCache, String str) { g.i(str, "key"); this.this$0 = diskLruCache; this.key = str; this.lengths = new long[diskLruCache.getValueCount()]; this.cleanFiles = new ArrayList(); this.dirtyFiles = new ArrayList(); StringBuilder sb = new StringBuilder(str); sb.append('.'); int length = sb.length(); int valueCount = diskLruCache.getValueCount(); for (int i10 = 0; i10 < valueCount; i10++) { sb.append(i10); this.cleanFiles.add(new File(this.this$0.getDirectory(), sb.toString())); sb.append(".tmp"); this.dirtyFiles.add(new File(this.this$0.getDirectory(), sb.toString())); sb.setLength(length); } } private final Void invalidLengths(List strings) throws IOException { throw new IOException("unexpected journal line: " + strings); } private final Source newSource(int index) throws FileNotFoundException { final Source source = this.this$0.getFileSystem().source(this.cleanFiles.get(index)); if (this.this$0.civilizedFileSystem) { return source; } this.lockingSourceCount++; final DiskLruCache diskLruCache = this.this$0; return new ForwardingSource(source) { // from class: okhttp3.internal.cache.DiskLruCache$Entry$newSource$1 private boolean closed; @Override // okio.ForwardingSource, okio.Source, java.io.Closeable, java.lang.AutoCloseable public void close() throws IOException { super.close(); if (this.closed) { return; } this.closed = true; DiskLruCache diskLruCache2 = diskLruCache; DiskLruCache.Entry entry = this; synchronized (diskLruCache2) { entry.setLockingSourceCount$okhttp(entry.getLockingSourceCount() - 1); if (entry.getLockingSourceCount() == 0 && entry.getZombie()) { diskLruCache2.removeEntry$okhttp(entry); } } } }; } @NotNull public final List getCleanFiles$okhttp() { return this.cleanFiles; } @Nullable /* JADX INFO: renamed from: getCurrentEditor$okhttp, reason: from getter */ public final Editor getCurrentEditor() { return this.currentEditor; } @NotNull public final List getDirtyFiles$okhttp() { return this.dirtyFiles; } @NotNull /* JADX INFO: renamed from: getKey$okhttp, reason: from getter */ public final String getKey() { return this.key; } @NotNull /* JADX INFO: renamed from: getLengths$okhttp, reason: from getter */ public final long[] getLengths() { return this.lengths; } /* JADX INFO: renamed from: getLockingSourceCount$okhttp, reason: from getter */ public final int getLockingSourceCount() { return this.lockingSourceCount; } /* JADX INFO: renamed from: getReadable$okhttp, reason: from getter */ public final boolean getReadable() { return this.readable; } /* JADX INFO: renamed from: getSequenceNumber$okhttp, reason: from getter */ public final long getSequenceNumber() { return this.sequenceNumber; } /* JADX INFO: renamed from: getZombie$okhttp, reason: from getter */ public final boolean getZombie() { return this.zombie; } public final void setCurrentEditor$okhttp(@Nullable Editor editor) { this.currentEditor = editor; } public final void setLengths$okhttp(@NotNull List strings) throws IOException { g.i(strings, "strings"); if (strings.size() != this.this$0.getValueCount()) { invalidLengths(strings); throw new KotlinNothingValueException(); } try { int size = strings.size(); for (int i10 = 0; i10 < size; i10++) { this.lengths[i10] = Long.parseLong(strings.get(i10)); } } catch (NumberFormatException unused) { invalidLengths(strings); throw new KotlinNothingValueException(); } } public final void setLockingSourceCount$okhttp(int i10) { this.lockingSourceCount = i10; } public final void setReadable$okhttp(boolean z10) { this.readable = z10; } public final void setSequenceNumber$okhttp(long j10) { this.sequenceNumber = j10; } public final void setZombie$okhttp(boolean z10) { this.zombie = z10; } @Nullable public final Snapshot snapshot$okhttp() { DiskLruCache diskLruCache = this.this$0; if (Util.assertionsEnabled && !Thread.holdsLock(diskLruCache)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + diskLruCache); } 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 = this.this$0.getValueCount(); for (int i10 = 0; i10 < valueCount; i10++) { arrayList.add(newSource(i10)); } return new Snapshot(this.this$0, this.key, this.sequenceNumber, arrayList, jArr); } catch (FileNotFoundException unused) { Iterator it = arrayList.iterator(); while (it.hasNext()) { Util.closeQuietly((Source) it.next()); } try { this.this$0.removeEntry$okhttp(this); } catch (IOException unused2) { } return null; } } public final void writeLengths$okhttp(@NotNull BufferedSink writer) throws IOException { g.i(writer, "writer"); for (long j10 : this.lengths) { writer.writeByte(32).writeDecimalLong(j10); } } } @Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\b\u0002\n\u0002\u0010\u0016\n\u0002\b\u0005\b\u0086\u0004\u0018\u00002\u00020\u0001B/\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0010\u001a\u00020\u000b\u0012\f\u0010\u0013\u001a\b\u0012\u0004\u0012\u00020\t0\u0012\u0012\u0006\u0010\u0016\u001a\u00020\u0015¢\u0006\u0004\b\u0018\u0010\u0019J\u0006\u0010\u0003\u001a\u00020\u0002J\f\u0010\u0006\u001a\b\u0018\u00010\u0004R\u00020\u0005J\u000e\u0010\n\u001a\u00020\t2\u0006\u0010\b\u001a\u00020\u0007J\u000e\u0010\f\u001a\u00020\u000b2\u0006\u0010\b\u001a\u00020\u0007J\b\u0010\u000e\u001a\u00020\rH\u0016R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u000fR\u0014\u0010\u0010\u001a\u00020\u000b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011R\u001a\u0010\u0013\u001a\b\u0012\u0004\u0012\u00020\t0\u00128\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014R\u0014\u0010\u0016\u001a\u00020\u00158\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0016\u0010\u0017¨\u0006\u001a"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Ljava/io/Closeable;", "", "key", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "edit", "", "index", "Lokio/Source;", "getSource", "", "getLength", "Lkd/e;", "close", "Ljava/lang/String;", "sequenceNumber", "J", "", "sources", "Ljava/util/List;", "", "lengths", "[J", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;JLjava/util/List;[J)V", "okhttp"}, k = 1, mv = {1, 8, 0}) public final class Snapshot implements Closeable { @NotNull private final String key; @NotNull private final long[] lengths; private final long sequenceNumber; @NotNull private final List sources; final /* synthetic */ DiskLruCache this$0; /* JADX WARN: Multi-variable type inference failed */ public Snapshot(@NotNull DiskLruCache diskLruCache, String str, @NotNull long j10, @NotNull List list, long[] jArr) { g.i(str, "key"); g.i(list, "sources"); g.i(jArr, "lengths"); this.this$0 = diskLruCache; this.key = str; this.sequenceNumber = j10; 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()); } } @Nullable public final Editor edit() throws IOException { return this.this$0.edit(this.key, this.sequenceNumber); } public final long getLength(int index) { return this.lengths[index]; } @NotNull public final Source getSource(int index) { return this.sources.get(index); } @NotNull /* JADX INFO: renamed from: key, reason: from getter */ public final String getKey() { return this.key; } } /* JADX INFO: renamed from: okhttp3.internal.cache.DiskLruCache$snapshots$1, reason: invalid class name */ @Metadata(d1 = {"\u0000'\n\u0000\n\u0002\u0010)\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0007*\u0001\u0000\b\n\u0018\u00002\f\u0012\b\u0012\u00060\u0002R\u00020\u00030\u0001J\t\u0010\u0005\u001a\u00020\u0004H\u0096\u0002J\r\u0010\u0006\u001a\u00060\u0002R\u00020\u0003H\u0096\u0002J\b\u0010\b\u001a\u00020\u0007H\u0016R*\u0010\u000b\u001a\u0018\u0012\u0014\u0012\u0012 \n*\b\u0018\u00010\tR\u00020\u00030\tR\u00020\u00030\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000b\u0010\fR\u001c\u0010\r\u001a\b\u0018\u00010\u0002R\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\r\u0010\u000eR\u001c\u0010\u000f\u001a\b\u0018\u00010\u0002R\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u000f\u0010\u000e¨\u0006\u0010"}, d2 = {"okhttp3/internal/cache/DiskLruCache$snapshots$1", "", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "", "hasNext", "next", "Lkd/e;", "remove", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "kotlin.jvm.PlatformType", "delegate", "Ljava/util/Iterator;", "nextSnapshot", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "removeSnapshot", "okhttp"}, k = 1, mv = {1, 8, 0}) @SourceDebugExtension({"SMAP\nDiskLruCache.kt\nKotlin\n*S Kotlin\n*F\n+ 1 DiskLruCache.kt\nokhttp3/internal/cache/DiskLruCache$snapshots$1\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n*L\n1#1,1065:1\n1#2:1066\n*E\n"}) public static final class AnonymousClass1 implements Iterator, a { @NotNull private final Iterator delegate; @Nullable private Snapshot nextSnapshot; @Nullable private Snapshot removeSnapshot; public AnonymousClass1() { Iterator it = new ArrayList(DiskLruCache.this.getLruEntries$okhttp().values()).iterator(); g.h(it, "ArrayList(lruEntries.values).iterator()"); this.delegate = it; } @Override // java.util.Iterator public boolean hasNext() { Snapshot snapshotSnapshot$okhttp; if (this.nextSnapshot != null) { return true; } DiskLruCache diskLruCache = DiskLruCache.this; synchronized (diskLruCache) { if (diskLruCache.getClosed()) { 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; } } 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.getKey()); } catch (IOException unused) { } catch (Throwable th) { this.removeSnapshot = null; throw th; } this.removeSnapshot = null; } @Override // java.util.Iterator @NotNull public Snapshot next() { if (!hasNext()) { throw new NoSuchElementException(); } Snapshot snapshot = this.nextSnapshot; this.removeSnapshot = snapshot; this.nextSnapshot = null; g.f(snapshot); return snapshot; } } /* JADX WARN: Type inference failed for: r5v3, types: [okhttp3.internal.cache.DiskLruCache$cleanupTask$1] */ public DiskLruCache(@NotNull FileSystem fileSystem, @NotNull File file, int i10, int i11, long j10, @NotNull TaskRunner taskRunner) { g.i(fileSystem, "fileSystem"); g.i(file, "directory"); g.i(taskRunner, "taskRunner"); this.fileSystem = fileSystem; this.directory = file; this.appVersion = i10; this.valueCount = i11; this.maxSize = j10; this.lruEntries = new LinkedHashMap<>(0, 0.75f, true); this.cleanupQueue = taskRunner.newQueue(); final String strO = defpackage.e.o(new StringBuilder(), Util.okHttpName, " Cache"); this.cleanupTask = new Task(strO) { // from class: okhttp3.internal.cache.DiskLruCache$cleanupTask$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { if (!diskLruCache.initialized || diskLruCache.getClosed()) { return -1L; } try { diskLruCache.trimToSize(); } catch (IOException unused) { diskLruCache.mostRecentTrimFailed = true; } try { if (diskLruCache.journalRebuildRequired()) { diskLruCache.rebuildJournal$okhttp(); diskLruCache.redundantOpCount = 0; } } catch (IOException unused2) { diskLruCache.mostRecentRebuildFailed = true; diskLruCache.journalWriter = Okio.buffer(Okio.blackhole()); } return -1L; } } }; if (j10 <= 0) { throw new IllegalArgumentException("maxSize <= 0".toString()); } if (i11 <= 0) { throw new IllegalArgumentException("valueCount <= 0".toString()); } this.journalFile = new File(file, JOURNAL_FILE); this.journalFileTmp = new File(file, JOURNAL_FILE_TEMP); this.journalFileBackup = new File(file, 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 j10, int i10, Object obj) throws IOException { if ((i10 & 2) != 0) { j10 = ANY_SEQUENCE_NUMBER; } return diskLruCache.edit(str, j10); } /* JADX INFO: Access modifiers changed from: private */ public final boolean journalRebuildRequired() { int i10 = this.redundantOpCount; return i10 >= 2000 && i10 >= this.lruEntries.size(); } private final BufferedSink newJournalWriter() throws FileNotFoundException { return Okio.buffer(new FaultHidingSink(this.fileSystem.appendingSink(this.journalFile), new l() { // from class: okhttp3.internal.cache.DiskLruCache$newJournalWriter$faultHidingSink$1 { super(1); } @Override // sd.l public /* bridge */ /* synthetic */ Object invoke(Object obj) { invoke((IOException) obj); return e.f29109a; } public final void invoke(@NotNull IOException iOException) { g.i(iOException, "it"); DiskLruCache diskLruCache = this.this$0; if (!Util.assertionsEnabled || Thread.holdsLock(diskLruCache)) { this.this$0.hasJournalErrors = true; return; } throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + diskLruCache); } })); } private final void processJournal() throws IOException { this.fileSystem.delete(this.journalFileTmp); Iterator it = this.lruEntries.values().iterator(); while (it.hasNext()) { Entry next = it.next(); g.h(next, "i.next()"); Entry entry = next; int i10 = 0; if (entry.getCurrentEditor() == null) { int i11 = this.valueCount; while (i10 < i11) { this.size += entry.getLengths()[i10]; i10++; } } else { entry.setCurrentEditor$okhttp(null); int i12 = this.valueCount; while (i10 < i12) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i10)); this.fileSystem.delete(entry.getDirtyFiles$okhttp().get(i10)); i10++; } it.remove(); } } } private final void readJournal() throws IOException { BufferedSource bufferedSourceBuffer = Okio.buffer(this.fileSystem.source(this.journalFile)); try { String utf8LineStrict = bufferedSourceBuffer.readUtf8LineStrict(); String utf8LineStrict2 = bufferedSourceBuffer.readUtf8LineStrict(); String utf8LineStrict3 = bufferedSourceBuffer.readUtf8LineStrict(); String utf8LineStrict4 = bufferedSourceBuffer.readUtf8LineStrict(); String utf8LineStrict5 = bufferedSourceBuffer.readUtf8LineStrict(); if (!g.c(MAGIC, utf8LineStrict) || !g.c(VERSION_1, utf8LineStrict2) || !g.c(String.valueOf(this.appVersion), utf8LineStrict3) || !g.c(String.valueOf(this.valueCount), utf8LineStrict4) || utf8LineStrict5.length() > 0) { throw new IOException("unexpected journal header: [" + utf8LineStrict + ", " + utf8LineStrict2 + ", " + utf8LineStrict4 + ", " + utf8LineStrict5 + ']'); } int i10 = 0; while (true) { try { readJournalLine(bufferedSourceBuffer.readUtf8LineStrict()); i10++; } catch (EOFException unused) { this.redundantOpCount = i10 - this.lruEntries.size(); if (bufferedSourceBuffer.exhausted()) { this.journalWriter = newJournalWriter(); } else { rebuildJournal$okhttp(); } b.g(bufferedSourceBuffer, null); return; } } } finally { } } private final void readJournalLine(String str) throws IOException { String strSubstring; int iP0 = i.p0(str, ' ', 0, false, 6); if (iP0 == -1) { throw new IOException("unexpected journal line: ".concat(str)); } int i10 = iP0 + 1; int iP02 = i.p0(str, ' ', i10, false, 4); if (iP02 == -1) { strSubstring = str.substring(i10); g.h(strSubstring, "this as java.lang.String).substring(startIndex)"); String str2 = REMOVE; if (iP0 == str2.length() && h.j0(str, str2, false)) { this.lruEntries.remove(strSubstring); return; } } else { strSubstring = str.substring(i10, iP02); g.h(strSubstring, "this as java.lang.String…ing(startIndex, endIndex)"); } Entry entry = this.lruEntries.get(strSubstring); if (entry == null) { entry = new Entry(this, strSubstring); this.lruEntries.put(strSubstring, entry); } if (iP02 != -1) { String str3 = CLEAN; if (iP0 == str3.length() && h.j0(str, str3, false)) { String strSubstring2 = str.substring(iP02 + 1); g.h(strSubstring2, "this as java.lang.String).substring(startIndex)"); List listA0 = i.A0(strSubstring2, new char[]{' '}); entry.setReadable$okhttp(true); entry.setCurrentEditor$okhttp(null); entry.setLengths$okhttp(listA0); return; } } if (iP02 == -1) { String str4 = DIRTY; if (iP0 == str4.length() && h.j0(str, str4, false)) { entry.setCurrentEditor$okhttp(new Editor(this, entry)); return; } } if (iP02 == -1) { String str5 = READ; if (iP0 == str5.length() && h.j0(str, str5, false)) { return; } } throw new IOException("unexpected journal line: ".concat(str)); } private final boolean removeOldestEntry() throws IOException { for (Entry entry : this.lruEntries.values()) { if (!entry.getZombie()) { 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 + '\"').toString()); } @Override // java.io.Closeable, java.lang.AutoCloseable public synchronized void close() throws IOException { Editor currentEditor; try { if (this.initialized && !this.closed) { Collection collectionValues = this.lruEntries.values(); g.h(collectionValues, "lruEntries.values"); for (Entry entry : (Entry[]) collectionValues.toArray(new Entry[0])) { if (entry.getCurrentEditor() != null && (currentEditor = entry.getCurrentEditor()) != null) { currentEditor.detach$okhttp(); } } trimToSize(); BufferedSink bufferedSink = this.journalWriter; g.f(bufferedSink); bufferedSink.close(); this.journalWriter = null; this.closed = true; return; } this.closed = true; } catch (Throwable th) { throw th; } } public final synchronized void completeEdit$okhttp(@NotNull Editor editor, boolean success) throws IOException { g.i(editor, "editor"); Entry entry = editor.getEntry(); if (!g.c(entry.getCurrentEditor(), editor)) { throw new IllegalStateException("Check failed.".toString()); } if (success && !entry.getReadable()) { int i10 = this.valueCount; for (int i11 = 0; i11 < i10; i11++) { boolean[] written = editor.getWritten(); g.f(written); if (!written[i11]) { editor.abort(); throw new IllegalStateException("Newly created entry didn't create value for index " + i11); } if (!this.fileSystem.exists(entry.getDirtyFiles$okhttp().get(i11))) { editor.abort(); return; } } } int i12 = this.valueCount; for (int i13 = 0; i13 < i12; i13++) { File file = entry.getDirtyFiles$okhttp().get(i13); if (!success || entry.getZombie()) { this.fileSystem.delete(file); } else if (this.fileSystem.exists(file)) { File file2 = entry.getCleanFiles$okhttp().get(i13); this.fileSystem.rename(file, file2); long j10 = entry.getLengths()[i13]; long size = this.fileSystem.size(file2); entry.getLengths()[i13] = size; this.size = (this.size - j10) + size; } } entry.setCurrentEditor$okhttp(null); if (entry.getZombie()) { removeEntry$okhttp(entry); return; } this.redundantOpCount++; BufferedSink bufferedSink = this.journalWriter; g.f(bufferedSink); if (entry.getReadable() || success) { entry.setReadable$okhttp(true); bufferedSink.writeUtf8(CLEAN).writeByte(32); bufferedSink.writeUtf8(entry.getKey()); entry.writeLengths$okhttp(bufferedSink); bufferedSink.writeByte(10); if (success) { long j11 = this.nextSequenceNumber; this.nextSequenceNumber = 1 + j11; entry.setSequenceNumber$okhttp(j11); } } else { this.lruEntries.remove(entry.getKey()); bufferedSink.writeUtf8(REMOVE).writeByte(32); bufferedSink.writeUtf8(entry.getKey()); bufferedSink.writeByte(10); } bufferedSink.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); } @JvmOverloads @Nullable public final Editor edit(@NotNull String str) throws IOException { g.i(str, "key"); return edit$default(this, str, 0L, 2, null); } public final synchronized void evictAll() throws IOException { try { initialize(); Collection collectionValues = this.lruEntries.values(); g.h(collectionValues, "lruEntries.values"); for (Entry entry : (Entry[]) collectionValues.toArray(new Entry[0])) { g.h(entry, "entry"); removeEntry$okhttp(entry); } this.mostRecentTrimFailed = false; } catch (Throwable th) { throw th; } } @Override // java.io.Flushable public synchronized void flush() throws IOException { if (this.initialized) { checkNotClosed(); trimToSize(); BufferedSink bufferedSink = this.journalWriter; g.f(bufferedSink); bufferedSink.flush(); } } @Nullable public final synchronized Snapshot get(@NotNull String key) throws IOException { g.i(key, "key"); initialize(); checkNotClosed(); validateKey(key); Entry entry = this.lruEntries.get(key); if (entry == null) { return null; } Snapshot snapshotSnapshot$okhttp = entry.snapshot$okhttp(); if (snapshotSnapshot$okhttp == null) { return null; } this.redundantOpCount++; BufferedSink bufferedSink = this.journalWriter; g.f(bufferedSink); bufferedSink.writeUtf8(READ).writeByte(32).writeUtf8(key).writeByte(10); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return snapshotSnapshot$okhttp; } /* JADX INFO: renamed from: getClosed$okhttp, reason: from getter */ public final boolean getClosed() { return this.closed; } @NotNull public final File getDirectory() { return this.directory; } @NotNull /* JADX INFO: renamed from: getFileSystem$okhttp, reason: from getter */ public final FileSystem getFileSystem() { return this.fileSystem; } @NotNull public final LinkedHashMap getLruEntries$okhttp() { return this.lruEntries; } public final synchronized long getMaxSize() { return this.maxSize; } /* JADX INFO: renamed from: getValueCount$okhttp, reason: from getter */ public final int getValueCount() { return this.valueCount; } public final synchronized void initialize() throws IOException { try { if (Util.assertionsEnabled && !Thread.holdsLock(this)) { throw new AssertionError("Thread " + Thread.currentThread().getName() + " MUST hold lock on " + this); } 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 e10) { Platform.INSTANCE.get().log("DiskLruCache " + this.directory + " is corrupt: " + e10.getMessage() + ", removing", 5, e10); try { delete(); this.closed = false; rebuildJournal$okhttp(); this.initialized = true; } catch (Throwable th) { this.closed = false; throw th; } } } rebuildJournal$okhttp(); this.initialized = true; } catch (Throwable th2) { throw th2; } } public final synchronized boolean isClosed() { return this.closed; } public final synchronized void rebuildJournal$okhttp() throws IOException { try { BufferedSink bufferedSink = this.journalWriter; if (bufferedSink != null) { bufferedSink.close(); } BufferedSink bufferedSinkBuffer = Okio.buffer(this.fileSystem.sink(this.journalFileTmp)); try { bufferedSinkBuffer.writeUtf8(MAGIC).writeByte(10); bufferedSinkBuffer.writeUtf8(VERSION_1).writeByte(10); bufferedSinkBuffer.writeDecimalLong(this.appVersion).writeByte(10); bufferedSinkBuffer.writeDecimalLong(this.valueCount).writeByte(10); bufferedSinkBuffer.writeByte(10); for (Entry entry : this.lruEntries.values()) { if (entry.getCurrentEditor() != null) { bufferedSinkBuffer.writeUtf8(DIRTY).writeByte(32); bufferedSinkBuffer.writeUtf8(entry.getKey()); bufferedSinkBuffer.writeByte(10); } else { bufferedSinkBuffer.writeUtf8(CLEAN).writeByte(32); bufferedSinkBuffer.writeUtf8(entry.getKey()); entry.writeLengths$okhttp(bufferedSinkBuffer); bufferedSinkBuffer.writeByte(10); } } b.g(bufferedSinkBuffer, 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 { } } catch (Throwable th) { throw th; } } public final synchronized boolean remove(@NotNull String key) throws IOException { g.i(key, "key"); initialize(); checkNotClosed(); validateKey(key); Entry entry = this.lruEntries.get(key); if (entry == null) { 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(@NotNull Entry entry) throws IOException { BufferedSink bufferedSink; g.i(entry, "entry"); if (!this.civilizedFileSystem) { if (entry.getLockingSourceCount() > 0 && (bufferedSink = this.journalWriter) != null) { bufferedSink.writeUtf8(DIRTY); bufferedSink.writeByte(32); bufferedSink.writeUtf8(entry.getKey()); bufferedSink.writeByte(10); bufferedSink.flush(); } if (entry.getLockingSourceCount() > 0 || entry.getCurrentEditor() != null) { entry.setZombie$okhttp(true); return true; } } Editor currentEditor = entry.getCurrentEditor(); if (currentEditor != null) { currentEditor.detach$okhttp(); } int i10 = this.valueCount; for (int i11 = 0; i11 < i10; i11++) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i11)); this.size -= entry.getLengths()[i11]; entry.getLengths()[i11] = 0; } this.redundantOpCount++; BufferedSink bufferedSink2 = this.journalWriter; if (bufferedSink2 != null) { bufferedSink2.writeUtf8(REMOVE); bufferedSink2.writeByte(32); bufferedSink2.writeUtf8(entry.getKey()); bufferedSink2.writeByte(10); } this.lruEntries.remove(entry.getKey()); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return true; } public final void setClosed$okhttp(boolean z10) { this.closed = z10; } public final synchronized void setMaxSize(long j10) { this.maxSize = j10; if (this.initialized) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } } public final synchronized long size() throws IOException { initialize(); return this.size; } @NotNull 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; } @JvmOverloads @Nullable public final synchronized Editor edit(@NotNull String key, long expectedSequenceNumber) throws IOException { g.i(key, "key"); initialize(); checkNotClosed(); validateKey(key); Entry entry = this.lruEntries.get(key); if (expectedSequenceNumber != ANY_SEQUENCE_NUMBER && (entry == null || entry.getSequenceNumber() != expectedSequenceNumber)) { return null; } if ((entry != null ? entry.getCurrentEditor() : null) != null) { return null; } if (entry != null && entry.getLockingSourceCount() != 0) { return null; } if (!this.mostRecentTrimFailed && !this.mostRecentRebuildFailed) { BufferedSink bufferedSink = this.journalWriter; g.f(bufferedSink); bufferedSink.writeUtf8(DIRTY).writeByte(32).writeUtf8(key).writeByte(10); bufferedSink.flush(); if (this.hasJournalErrors) { return null; } if (entry == null) { entry = new Entry(this, key); this.lruEntries.put(key, 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; } }