NetMirror.apk
Download file
package a3;
import D2.p;
import D2.r;
import K2.o;
import M2.A;
import M2.B;
import M2.D;
import M2.H;
import M2.I;
import M2.InterfaceC0194e;
import M2.InterfaceC0195f;
import M2.z;
import a3.g;
import b3.j;
import b3.k;
import b3.l;
import java.io.Closeable;
import java.io.IOException;
import java.net.ProtocolException;
import java.net.SocketTimeoutException;
import java.util.ArrayDeque;
import java.util.List;
import java.util.Random;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.internal.DefaultConstructorMarker;
import s2.AbstractC0717n;
/* JADX INFO: loaded from: classes.dex */
public final class d implements H, g.a {
/* JADX INFO: renamed from: A, reason: collision with root package name */
public static final b f2875A = new b(null);
/* JADX INFO: renamed from: z, reason: collision with root package name */
private static final List f2876z = AbstractC0717n.b(A.HTTP_1_1);
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final String f2877a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private InterfaceC0194e f2878b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private Q2.a f2879c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private a3.g f2880d;
/* JADX INFO: renamed from: e, reason: collision with root package name */
private a3.h f2881e;
/* JADX INFO: renamed from: f, reason: collision with root package name */
private Q2.d f2882f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
private String f2883g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
private AbstractC0048d f2884h;
/* JADX INFO: renamed from: i, reason: collision with root package name */
private final ArrayDeque f2885i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
private final ArrayDeque f2886j;
/* JADX INFO: renamed from: k, reason: collision with root package name */
private long f2887k;
/* JADX INFO: renamed from: l, reason: collision with root package name */
private boolean f2888l;
/* JADX INFO: renamed from: m, reason: collision with root package name */
private int f2889m;
/* JADX INFO: renamed from: n, reason: collision with root package name */
private String f2890n;
/* JADX INFO: renamed from: o, reason: collision with root package name */
private boolean f2891o;
/* JADX INFO: renamed from: p, reason: collision with root package name */
private int f2892p;
/* JADX INFO: renamed from: q, reason: collision with root package name */
private int f2893q;
/* JADX INFO: renamed from: r, reason: collision with root package name */
private int f2894r;
/* JADX INFO: renamed from: s, reason: collision with root package name */
private boolean f2895s;
/* JADX INFO: renamed from: t, reason: collision with root package name */
private final B f2896t;
/* JADX INFO: renamed from: u, reason: collision with root package name */
private final I f2897u;
/* JADX INFO: renamed from: v, reason: collision with root package name */
private final Random f2898v;
/* JADX INFO: renamed from: w, reason: collision with root package name */
private final long f2899w;
/* JADX INFO: renamed from: x, reason: collision with root package name */
private a3.e f2900x;
/* JADX INFO: renamed from: y, reason: collision with root package name */
private long f2901y;
public static final class a {
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final int f2902a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final l f2903b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final long f2904c;
public a(int i3, l lVar, long j3) {
this.f2902a = i3;
this.f2903b = lVar;
this.f2904c = j3;
}
public final long a() {
return this.f2904c;
}
public final int b() {
return this.f2902a;
}
public final l c() {
return this.f2903b;
}
}
public static final class b {
private b() {
}
public /* synthetic */ b(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
public static final class c {
/* JADX INFO: renamed from: a, reason: collision with root package name */
private final int f2905a;
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final l f2906b;
public c(int i3, l lVar) {
D2.h.f(lVar, "data");
this.f2905a = i3;
this.f2906b = lVar;
}
public final l a() {
return this.f2906b;
}
public final int b() {
return this.f2905a;
}
}
/* JADX INFO: renamed from: a3.d$d, reason: collision with other inner class name */
public static abstract class AbstractC0048d implements Closeable {
/* JADX INFO: renamed from: b, reason: collision with root package name */
private final boolean f2907b;
/* JADX INFO: renamed from: c, reason: collision with root package name */
private final k f2908c;
/* JADX INFO: renamed from: d, reason: collision with root package name */
private final j f2909d;
public AbstractC0048d(boolean z3, k kVar, j jVar) {
D2.h.f(kVar, "source");
D2.h.f(jVar, "sink");
this.f2907b = z3;
this.f2908c = kVar;
this.f2909d = jVar;
}
public final boolean a() {
return this.f2907b;
}
public final j i() {
return this.f2909d;
}
public final k o() {
return this.f2908c;
}
}
private final class e extends Q2.a {
public e() {
super(d.this.f2883g + " writer", false, 2, null);
}
@Override // Q2.a
public long f() {
try {
return d.this.x() ? 0L : -1L;
} catch (IOException e4) {
d.this.q(e4, null);
return -1L;
}
}
}
public static final class f implements InterfaceC0195f {
/* JADX INFO: renamed from: b, reason: collision with root package name */
final /* synthetic */ B f2912b;
f(B b4) {
this.f2912b = b4;
}
@Override // M2.InterfaceC0195f
public void a(InterfaceC0194e interfaceC0194e, IOException iOException) {
D2.h.f(interfaceC0194e, "call");
D2.h.f(iOException, "e");
d.this.q(iOException, null);
}
@Override // M2.InterfaceC0195f
public void b(InterfaceC0194e interfaceC0194e, D d4) {
D2.h.f(interfaceC0194e, "call");
D2.h.f(d4, "response");
R2.c cVarD = d4.D();
try {
d.this.n(d4, cVarD);
D2.h.c(cVarD);
AbstractC0048d abstractC0048dM = cVarD.m();
a3.e eVarA = a3.e.f2930g.a(d4.d0());
d.this.f2900x = eVarA;
if (!d.this.t(eVarA)) {
synchronized (d.this) {
d.this.f2886j.clear();
d.this.a(1010, "unexpected Sec-WebSocket-Extensions in response header");
}
}
try {
d.this.s(N2.c.f1410i + " WebSocket " + this.f2912b.l().n(), abstractC0048dM);
d.this.r().f(d.this, d4);
d.this.u();
} catch (Exception e4) {
d.this.q(e4, null);
}
} catch (IOException e5) {
if (cVarD != null) {
cVarD.u();
}
d.this.q(e5, d4);
N2.c.j(d4);
}
}
}
public static final class g extends Q2.a {
/* JADX INFO: renamed from: e, reason: collision with root package name */
final /* synthetic */ String f2913e;
/* JADX INFO: renamed from: f, reason: collision with root package name */
final /* synthetic */ long f2914f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
final /* synthetic */ d f2915g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
final /* synthetic */ String f2916h;
/* JADX INFO: renamed from: i, reason: collision with root package name */
final /* synthetic */ AbstractC0048d f2917i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
final /* synthetic */ a3.e f2918j;
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
public g(String str, String str2, long j3, d dVar, String str3, AbstractC0048d abstractC0048d, a3.e eVar) {
super(str2, false, 2, null);
this.f2913e = str;
this.f2914f = j3;
this.f2915g = dVar;
this.f2916h = str3;
this.f2917i = abstractC0048d;
this.f2918j = eVar;
}
@Override // Q2.a
public long f() {
this.f2915g.y();
return this.f2914f;
}
}
public static final class h extends Q2.a {
/* JADX INFO: renamed from: e, reason: collision with root package name */
final /* synthetic */ String f2919e;
/* JADX INFO: renamed from: f, reason: collision with root package name */
final /* synthetic */ boolean f2920f;
/* JADX INFO: renamed from: g, reason: collision with root package name */
final /* synthetic */ d f2921g;
/* JADX INFO: renamed from: h, reason: collision with root package name */
final /* synthetic */ a3.h f2922h;
/* JADX INFO: renamed from: i, reason: collision with root package name */
final /* synthetic */ l f2923i;
/* JADX INFO: renamed from: j, reason: collision with root package name */
final /* synthetic */ r f2924j;
/* JADX INFO: renamed from: k, reason: collision with root package name */
final /* synthetic */ p f2925k;
/* JADX INFO: renamed from: l, reason: collision with root package name */
final /* synthetic */ r f2926l;
/* JADX INFO: renamed from: m, reason: collision with root package name */
final /* synthetic */ r f2927m;
/* JADX INFO: renamed from: n, reason: collision with root package name */
final /* synthetic */ r f2928n;
/* JADX INFO: renamed from: o, reason: collision with root package name */
final /* synthetic */ r f2929o;
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
public h(String str, boolean z3, String str2, boolean z4, d dVar, a3.h hVar, l lVar, r rVar, p pVar, r rVar2, r rVar3, r rVar4, r rVar5) {
super(str2, z4);
this.f2919e = str;
this.f2920f = z3;
this.f2921g = dVar;
this.f2922h = hVar;
this.f2923i = lVar;
this.f2924j = rVar;
this.f2925k = pVar;
this.f2926l = rVar2;
this.f2927m = rVar3;
this.f2928n = rVar4;
this.f2929o = rVar5;
}
@Override // Q2.a
public long f() {
this.f2921g.m();
return -1L;
}
}
public d(Q2.e eVar, B b4, I i3, Random random, long j3, a3.e eVar2, long j4) {
D2.h.f(eVar, "taskRunner");
D2.h.f(b4, "originalRequest");
D2.h.f(i3, "listener");
D2.h.f(random, "random");
this.f2896t = b4;
this.f2897u = i3;
this.f2898v = random;
this.f2899w = j3;
this.f2900x = eVar2;
this.f2901y = j4;
this.f2882f = eVar.i();
this.f2885i = new ArrayDeque();
this.f2886j = new ArrayDeque();
this.f2889m = -1;
if (!D2.h.b("GET", b4.h())) {
throw new IllegalArgumentException(("Request must be GET: " + b4.h()).toString());
}
l.a aVar = l.f5639f;
byte[] bArr = new byte[16];
random.nextBytes(bArr);
r2.r rVar = r2.r.f10584a;
this.f2877a = l.a.h(aVar, bArr, 0, 0, 3, null).a();
}
/* JADX INFO: Access modifiers changed from: private */
public final boolean t(a3.e eVar) {
if (eVar.f2936f || eVar.f2932b != null) {
return false;
}
Integer num = eVar.f2934d;
if (num == null) {
return true;
}
int iIntValue = num.intValue();
return 8 <= iIntValue && 15 >= iIntValue;
}
private final void v() {
if (!N2.c.f1409h || Thread.holdsLock(this)) {
Q2.a aVar = this.f2879c;
if (aVar != null) {
Q2.d.j(this.f2882f, aVar, 0L, 2, null);
return;
}
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(this);
throw new AssertionError(sb.toString());
}
private final synchronized boolean w(l lVar, int i3) {
if (!this.f2891o && !this.f2888l) {
if (this.f2887k + ((long) lVar.v()) > 16777216) {
a(1001, null);
return false;
}
this.f2887k += (long) lVar.v();
this.f2886j.add(new c(i3, lVar));
v();
return true;
}
return false;
}
@Override // M2.H
public boolean a(int i3, String str) {
return o(i3, str, 60000L);
}
@Override // M2.H
public boolean b(String str) {
D2.h.f(str, "text");
return w(l.f5639f.e(str), 1);
}
@Override // a3.g.a
public synchronized void c(l lVar) {
try {
D2.h.f(lVar, "payload");
if (!this.f2891o && (!this.f2888l || !this.f2886j.isEmpty())) {
this.f2885i.add(lVar);
v();
this.f2893q++;
}
} finally {
}
}
@Override // a3.g.a
public synchronized void d(l lVar) {
D2.h.f(lVar, "payload");
this.f2894r++;
this.f2895s = false;
}
@Override // a3.g.a
public void e(String str) {
D2.h.f(str, "text");
this.f2897u.e(this, str);
}
@Override // M2.H
public boolean f(l lVar) {
D2.h.f(lVar, "bytes");
return w(lVar, 2);
}
@Override // a3.g.a
public void g(l lVar) {
D2.h.f(lVar, "bytes");
this.f2897u.d(this, lVar);
}
@Override // a3.g.a
public void h(int i3, String str) {
AbstractC0048d abstractC0048d;
a3.g gVar;
a3.h hVar;
D2.h.f(str, "reason");
if (!(i3 != -1)) {
throw new IllegalArgumentException("Failed requirement.");
}
synchronized (this) {
try {
if (!(this.f2889m == -1)) {
throw new IllegalStateException("already closed");
}
this.f2889m = i3;
this.f2890n = str;
abstractC0048d = null;
if (this.f2888l && this.f2886j.isEmpty()) {
AbstractC0048d abstractC0048d2 = this.f2884h;
this.f2884h = null;
gVar = this.f2880d;
this.f2880d = null;
hVar = this.f2881e;
this.f2881e = null;
this.f2882f.n();
abstractC0048d = abstractC0048d2;
} else {
gVar = null;
hVar = null;
}
r2.r rVar = r2.r.f10584a;
} catch (Throwable th) {
throw th;
}
}
try {
this.f2897u.b(this, i3, str);
if (abstractC0048d != null) {
this.f2897u.a(this, i3, str);
}
} finally {
if (abstractC0048d != null) {
N2.c.j(abstractC0048d);
}
if (gVar != null) {
N2.c.j(gVar);
}
if (hVar != null) {
N2.c.j(hVar);
}
}
}
public void m() {
InterfaceC0194e interfaceC0194e = this.f2878b;
D2.h.c(interfaceC0194e);
interfaceC0194e.cancel();
}
public final void n(D d4, R2.c cVar) throws ProtocolException {
D2.h.f(d4, "response");
if (d4.A() != 101) {
throw new ProtocolException("Expected HTTP 101 response but was '" + d4.A() + ' ' + d4.n0() + '\'');
}
String strC0 = D.c0(d4, "Connection", null, 2, null);
if (!o.n("Upgrade", strC0, true)) {
throw new ProtocolException("Expected 'Connection' header value 'Upgrade' but was '" + strC0 + '\'');
}
String strC02 = D.c0(d4, "Upgrade", null, 2, null);
if (!o.n("websocket", strC02, true)) {
throw new ProtocolException("Expected 'Upgrade' header value 'websocket' but was '" + strC02 + '\'');
}
String strC03 = D.c0(d4, "Sec-WebSocket-Accept", null, 2, null);
String strA = l.f5639f.e(this.f2877a + "258EAFA5-E914-47DA-95CA-C5AB0DC85B11").t().a();
if (D2.h.b(strA, strC03)) {
if (cVar == null) {
throw new ProtocolException("Web Socket exchange missing: bad interceptor?");
}
return;
}
throw new ProtocolException("Expected 'Sec-WebSocket-Accept' header value '" + strA + "' but was '" + strC03 + '\'');
}
public final synchronized boolean o(int i3, String str, long j3) {
l lVarE;
try {
a3.f.f2937a.c(i3);
if (str != null) {
lVarE = l.f5639f.e(str);
if (!(((long) lVarE.v()) <= 123)) {
throw new IllegalArgumentException(("reason.size() > 123: " + str).toString());
}
} else {
lVarE = null;
}
if (!this.f2891o && !this.f2888l) {
this.f2888l = true;
this.f2886j.add(new a(i3, lVarE, j3));
v();
return true;
}
return false;
} finally {
}
}
public final void p(z zVar) {
D2.h.f(zVar, "client");
if (this.f2896t.d("Sec-WebSocket-Extensions") != null) {
q(new ProtocolException("Request header not permitted: 'Sec-WebSocket-Extensions'"), null);
return;
}
z zVarB = zVar.C().g(M2.r.f1214a).L(f2876z).b();
B b4 = this.f2896t.i().e("Upgrade", "websocket").e("Connection", "Upgrade").e("Sec-WebSocket-Key", this.f2877a).e("Sec-WebSocket-Version", "13").e("Sec-WebSocket-Extensions", "permessage-deflate").b();
R2.e eVar = new R2.e(zVarB, b4, true);
this.f2878b = eVar;
D2.h.c(eVar);
eVar.o(new f(b4));
}
public final void q(Exception exc, D d4) {
D2.h.f(exc, "e");
synchronized (this) {
if (this.f2891o) {
return;
}
this.f2891o = true;
AbstractC0048d abstractC0048d = this.f2884h;
this.f2884h = null;
a3.g gVar = this.f2880d;
this.f2880d = null;
a3.h hVar = this.f2881e;
this.f2881e = null;
this.f2882f.n();
r2.r rVar = r2.r.f10584a;
try {
this.f2897u.c(this, exc, d4);
} finally {
if (abstractC0048d != null) {
N2.c.j(abstractC0048d);
}
if (gVar != null) {
N2.c.j(gVar);
}
if (hVar != null) {
N2.c.j(hVar);
}
}
}
}
public final I r() {
return this.f2897u;
}
public final void s(String str, AbstractC0048d abstractC0048d) {
D2.h.f(str, "name");
D2.h.f(abstractC0048d, "streams");
a3.e eVar = this.f2900x;
D2.h.c(eVar);
synchronized (this) {
try {
this.f2883g = str;
this.f2884h = abstractC0048d;
this.f2881e = new a3.h(abstractC0048d.a(), abstractC0048d.i(), this.f2898v, eVar.f2931a, eVar.a(abstractC0048d.a()), this.f2901y);
this.f2879c = new e();
long j3 = this.f2899w;
if (j3 != 0) {
long nanos = TimeUnit.MILLISECONDS.toNanos(j3);
String str2 = str + " ping";
this.f2882f.i(new g(str2, str2, nanos, this, str, abstractC0048d, eVar), nanos);
}
if (!this.f2886j.isEmpty()) {
v();
}
r2.r rVar = r2.r.f10584a;
} catch (Throwable th) {
throw th;
}
}
this.f2880d = new a3.g(abstractC0048d.a(), abstractC0048d.o(), this, eVar.f2931a, eVar.a(!abstractC0048d.a()));
}
public final void u() {
while (this.f2889m == -1) {
a3.g gVar = this.f2880d;
D2.h.c(gVar);
gVar.a();
}
}
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARN: Removed duplicated region for block: B:61:0x0186 */
/* JADX WARN: Removed duplicated region for block: B:64:0x0191 */
/* JADX WARN: Removed duplicated region for block: B:67:0x019c */
/* JADX WARN: Removed duplicated region for block: B:96:? A[RETURN, SYNTHETIC] */
/* JADX WARN: Type inference failed for: r1v2 */
/* JADX WARN: Type inference failed for: r1v29 */
/* JADX WARN: Type inference failed for: r1v3, types: [D2.r] */
/* JADX WARN: Type inference failed for: r1v30 */
/* JADX WARN: Type inference failed for: r2v1 */
/* JADX WARN: Type inference failed for: r2v18 */
/* JADX WARN: Type inference failed for: r2v2, types: [D2.r] */
/* JADX WARN: Type inference failed for: r2v8 */
/* JADX WARN: Type inference failed for: r3v23 */
/* JADX WARN: Type inference failed for: r3v24 */
/* JADX WARN: Type inference failed for: r3v25 */
/* JADX WARN: Type inference failed for: r3v26 */
/* JADX WARN: Type inference failed for: r3v27 */
/* JADX WARN: Type inference failed for: r3v28 */
/* JADX WARN: Type inference failed for: r3v3 */
/* JADX WARN: Type inference failed for: r3v4 */
/* JADX WARN: Type inference failed for: r3v5 */
/* JADX WARN: Type inference failed for: r3v6, types: [D2.r] */
/* JADX WARN: Type inference failed for: r3v9 */
/*
Code decompiled incorrectly, please refer to instructions dump.
To view partially-correct code enable 'Show inconsistent code' option in preferences
*/
public final boolean x() throws java.lang.Throwable {
/*
Method dump skipped, instruction units count: 475
To view this dump change 'Code comments level' option to 'DEBUG'
*/
throw new UnsupportedOperationException("Method not decompiled: a3.d.x():boolean");
}
public final void y() {
synchronized (this) {
try {
if (this.f2891o) {
return;
}
a3.h hVar = this.f2881e;
if (hVar != null) {
int i3 = this.f2895s ? this.f2892p : -1;
this.f2892p++;
this.f2895s = true;
r2.r rVar = r2.r.f10584a;
if (i3 == -1) {
try {
hVar.q(l.f5638e);
return;
} catch (IOException e4) {
q(e4, null);
return;
}
}
q(new SocketTimeoutException("sent ping but didn't receive pong within " + this.f2899w + "ms (after " + (i3 - 1) + " successful ping/pongs)"), null);
}
} catch (Throwable th) {
throw th;
}
}
}
}
⚠️ 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