NetMirror.apk
Download file
package S;
import R.a;
import R.c;
import S.f;
import c0.C0327a;
import e0.InterfaceC0522a;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
/* JADX INFO: loaded from: classes.dex */
public class g implements k, U.a {
/* JADX INFO: renamed from: r, reason: collision with root package name */
private static final Class f2254r = g.class;
/* JADX INFO: renamed from: s, reason: collision with root package name */
private static final long f2255s = TimeUnit.HOURS.toMillis(2);
/* JADX INFO: renamed from: t, reason: collision with root package name */
private static final long f2256t = TimeUnit.MINUTES.toMillis(30);
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final long f2257a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final long f2258b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final CountDownLatch f2259c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private long f2260d;
/* JADX INFO: renamed from: e, reason: collision with root package name */
private final R.c f2261e;
/* JADX INFO: renamed from: f, reason: collision with root package name */
final Set f2262f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
private long f2263g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
private final long f2264h;
/* JADX INFO: renamed from: i, reason: collision with root package name */
private final C0327a f2265i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
private final f f2266j;
/* JADX INFO: renamed from: k, reason: collision with root package name */
private final j f2267k;
/* JADX INFO: renamed from: l, reason: collision with root package name */
private final R.a f2268l;
/* JADX INFO: renamed from: m, reason: collision with root package name */
private final boolean f2269m;
/* JADX INFO: renamed from: n, reason: collision with root package name */
private final b f2270n;
/* JADX INFO: renamed from: o, reason: collision with root package name */
private final InterfaceC0522a f2271o;
/* JADX INFO: renamed from: p, reason: collision with root package name */
private final Object f2272p = new Object();
/* JADX INFO: renamed from: q, reason: collision with root package name */
private boolean f2273q;
class a implements Runnable {
a() {
}
@Override // java.lang.Runnable
public void run() {
synchronized (g.this.f2272p) {
g.this.p();
}
g.this.f2273q = true;
g.this.f2259c.countDown();
}
}
static class b {
/* JADX INFO: renamed from: a, reason: collision with root package name */
private boolean f2275a = false;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private long f2276b = -1;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private long f2277c = -1;
b() {
}
public synchronized long a() {
return this.f2277c;
}
public synchronized long b() {
return this.f2276b;
}
public synchronized void c(long j3, long j4) {
if (this.f2275a) {
this.f2276b += j3;
this.f2277c += j4;
}
}
public synchronized boolean d() {
return this.f2275a;
}
public synchronized void e() {
this.f2275a = false;
this.f2277c = -1L;
this.f2276b = -1L;
}
public synchronized void f(long j3, long j4) {
this.f2277c = j4;
this.f2276b = j3;
this.f2275a = true;
}
}
public static class c {
/* JADX INFO: renamed from: a, reason: collision with root package name */
public final long f2278a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
public final long f2279b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
public final long f2280c;
public c(long j3, long j4, long j5) {
this.f2278a = j3;
this.f2279b = j4;
this.f2280c = j5;
}
}
public g(f fVar, j jVar, c cVar, R.c cVar2, R.a aVar, U.b bVar, Executor executor, boolean z3) {
this.f2257a = cVar.f2279b;
long j3 = cVar.f2280c;
this.f2258b = j3;
this.f2260d = j3;
this.f2265i = C0327a.d();
this.f2266j = fVar;
this.f2267k = jVar;
this.f2263g = -1L;
this.f2261e = cVar2;
this.f2264h = cVar.f2278a;
this.f2268l = aVar;
this.f2270n = new b();
this.f2271o = e0.d.a();
this.f2269m = z3;
this.f2262f = new HashSet();
if (bVar != null) {
bVar.a(this);
}
if (!z3) {
this.f2259c = new CountDownLatch(0);
} else {
this.f2259c = new CountDownLatch(1);
executor.execute(new a());
}
}
private Q.a l(f.b bVar, R.d dVar, String str) {
Q.a aVarC;
synchronized (this.f2272p) {
aVarC = bVar.c(dVar);
this.f2262f.add(str);
this.f2270n.c(aVarC.size(), 1L);
}
return aVarC;
}
private void m(long j3, c.a aVar) throws IOException {
try {
Collection<f.a> collectionN = n(this.f2266j.b());
long jB = this.f2270n.b();
long j4 = jB - j3;
int i3 = 0;
long j5 = 0;
for (f.a aVar2 : collectionN) {
if (j5 > j4) {
break;
}
long jE = this.f2266j.e(aVar2);
this.f2262f.remove(aVar2.getId());
if (jE > 0) {
i3++;
j5 += jE;
l lVarE = l.a().j(aVar2.getId()).g(aVar).i(jE).f(jB - j5).e(j3);
R.c cVar = this.f2261e;
if (cVar != null) {
cVar.a(lVarE);
}
lVarE.b();
}
}
this.f2270n.c(-j5, -i3);
this.f2266j.d();
} catch (IOException e4) {
this.f2268l.a(a.EnumC0028a.EVICTION, f2254r, "evictAboveSize: " + e4.getMessage(), e4);
throw e4;
}
}
private Collection n(Collection collection) {
long jNow = this.f2271o.now() + f2255s;
ArrayList arrayList = new ArrayList(collection.size());
ArrayList arrayList2 = new ArrayList(collection.size());
Iterator it = collection.iterator();
while (it.hasNext()) {
f.a aVar = (f.a) it.next();
if (aVar.a() > jNow) {
arrayList.add(aVar);
} else {
arrayList2.add(aVar);
}
}
Collections.sort(arrayList2, this.f2267k.get());
arrayList.addAll(arrayList2);
return arrayList;
}
private void o() {
synchronized (this.f2272p) {
try {
boolean zP = p();
s();
long jB = this.f2270n.b();
if (jB > this.f2260d && !zP) {
this.f2270n.e();
p();
}
long j3 = this.f2260d;
if (jB > j3) {
m((j3 * 9) / 10, c.a.CACHE_FULL);
}
} catch (Throwable th) {
throw th;
}
}
}
/* JADX INFO: Access modifiers changed from: private */
public boolean p() {
long jNow = this.f2271o.now();
if (this.f2270n.d()) {
long j3 = this.f2263g;
if (j3 != -1 && jNow - j3 <= f2256t) {
return false;
}
}
return q();
}
private boolean q() {
long j3;
long jNow = this.f2271o.now();
long j4 = f2255s + jNow;
Set hashSet = (this.f2269m && this.f2262f.isEmpty()) ? this.f2262f : this.f2269m ? new HashSet() : null;
try {
long jI = 0;
long jMax = -1;
int i3 = 0;
boolean z3 = false;
int i4 = 0;
int i5 = 0;
for (f.a aVar : this.f2266j.b()) {
i4++;
jI += aVar.i();
if (aVar.a() > j4) {
i5++;
i3 = (int) (((long) i3) + aVar.i());
j3 = j4;
jMax = Math.max(aVar.a() - jNow, jMax);
z3 = true;
} else {
j3 = j4;
if (this.f2269m) {
X.k.g(hashSet);
hashSet.add(aVar.getId());
}
}
j4 = j3;
}
if (z3) {
this.f2268l.a(a.EnumC0028a.READ_INVALID_ENTRY, f2254r, "Future timestamp found in " + i5 + " files , with a total size of " + i3 + " bytes, and a maximum time delta of " + jMax + "ms", null);
}
long j5 = i4;
if (this.f2270n.a() != j5 || this.f2270n.b() != jI) {
if (this.f2269m && this.f2262f != hashSet) {
X.k.g(hashSet);
this.f2262f.clear();
this.f2262f.addAll(hashSet);
}
this.f2270n.f(jI, j5);
}
this.f2263g = jNow;
return true;
} catch (IOException e4) {
this.f2268l.a(a.EnumC0028a.GENERIC_IO, f2254r, "calcFileCacheSize: " + e4.getMessage(), e4);
return false;
}
}
private f.b r(String str, R.d dVar) {
o();
return this.f2266j.f(str, dVar);
}
private void s() {
if (this.f2265i.f(this.f2266j.c() ? C0327a.EnumC0088a.EXTERNAL : C0327a.EnumC0088a.INTERNAL, this.f2258b - this.f2270n.b())) {
this.f2260d = this.f2257a;
} else {
this.f2260d = this.f2258b;
}
}
@Override // S.k
public void a() {
synchronized (this.f2272p) {
try {
this.f2266j.a();
this.f2262f.clear();
R.c cVar = this.f2261e;
if (cVar != null) {
cVar.e();
}
} catch (IOException | NullPointerException e4) {
this.f2268l.a(a.EnumC0028a.EVICTION, f2254r, "clearAll: " + e4.getMessage(), e4);
}
this.f2270n.e();
}
}
@Override // S.k
public boolean b(R.d dVar) {
synchronized (this.f2272p) {
try {
List listB = R.e.b(dVar);
for (int i3 = 0; i3 < listB.size(); i3++) {
if (this.f2262f.contains((String) listB.get(i3))) {
return true;
}
}
return false;
} catch (Throwable th) {
throw th;
}
}
}
@Override // S.k
public Q.a c(R.d dVar, R.j jVar) {
String strA;
l lVarD = l.a().d(dVar);
R.c cVar = this.f2261e;
if (cVar != null) {
cVar.h(lVarD);
}
synchronized (this.f2272p) {
strA = R.e.a(dVar);
}
lVarD.j(strA);
try {
try {
f.b bVarR = r(strA, dVar);
try {
bVarR.b(jVar, dVar);
Q.a aVarL = l(bVarR, dVar, strA);
lVarD.i(aVarL.size()).f(this.f2270n.b());
R.c cVar2 = this.f2261e;
if (cVar2 != null) {
cVar2.b(lVarD);
}
return aVarL;
} finally {
if (!bVarR.a()) {
Y.a.i(f2254r, "Failed to delete temp file");
}
}
} catch (IOException e4) {
lVarD.h(e4);
R.c cVar3 = this.f2261e;
if (cVar3 != null) {
cVar3.f(lVarD);
}
Y.a.j(f2254r, "Failed inserting a file into the cache", e4);
throw e4;
}
} finally {
lVarD.b();
}
}
@Override // S.k
public Q.a d(R.d dVar) {
Q.a aVarJ;
l lVarD = l.a().d(dVar);
try {
synchronized (this.f2272p) {
try {
List listB = R.e.b(dVar);
String str = null;
aVarJ = null;
for (int i3 = 0; i3 < listB.size(); i3++) {
str = (String) listB.get(i3);
lVarD.j(str);
aVarJ = this.f2266j.j(str, dVar);
if (aVarJ != null) {
break;
}
}
if (aVarJ == null) {
R.c cVar = this.f2261e;
if (cVar != null) {
cVar.d(lVarD);
}
this.f2262f.remove(str);
} else {
X.k.g(str);
R.c cVar2 = this.f2261e;
if (cVar2 != null) {
cVar2.g(lVarD);
}
this.f2262f.add(str);
}
} finally {
}
}
return aVarJ;
} catch (IOException e4) {
this.f2268l.a(a.EnumC0028a.GENERIC_IO, f2254r, "getResource", e4);
lVarD.h(e4);
R.c cVar3 = this.f2261e;
if (cVar3 != null) {
cVar3.c(lVarD);
}
return null;
} finally {
lVarD.b();
}
}
@Override // S.k
public boolean e(R.d dVar) throws Throwable {
String str;
IOException e4;
String str2 = null;
try {
try {
synchronized (this.f2272p) {
try {
List listB = R.e.b(dVar);
int i3 = 0;
while (i3 < listB.size()) {
String str3 = (String) listB.get(i3);
if (this.f2266j.g(str3, dVar)) {
this.f2262f.add(str3);
return true;
}
i3++;
str2 = str3;
}
return false;
} catch (Throwable th) {
str = str2;
th = th;
try {
throw th;
} catch (IOException e5) {
e4 = e5;
l lVarH = l.a().d(dVar).j(str).h(e4);
R.c cVar = this.f2261e;
if (cVar != null) {
cVar.c(lVarH);
}
lVarH.b();
return false;
}
}
}
} catch (Throwable th2) {
th = th2;
}
} catch (IOException e6) {
str = null;
e4 = e6;
}
}
@Override // S.k
public boolean f(R.d dVar) {
synchronized (this.f2272p) {
if (b(dVar)) {
return true;
}
try {
List listB = R.e.b(dVar);
for (int i3 = 0; i3 < listB.size(); i3++) {
String str = (String) listB.get(i3);
if (this.f2266j.i(str, dVar)) {
this.f2262f.add(str);
return true;
}
}
return false;
} catch (IOException unused) {
return false;
}
}
}
@Override // S.k
public void g(R.d dVar) {
synchronized (this.f2272p) {
try {
List listB = R.e.b(dVar);
for (int i3 = 0; i3 < listB.size(); i3++) {
String str = (String) listB.get(i3);
this.f2266j.h(str);
this.f2262f.remove(str);
}
} catch (IOException e4) {
this.f2268l.a(a.EnumC0028a.DELETE_FILE, f2254r, "delete: " + e4.getMessage(), e4);
}
}
}
}
⚠️ This content was hidden by an advertisement filtering extension in your browser. Please disable it and reload the page to access the decompiled content.
We only display one small text ad to keep this service free. Here's what it looks like:
Read the Docs for Business: You write the docs. We do the rest.
Try it today!Ad by EthicalAds