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 kotlin.Metadata; import kotlin.TypeCastException; import kotlin.Unit; import kotlin.io.CloseableKt; import kotlin.jvm.functions.Function1; import kotlin.jvm.internal.Intrinsics; import kotlin.text.Regex; import kotlin.text.StringsKt; 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.Okio; import okio.Sink; import okio.Source; import org.apache.http.message.TokenParser; /* compiled from: DiskLruCache.kt */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000{\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\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\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0010)\n\u0002\b\u0007*\u0001\u0012\u0018\u0000 Y2\u00020\u00012\u00020\u0002:\u0004YZ[\\B7\b\u0000\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\u0006\u0010\u0005\u001a\u00020\u0006\u0012\u0006\u0010\u0007\u001a\u00020\b\u0012\u0006\u0010\t\u001a\u00020\b\u0012\u0006\u0010\n\u001a\u00020\u000b\u0012\u0006\u0010\f\u001a\u00020\r¢\u0006\u0002\u0010\u000eJ\b\u00107\u001a\u000208H\u0002J\b\u00109\u001a\u000208H\u0016J!\u0010:\u001a\u0002082\n\u0010;\u001a\u00060J\u0006\u0010?\u001a\u000208J \u0010@\u001a\b\u0018\u00010 lruEntries; private long maxSize; private boolean mostRecentRebuildFailed; private boolean mostRecentTrimFailed; private long nextSequenceNumber; private int redundantOpCount; private long size; private final int valueCount; public static final String JOURNAL_FILE = JOURNAL_FILE; public static final String JOURNAL_FILE = JOURNAL_FILE; public static final String JOURNAL_FILE_TEMP = JOURNAL_FILE_TEMP; public static final String JOURNAL_FILE_TEMP = JOURNAL_FILE_TEMP; public static final String JOURNAL_FILE_BACKUP = JOURNAL_FILE_BACKUP; public static final String JOURNAL_FILE_BACKUP = JOURNAL_FILE_BACKUP; public static final String MAGIC = MAGIC; public static final String MAGIC = MAGIC; public static final String VERSION_1 = VERSION_1; public static final String VERSION_1 = VERSION_1; public static final long ANY_SEQUENCE_NUMBER = -1; public static final Regex LEGAL_KEY_PATTERN = new Regex("[a-z0-9_-]{1,120}"); public static final String CLEAN = CLEAN; public static final String CLEAN = CLEAN; public static final String DIRTY = DIRTY; public static final String DIRTY = DIRTY; public static final String REMOVE = REMOVE; public static final String REMOVE = REMOVE; public static final String READ = READ; public static final String READ = READ; public final Editor edit(String str) throws IOException { return edit$default(this, str, 0L, 2, null); } /* JADX WARN: Type inference failed for: r5v3, types: [okhttp3.internal.cache.DiskLruCache$cleanupTask$1] */ public DiskLruCache(FileSystem fileSystem, File directory, int i, int i2, long j, TaskRunner taskRunner) { Intrinsics.checkParameterIsNotNull(fileSystem, "fileSystem"); Intrinsics.checkParameterIsNotNull(directory, "directory"); Intrinsics.checkParameterIsNotNull(taskRunner, "taskRunner"); this.fileSystem = fileSystem; this.directory = directory; this.appVersion = i; this.valueCount = i2; this.maxSize = j; this.lruEntries = new LinkedHashMap<>(0, 0.75f, true); this.cleanupQueue = taskRunner.newQueue(); final String str = Util.okHttpName + " Cache"; this.cleanupTask = new Task(str) { // from class: okhttp3.internal.cache.DiskLruCache$cleanupTask$1 @Override // okhttp3.internal.concurrent.Task public long runOnce() { boolean z; boolean journalRebuildRequired; synchronized (DiskLruCache.this) { z = DiskLruCache.this.initialized; if (!z || DiskLruCache.this.getClosed()) { return -1L; } try { DiskLruCache.this.trimToSize(); } catch (IOException unused) { DiskLruCache.this.mostRecentTrimFailed = true; } try { journalRebuildRequired = DiskLruCache.this.journalRebuildRequired(); if (journalRebuildRequired) { DiskLruCache.this.rebuildJournal$okhttp(); DiskLruCache.this.redundantOpCount = 0; } } catch (IOException unused2) { DiskLruCache.this.mostRecentRebuildFailed = true; DiskLruCache.this.journalWriter = Okio.buffer(Okio.blackhole()); } return -1L; } } }; if (!(j > 0)) { throw new IllegalArgumentException("maxSize <= 0".toString()); } if (!(i2 > 0)) { throw new IllegalArgumentException("valueCount <= 0".toString()); } this.journalFile = new File(directory, JOURNAL_FILE); this.journalFileTmp = new File(directory, JOURNAL_FILE_TEMP); this.journalFileBackup = new File(directory, JOURNAL_FILE_BACKUP); } /* renamed from: getFileSystem$okhttp, reason: from getter */ public final FileSystem getFileSystem() { return this.fileSystem; } public final File getDirectory() { return this.directory; } /* renamed from: getValueCount$okhttp, reason: from getter */ public final int getValueCount() { return this.valueCount; } public final synchronized long getMaxSize() { return this.maxSize; } 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 LinkedHashMap getLruEntries$okhttp() { return this.lruEntries; } /* renamed from: getClosed$okhttp, reason: from getter */ public final boolean getClosed() { return this.closed; } public final void setClosed$okhttp(boolean z) { this.closed = z; } private final void readJournal() throws IOException { BufferedSource buffer = Okio.buffer(this.fileSystem.source(this.journalFile)); try { BufferedSource bufferedSource = buffer; String readUtf8LineStrict = bufferedSource.readUtf8LineStrict(); String readUtf8LineStrict2 = bufferedSource.readUtf8LineStrict(); String readUtf8LineStrict3 = bufferedSource.readUtf8LineStrict(); String readUtf8LineStrict4 = bufferedSource.readUtf8LineStrict(); String readUtf8LineStrict5 = bufferedSource.readUtf8LineStrict(); if (!Intrinsics.areEqual(MAGIC, readUtf8LineStrict) || !Intrinsics.areEqual(VERSION_1, readUtf8LineStrict2) || !Intrinsics.areEqual(String.valueOf(this.appVersion), readUtf8LineStrict3) || !Intrinsics.areEqual(String.valueOf(this.valueCount), readUtf8LineStrict4) || readUtf8LineStrict5.length() > 0) { throw new IOException("unexpected journal header: [" + readUtf8LineStrict + ", " + readUtf8LineStrict2 + ", " + readUtf8LineStrict4 + ", " + readUtf8LineStrict5 + ']'); } int i = 0; while (true) { try { readJournalLine(bufferedSource.readUtf8LineStrict()); i++; } catch (EOFException unused) { this.redundantOpCount = i - this.lruEntries.size(); if (bufferedSource.exhausted()) { this.journalWriter = newJournalWriter(); } else { rebuildJournal$okhttp(); } Unit unit = Unit.INSTANCE; CloseableKt.closeFinally(buffer, null); return; } } } finally { } } private final BufferedSink newJournalWriter() throws FileNotFoundException { return Okio.buffer(new FaultHidingSink(this.fileSystem.appendingSink(this.journalFile), new Function1() { // from class: okhttp3.internal.cache.DiskLruCache$newJournalWriter$faultHidingSink$1 /* JADX INFO: Access modifiers changed from: package-private */ { super(1); } @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(IOException iOException) { invoke2(iOException); return Unit.INSTANCE; } /* renamed from: invoke, reason: avoid collision after fix types in other method */ public final void invoke2(IOException it) { Intrinsics.checkParameterIsNotNull(it, "it"); DiskLruCache diskLruCache = DiskLruCache.this; if (!Util.assertionsEnabled || Thread.holdsLock(diskLruCache)) { DiskLruCache.this.hasJournalErrors = true; return; } StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST hold lock on ").append(diskLruCache).toString()); } })); } private final void readJournalLine(String line) throws IOException { String substring; String str = line; int indexOf$default = StringsKt.indexOf$default((CharSequence) str, TokenParser.SP, 0, false, 6, (Object) null); if (indexOf$default == -1) { throw new IOException("unexpected journal line: " + line); } int i = indexOf$default + 1; int indexOf$default2 = StringsKt.indexOf$default((CharSequence) str, TokenParser.SP, i, false, 4, (Object) null); if (indexOf$default2 == -1) { if (line != null) { substring = line.substring(i); Intrinsics.checkExpressionValueIsNotNull(substring, "(this as java.lang.String).substring(startIndex)"); String str2 = REMOVE; if (indexOf$default == str2.length() && StringsKt.startsWith$default(line, str2, false, 2, (Object) null)) { this.lruEntries.remove(substring); return; } } else { throw new TypeCastException("null cannot be cast to non-null type java.lang.String"); } } else if (line != null) { substring = line.substring(i, indexOf$default2); Intrinsics.checkExpressionValueIsNotNull(substring, "(this as java.lang.Strin…ing(startIndex, endIndex)"); } else { throw new TypeCastException("null cannot be cast to non-null type java.lang.String"); } Entry entry = this.lruEntries.get(substring); if (entry == null) { entry = new Entry(this, substring); this.lruEntries.put(substring, entry); } if (indexOf$default2 != -1) { String str3 = CLEAN; if (indexOf$default == str3.length() && StringsKt.startsWith$default(line, str3, false, 2, (Object) null)) { int i2 = indexOf$default2 + 1; if (line != null) { String substring2 = line.substring(i2); Intrinsics.checkExpressionValueIsNotNull(substring2, "(this as java.lang.String).substring(startIndex)"); List split$default = StringsKt.split$default((CharSequence) substring2, new char[]{TokenParser.SP}, false, 0, 6, (Object) null); entry.setReadable$okhttp(true); entry.setCurrentEditor$okhttp(null); entry.setLengths$okhttp(split$default); return; } throw new TypeCastException("null cannot be cast to non-null type java.lang.String"); } } if (indexOf$default2 == -1) { String str4 = DIRTY; if (indexOf$default == str4.length() && StringsKt.startsWith$default(line, str4, false, 2, (Object) null)) { entry.setCurrentEditor$okhttp(new Editor(this, entry)); return; } } if (indexOf$default2 == -1) { String str5 = READ; if (indexOf$default == str5.length() && StringsKt.startsWith$default(line, str5, false, 2, (Object) null)) { return; } } throw new IOException("unexpected journal line: " + line); } private final void processJournal() throws IOException { this.fileSystem.delete(this.journalFileTmp); Iterator it = this.lruEntries.values().iterator(); while (it.hasNext()) { Entry next = it.next(); Intrinsics.checkExpressionValueIsNotNull(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(); } } } public final synchronized void rebuildJournal$okhttp() throws IOException { BufferedSink bufferedSink = this.journalWriter; if (bufferedSink != null) { bufferedSink.close(); } BufferedSink buffer = Okio.buffer(this.fileSystem.sink(this.journalFileTmp)); try { BufferedSink bufferedSink2 = buffer; bufferedSink2.writeUtf8(MAGIC).writeByte(10); bufferedSink2.writeUtf8(VERSION_1).writeByte(10); bufferedSink2.writeDecimalLong(this.appVersion).writeByte(10); bufferedSink2.writeDecimalLong(this.valueCount).writeByte(10); bufferedSink2.writeByte(10); for (Entry entry : this.lruEntries.values()) { if (entry.getCurrentEditor() != null) { bufferedSink2.writeUtf8(DIRTY).writeByte(32); bufferedSink2.writeUtf8(entry.getKey()); bufferedSink2.writeByte(10); } else { bufferedSink2.writeUtf8(CLEAN).writeByte(32); bufferedSink2.writeUtf8(entry.getKey()); entry.writeLengths$okhttp(bufferedSink2); bufferedSink2.writeByte(10); } } Unit unit = Unit.INSTANCE; CloseableKt.closeFinally(buffer, null); if (this.fileSystem.exists(this.journalFile)) { this.fileSystem.rename(this.journalFile, this.journalFileBackup); } this.fileSystem.rename(this.journalFileTmp, this.journalFile); this.fileSystem.delete(this.journalFileBackup); this.journalWriter = newJournalWriter(); this.hasJournalErrors = false; this.mostRecentRebuildFailed = false; } finally { } } public final synchronized Snapshot get(String key) throws IOException { Intrinsics.checkParameterIsNotNull(key, "key"); initialize(); checkNotClosed(); validateKey(key); Entry entry = this.lruEntries.get(key); if (entry == null) { return null; } Intrinsics.checkExpressionValueIsNotNull(entry, "lruEntries[key] ?: return null"); if (!entry.getReadable()) { return null; } Snapshot snapshot$okhttp = entry.snapshot$okhttp(); if (snapshot$okhttp == null) { return null; } this.redundantOpCount++; BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } bufferedSink.writeUtf8(READ).writeByte(32).writeUtf8(key).writeByte(10); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return snapshot$okhttp; } 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); } public final synchronized Editor edit(String key, long expectedSequenceNumber) throws IOException { Intrinsics.checkParameterIsNotNull(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 (!this.mostRecentTrimFailed && !this.mostRecentRebuildFailed) { BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } 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; } public final synchronized long size() throws IOException { initialize(); return this.size; } public final synchronized void completeEdit$okhttp(Editor editor, boolean success) throws IOException { Intrinsics.checkParameterIsNotNull(editor, "editor"); Entry entry = editor.getEntry(); if (!Intrinsics.areEqual(entry.getCurrentEditor(), editor)) { throw new IllegalStateException("Check failed.".toString()); } if (success && !entry.getReadable()) { int i = this.valueCount; for (int i2 = 0; i2 < i; i2++) { boolean[] written = editor.getWritten(); if (written == null) { Intrinsics.throwNpe(); } 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) { 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; } } else { this.fileSystem.delete(file); } } this.redundantOpCount++; entry.setCurrentEditor$okhttp(null); BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } if (!entry.getReadable() && !success) { 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); } } entry.setReadable$okhttp(true); bufferedSink.writeUtf8(CLEAN).writeByte(32); bufferedSink.writeUtf8(entry.getKey()); entry.writeLengths$okhttp(bufferedSink); bufferedSink.writeByte(10); if (success) { long j2 = this.nextSequenceNumber; this.nextSequenceNumber = 1 + j2; entry.setSequenceNumber$okhttp(j2); } bufferedSink.flush(); if (this.size <= this.maxSize) { } TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } /* JADX INFO: Access modifiers changed from: private */ public final boolean journalRebuildRequired() { int i = this.redundantOpCount; return i >= 2000 && i >= this.lruEntries.size(); } public final synchronized boolean remove(String key) throws IOException { Intrinsics.checkParameterIsNotNull(key, "key"); initialize(); checkNotClosed(); validateKey(key); Entry entry = this.lruEntries.get(key); if (entry == null) { return false; } Intrinsics.checkExpressionValueIsNotNull(entry, "lruEntries[key] ?: return false"); boolean removeEntry$okhttp = removeEntry$okhttp(entry); if (removeEntry$okhttp && this.size <= this.maxSize) { this.mostRecentTrimFailed = false; } return removeEntry$okhttp; } public final boolean removeEntry$okhttp(Entry entry) throws IOException { Intrinsics.checkParameterIsNotNull(entry, "entry"); 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++; BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } bufferedSink.writeUtf8(REMOVE).writeByte(32).writeUtf8(entry.getKey()).writeByte(10); this.lruEntries.remove(entry.getKey()); if (journalRebuildRequired()) { TaskQueue.schedule$default(this.cleanupQueue, this.cleanupTask, 0L, 2, null); } return true; } private final synchronized void checkNotClosed() { if (this.closed) { throw new IllegalStateException("cache is closed".toString()); } } @Override // java.io.Flushable public synchronized void flush() throws IOException { if (this.initialized) { checkNotClosed(); trimToSize(); BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } bufferedSink.flush(); } } public final synchronized boolean isClosed() { return this.closed; } @Override // java.io.Closeable, java.lang.AutoCloseable public synchronized void close() throws IOException { if (this.initialized && !this.closed) { Collection values = this.lruEntries.values(); Intrinsics.checkExpressionValueIsNotNull(values, "lruEntries.values"); Object[] array = values.toArray(new Entry[0]); if (array != null) { for (Entry entry : (Entry[]) array) { if (entry.getCurrentEditor() != null) { Editor currentEditor = entry.getCurrentEditor(); if (currentEditor == null) { Intrinsics.throwNpe(); } currentEditor.abort(); } } trimToSize(); BufferedSink bufferedSink = this.journalWriter; if (bufferedSink == null) { Intrinsics.throwNpe(); } bufferedSink.close(); this.journalWriter = null; this.closed = true; return; } throw new TypeCastException("null cannot be cast to non-null type kotlin.Array"); } this.closed = true; } public final void trimToSize() throws IOException { while (this.size > this.maxSize) { Entry next = this.lruEntries.values().iterator().next(); Intrinsics.checkExpressionValueIsNotNull(next, "lruEntries.values.iterator().next()"); removeEntry$okhttp(next); } this.mostRecentTrimFailed = false; } public final void delete() throws IOException { close(); this.fileSystem.deleteContents(this.directory); } public final synchronized void evictAll() throws IOException { initialize(); Collection values = this.lruEntries.values(); Intrinsics.checkExpressionValueIsNotNull(values, "lruEntries.values"); Object[] array = values.toArray(new Entry[0]); if (array != null) { for (Entry entry : (Entry[]) array) { Intrinsics.checkExpressionValueIsNotNull(entry, "entry"); removeEntry$okhttp(entry); } this.mostRecentTrimFailed = false; } else { throw new TypeCastException("null cannot be cast to non-null type kotlin.Array"); } } private final void validateKey(String key) { if (!LEGAL_KEY_PATTERN.matches(key)) { throw new IllegalArgumentException(("keys must match regex [a-z0-9_-]{1,120}: \"" + key + '\"').toString()); } } public final synchronized Iterator snapshots() throws IOException { initialize(); return new DiskLruCache$snapshots$1(this); } /* compiled from: DiskLruCache.kt */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\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\u0002\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0002\b\u0086\u0004\u0018\u00002\u00020\u0001B-\b\u0000\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\f\u0010\u0006\u001a\b\u0012\u0004\u0012\u00020\b0\u0007\u0012\u0006\u0010\t\u001a\u00020\n¢\u0006\u0002\u0010\u000bJ\b\u0010\f\u001a\u00020\rH\u0016J\f\u0010\u000e\u001a\b\u0018\u00010\u000fR\u00020\u0010J\u000e\u0010\u0011\u001a\u00020\u00052\u0006\u0010\u0012\u001a\u00020\u0013J\u000e\u0010\u0014\u001a\u00020\b2\u0006\u0010\u0012\u001a\u00020\u0013J\u0006\u0010\u0002\u001a\u00020\u0003R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\t\u001a\u00020\nX\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004¢\u0006\u0002\n\u0000R\u0014\u0010\u0006\u001a\b\u0012\u0004\u0012\u00020\b0\u0007X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\u0015"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "Ljava/io/Closeable;", "key", "", "sequenceNumber", "", "sources", "", "Lokio/Source;", "lengths", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;JLjava/util/List;[J)V", "close", "", "edit", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "getLength", "index", "", "getSource", "okhttp"}, k = 1, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public final class Snapshot implements Closeable { private final String key; private final long[] lengths; private final long sequenceNumber; private final List sources; final /* synthetic */ DiskLruCache this$0; /* JADX WARN: Multi-variable type inference failed */ public Snapshot(DiskLruCache diskLruCache, String key, long j, List sources, long[] lengths) { Intrinsics.checkParameterIsNotNull(key, "key"); Intrinsics.checkParameterIsNotNull(sources, "sources"); Intrinsics.checkParameterIsNotNull(lengths, "lengths"); this.this$0 = diskLruCache; this.key = key; this.sequenceNumber = j; this.sources = sources; this.lengths = lengths; } /* renamed from: key, reason: from getter */ public final String getKey() { return this.key; } public final Editor edit() throws IOException { return this.this$0.edit(this.key, this.sequenceNumber); } public final Source getSource(int index) { return this.sources.get(index); } public final long getLength(int index) { return this.lengths[index]; } @Override // java.io.Closeable, java.lang.AutoCloseable public void close() { Iterator it = this.sources.iterator(); while (it.hasNext()) { Util.closeQuietly(it.next()); } } } /* compiled from: DiskLruCache.kt */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000@\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u0018\n\u0002\b\u0003\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0000\b\u0086\u0004\u0018\u00002\u00020\u0001B\u0013\b\u0000\u0012\n\u0010\u0002\u001a\u00060\u0003R\u00020\u0004¢\u0006\u0002\u0010\u0005J\u0006\u0010\u000e\u001a\u00020\u000fJ\u0006\u0010\u0010\u001a\u00020\u000fJ\r\u0010\u0011\u001a\u00020\u000fH\u0000¢\u0006\u0002\b\u0012J\u000e\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u0016J\u0010\u0010\u0017\u001a\u0004\u0018\u00010\u00182\u0006\u0010\u0015\u001a\u00020\u0016R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u000e¢\u0006\u0002\n\u0000R\u0018\u0010\u0002\u001a\u00060\u0003R\u00020\u0004X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\b\u0010\tR\u0016\u0010\n\u001a\u0004\u0018\u00010\u000bX\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\f\u0010\r¨\u0006\u0019"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Editor;", "", "entry", "Lokhttp3/internal/cache/DiskLruCache$Entry;", "Lokhttp3/internal/cache/DiskLruCache;", "(Lokhttp3/internal/cache/DiskLruCache;Lokhttp3/internal/cache/DiskLruCache$Entry;)V", "done", "", "getEntry$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Entry;", "written", "", "getWritten$okhttp", "()[Z", "abort", "", "commit", "detach", "detach$okhttp", "newSink", "Lokio/Sink;", "index", "", "newSource", "Lokio/Source;", "okhttp"}, k = 1, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public final class Editor { private boolean done; private final Entry entry; final /* synthetic */ DiskLruCache this$0; private final boolean[] written; public Editor(DiskLruCache diskLruCache, Entry entry) { Intrinsics.checkParameterIsNotNull(entry, "entry"); this.this$0 = diskLruCache; this.entry = entry; this.written = entry.getReadable() ? null : new boolean[diskLruCache.getValueCount()]; } /* renamed from: getEntry$okhttp, reason: from getter */ public final Entry getEntry() { return this.entry; } /* renamed from: getWritten$okhttp, reason: from getter */ public final boolean[] getWritten() { return this.written; } public final void detach$okhttp() { if (Intrinsics.areEqual(this.entry.getCurrentEditor(), this)) { int valueCount = this.this$0.getValueCount(); for (int i = 0; i < valueCount; i++) { try { this.this$0.getFileSystem().delete(this.entry.getDirtyFiles$okhttp().get(i)); } catch (IOException unused) { } } this.entry.setCurrentEditor$okhttp(null); } } public final Source newSource(int index) { synchronized (this.this$0) { if (this.done) { throw new IllegalStateException("Check failed.".toString()); } Source source = null; if (this.entry.getReadable()) { Editor editor = this; if (Intrinsics.areEqual(this.entry.getCurrentEditor(), this)) { try { source = this.this$0.getFileSystem().source(this.entry.getCleanFiles$okhttp().get(index)); } catch (FileNotFoundException unused) { } return source; } } return null; } } public final Sink newSink(final int index) { synchronized (this.this$0) { if (this.done) { throw new IllegalStateException("Check failed.".toString()); } Editor editor = this; if (!Intrinsics.areEqual(this.entry.getCurrentEditor(), this)) { return Okio.blackhole(); } if (!this.entry.getReadable()) { boolean[] zArr = this.written; if (zArr == null) { Intrinsics.throwNpe(); } zArr[index] = true; } try { return new FaultHidingSink(this.this$0.getFileSystem().sink(this.entry.getDirtyFiles$okhttp().get(index)), new Function1() { // from class: okhttp3.internal.cache.DiskLruCache$Editor$newSink$$inlined$synchronized$lambda$1 /* JADX INFO: Access modifiers changed from: package-private */ /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(1); } @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(IOException iOException) { invoke2(iOException); return Unit.INSTANCE; } /* renamed from: invoke, reason: avoid collision after fix types in other method */ public final void invoke2(IOException it) { Intrinsics.checkParameterIsNotNull(it, "it"); synchronized (DiskLruCache.Editor.this.this$0) { DiskLruCache.Editor.this.detach$okhttp(); Unit unit = Unit.INSTANCE; } } }); } catch (FileNotFoundException unused) { return Okio.blackhole(); } } } public final void commit() throws IOException { synchronized (this.this$0) { if (this.done) { throw new IllegalStateException("Check failed.".toString()); } Editor editor = this; if (Intrinsics.areEqual(this.entry.getCurrentEditor(), this)) { this.this$0.completeEdit$okhttp(this, true); } this.done = true; Unit unit = Unit.INSTANCE; } } public final void abort() throws IOException { synchronized (this.this$0) { if (this.done) { throw new IllegalStateException("Check failed.".toString()); } Editor editor = this; if (Intrinsics.areEqual(this.entry.getCurrentEditor(), this)) { this.this$0.completeEdit$okhttp(this, false); } this.done = true; Unit unit = Unit.INSTANCE; } } } /* compiled from: DiskLruCache.kt */ @Metadata(bv = {1, 0, 3}, d1 = {"\u0000f\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010!\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0010\u0016\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0080\u0004\u0018\u00002\u00020\u0001B\u000f\b\u0000\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\u0016\u0010%\u001a\u00020&2\f\u0010'\u001a\b\u0012\u0004\u0012\u00020\u00030(H\u0002J\u001b\u0010)\u001a\u00020*2\f\u0010'\u001a\b\u0012\u0004\u0012\u00020\u00030(H\u0000¢\u0006\u0002\b+J\u0013\u0010,\u001a\b\u0018\u00010-R\u00020\fH\u0000¢\u0006\u0002\b.J\u0015\u0010/\u001a\u00020*2\u0006\u00100\u001a\u000201H\u0000¢\u0006\u0002\b2R\u001a\u0010\u0005\u001a\b\u0012\u0004\u0012\u00020\u00070\u0006X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\b\u0010\tR \u0010\n\u001a\b\u0018\u00010\u000bR\u00020\fX\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\r\u0010\u000e\"\u0004\b\u000f\u0010\u0010R\u001a\u0010\u0011\u001a\b\u0012\u0004\u0012\u00020\u00070\u0006X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0012\u0010\tR\u0014\u0010\u0002\u001a\u00020\u0003X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0013\u0010\u0014R\u0014\u0010\u0015\u001a\u00020\u0016X\u0080\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0017\u0010\u0018R\u001a\u0010\u0019\u001a\u00020\u001aX\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u001b\u0010\u001c\"\u0004\b\u001d\u0010\u001eR\u001a\u0010\u001f\u001a\u00020 X\u0080\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b!\u0010\"\"\u0004\b#\u0010$¨\u00063"}, d2 = {"Lokhttp3/internal/cache/DiskLruCache$Entry;", "", "key", "", "(Lokhttp3/internal/cache/DiskLruCache;Ljava/lang/String;)V", "cleanFiles", "", "Ljava/io/File;", "getCleanFiles$okhttp", "()Ljava/util/List;", "currentEditor", "Lokhttp3/internal/cache/DiskLruCache$Editor;", "Lokhttp3/internal/cache/DiskLruCache;", "getCurrentEditor$okhttp", "()Lokhttp3/internal/cache/DiskLruCache$Editor;", "setCurrentEditor$okhttp", "(Lokhttp3/internal/cache/DiskLruCache$Editor;)V", "dirtyFiles", "getDirtyFiles$okhttp", "getKey$okhttp", "()Ljava/lang/String;", "lengths", "", "getLengths$okhttp", "()[J", "readable", "", "getReadable$okhttp", "()Z", "setReadable$okhttp", "(Z)V", "sequenceNumber", "", "getSequenceNumber$okhttp", "()J", "setSequenceNumber$okhttp", "(J)V", "invalidLengths", "Ljava/io/IOException;", "strings", "", "setLengths", "", "setLengths$okhttp", "snapshot", "Lokhttp3/internal/cache/DiskLruCache$Snapshot;", "snapshot$okhttp", "writeLengths", "writer", "Lokio/BufferedSink;", "writeLengths$okhttp", "okhttp"}, k = 1, mv = {1, 1, 16}) /* loaded from: classes2.dex */ public final class Entry { private final List cleanFiles; private Editor currentEditor; private final List dirtyFiles; private final String key; private final long[] lengths; private boolean readable; private long sequenceNumber; final /* synthetic */ DiskLruCache this$0; public Entry(DiskLruCache diskLruCache, String key) { Intrinsics.checkParameterIsNotNull(key, "key"); this.this$0 = diskLruCache; this.key = key; this.lengths = new long[diskLruCache.getValueCount()]; this.cleanFiles = new ArrayList(); this.dirtyFiles = new ArrayList(); StringBuilder append = new StringBuilder(key).append('.'); int length = append.length(); int valueCount = diskLruCache.getValueCount(); for (int i = 0; i < valueCount; i++) { append.append(i); this.cleanFiles.add(new File(diskLruCache.getDirectory(), append.toString())); append.append(".tmp"); this.dirtyFiles.add(new File(diskLruCache.getDirectory(), append.toString())); append.setLength(length); } } /* renamed from: getKey$okhttp, reason: from getter */ public final String getKey() { return this.key; } /* renamed from: getLengths$okhttp, reason: from getter */ public final long[] getLengths() { return this.lengths; } public final List getCleanFiles$okhttp() { return this.cleanFiles; } public final List getDirtyFiles$okhttp() { return this.dirtyFiles; } /* renamed from: getReadable$okhttp, reason: from getter */ public final boolean getReadable() { return this.readable; } public final void setReadable$okhttp(boolean z) { this.readable = z; } /* renamed from: getCurrentEditor$okhttp, reason: from getter */ public final Editor getCurrentEditor() { return this.currentEditor; } public final void setCurrentEditor$okhttp(Editor editor) { this.currentEditor = editor; } /* renamed from: getSequenceNumber$okhttp, reason: from getter */ public final long getSequenceNumber() { return this.sequenceNumber; } public final void setSequenceNumber$okhttp(long j) { this.sequenceNumber = j; } public final void setLengths$okhttp(List strings) throws IOException { Intrinsics.checkParameterIsNotNull(strings, "strings"); if (strings.size() != this.this$0.getValueCount()) { throw invalidLengths(strings); } try { int size = strings.size(); for (int i = 0; i < size; i++) { this.lengths[i] = Long.parseLong(strings.get(i)); } } catch (NumberFormatException unused) { throw invalidLengths(strings); } } public final void writeLengths$okhttp(BufferedSink writer) throws IOException { Intrinsics.checkParameterIsNotNull(writer, "writer"); for (long j : this.lengths) { writer.writeByte(32).writeDecimalLong(j); } } private final IOException invalidLengths(List strings) throws IOException { throw new IOException("unexpected journal line: " + strings); } public final Snapshot snapshot$okhttp() { DiskLruCache diskLruCache = this.this$0; if (!Util.assertionsEnabled || Thread.holdsLock(diskLruCache)) { 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(this.this$0.getFileSystem().source(this.cleanFiles.get(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((Source) it.next()); } try { this.this$0.removeEntry$okhttp(this); return null; } catch (IOException unused2) { return null; } } } StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST hold lock on ").append(diskLruCache).toString()); } } public final synchronized void initialize() throws IOException { if (Util.assertionsEnabled && !Thread.holdsLock(this)) { StringBuilder sb = new StringBuilder("Thread "); Thread currentThread = Thread.currentThread(); Intrinsics.checkExpressionValueIsNotNull(currentThread, "Thread.currentThread()"); throw new AssertionError(sb.append(currentThread.getName()).append(" MUST hold lock on ").append(this).toString()); } if (this.initialized) { return; } if (this.fileSystem.exists(this.journalFileBackup)) { if (this.fileSystem.exists(this.journalFile)) { this.fileSystem.delete(this.journalFileBackup); } else { this.fileSystem.rename(this.journalFileBackup, this.journalFile); } } if (this.fileSystem.exists(this.journalFile)) { try { readJournal(); processJournal(); this.initialized = true; return; } catch (IOException e) { Platform.INSTANCE.get().log("DiskLruCache " + this.directory + " is corrupt: " + e.getMessage() + ", removing", 5, e); try { delete(); this.closed = false; } catch (Throwable th) { this.closed = false; throw th; } } } rebuildJournal$okhttp(); this.initialized = true; } }