107 lines
3.4 KiB
Java
107 lines
3.4 KiB
Java
package h3;
|
|
|
|
import i3.m;
|
|
import java.io.IOException;
|
|
import java.net.Socket;
|
|
import java.util.Iterator;
|
|
import kotlin.Unit;
|
|
import kotlin.jvm.internal.Intrinsics;
|
|
import l3.l;
|
|
import l3.q;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public final class b extends a {
|
|
|
|
/* renamed from: e, reason: collision with root package name */
|
|
public final /* synthetic */ int f6782e;
|
|
|
|
/* renamed from: f, reason: collision with root package name */
|
|
public final /* synthetic */ Object f6783f;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
public /* synthetic */ b(Object obj, int i, String str) {
|
|
super(str, true);
|
|
this.f6782e = i;
|
|
this.f6783f = obj;
|
|
}
|
|
|
|
@Override // h3.a
|
|
public final long a() {
|
|
int i = 0;
|
|
switch (this.f6782e) {
|
|
case 0:
|
|
((l) this.f6783f).invoke();
|
|
return -1L;
|
|
case 1:
|
|
m mVar = (m) this.f6783f;
|
|
long nanoTime = System.nanoTime();
|
|
Iterator it = mVar.f6889d.iterator();
|
|
long j4 = Long.MIN_VALUE;
|
|
i3.l lVar = null;
|
|
int i4 = 0;
|
|
while (it.hasNext()) {
|
|
i3.l connection = (i3.l) it.next();
|
|
Intrinsics.checkNotNullExpressionValue(connection, "connection");
|
|
synchronized (connection) {
|
|
if (mVar.b(connection, nanoTime) > 0) {
|
|
i4++;
|
|
} else {
|
|
i++;
|
|
long j5 = nanoTime - connection.f6885q;
|
|
if (j5 > j4) {
|
|
lVar = connection;
|
|
j4 = j5;
|
|
}
|
|
Unit unit = Unit.INSTANCE;
|
|
}
|
|
}
|
|
}
|
|
long j6 = mVar.f6886a;
|
|
if (j4 < j6 && i <= 5) {
|
|
if (i > 0) {
|
|
return j6 - j4;
|
|
}
|
|
if (i4 > 0) {
|
|
return j6;
|
|
}
|
|
return -1L;
|
|
}
|
|
Intrinsics.checkNotNull(lVar);
|
|
synchronized (lVar) {
|
|
if (!lVar.p.isEmpty()) {
|
|
return 0L;
|
|
}
|
|
if (lVar.f6885q + j4 != nanoTime) {
|
|
return 0L;
|
|
}
|
|
lVar.f6879j = true;
|
|
mVar.f6889d.remove(lVar);
|
|
Socket socket = lVar.f6875d;
|
|
Intrinsics.checkNotNull(socket);
|
|
f3.c.d(socket);
|
|
if (!mVar.f6889d.isEmpty()) {
|
|
return 0L;
|
|
}
|
|
mVar.f6887b.a();
|
|
return 0L;
|
|
}
|
|
default:
|
|
q qVar = (q) this.f6783f;
|
|
qVar.getClass();
|
|
try {
|
|
qVar.f7448w.Y(2, 0, false);
|
|
} catch (IOException e4) {
|
|
qVar.e(e4);
|
|
}
|
|
return -1L;
|
|
}
|
|
}
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
public b(m mVar, String str) {
|
|
super(str, true);
|
|
this.f6782e = 1;
|
|
this.f6783f = mVar;
|
|
}
|
|
}
|