package okhttp3.internal.cache; import androidx.media3.container.NalUnitUtil; import androidx.media3.extractor.metadata.icy.IcyHeaders; import com.google.android.gms.measurement.api.AppMeasurementSdk; import defpackage.a45; import defpackage.cr4; import defpackage.eu6; import defpackage.i25; import defpackage.kp6; import defpackage.m15; import defpackage.mv8; import defpackage.n41; import defpackage.n89; import defpackage.pq6; import defpackage.pw7; import defpackage.px8; import defpackage.rh0; import defpackage.s15; import defpackage.su7; import defpackage.tk3; import defpackage.uu7; import defpackage.vx8; 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 kotlin.Metadata; 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; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000\u0083\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010)\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u001d\n\u0002\u0018\u0002\n\u0002\b\u0010\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\b\b*\u0001j\u0018\u0000 m2\u00020\u00012\u00020\u0002:\u0004mnopB9\b\u0000\u0012\u0006\u0010\u0004\u001a\u00020\u0003\u0012\u0006\u0010\u0006\u001a\u00020\u0005\u0012\u0006\u0010\b\u001a\u00020\u0007\u0012\u0006\u0010\t\u001a\u00020\u0007\u0012\u0006\u0010\u000b\u001a\u00020\n\u0012\u0006\u0010\r\u001a\u00020\f¢\u0006\u0004\b\u000e\u0010\u000fJ\r\u0010\u0011\u001a\u00020\u0010¢\u0006\u0004\b\u0011\u0010\u0012J\u000f\u0010\u0014\u001a\u00020\u0010H\u0000¢\u0006\u0004\b\u0013\u0010\u0012J\u001e\u0010\u0018\u001a\b\u0018\u00010\u0017R\u00020\u00002\u0006\u0010\u0016\u001a\u00020\u0015H\u0086\u0002¢\u0006\u0004\b\u0018\u0010\u0019J'\u0010\u001c\u001a\b\u0018\u00010\u001bR\u00020\u00002\u0006\u0010\u0016\u001a\u00020\u00152\b\b\u0002\u0010\u001a\u001a\u00020\nH\u0007¢\u0006\u0004\b\u001c\u0010\u001dJ\r\u0010\u001e\u001a\u00020\n¢\u0006\u0004\b\u001e\u0010\u001fJ#\u0010%\u001a\u00020\u00102\n\u0010 \u001a\u00060\u001bR\u00020\u00002\u0006\u0010\"\u001a\u00020!H\u0000¢\u0006\u0004\b#\u0010$J\u0015\u0010&\u001a\u00020!2\u0006\u0010\u0016\u001a\u00020\u0015¢\u0006\u0004\b&\u0010'J\u001b\u0010,\u001a\u00020!2\n\u0010)\u001a\u00060(R\u00020\u0000H\u0000¢\u0006\u0004\b*\u0010+J\u000f\u0010-\u001a\u00020\u0010H\u0016¢\u0006\u0004\b-\u0010\u0012J\r\u0010.\u001a\u00020!¢\u0006\u0004\b.\u0010/J\u000f\u00100\u001a\u00020\u0010H\u0016¢\u0006\u0004\b0\u0010\u0012J\r\u00101\u001a\u00020\u0010¢\u0006\u0004\b1\u0010\u0012J\r\u00102\u001a\u00020\u0010¢\u0006\u0004\b2\u0010\u0012J\r\u00103\u001a\u00020\u0010¢\u0006\u0004\b3\u0010\u0012J\u0017\u00105\u001a\f\u0012\b\u0012\u00060\u0017R\u00020\u000004¢\u0006\u0004\b5\u00106J\u000f\u00107\u001a\u00020\u0010H\u0002¢\u0006\u0004\b7\u0010\u0012J\u000f\u00109\u001a\u000208H\u0002¢\u0006\u0004\b9\u0010:J\u0017\u0010<\u001a\u00020\u00102\u0006\u0010;\u001a\u00020\u0015H\u0002¢\u0006\u0004\b<\u0010=J\u000f\u0010>\u001a\u00020\u0010H\u0002¢\u0006\u0004\b>\u0010\u0012J\u000f\u0010?\u001a\u00020!H\u0002¢\u0006\u0004\b?\u0010/J\u000f\u0010@\u001a\u00020\u0010H\u0002¢\u0006\u0004\b@\u0010\u0012J\u000f\u0010A\u001a\u00020!H\u0002¢\u0006\u0004\bA\u0010/J\u0017\u0010B\u001a\u00020\u00102\u0006\u0010\u0016\u001a\u00020\u0015H\u0002¢\u0006\u0004\bB\u0010=R\u001a\u0010\u0004\u001a\u00020\u00038\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0004\u0010C\u001a\u0004\bD\u0010ER\u0017\u0010\u0006\u001a\u00020\u00058\u0006¢\u0006\f\n\u0004\b\u0006\u0010F\u001a\u0004\bG\u0010HR\u0014\u0010\b\u001a\u00020\u00078\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\b\u0010IR\u001a\u0010\t\u001a\u00020\u00078\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\t\u0010I\u001a\u0004\bJ\u0010KR*\u0010\u000b\u001a\u00020\n2\u0006\u0010L\u001a\u00020\n8F@FX\u0086\u000e¢\u0006\u0012\n\u0004\b\u000b\u0010M\u001a\u0004\bN\u0010\u001f\"\u0004\bO\u0010PR\u0014\u0010Q\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bQ\u0010FR\u0014\u0010R\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bR\u0010FR\u0014\u0010S\u001a\u00020\u00058\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bS\u0010FR\u0016\u0010\u001e\u001a\u00020\n8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u001e\u0010MR\u0018\u0010T\u001a\u0004\u0018\u0001088\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bT\u0010UR*\u0010W\u001a\u0012\u0012\u0004\u0012\u00020\u0015\u0012\b\u0012\u00060(R\u00020\u00000V8\u0000X\u0080\u0004¢\u0006\f\n\u0004\bW\u0010X\u001a\u0004\bY\u0010ZR\u0016\u0010[\u001a\u00020\u00078\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b[\u0010IR\u0016\u0010\\\u001a\u00020!8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\\\u0010]R\u0016\u0010^\u001a\u00020!8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b^\u0010]R\u0016\u0010_\u001a\u00020!8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b_\u0010]R\"\u0010`\u001a\u00020!8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b`\u0010]\u001a\u0004\ba\u0010/\"\u0004\bb\u0010cR\u0016\u0010d\u001a\u00020!8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bd\u0010]R\u0016\u0010e\u001a\u00020!8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\be\u0010]R\u0016\u0010f\u001a\u00020\n8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bf\u0010MR\u0014\u0010h\u001a\u00020g8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bh\u0010iR\u0014\u0010k\u001a\u00020j8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bk\u0010l¨\u0006q"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache;", "Ljava/io/Closeable;", "Ljava/io/Flushable;", "Lokhttp3/internal/io/FileSystem;", "fileSystem", "Ljava/io/File;", "directory", "", "appVersion", "valueCount", "", "maxSize", "Lokhttp3/internal/concurrent/TaskRunner;", "taskRunner", "", "(Lokhttp3/internal/io/FileSystem;Ljava/io/File;IIJLokhttp3/internal/concurrent/TaskRunner;)V", "Le6a;", "initialize", "()V", "rebuildJournal$okhttp", "rebuildJournal", "", "key", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "get", "(Ljava/lang/String;)Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "expectedSequenceNumber", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "edit", "(Ljava/lang/String;J)Lokhttp3/internal/cache/DiskLruCache$Editor;", "size", "()J", "editor", "", "success", "completeEdit$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;Z)V", "completeEdit", "remove", "(Ljava/lang/String;)Z", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "entry", "removeEntry$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Entry;)Z", "removeEntry", "flush", "isClosed", "()Z", "close", "trimToSize", "delete", "evictAll", "", "snapshots", "()Ljava/util/Iterator;", "readJournal", "Lrh0;", "newJournalWriter", "()Lrh0;", "line", "readJournalLine", "(Ljava/lang/String;)V", "processJournal", "journalRebuildRequired", "checkNotClosed", "removeOldestEntry", "validateKey", "Lokhttp3/internal/io/FileSystem;", "getFileSystem$okhttp", "()Lokhttp3/internal/io/FileSystem;", "Ljava/io/File;", "getDirectory", "()Ljava/io/File;", "I", "getValueCount$okhttp", "()I", AppMeasurementSdk.ConditionalUserProperty.VALUE, "J", "getMaxSize", "setMaxSize", "(J)V", "journalFile", "journalFileTmp", "journalFileBackup", "journalWriter", "Lrh0;", "Ljava/util/LinkedHashMap;", "lruEntries", "Ljava/util/LinkedHashMap;", "getLruEntries$okhttp", "()Ljava/util/LinkedHashMap;", "redundantOpCount", "hasJournalErrors", "Z", "civilizedFileSystem", "initialized", "closed", "getClosed$okhttp", "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;", "Companion", "Editor", "Entry", "Snapshot", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class DiskLruCache implements Closeable, Flushable { private final int appVersion; private boolean civilizedFileSystem; @kp6 private final TaskQueue cleanupQueue; @kp6 private final DiskLruCache$cleanupTask$1 cleanupTask; private boolean closed; @kp6 private final File directory; @kp6 private final FileSystem fileSystem; private boolean hasJournalErrors; private boolean initialized; @kp6 private final File journalFile; @kp6 private final File journalFileBackup; @kp6 private final File journalFileTmp; @pq6 private rh0 journalWriter; @kp6 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; @kp6 @m15 public static final String JOURNAL_FILE = "journal"; @kp6 @m15 public static final String JOURNAL_FILE_TEMP = "journal.tmp"; @kp6 @m15 public static final String JOURNAL_FILE_BACKUP = "journal.bkp"; @kp6 @m15 public static final String MAGIC = "libcore.io.DiskLruCache"; @kp6 @m15 public static final String VERSION_1 = IcyHeaders.REQUEST_HEADER_ENABLE_METADATA_VALUE; @m15 public static final long ANY_SEQUENCE_NUMBER = -1; @kp6 @m15 public static final pw7 LEGAL_KEY_PATTERN = new pw7("[a-z0-9_-]{1,120}"); @kp6 @m15 public static final String CLEAN = "CLEAN"; @kp6 @m15 public static final String DIRTY = "DIRTY"; @kp6 @m15 public static final String REMOVE = "REMOVE"; @kp6 @m15 public static final String READ = "READ"; @Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\u0018\n\u0002\b\u0004\n\u0002\u0010\u000b\n\u0002\b\u0003\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0015\b\u0000\u0012\n\u0010\u0004\u001a\u00060\u0002R\u00020\u0003¢\u0006\u0004\b\u0005\u0010\u0006J\u000f\u0010\n\u001a\u00020\u0007H\u0000¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\u000e\u001a\u0004\u0018\u00010\r2\u0006\u0010\f\u001a\u00020\u000b¢\u0006\u0004\b\u000e\u0010\u000fJ\u0015\u0010\u0011\u001a\u00020\u00102\u0006\u0010\f\u001a\u00020\u000b¢\u0006\u0004\b\u0011\u0010\u0012J\r\u0010\u0013\u001a\u00020\u0007¢\u0006\u0004\b\u0013\u0010\tJ\r\u0010\u0014\u001a\u00020\u0007¢\u0006\u0004\b\u0014\u0010\tR\u001e\u0010\u0004\u001a\u00060\u0002R\u00020\u00038\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0004\u0010\u0015\u001a\u0004\b\u0016\u0010\u0017R\u001c\u0010\u0019\u001a\u0004\u0018\u00010\u00188\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0019\u0010\u001a\u001a\u0004\b\u001b\u0010\u001cR\u0016\u0010\u001e\u001a\u00020\u001d8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u001e\u0010\u001f¨\u0006 "}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "Lokhttp3/internal/cache/DiskLruCache;", "entry", "", "(Lokhttp3/internal/cache/DiskLruCache;Lokhttp3/internal/cache/DiskLruCache$Entry;)V", "Le6a;", "detach$okhttp", "()V", "detach", "", "index", "Lpx8;", "newSource", "(I)Lpx8;", "Lmv8;", "newSink", "(I)Lmv8;", "commit", "abort", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "getEntry$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "written", "[Z", "getWritten$okhttp", "()[Z", "", "done", "Z", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class Editor { private boolean done; @kp6 private final Entry entry; final /* synthetic */ DiskLruCache this$0; @pq6 private final boolean[] written; public Editor(@kp6 DiskLruCache diskLruCache, Entry entry) { cr4.g(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."); } if (cr4.b(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."); } if (cr4.b(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 (cr4.b(this.entry.getCurrentEditor(), this)) { if (this.this$0.civilizedFileSystem) { this.this$0.completeEdit$okhttp(this, false); } else { this.entry.setZombie$okhttp(true); } } } @kp6 /* JADX INFO: renamed from: getEntry$okhttp, reason: from getter */ public final Entry getEntry() { return this.entry; } @pq6 /* JADX INFO: renamed from: getWritten$okhttp, reason: from getter */ public final boolean[] getWritten() { return this.written; } @kp6 public final mv8 newSink(int index) { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { if (this.done) { throw new IllegalStateException("Check failed."); } if (!cr4.b(this.entry.getCurrentEditor(), this)) { return eu6.b(); } if (!this.entry.getReadable()) { boolean[] zArr = this.written; cr4.d(zArr); zArr[index] = true; } try { return new FaultHidingSink(diskLruCache.getFileSystem().sink(this.entry.getDirtyFiles$okhttp().get(index)), new DiskLruCache$Editor$newSink$1$1(diskLruCache, this)); } catch (FileNotFoundException unused) { return eu6.b(); } } } @pq6 public final px8 newSource(int index) { DiskLruCache diskLruCache = this.this$0; synchronized (diskLruCache) { if (this.done) { throw new IllegalStateException("Check failed."); } px8 px8VarSource = null; if (!this.entry.getReadable() || !cr4.b(this.entry.getCurrentEditor(), this) || this.entry.getZombie()) { return null; } try { px8VarSource = diskLruCache.getFileSystem().source(this.entry.getCleanFiles$okhttp().get(index)); } catch (FileNotFoundException unused) { } return px8VarSource; } } } @Metadata(d1 = {"\u0000t\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010 \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\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\u0006\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\u0007\b\u0080\u0004\u0018\u00002\u00020\u0001B\u0011\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u001d\u0010\t\u001a\u00020\b2\f\u0010\u0007\u001a\b\u0012\u0004\u0012\u00020\u00020\u0006H\u0002¢\u0006\u0004\b\t\u0010\nJ\u0017\u0010\u000e\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ\u001d\u0010\u0013\u001a\u00020\u00102\f\u0010\u0007\u001a\b\u0012\u0004\u0012\u00020\u00020\u0006H\u0000¢\u0006\u0004\b\u0011\u0010\u0012J\u0017\u0010\u0018\u001a\u00020\u00102\u0006\u0010\u0015\u001a\u00020\u0014H\u0000¢\u0006\u0004\b\u0016\u0010\u0017J\u0015\u0010\u001d\u001a\b\u0018\u00010\u0019R\u00020\u001aH\u0000¢\u0006\u0004\b\u001b\u0010\u001cR\u001a\u0010\u0003\u001a\u00020\u00028\u0000X\u0080\u0004¢\u0006\f\n\u0004\b\u0003\u0010\u001e\u001a\u0004\b\u001f\u0010 R\u001a\u0010\"\u001a\u00020!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\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/\u00100\u001a\u0004\b1\u00102\"\u0004\b3\u00104R\"\u00105\u001a\u00020.8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b5\u00100\u001a\u0004\b6\u00102\"\u0004\b7\u00104R(\u00109\u001a\b\u0018\u000108R\u00020\u001a8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b9\u0010:\u001a\u0004\b;\u0010<\"\u0004\b=\u0010>R\"\u0010?\u001a\u00020\u000b8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\b?\u0010@\u001a\u0004\bA\u0010B\"\u0004\bC\u0010DR\"\u0010F\u001a\u00020E8\u0000@\u0000X\u0080\u000e¢\u0006\u0012\n\u0004\bF\u0010G\u001a\u0004\bH\u0010I\"\u0004\bJ\u0010K¨\u0006L"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "", "key", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;)V", "", "strings", "", "invalidLengths", "(Ljava/util/List;)Ljava/lang/Void;", "", "index", "Lpx8;", "newSource", "(I)Lpx8;", "Le6a;", "setLengths$okhttp", "(Ljava/util/List;)V", "setLengths", "Lrh0;", "writer", "writeLengths$okhttp", "(Lrh0;)V", "writeLengths", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "snapshot$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "snapshot", "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", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class Entry { @kp6 private final List cleanFiles; @pq6 private Editor currentEditor; @kp6 private final List dirtyFiles; @kp6 private final String key; @kp6 private final long[] lengths; private int lockingSourceCount; private boolean readable; private long sequenceNumber; final /* synthetic */ DiskLruCache this$0; private boolean zombie; public Entry(@kp6 DiskLruCache diskLruCache, String str) { cr4.g(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 i = 0; i < valueCount; i++) { sb.append(i); 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 px8 newSource(int index) throws FileNotFoundException { final px8 px8VarSource = this.this$0.getFileSystem().source(this.cleanFiles.get(index)); if (this.this$0.civilizedFileSystem) { return px8VarSource; } this.lockingSourceCount++; final DiskLruCache diskLruCache = this.this$0; return new tk3(px8VarSource) { // from class: okhttp3.internal.cache.DiskLruCache$Entry$newSource$1 private boolean closed; @Override // defpackage.tk3, 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); } } } }; } @kp6 public final List getCleanFiles$okhttp() { return this.cleanFiles; } @pq6 /* JADX INFO: renamed from: getCurrentEditor$okhttp, reason: from getter */ public final Editor getCurrentEditor() { return this.currentEditor; } @kp6 public final List getDirtyFiles$okhttp() { return this.dirtyFiles; } @kp6 /* JADX INFO: renamed from: getKey$okhttp, reason: from getter */ public final String getKey() { return this.key; } @kp6 /* 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(@pq6 Editor editor) { this.currentEditor = editor; } public final void setLengths$okhttp(@kp6 List strings) throws IOException { cr4.g(strings, "strings"); if (strings.size() != this.this$0.getValueCount()) { invalidLengths(strings); throw new a45(); } try { int size = strings.size(); for (int i = 0; i < size; i++) { this.lengths[i] = Long.parseLong(strings.get(i)); } } catch (NumberFormatException unused) { invalidLengths(strings); throw new a45(); } } public final void setLockingSourceCount$okhttp(int i) { this.lockingSourceCount = i; } public final void setReadable$okhttp(boolean z) { this.readable = z; } public final void setSequenceNumber$okhttp(long j) { this.sequenceNumber = j; } public final void setZombie$okhttp(boolean z) { this.zombie = z; } @pq6 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 i = 0; i < valueCount; i++) { arrayList.add(newSource(i)); } return new Snapshot(this.this$0, this.key, this.sequenceNumber, arrayList, jArr); } catch (FileNotFoundException unused) { Iterator it = arrayList.iterator(); while (it.hasNext()) { Util.closeQuietly((px8) it.next()); } try { this.this$0.removeEntry$okhttp(this); } catch (IOException unused2) { } return null; } } public final void writeLengths$okhttp(@kp6 rh0 writer) throws IOException { cr4.g(writer, "writer"); for (long j : this.lengths) { writer.writeByte(32).ay(j); } } } @Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0016\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0007\b\u0086\u0004\u0018\u00002\u00020\u0001B/\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\f\u0010\b\u001a\b\u0012\u0004\u0012\u00020\u00070\u0006\u0012\u0006\u0010\n\u001a\u00020\t¢\u0006\u0004\b\u000b\u0010\fJ\r\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0003\u0010\rJ\u0013\u0010\u0010\u001a\b\u0018\u00010\u000eR\u00020\u000f¢\u0006\u0004\b\u0010\u0010\u0011J\u0015\u0010\u0014\u001a\u00020\u00072\u0006\u0010\u0013\u001a\u00020\u0012¢\u0006\u0004\b\u0014\u0010\u0015J\u0015\u0010\u0016\u001a\u00020\u00042\u0006\u0010\u0013\u001a\u00020\u0012¢\u0006\u0004\b\u0016\u0010\u0017J\u000f\u0010\u0019\u001a\u00020\u0018H\u0016¢\u0006\u0004\b\u0019\u0010\u001aR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u001bR\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010\u001cR\u001a\u0010\b\u001a\b\u0012\u0004\u0012\u00020\u00070\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\b\u0010\u001dR\u0014\u0010\n\u001a\u00020\t8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\n\u0010\u001e¨\u0006\u001f"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Ljava/io/Closeable;", "", "key", "", "sequenceNumber", "", "Lpx8;", "sources", "", "lengths", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;JLjava/util/List;[J)V", "()Ljava/lang/String;", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "edit", "()Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "index", "getSource", "(I)Lpx8;", "getLength", "(I)J", "Le6a;", "close", "()V", "Ljava/lang/String;", "J", "Ljava/util/List;", "[J", "okhttp"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class Snapshot implements Closeable { @kp6 private final String key; @kp6 private final long[] lengths; private final long sequenceNumber; @kp6 private final List sources; final /* synthetic */ DiskLruCache this$0; /* JADX WARN: Multi-variable type inference failed */ public Snapshot(@kp6 DiskLruCache diskLruCache, String str, @kp6 long j, @kp6 List list, long[] jArr) { cr4.g(str, "key"); cr4.g(list, "sources"); cr4.g(jArr, "lengths"); this.this$0 = diskLruCache; this.key = str; this.sequenceNumber = j; 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()); } } @pq6 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]; } @kp6 public final px8 getSource(int index) { return this.sources.get(index); } @kp6 /* 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\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007*\u0001\u0000\b\n\u0018\u00002\f\u0012\b\u0012\u00060\u0002R\u00020\u00030\u0001J\u0010\u0010\u0005\u001a\u00020\u0004H\u0096\u0002¢\u0006\u0004\b\u0005\u0010\u0006J\u0014\u0010\u0007\u001a\u00060\u0002R\u00020\u0003H\u0096\u0002¢\u0006\u0004\b\u0007\u0010\bJ\u000f\u0010\n\u001a\u00020\tH\u0016¢\u0006\u0004\b\n\u0010\u000bR*\u0010\u000e\u001a\u0018\u0012\u0014\u0012\u0012 \r*\b\u0018\u00010\fR\u00020\u00030\fR\u00020\u00030\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000e\u0010\u000fR\u001c\u0010\u0010\u001a\b\u0018\u00010\u0002R\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011R\u001c\u0010\u0012\u001a\b\u0018\u00010\u0002R\u00020\u00038\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0012\u0010\u0011¨\u0006\u0013"}, d2 = {"okhttp3/internal/cache/DiskLruCache$snapshots$1", "", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Lokhttp3/internal/cache/DiskLruCache;", "", "hasNext", "()Z", "next", "()Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Le6a;", "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, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class AnonymousClass1 implements Iterator, i25 { @kp6 private final Iterator delegate; @pq6 private Snapshot nextSnapshot; @pq6 private Snapshot removeSnapshot; public AnonymousClass1() { Iterator it = new ArrayList(DiskLruCache.this.getLruEntries$okhttp().values()).iterator(); cr4.f(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()"); } try { DiskLruCache.this.remove(snapshot.getKey()); } catch (IOException unused) { } finally { this.removeSnapshot = null; } } @Override // java.util.Iterator @kp6 public Snapshot next() { if (!hasNext()) { throw new NoSuchElementException(); } Snapshot snapshot = this.nextSnapshot; this.removeSnapshot = snapshot; this.nextSnapshot = null; cr4.d(snapshot); return snapshot; } } /* JADX WARN: Type inference failed for: r5v3, types: [okhttp3.internal.cache.DiskLruCache$cleanupTask$1] */ public DiskLruCache(@kp6 FileSystem fileSystem, @kp6 File file, int i, int i2, long j, @kp6 TaskRunner taskRunner) { cr4.g(fileSystem, "fileSystem"); cr4.g(file, "directory"); cr4.g(taskRunner, "taskRunner"); this.fileSystem = fileSystem; this.directory = file; this.appVersion = i; this.valueCount = i2; this.maxSize = j; this.lruEntries = new LinkedHashMap<>(0, 0.75f, true); this.cleanupQueue = taskRunner.newQueue(); final String strS = n41.s(new StringBuilder(), Util.okHttpName, " Cache"); this.cleanupTask = new Task(strS) { // 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 = eu6.c(eu6.b()); } return -1L; } } }; if (j <= 0) { throw new IllegalArgumentException("maxSize <= 0"); } if (i2 <= 0) { throw new IllegalArgumentException("valueCount <= 0"); } 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"); } } public static /* synthetic */ Editor edit$default(DiskLruCache diskLruCache, String str, long j, int i, Object obj) throws IOException { if ((i & 2) != 0) { j = ANY_SEQUENCE_NUMBER; } return diskLruCache.edit(str, j); } /* JADX INFO: Access modifiers changed from: private */ public final boolean journalRebuildRequired() { int i = this.redundantOpCount; return i >= 2000 && i >= this.lruEntries.size(); } private final rh0 newJournalWriter() throws FileNotFoundException { return eu6.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(); cr4.f(next, "i.next()"); Entry entry = next; int i = 0; if (entry.getCurrentEditor() == null) { int i2 = this.valueCount; while (i < i2) { this.size += entry.getLengths()[i]; i++; } } else { entry.setCurrentEditor$okhttp(null); int i3 = this.valueCount; while (i < i3) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i)); this.fileSystem.delete(entry.getDirtyFiles$okhttp().get(i)); i++; } it.remove(); } } } private final void readJournal() throws IOException { uu7 uu7VarD = eu6.d(this.fileSystem.source(this.journalFile)); try { String strX = uu7VarD.x(Long.MAX_VALUE); String strX2 = uu7VarD.x(Long.MAX_VALUE); String strX3 = uu7VarD.x(Long.MAX_VALUE); String strX4 = uu7VarD.x(Long.MAX_VALUE); String strX5 = uu7VarD.x(Long.MAX_VALUE); if (!cr4.b(MAGIC, strX) || !cr4.b(VERSION_1, strX2) || !cr4.b(String.valueOf(this.appVersion), strX3) || !cr4.b(String.valueOf(this.valueCount), strX4) || strX5.length() > 0) { throw new IOException("unexpected journal header: [" + strX + ", " + strX2 + ", " + strX4 + ", " + strX5 + ']'); } int i = 0; while (true) { try { readJournalLine(uu7VarD.x(Long.MAX_VALUE)); i++; } catch (EOFException unused) { this.redundantOpCount = i - this.lruEntries.size(); if (uu7VarD.j()) { this.journalWriter = newJournalWriter(); } else { rebuildJournal$okhttp(); } uu7VarD.close(); return; } } } finally { } } private final void readJournalLine(String line) throws IOException { String strSubstring; int iY = n89.y(line, ' ', 0, 6); if (iY == -1) { throw new IOException("unexpected journal line: ".concat(line)); } int i = iY + 1; int iY2 = n89.y(line, ' ', i, 4); if (iY2 == -1) { strSubstring = line.substring(i); cr4.f(strSubstring, "this as java.lang.String).substring(startIndex)"); String str = REMOVE; if (iY == str.length() && n89.ar(line, str, false)) { this.lruEntries.remove(strSubstring); return; } } else { strSubstring = line.substring(i, iY2); cr4.f(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 (iY2 != -1) { String str2 = CLEAN; if (iY == str2.length() && n89.ar(line, str2, false)) { String strSubstring2 = line.substring(iY2 + 1); cr4.f(strSubstring2, "this as java.lang.String).substring(startIndex)"); List listAp = n89.ap(strSubstring2, new char[]{' '}); entry.setReadable$okhttp(true); entry.setCurrentEditor$okhttp(null); entry.setLengths$okhttp(listAp); return; } } if (iY2 == -1) { String str3 = DIRTY; if (iY == str3.length() && n89.ar(line, str3, false)) { entry.setCurrentEditor$okhttp(new Editor(this, entry)); return; } } if (iY2 == -1) { String str4 = READ; if (iY == str4.length() && n89.ar(line, str4, false)) { return; } } throw new IOException("unexpected journal line: ".concat(line)); } 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 key) { if (!LEGAL_KEY_PATTERN.d(key)) { throw new IllegalArgumentException(n41.g('\"', "keys must match regex [a-z0-9_-]{1,120}: \"", key).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(); cr4.f(collectionValues, "lruEntries.values"); for (Entry entry : (Entry[]) collectionValues.toArray(new Entry[0])) { if (entry.getCurrentEditor() != null && (currentEditor = entry.getCurrentEditor()) != null) { currentEditor.detach$okhttp(); } } trimToSize(); rh0 rh0Var = this.journalWriter; cr4.d(rh0Var); rh0Var.close(); this.journalWriter = null; this.closed = true; return; } this.closed = true; } catch (Throwable th) { throw th; } } public final synchronized void completeEdit$okhttp(@kp6 Editor editor, boolean success) throws IOException { cr4.g(editor, "editor"); Entry entry = editor.getEntry(); if (!cr4.b(entry.getCurrentEditor(), editor)) { throw new IllegalStateException("Check failed."); } if (success && !entry.getReadable()) { int i = this.valueCount; for (int i2 = 0; i2 < i; i2++) { boolean[] written = editor.getWritten(); cr4.d(written); if (!written[i2]) { editor.abort(); throw new IllegalStateException("Newly created entry didn't create value for index " + i2); } if (!this.fileSystem.exists(entry.getDirtyFiles$okhttp().get(i2))) { editor.abort(); return; } } } int i3 = this.valueCount; for (int i4 = 0; i4 < i3; i4++) { File file = entry.getDirtyFiles$okhttp().get(i4); if (!success || entry.getZombie()) { this.fileSystem.delete(file); } else if (this.fileSystem.exists(file)) { File file2 = entry.getCleanFiles$okhttp().get(i4); this.fileSystem.rename(file, file2); long j = entry.getLengths()[i4]; long size = this.fileSystem.size(file2); entry.getLengths()[i4] = size; this.size = (this.size - j) + size; } } entry.setCurrentEditor$okhttp(null); if (entry.getZombie()) { removeEntry$okhttp(entry); return; } this.redundantOpCount++; rh0 rh0Var = this.journalWriter; cr4.d(rh0Var); if (entry.getReadable() || success) { entry.setReadable$okhttp(true); rh0Var.ac(CLEAN).writeByte(32); rh0Var.ac(entry.getKey()); entry.writeLengths$okhttp(rh0Var); rh0Var.writeByte(10); if (success) { long j2 = this.nextSequenceNumber; this.nextSequenceNumber = 1 + j2; entry.setSequenceNumber$okhttp(j2); } } else { this.lruEntries.remove(entry.getKey()); rh0Var.ac(REMOVE).writeByte(32); rh0Var.ac(entry.getKey()); rh0Var.writeByte(10); } rh0Var.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); } @pq6 @s15 public final Editor edit(@kp6 String str) throws IOException { cr4.g(str, "key"); return edit$default(this, str, 0L, 2, null); } public final synchronized void evictAll() throws IOException { try { initialize(); Collection collectionValues = this.lruEntries.values(); cr4.f(collectionValues, "lruEntries.values"); for (Entry entry : (Entry[]) collectionValues.toArray(new Entry[0])) { cr4.f(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(); rh0 rh0Var = this.journalWriter; cr4.d(rh0Var); rh0Var.flush(); } } @pq6 public final synchronized Snapshot get(@kp6 String key) throws IOException { cr4.g(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++; rh0 rh0Var = this.journalWriter; cr4.d(rh0Var); rh0Var.ac(READ).writeByte(32).ac(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; } @kp6 public final File getDirectory() { return this.directory; } @kp6 /* JADX INFO: renamed from: getFileSystem$okhttp, reason: from getter */ public final FileSystem getFileSystem() { return this.fileSystem; } @kp6 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 e) { Platform.INSTANCE.get().log("DiskLruCache " + this.directory + " is corrupt: " + e.getMessage() + ", removing", 5, e); try { delete(); this.closed = false; rebuildJournal$okhttp(); this.initialized = true; } catch (Throwable th) { this.closed = false; throw th; } } } rebuildJournal$okhttp(); this.initialized = true; } catch (Throwable th2) { throw th2; } } public final synchronized boolean isClosed() { return this.closed; } public final synchronized void rebuildJournal$okhttp() throws IOException { try { rh0 rh0Var = this.journalWriter; if (rh0Var != null) { rh0Var.close(); } su7 su7VarC = eu6.c(this.fileSystem.sink(this.journalFileTmp)); try { su7VarC.ac(MAGIC); su7VarC.writeByte(10); su7VarC.ac(VERSION_1); su7VarC.writeByte(10); su7VarC.ay(this.appVersion); su7VarC.writeByte(10); su7VarC.ay(this.valueCount); su7VarC.writeByte(10); su7VarC.writeByte(10); for (Entry entry : this.lruEntries.values()) { if (entry.getCurrentEditor() != null) { su7VarC.ac(DIRTY); su7VarC.writeByte(32); su7VarC.ac(entry.getKey()); su7VarC.writeByte(10); } else { su7VarC.ac(CLEAN); su7VarC.writeByte(32); su7VarC.ac(entry.getKey()); entry.writeLengths$okhttp(su7VarC); su7VarC.writeByte(10); } } su7VarC.close(); 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(@kp6 String key) throws IOException { cr4.g(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(@kp6 Entry entry) throws IOException { rh0 rh0Var; cr4.g(entry, "entry"); if (!this.civilizedFileSystem) { if (entry.getLockingSourceCount() > 0 && (rh0Var = this.journalWriter) != null) { rh0Var.ac(DIRTY); rh0Var.writeByte(32); rh0Var.ac(entry.getKey()); rh0Var.writeByte(10); rh0Var.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 i = this.valueCount; for (int i2 = 0; i2 < i; i2++) { this.fileSystem.delete(entry.getCleanFiles$okhttp().get(i2)); this.size -= entry.getLengths()[i2]; entry.getLengths()[i2] = 0; } this.redundantOpCount++; rh0 rh0Var2 = this.journalWriter; if (rh0Var2 != null) { rh0Var2.ac(REMOVE); rh0Var2.writeByte(32); rh0Var2.ac(entry.getKey()); rh0Var2.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 z) { this.closed = z; } public final synchronized void setMaxSize(long j) { this.maxSize = j; if (this.initialized) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } } public final synchronized long size() throws IOException { initialize(); return this.size; } @kp6 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; } @pq6 @s15 public final synchronized Editor edit(@kp6 String key, long expectedSequenceNumber) throws IOException { cr4.g(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) { rh0 rh0Var = this.journalWriter; cr4.d(rh0Var); rh0Var.ac(DIRTY).writeByte(32).ac(key).writeByte(10); rh0Var.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; } }