NetMirror.apk
Download file
package R2;
import R2.e;
import java.lang.ref.Reference;
import java.util.List;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.internal.DefaultConstructorMarker;
import r2.r;
/* JADX INFO: loaded from: classes.dex */
public final class h {
/* JADX INFO: renamed from: f, reason: collision with root package name */
public static final a f2184f = new a(null);
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final long f2185a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final Q2.d f2186b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final b f2187c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private final ConcurrentLinkedQueue f2188d;
/* JADX INFO: renamed from: e, reason: collision with root package name */
private final int f2189e;
public static final class a {
private a() {
}
public /* synthetic */ a(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
public static final class b extends Q2.a {
b(String str) {
super(str, false, 2, null);
}
@Override // Q2.a
public long f() {
return h.this.b(System.nanoTime());
}
}
public h(Q2.e eVar, int i3, long j3, TimeUnit timeUnit) {
D2.h.f(eVar, "taskRunner");
D2.h.f(timeUnit, "timeUnit");
this.f2189e = i3;
this.f2185a = timeUnit.toNanos(j3);
this.f2186b = eVar.i();
this.f2187c = new b(N2.c.f1410i + " ConnectionPool");
this.f2188d = new ConcurrentLinkedQueue();
if (j3 > 0) {
return;
}
throw new IllegalArgumentException(("keepAliveDuration <= 0: " + j3).toString());
}
private final int d(f fVar, long j3) {
if (N2.c.f1409h && !Thread.holdsLock(fVar)) {
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread threadCurrentThread = Thread.currentThread();
D2.h.e(threadCurrentThread, "Thread.currentThread()");
sb.append(threadCurrentThread.getName());
sb.append(" MUST hold lock on ");
sb.append(fVar);
throw new AssertionError(sb.toString());
}
List listN = fVar.n();
int i3 = 0;
while (i3 < listN.size()) {
Reference reference = (Reference) listN.get(i3);
if (reference.get() != null) {
i3++;
} else {
W2.j.f2732c.g().m("A connection to " + fVar.A().a().l() + " was leaked. Did you forget to close a response body?", ((e.b) reference).a());
listN.remove(i3);
fVar.D(true);
if (listN.isEmpty()) {
fVar.C(j3 - this.f2185a);
return 0;
}
}
}
return listN.size();
}
/* JADX WARN: Removed duplicated region for block: B:13:0x002d A[Catch: all -> 0x002b, TryCatch #0 {all -> 0x002b, blocks: (B:8:0x0024, B:15:0x0033, B:13:0x002d, B:18:0x0037), top: B:26:0x0024 }] */
/*
Code decompiled incorrectly, please refer to instructions dump.
To view partially-correct code enable 'Show inconsistent code' option in preferences
*/
public final boolean a(M2.C0190a r4, R2.e r5, java.util.List r6, boolean r7) {
/*
r3 = this;
java.lang.String r0 = "address"
D2.h.f(r4, r0)
java.lang.String r0 = "call"
D2.h.f(r5, r0)
java.util.concurrent.ConcurrentLinkedQueue r0 = r3.f2188d
java.util.Iterator r0 = r0.iterator()
L10:
boolean r1 = r0.hasNext()
if (r1 == 0) goto L3f
java.lang.Object r1 = r0.next()
R2.f r1 = (R2.f) r1
java.lang.String r2 = "connection"
D2.h.e(r1, r2)
monitor-enter(r1)
if (r7 == 0) goto L2d
boolean r2 = r1.v() // Catch: java.lang.Throwable -> L2b
if (r2 != 0) goto L2d
goto L33
L2b:
r4 = move-exception
goto L3d
L2d:
boolean r2 = r1.t(r4, r6) // Catch: java.lang.Throwable -> L2b
if (r2 != 0) goto L37
L33:
r2.r r2 = r2.r.f10584a // Catch: java.lang.Throwable -> L2b
monitor-exit(r1)
goto L10
L37:
r5.d(r1) // Catch: java.lang.Throwable -> L2b
monitor-exit(r1)
r4 = 1
return r4
L3d:
monitor-exit(r1)
throw r4
L3f:
r4 = 0
return r4
*/
throw new UnsupportedOperationException("Method not decompiled: R2.h.a(M2.a, R2.e, java.util.List, boolean):boolean");
}
public final long b(long j3) {
int i3 = 0;
long j4 = Long.MIN_VALUE;
f fVar = null;
int i4 = 0;
for (f fVar2 : this.f2188d) {
D2.h.e(fVar2, "connection");
synchronized (fVar2) {
try {
if (d(fVar2, j3) > 0) {
i4++;
} else {
i3++;
long jO = j3 - fVar2.o();
if (jO > j4) {
r rVar = r.f10584a;
fVar = fVar2;
j4 = jO;
} else {
r rVar2 = r.f10584a;
}
}
} catch (Throwable th) {
throw th;
}
}
}
long j5 = this.f2185a;
if (j4 < j5 && i3 <= this.f2189e) {
if (i3 > 0) {
return j5 - j4;
}
if (i4 > 0) {
return j5;
}
return -1L;
}
D2.h.c(fVar);
synchronized (fVar) {
if (!fVar.n().isEmpty()) {
return 0L;
}
if (fVar.o() + j4 != j3) {
return 0L;
}
fVar.D(true);
this.f2188d.remove(fVar);
N2.c.k(fVar.E());
if (this.f2188d.isEmpty()) {
this.f2186b.a();
}
return 0L;
}
}
public final boolean c(f fVar) {
D2.h.f(fVar, "connection");
if (N2.c.f1409h && !Thread.holdsLock(fVar)) {
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread threadCurrentThread = Thread.currentThread();
D2.h.e(threadCurrentThread, "Thread.currentThread()");
sb.append(threadCurrentThread.getName());
sb.append(" MUST hold lock on ");
sb.append(fVar);
throw new AssertionError(sb.toString());
}
if (!fVar.p() && this.f2189e != 0) {
Q2.d.j(this.f2186b, this.f2187c, 0L, 2, null);
return false;
}
fVar.D(true);
this.f2188d.remove(fVar);
if (this.f2188d.isEmpty()) {
this.f2186b.a();
}
return true;
}
public final void e(f fVar) {
D2.h.f(fVar, "connection");
if (!N2.c.f1409h || Thread.holdsLock(fVar)) {
this.f2188d.add(fVar);
Q2.d.j(this.f2186b, this.f2187c, 0L, 2, null);
return;
}
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread threadCurrentThread = Thread.currentThread();
D2.h.e(threadCurrentThread, "Thread.currentThread()");
sb.append(threadCurrentThread.getName());
sb.append(" MUST hold lock on ");
sb.append(fVar);
throw new AssertionError(sb.toString());
}
}
⚠️ 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