472 lines
16 KiB
Java
472 lines
16 KiB
Java
package o;
|
|
|
|
import android.os.SystemClock;
|
|
import android.text.TextUtils;
|
|
import java.io.BufferedInputStream;
|
|
import java.io.BufferedOutputStream;
|
|
import java.io.DataInputStream;
|
|
import java.io.EOFException;
|
|
import java.io.File;
|
|
import java.io.FileInputStream;
|
|
import java.io.FileOutputStream;
|
|
import java.io.FilterInputStream;
|
|
import java.io.IOException;
|
|
import java.io.InputStream;
|
|
import java.io.OutputStream;
|
|
import java.util.ArrayList;
|
|
import java.util.Collections;
|
|
import java.util.Iterator;
|
|
import java.util.LinkedHashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import o.InterfaceC17333vqS;
|
|
|
|
/* loaded from: classes.dex */
|
|
public final class RRt implements InterfaceC17333vqS {
|
|
private final int a;
|
|
private final Sts b;
|
|
private long d;
|
|
private final Map<String, HBt> e;
|
|
|
|
/* loaded from: classes.dex */
|
|
public interface Sts {
|
|
File b();
|
|
}
|
|
|
|
private RRt(Sts sts, byte b) {
|
|
this.e = new LinkedHashMap(16, 0.75f, true);
|
|
this.d = 0L;
|
|
this.b = sts;
|
|
this.a = 5242880;
|
|
}
|
|
|
|
public RRt(Sts sts) {
|
|
this(sts, (byte) 0);
|
|
}
|
|
|
|
@Override // o.InterfaceC17333vqS
|
|
public final InterfaceC17333vqS.IeS d(String str) {
|
|
synchronized (this) {
|
|
HBt hBt = this.e.get(str);
|
|
if (hBt == null) {
|
|
return null;
|
|
}
|
|
File file = new File(this.b.b(), c(str));
|
|
try {
|
|
IeS ieS = new IeS(new BufferedInputStream(new FileInputStream(file)), file.length());
|
|
try {
|
|
HBt c = HBt.c(ieS);
|
|
if (!TextUtils.equals(str, c.d)) {
|
|
qWd.d("%s: key=%s, found=%s", file.getAbsolutePath(), str, c.d);
|
|
e(str);
|
|
return null;
|
|
}
|
|
byte[] b = b(ieS, ieS.a - ieS.d);
|
|
InterfaceC17333vqS.IeS ieS2 = new InterfaceC17333vqS.IeS();
|
|
ieS2.a = b;
|
|
ieS2.e = hBt.c;
|
|
ieS2.h = hBt.b;
|
|
ieS2.b = hBt.e;
|
|
ieS2.f = hBt.f;
|
|
ieS2.i = hBt.g;
|
|
ieS2.c = HNc.b(hBt.a);
|
|
ieS2.d = Collections.unmodifiableList(hBt.a);
|
|
return ieS2;
|
|
} finally {
|
|
ieS.close();
|
|
}
|
|
} catch (IOException e) {
|
|
qWd.d("%s: %s", file.getAbsolutePath(), e.toString());
|
|
synchronized (this) {
|
|
boolean delete = new File(this.b.b(), c(str)).delete();
|
|
e(str);
|
|
if (!delete) {
|
|
qWd.d("Could not delete cache entry for key=%s, filename=%s", str, c(str));
|
|
}
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC17333vqS
|
|
public final void c() {
|
|
synchronized (this) {
|
|
File b = this.b.b();
|
|
if (!b.exists()) {
|
|
if (!b.mkdirs()) {
|
|
qWd.a("Unable to create cache dir %s", b.getAbsolutePath());
|
|
}
|
|
return;
|
|
}
|
|
File[] listFiles = b.listFiles();
|
|
if (listFiles == null) {
|
|
return;
|
|
}
|
|
for (File file : listFiles) {
|
|
try {
|
|
long length = file.length();
|
|
IeS ieS = new IeS(new BufferedInputStream(new FileInputStream(file)), length);
|
|
try {
|
|
HBt c = HBt.c(ieS);
|
|
c.j = length;
|
|
c(c.d, c);
|
|
ieS.close();
|
|
} catch (Throwable th) {
|
|
ieS.close();
|
|
throw th;
|
|
break;
|
|
}
|
|
} catch (IOException unused) {
|
|
file.delete();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC17333vqS
|
|
public final void a(String str) {
|
|
synchronized (this) {
|
|
InterfaceC17333vqS.IeS d = d(str);
|
|
if (d != null) {
|
|
d.i = 0L;
|
|
d.f = 0L;
|
|
c(str, d);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC17333vqS
|
|
public final void c(String str, InterfaceC17333vqS.IeS ieS) {
|
|
BufferedOutputStream bufferedOutputStream;
|
|
HBt hBt;
|
|
synchronized (this) {
|
|
if (this.d + ieS.a.length <= this.a || ieS.a.length <= this.a * 0.9f) {
|
|
File file = new File(this.b.b(), c(str));
|
|
try {
|
|
bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(file));
|
|
hBt = new HBt(str, ieS);
|
|
} catch (IOException unused) {
|
|
if (!file.delete()) {
|
|
qWd.d("Could not clean up file %s", file.getAbsolutePath());
|
|
}
|
|
b();
|
|
}
|
|
if (!hBt.b(bufferedOutputStream)) {
|
|
bufferedOutputStream.close();
|
|
qWd.d("Failed to write header for %s", file.getAbsolutePath());
|
|
throw new IOException();
|
|
}
|
|
bufferedOutputStream.write(ieS.a);
|
|
bufferedOutputStream.close();
|
|
hBt.j = file.length();
|
|
c(str, hBt);
|
|
a();
|
|
}
|
|
}
|
|
}
|
|
|
|
private static String c(String str) {
|
|
int length = str.length() / 2;
|
|
int hashCode = str.substring(0, length).hashCode();
|
|
StringBuilder sb = new StringBuilder();
|
|
sb.append(String.valueOf(hashCode));
|
|
sb.append(String.valueOf(str.substring(length).hashCode()));
|
|
return sb.toString();
|
|
}
|
|
|
|
private void b() {
|
|
if (this.b.b().exists()) {
|
|
return;
|
|
}
|
|
qWd.d("Re-initializing cache after external clearing.", new Object[0]);
|
|
this.e.clear();
|
|
this.d = 0L;
|
|
c();
|
|
}
|
|
|
|
private void a() {
|
|
if (this.d < this.a) {
|
|
return;
|
|
}
|
|
int i = 0;
|
|
if (qWd.a) {
|
|
qWd.e("Pruning old cache entries.", new Object[0]);
|
|
}
|
|
long j = this.d;
|
|
long elapsedRealtime = SystemClock.elapsedRealtime();
|
|
Iterator<Map.Entry<String, HBt>> it = this.e.entrySet().iterator();
|
|
while (it.hasNext()) {
|
|
HBt value = it.next().getValue();
|
|
if (new File(this.b.b(), c(value.d)).delete()) {
|
|
this.d -= value.j;
|
|
} else {
|
|
qWd.d("Could not delete cache entry for key=%s, filename=%s", value.d, c(value.d));
|
|
}
|
|
it.remove();
|
|
i++;
|
|
if (((float) this.d) < this.a * 0.9f) {
|
|
break;
|
|
}
|
|
}
|
|
if (qWd.a) {
|
|
qWd.e("pruned %d files, %d bytes, %d ms", Integer.valueOf(i), Long.valueOf(this.d - j), Long.valueOf(SystemClock.elapsedRealtime() - elapsedRealtime));
|
|
}
|
|
}
|
|
|
|
private void c(String str, HBt hBt) {
|
|
if (!this.e.containsKey(str)) {
|
|
this.d += hBt.j;
|
|
} else {
|
|
this.d += hBt.j - this.e.get(str).j;
|
|
}
|
|
this.e.put(str, hBt);
|
|
}
|
|
|
|
private void e(String str) {
|
|
HBt remove = this.e.remove(str);
|
|
if (remove != null) {
|
|
this.d -= remove.j;
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* loaded from: classes.dex */
|
|
public static class HBt {
|
|
final List<ucE> a;
|
|
final long b;
|
|
final String c;
|
|
final String d;
|
|
final long e;
|
|
final long f;
|
|
final long g;
|
|
long j;
|
|
|
|
private HBt(String str, String str2, long j, long j2, long j3, long j4, List<ucE> list) {
|
|
this.d = str;
|
|
this.c = "".equals(str2) ? null : str2;
|
|
this.b = j;
|
|
this.e = j2;
|
|
this.f = j3;
|
|
this.g = j4;
|
|
this.a = list;
|
|
}
|
|
|
|
/* JADX WARN: Illegal instructions before constructor call */
|
|
/*
|
|
Code decompiled incorrectly, please refer to instructions dump.
|
|
To view partially-correct add '--show-bad-code' argument
|
|
*/
|
|
HBt(java.lang.String r13, o.InterfaceC17333vqS.IeS r14) {
|
|
/*
|
|
r12 = this;
|
|
java.lang.String r2 = r14.e
|
|
long r3 = r14.h
|
|
long r5 = r14.b
|
|
long r7 = r14.f
|
|
long r9 = r14.i
|
|
java.util.List<o.ucE> r0 = r14.d
|
|
if (r0 == 0) goto L11
|
|
java.util.List<o.ucE> r14 = r14.d
|
|
goto L17
|
|
L11:
|
|
java.util.Map<java.lang.String, java.lang.String> r14 = r14.c
|
|
java.util.List r14 = o.HNc.a(r14)
|
|
L17:
|
|
r11 = r14
|
|
r0 = r12
|
|
r1 = r13
|
|
r0.<init>(r1, r2, r3, r5, r7, r9, r11)
|
|
return
|
|
*/
|
|
throw new UnsupportedOperationException("Method not decompiled: o.RRt.HBt.<init>(java.lang.String, o.vqS$IeS):void");
|
|
}
|
|
|
|
static HBt c(IeS ieS) throws IOException {
|
|
if (RRt.d(ieS) != 538247942) {
|
|
throw new IOException();
|
|
}
|
|
return new HBt(new String(RRt.b(ieS, RRt.c((InputStream) ieS)), "UTF-8"), new String(RRt.b(ieS, RRt.c((InputStream) ieS)), "UTF-8"), RRt.c((InputStream) ieS), RRt.c((InputStream) ieS), RRt.c((InputStream) ieS), RRt.c((InputStream) ieS), RRt.c(ieS));
|
|
}
|
|
|
|
final boolean b(OutputStream outputStream) {
|
|
try {
|
|
RRt.a(outputStream, 538247942);
|
|
byte[] bytes = this.d.getBytes("UTF-8");
|
|
RRt.c(outputStream, bytes.length);
|
|
outputStream.write(bytes, 0, bytes.length);
|
|
String str = this.c;
|
|
if (str == null) {
|
|
str = "";
|
|
}
|
|
byte[] bytes2 = str.getBytes("UTF-8");
|
|
RRt.c(outputStream, bytes2.length);
|
|
outputStream.write(bytes2, 0, bytes2.length);
|
|
RRt.c(outputStream, this.b);
|
|
RRt.c(outputStream, this.e);
|
|
RRt.c(outputStream, this.f);
|
|
RRt.c(outputStream, this.g);
|
|
List<ucE> list = this.a;
|
|
if (list != null) {
|
|
RRt.a(outputStream, list.size());
|
|
for (ucE uce : list) {
|
|
byte[] bytes3 = uce.e.getBytes("UTF-8");
|
|
RRt.c(outputStream, bytes3.length);
|
|
outputStream.write(bytes3, 0, bytes3.length);
|
|
byte[] bytes4 = uce.b.getBytes("UTF-8");
|
|
RRt.c(outputStream, bytes4.length);
|
|
outputStream.write(bytes4, 0, bytes4.length);
|
|
}
|
|
} else {
|
|
RRt.a(outputStream, 0);
|
|
}
|
|
outputStream.flush();
|
|
return true;
|
|
} catch (IOException e) {
|
|
qWd.d("%s", e.toString());
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* loaded from: classes.dex */
|
|
public static class IeS extends FilterInputStream {
|
|
final long a;
|
|
long d;
|
|
|
|
IeS(InputStream inputStream, long j) {
|
|
super(inputStream);
|
|
this.a = j;
|
|
}
|
|
|
|
@Override // java.io.FilterInputStream, java.io.InputStream
|
|
public final int read() throws IOException {
|
|
int read = super.read();
|
|
if (read != -1) {
|
|
this.d++;
|
|
}
|
|
return read;
|
|
}
|
|
|
|
@Override // java.io.FilterInputStream, java.io.InputStream
|
|
public final int read(byte[] bArr, int i, int i2) throws IOException {
|
|
int read = super.read(bArr, i, i2);
|
|
if (read != -1) {
|
|
this.d += read;
|
|
}
|
|
return read;
|
|
}
|
|
}
|
|
|
|
static void a(OutputStream outputStream, int i) throws IOException {
|
|
outputStream.write(i & 255);
|
|
outputStream.write((i >> 8) & 255);
|
|
outputStream.write((i >> 16) & 255);
|
|
outputStream.write(i >>> 24);
|
|
}
|
|
|
|
static void c(OutputStream outputStream, long j) throws IOException {
|
|
outputStream.write((byte) j);
|
|
outputStream.write((byte) (j >>> 8));
|
|
outputStream.write((byte) (j >>> 16));
|
|
outputStream.write((byte) (j >>> 24));
|
|
outputStream.write((byte) (j >>> 32));
|
|
outputStream.write((byte) (j >>> 40));
|
|
outputStream.write((byte) (j >>> 48));
|
|
outputStream.write((byte) (j >>> 56));
|
|
}
|
|
|
|
static List<ucE> c(IeS ieS) throws IOException {
|
|
int d = d(ieS);
|
|
if (d < 0) {
|
|
throw new IOException("readHeaderList size=".concat(String.valueOf(d)));
|
|
}
|
|
List<ucE> emptyList = d == 0 ? Collections.emptyList() : new ArrayList<>();
|
|
for (int i = 0; i < d; i++) {
|
|
emptyList.add(new ucE(new String(b(ieS, c((InputStream) ieS)), "UTF-8").intern(), new String(b(ieS, c((InputStream) ieS)), "UTF-8").intern()));
|
|
}
|
|
return emptyList;
|
|
}
|
|
|
|
static int d(InputStream inputStream) throws IOException {
|
|
int read = inputStream.read();
|
|
if (read == -1) {
|
|
throw new EOFException();
|
|
}
|
|
int read2 = inputStream.read();
|
|
if (read2 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
int read3 = inputStream.read();
|
|
if (read3 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
int read4 = inputStream.read();
|
|
if (read4 != -1) {
|
|
return (read4 << 24) | read | (read2 << 8) | (read3 << 16);
|
|
}
|
|
throw new EOFException();
|
|
}
|
|
|
|
static long c(InputStream inputStream) throws IOException {
|
|
int read = inputStream.read();
|
|
if (read == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j = read;
|
|
int read2 = inputStream.read();
|
|
if (read2 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j2 = read2;
|
|
int read3 = inputStream.read();
|
|
if (read3 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j3 = read3;
|
|
int read4 = inputStream.read();
|
|
if (read4 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j4 = read4;
|
|
int read5 = inputStream.read();
|
|
if (read5 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j5 = read5;
|
|
int read6 = inputStream.read();
|
|
if (read6 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j6 = read6;
|
|
int read7 = inputStream.read();
|
|
if (read7 == -1) {
|
|
throw new EOFException();
|
|
}
|
|
long j7 = (j & 255) | ((j2 & 255) << 8) | ((j3 & 255) << 16) | ((j4 & 255) << 24) | ((j5 & 255) << 32) | ((j6 & 255) << 40) | ((read7 & 255) << 48);
|
|
int read8 = inputStream.read();
|
|
if (read8 != -1) {
|
|
return ((read8 & 255) << 56) | j7;
|
|
}
|
|
throw new EOFException();
|
|
}
|
|
|
|
static byte[] b(IeS ieS, long j) throws IOException {
|
|
long j2 = ieS.a - ieS.d;
|
|
if (j >= 0 && j <= j2) {
|
|
int i = (int) j;
|
|
if (i == j) {
|
|
byte[] bArr = new byte[i];
|
|
new DataInputStream(ieS).readFully(bArr);
|
|
return bArr;
|
|
}
|
|
}
|
|
StringBuilder sb = new StringBuilder("streamToBytes length=");
|
|
sb.append(j);
|
|
sb.append(", maxLength=");
|
|
sb.append(j2);
|
|
throw new IOException(sb.toString());
|
|
}
|
|
}
|