package n4; import C0.C0109j; import F.f0; import I0.C0311u; import I2.C0334s; import I2.K; import I2.O; import a.AbstractC0872a; import androidx.recyclerview.widget.i0; import com.revenuecat.purchases.common.Constants; import java.io.EOFException; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.IDN; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; import java.net.URI; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.EnumMap; import java.util.HashMap; import java.util.IdentityHashMap; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.LinkedList; import java.util.Locale; import java.util.Map; import java.util.Random; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.logging.Level; import java.util.logging.Logger; import javax.net.SocketFactory; import javax.net.ssl.SSLSocketFactory; import k4.AbstractC2400m; import k4.C2385D; import k4.C2388a; import k4.C2389b; import k4.C2394g; import k4.J; import k4.g0; import k4.h0; import k4.r0; import k4.s0; import m4.A0; import m4.AbstractC2504f0; import m4.B; import m4.C2498d0; import m4.C2519k0; import m4.C2522l0; import m4.C2563z0; import m4.EnumC2550v; import m4.InterfaceC2547u; import m4.RunnableC2516j0; import m4.Z0; import m4.Z1; import m4.c2; import m4.g2; import m4.i2; import m4.k2; import p4.C2730i; import p4.EnumC2722a; import p5.AbstractC2732b; import p5.C2735e; import p5.C2740j; import p5.C2743m; import p5.I; import q4.C2860a; /* JADX INFO: loaded from: classes3.dex */ public final class n implements B { /* JADX INFO: renamed from: P, reason: collision with root package name */ public static final Map f21706P; /* JADX INFO: renamed from: Q, reason: collision with root package name */ public static final Logger f21707Q; /* JADX INFO: renamed from: A, reason: collision with root package name */ public final SocketFactory f21708A; /* JADX INFO: renamed from: B, reason: collision with root package name */ public final SSLSocketFactory f21709B; /* JADX INFO: renamed from: C, reason: collision with root package name */ public int f21710C; /* JADX INFO: renamed from: D, reason: collision with root package name */ public final LinkedList f21711D; /* JADX INFO: renamed from: E, reason: collision with root package name */ public final o4.c f21712E; /* JADX INFO: renamed from: F, reason: collision with root package name */ public A0 f21713F; /* JADX INFO: renamed from: G, reason: collision with root package name */ public boolean f21714G; /* JADX INFO: renamed from: H, reason: collision with root package name */ public long f21715H; /* JADX INFO: renamed from: I, reason: collision with root package name */ public long f21716I; /* JADX INFO: renamed from: J, reason: collision with root package name */ public final K f21717J; /* JADX INFO: renamed from: K, reason: collision with root package name */ public final int f21718K; /* JADX INFO: renamed from: L, reason: collision with root package name */ public final k2 f21719L; /* JADX INFO: renamed from: M, reason: collision with root package name */ public final C2522l0 f21720M; /* JADX INFO: renamed from: N, reason: collision with root package name */ public final C2385D f21721N; /* JADX INFO: renamed from: O, reason: collision with root package name */ public final int f21722O; /* JADX INFO: renamed from: a, reason: collision with root package name */ public final InetSocketAddress f21723a; /* JADX INFO: renamed from: b, reason: collision with root package name */ public final String f21724b; /* JADX INFO: renamed from: c, reason: collision with root package name */ public final String f21725c; /* JADX INFO: renamed from: d, reason: collision with root package name */ public final Random f21726d; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final C2498d0 f21727e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public final int f21728f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public final p4.j f21729g; /* JADX INFO: renamed from: h, reason: collision with root package name */ public C0109j f21730h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public C2626d f21731i; /* JADX INFO: renamed from: j, reason: collision with root package name */ public O f21732j; /* JADX INFO: renamed from: k, reason: collision with root package name */ public final Object f21733k; public final J l; /* JADX INFO: renamed from: m, reason: collision with root package name */ public int f21734m; /* JADX INFO: renamed from: n, reason: collision with root package name */ public final HashMap f21735n; /* JADX INFO: renamed from: o, reason: collision with root package name */ public final Executor f21736o; /* JADX INFO: renamed from: p, reason: collision with root package name */ public final Z1 f21737p; /* JADX INFO: renamed from: q, reason: collision with root package name */ public final ScheduledExecutorService f21738q; /* JADX INFO: renamed from: r, reason: collision with root package name */ public final int f21739r; /* JADX INFO: renamed from: s, reason: collision with root package name */ public int f21740s; /* JADX INFO: renamed from: t, reason: collision with root package name */ public m f21741t; /* JADX INFO: renamed from: u, reason: collision with root package name */ public C2389b f21742u; /* JADX INFO: renamed from: v, reason: collision with root package name */ public r0 f21743v; /* JADX INFO: renamed from: w, reason: collision with root package name */ public boolean f21744w; /* JADX INFO: renamed from: x, reason: collision with root package name */ public C2519k0 f21745x; /* JADX INFO: renamed from: y, reason: collision with root package name */ public boolean f21746y; /* JADX INFO: renamed from: z, reason: collision with root package name */ public boolean f21747z; static { EnumMap enumMap = new EnumMap(EnumC2722a.class); EnumC2722a enumC2722a = EnumC2722a.NO_ERROR; r0 r0Var = r0.f19945m; enumMap.put(enumC2722a, r0Var.g("No error: A GRPC status of OK should have been sent")); enumMap.put(EnumC2722a.PROTOCOL_ERROR, r0Var.g("Protocol error")); enumMap.put(EnumC2722a.INTERNAL_ERROR, r0Var.g("Internal error")); enumMap.put(EnumC2722a.FLOW_CONTROL_ERROR, r0Var.g("Flow control error")); enumMap.put(EnumC2722a.STREAM_CLOSED, r0Var.g("Stream closed")); enumMap.put(EnumC2722a.FRAME_TOO_LARGE, r0Var.g("Frame too large")); enumMap.put(EnumC2722a.REFUSED_STREAM, r0.f19946n.g("Refused stream")); enumMap.put(EnumC2722a.CANCEL, r0.f19939f.g("Cancelled")); enumMap.put(EnumC2722a.COMPRESSION_ERROR, r0Var.g("Compression error")); enumMap.put(EnumC2722a.CONNECT_ERROR, r0Var.g("Connect error")); enumMap.put(EnumC2722a.ENHANCE_YOUR_CALM, r0.f19944k.g("Enhance your calm")); enumMap.put(EnumC2722a.INADEQUATE_SECURITY, r0.f19942i.g("Inadequate security")); f21706P = Collections.unmodifiableMap(enumMap); f21707Q = Logger.getLogger(n.class.getName()); } public n(g gVar, InetSocketAddress inetSocketAddress, String str, C2389b c2389b, C2385D c2385d, K k6) { C2498d0 c2498d0 = AbstractC2504f0.f21011r; p4.j jVar = new p4.j(); this.f21726d = new Random(); Object obj = new Object(); this.f21733k = obj; this.f21735n = new HashMap(); this.f21710C = 0; this.f21711D = new LinkedList(); this.f21720M = new C2522l0(this, 2); this.f21722O = 30000; A4.g.o(inetSocketAddress, "address"); this.f21723a = inetSocketAddress; this.f21724b = str; this.f21739r = gVar.f21657k; this.f21728f = gVar.f21660o; Executor executor = gVar.f21651b; A4.g.o(executor, "executor"); this.f21736o = executor; this.f21737p = new Z1(gVar.f21651b); ScheduledExecutorService scheduledExecutorService = gVar.f21653d; A4.g.o(scheduledExecutorService, "scheduledExecutorService"); this.f21738q = scheduledExecutorService; this.f21734m = 3; this.f21708A = SocketFactory.getDefault(); this.f21709B = gVar.f21655f; o4.c cVar = gVar.f21656j; A4.g.o(cVar, "connectionSpec"); this.f21712E = cVar; A4.g.o(c2498d0, "stopwatchFactory"); this.f21727e = c2498d0; this.f21729g = jVar; this.f21725c = "grpc-java-okhttp/1.62.2"; this.f21721N = c2385d; this.f21717J = k6; this.f21718K = gVar.f21661p; gVar.f21654e.getClass(); this.f21719L = new k2(); this.l = J.a(n.class, inetSocketAddress.toString()); C2389b c2389b2 = C2389b.f19841b; C2388a c2388a = c2.f20975b; IdentityHashMap identityHashMap = new IdentityHashMap(1); identityHashMap.put(c2388a, c2389b); for (Map.Entry entry : c2389b2.f19842a.entrySet()) { if (!identityHashMap.containsKey(entry.getKey())) { identityHashMap.put((C2388a) entry.getKey(), entry.getValue()); } } this.f21742u = new C2389b(identityHashMap); synchronized (obj) { } } public static void g(n nVar, String str) { EnumC2722a enumC2722a = EnumC2722a.PROTOCOL_ERROR; nVar.getClass(); nVar.s(0, enumC2722a, w(enumC2722a).a(str)); } public static Socket h(n nVar, InetSocketAddress inetSocketAddress, InetSocketAddress inetSocketAddress2, String str, String str2) throws s0 { nVar.getClass(); Socket socket = null; try { InetAddress address = inetSocketAddress2.getAddress(); SocketFactory socketFactory = nVar.f21708A; Socket socketCreateSocket = address != null ? socketFactory.createSocket(inetSocketAddress2.getAddress(), inetSocketAddress2.getPort()) : socketFactory.createSocket(inetSocketAddress2.getHostName(), inetSocketAddress2.getPort()); try { socketCreateSocket.setTcpNoDelay(true); socketCreateSocket.setSoTimeout(nVar.f21722O); C2735e c2735eL = AbstractC2732b.l(socketCreateSocket); I iB = AbstractC2732b.b(AbstractC2732b.i(socketCreateSocket)); i0 i0VarI = nVar.i(inetSocketAddress, str, str2); l2.c cVar = (l2.c) i0VarI.f13106c; C2860a c2860a = (C2860a) i0VarI.f13105b; Locale locale = Locale.US; iB.n("CONNECT " + c2860a.f23729a + Constants.SUBS_ID_BASE_PLAN_ID_SEPARATOR + c2860a.f23730b + " HTTP/1.1"); iB.n("\r\n"); int length = ((String[]) cVar.f20267b).length / 2; for (int i6 = 0; i6 < length; i6++) { int i7 = i6 * 2; String[] strArr = (String[]) cVar.f20267b; iB.n((i7 < 0 || i7 >= strArr.length) ? null : strArr[i7]); iB.n(": "); int i8 = i7 + 1; iB.n((i8 < 0 || i8 >= strArr.length) ? null : strArr[i8]); iB.n("\r\n"); } iB.n("\r\n"); iB.flush(); f0 f0VarI = f0.i(q(c2735eL)); while (!q(c2735eL).equals("")) { } int i9 = f0VarI.f1279b; if (i9 >= 200 && i9 < 300) { socketCreateSocket.setSoTimeout(0); return socketCreateSocket; } C2740j c2740j = new C2740j(); try { socketCreateSocket.shutdownOutput(); c2735eL.read(c2740j, 1024L); } catch (IOException e6) { c2740j.W("Unable to read body: " + e6.toString()); } try { socketCreateSocket.close(); } catch (IOException unused) { } Locale locale2 = Locale.US; throw new s0(r0.f19946n.g("Response returned from proxy was not successful (expected 2xx, got " + i9 + " " + ((String) f0VarI.f1281d) + "). Response body:\n" + c2740j.H())); } catch (IOException e7) { e = e7; socket = socketCreateSocket; if (socket != null) { AbstractC2504f0.b(socket); } throw new s0(r0.f19946n.g("Failed trying to connect with proxy").f(e)); } } catch (IOException e8) { e = e8; } } public static String q(C2735e c2735e) throws EOFException { C2740j c2740j = new C2740j(); while (c2735e.read(c2740j, 1L) != -1) { if (c2740j.f(c2740j.f23100b - 1) == 10) { return c2740j.I(Long.MAX_VALUE); } } throw new EOFException("\\n not found: " + c2740j.A(c2740j.f23100b).e()); } public static r0 w(EnumC2722a enumC2722a) { r0 r0Var = (r0) f21706P.get(enumC2722a); if (r0Var != null) { return r0Var; } return r0.f19940g.g("Unknown http2 error code: " + enumC2722a.f22993a); } @Override // m4.InterfaceC2490a1 public final void a(r0 r0Var) { d(r0Var); synchronized (this.f21733k) { try { Iterator it = this.f21735n.entrySet().iterator(); while (it.hasNext()) { Map.Entry entry = (Map.Entry) it.next(); it.remove(); ((k) entry.getValue()).f21698n.g(r0Var, false, new g0()); o((k) entry.getValue()); } for (k kVar : this.f21711D) { kVar.f21698n.f(r0Var, EnumC2550v.f21204d, true, new g0()); o(kVar); } this.f21711D.clear(); v(); } catch (Throwable th) { throw th; } } } @Override // m4.B public final C2389b b() { return this.f21742u; } @Override // m4.InterfaceC2556x public final InterfaceC2547u c(k4.i0 i0Var, g0 g0Var, C2394g c2394g, AbstractC2400m[] abstractC2400mArr) { k kVar; A4.g.o(i0Var, "method"); A4.g.o(g0Var, "headers"); C2389b c2389b = this.f21742u; g2 g2Var = new g2(abstractC2400mArr); for (AbstractC2400m abstractC2400m : abstractC2400mArr) { abstractC2400m.n(c2389b, g0Var); } synchronized (this.f21733k) { kVar = new k(i0Var, g0Var, this.f21731i, this, this.f21732j, this.f21733k, this.f21739r, this.f21728f, this.f21724b, this.f21725c, g2Var, this.f21719L, c2394g); } return kVar; } @Override // m4.InterfaceC2490a1 public final void d(r0 r0Var) { synchronized (this.f21733k) { try { if (this.f21743v != null) { return; } this.f21743v = r0Var; this.f21730h.h(r0Var); v(); } catch (Throwable th) { throw th; } } } @Override // k4.I public final J e() { return this.l; } @Override // m4.InterfaceC2490a1 public final Runnable f(Z0 z02) { this.f21730h = (C0109j) z02; if (this.f21714G) { A0 a02 = new A0(new l2.c(this, 3), this.f21738q, this.f21715H, this.f21716I); this.f21713F = a02; synchronized (a02) { } } C2625c c2625c = new C2625c(this.f21737p, this); p4.j jVar = this.f21729g; I iB = AbstractC2732b.b(c2625c); jVar.getClass(); C2624b c2624b = new C2624b(c2625c, new C2730i(iB)); synchronized (this.f21733k) { C2626d c2626d = new C2626d(this, c2624b); this.f21731i = c2626d; this.f21732j = new O(this, c2626d); } CountDownLatch countDownLatch = new CountDownLatch(1); this.f21737p.execute(new C1.o(this, countDownLatch, c2625c, 10)); try { r(); countDownLatch.countDown(); this.f21737p.execute(new K(this, 18)); return null; } catch (Throwable th) { countDownLatch.countDown(); throw th; } } /* JADX WARN: Removed duplicated region for block: B:108:0x019a A[EDGE_INSN: B:108:0x019a->B:160:0x0244 BREAK A[LOOP:9: B:147:0x0221->B:158:0x0240]] */ /* JADX WARN: Removed duplicated region for block: B:109:0x019d */ /* JADX WARN: Removed duplicated region for block: B:19:0x005e */ /* JADX WARN: Removed duplicated region for block: B:203:0x012d A[ADDED_TO_REGION, EDGE_INSN: B:203:0x012d->B:83:0x012d BREAK A[LOOP:2: B:28:0x0091->B:98:0x015f], REMOVE, SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:226:0x012d A[EDGE_INSN: B:226:0x012d->B:83:0x012d BREAK A[LOOP:7: B:52:0x00d2->B:80:0x011a], SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:232:0x0113 A[SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:64:0x00ec */ /* JADX WARN: Removed duplicated region for block: B:80:0x011a A[LOOP:7: B:52:0x00d2->B:80:0x011a, LOOP_END] */ /* JADX WARN: Removed duplicated region for block: B:88:0x013e */ /* JADX WARN: Removed duplicated region for block: B:95:0x015b */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final i0 i(InetSocketAddress inetSocketAddress, String str, String str2) { String strSubstring; String strH; int i6; int i7; InetAddress byAddress; int i8; int i9; int i10; int i11; int i12; int i13; f0 f0Var = new f0(6); f0Var.f1279b = -1; f0Var.f1280c = "https"; String hostName = inetSocketAddress.getHostName(); if (hostName == null) { throw new IllegalArgumentException("host == null"); } int length = hostName.length(); int i14 = 0; int iCharCount = 0; while (true) { if (iCharCount >= length) { strSubstring = hostName.substring(0, length); break; } if (hostName.charAt(iCharCount) != '%') { iCharCount++; } else { C2740j c2740j = new C2740j(); c2740j.V(0, iCharCount, hostName); while (iCharCount < length) { int iCodePointAt = hostName.codePointAt(iCharCount); if (iCodePointAt != 37 || (i13 = iCharCount + 2) >= length) { c2740j.X(iCodePointAt); } else { int iA = C2860a.a(hostName.charAt(iCharCount + 1)); int iA2 = C2860a.a(hostName.charAt(i13)); if (iA != -1 && iA2 != -1) { c2740j.Q((iA << 4) + iA2); iCharCount = i13; } } iCharCount += Character.charCount(iCodePointAt); } strSubstring = c2740j.H(); } } if (!strSubstring.startsWith("[") || !strSubstring.endsWith("]")) { try { String lowerCase = IDN.toASCII(strSubstring).toLowerCase(Locale.US); if (!lowerCase.isEmpty()) { for (int i15 = 0; i15 < lowerCase.length(); i15++) { char cCharAt = lowerCase.charAt(i15); if (cCharAt > 31 && cCharAt < 127 && " #%/:?@[\\]".indexOf(cCharAt) == -1) { } } strH = lowerCase; } } catch (IllegalArgumentException unused) { } strH = null; break; } int length2 = strSubstring.length() - 1; int i16 = 16; byte[] bArr = new byte[16]; int i17 = -1; int i18 = -1; int i19 = 0; int i20 = 1; while (i20 < length2) { if (i19 != i16) { int i21 = i20 + 2; char c6 = 2; if (i21 > length2 || !strSubstring.regionMatches(i20, "::", i14, 2)) { if (i19 == 0) { i11 = i20; int i22 = 0; while (i11 < length2) { } i12 = i11 - i20; if (i12 != 0) { break; } break; break; } if (strSubstring.regionMatches(i20, Constants.SUBS_ID_BASE_PLAN_ID_SEPARATOR, i14, 1)) { i20++; i11 = i20; int i222 = 0; while (i11 < length2) { int iA3 = C2860a.a(strSubstring.charAt(i11)); char c7 = c6; if (iA3 == -1) { break; } i222 = (i222 << 4) + iA3; i11++; c6 = c7; } i12 = i11 - i20; if (i12 != 0 || i12 > 4) { break; } int i23 = i19 + 1; bArr[i19] = (byte) (255 & (i222 >>> 8)); i19 += 2; bArr[i23] = (byte) (i222 & 255); i18 = i20; i16 = 16; i20 = i11; i14 = 0; } else if (strSubstring.regionMatches(i20, ".", i14, 1)) { int i24 = i19 - 2; int i25 = i24; int i26 = i18; loop7: while (true) { if (i26 >= length2) { int i27 = i17; if (i25 == i19 + 2) { i19 += 2; i17 = i27; } } else { if (i25 == 16) { break; } if (i25 == i24) { i8 = i26; int i28 = 0; while (true) { i9 = i24; if (i8 < length2) { i10 = i17; break; } char cCharAt2 = strSubstring.charAt(i8); i10 = i17; if (cCharAt2 < '0' || cCharAt2 > '9') { break; } if ((i28 == 0 && i26 != i8) || ((i28 * 10) + cCharAt2) - 48 > 255) { break loop7; } i8++; i24 = i9; i17 = i10; } if (i8 - i26 != 0) { break; } bArr[i25] = (byte) i28; i25++; i26 = i8; i24 = i9; i17 = i10; } else { if (strSubstring.charAt(i26) != '.') { break; } i26++; i8 = i26; int i282 = 0; while (true) { i9 = i24; if (i8 < length2) { } i8++; i24 = i9; i17 = i10; } if (i8 - i26 != 0) { } } } } } } else if (i17 == -1) { i19 += 2; if (i21 == length2) { i17 = i19; i6 = 16; break; } i20 = i21; i17 = i19; i11 = i20; int i2222 = 0; while (i11 < length2) { } i12 = i11 - i20; if (i12 != 0) { } } } i7 = i14; break; } i6 = i16; try { if (i19 != i6) { if (i17 != -1) { int i29 = i19 - i17; System.arraycopy(bArr, i17, bArr, 16 - i29, i29); i7 = 0; Arrays.fill(bArr, i17, (16 - i19) + i17, (byte) 0); } i7 = 0; byAddress = null; if (byAddress != null) { strH = null; break; } byte[] address = byAddress.getAddress(); int i30 = 16; if (address.length != 16) { throw new AssertionError(); } int i31 = i7; int i32 = i31; int i33 = -1; while (i31 < address.length) { int i34 = i31; while (i34 < i30 && address[i34] == 0 && address[i34 + 1] == 0) { i34 += 2; i30 = 16; } int i35 = i34 - i31; if (i35 > i32) { i33 = i31; i32 = i35; } i31 = i34 + 2; i30 = 16; } C2740j c2740j2 = new C2740j(); while (i7 < address.length) { if (i7 == i33) { c2740j2.Q(58); i7 += i32; if (i7 == 16) { c2740j2.Q(58); } } else { if (i7 > 0) { c2740j2.Q(58); } c2740j2.S(((address[i7] & 255) << 8) | (address[i7 + 1] & 255)); i7 += 2; } } strH = c2740j2.H(); } else { i7 = 0; } byAddress = InetAddress.getByAddress(bArr); if (byAddress != null) { } } catch (UnknownHostException unused2) { throw new AssertionError(); } if (strH == null) { throw new IllegalArgumentException("unexpected host: ".concat(hostName)); } f0Var.f1281d = strH; int port = inetSocketAddress.getPort(); if (port <= 0 || port > 65535) { throw new IllegalArgumentException(Z0.o.l("unexpected port: ", port)); } f0Var.f1279b = port; if (((String) f0Var.f1281d) == null) { throw new IllegalStateException("host == null"); } C2860a c2860a = new C2860a(f0Var); i0 i0Var = new i0(11); i0Var.f13106c = new C0334s(4, (byte) 0); i0Var.f13105b = c2860a; i0Var.g("Host", c2860a.f23729a + Constants.SUBS_ID_BASE_PLAN_ID_SEPARATOR + c2860a.f23730b); i0Var.g("User-Agent", this.f21725c); if (str != null && str2 != null) { try { i0Var.g("Proxy-Authorization", "Basic " + C2743m.l((str + Constants.SUBS_ID_BASE_PLAN_ID_SEPARATOR + str2).getBytes("ISO-8859-1")).a()); } catch (UnsupportedEncodingException unused3) { throw new AssertionError(); } } if (((C2860a) i0Var.f13105b) != null) { return new i0(i0Var); } throw new IllegalStateException("url == null"); } public final void j(int i6, r0 r0Var, EnumC2550v enumC2550v, boolean z6, EnumC2722a enumC2722a, g0 g0Var) { synchronized (this.f21733k) { try { k kVar = (k) this.f21735n.remove(Integer.valueOf(i6)); if (kVar != null) { if (enumC2722a != null) { this.f21731i.d(i6, EnumC2722a.CANCEL); } if (r0Var != null) { j jVar = kVar.f21698n; if (g0Var == null) { g0Var = new g0(); } jVar.f(r0Var, enumC2550v, z6, g0Var); } if (!t()) { v(); o(kVar); } } } catch (Throwable th) { throw th; } } } public final w[] k() { w[] wVarArr; w wVar; synchronized (this.f21733k) { wVarArr = new w[this.f21735n.size()]; Iterator it = this.f21735n.values().iterator(); int i6 = 0; while (it.hasNext()) { int i7 = i6 + 1; j jVar = ((k) it.next()).f21698n; synchronized (jVar.f21690w) { wVar = jVar.f21686J; } wVarArr[i6] = wVar; i6 = i7; } } return wVarArr; } public final int l() { URI uriA = AbstractC2504f0.a(this.f21724b); return uriA.getPort() != -1 ? uriA.getPort() : this.f21723a.getPort(); } public final s0 m() { synchronized (this.f21733k) { r0 r0Var = this.f21743v; if (r0Var != null) { return new s0(r0Var); } return new s0(r0.f19946n.g("Connection closed")); } } /* JADX WARN: Removed duplicated region for block: B:9:0x000c */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final boolean n(int i6) { boolean z6; synchronized (this.f21733k) { if (i6 < this.f21734m) { z6 = true; if ((i6 & 1) != 1) { z6 = false; } } } return z6; } public final void o(k kVar) { if (this.f21747z && this.f21711D.isEmpty() && this.f21735n.isEmpty()) { this.f21747z = false; A0 a02 = this.f21713F; if (a02 != null) { synchronized (a02) { int i6 = a02.f20559d; if (i6 == 2 || i6 == 3) { a02.f20559d = 1; } if (a02.f20559d == 4) { a02.f20559d = 5; } } } } if (kVar.f20946e) { this.f21720M.l(kVar, false); } } public final void p(Exception exc) { s(0, EnumC2722a.INTERNAL_ERROR, r0.f19946n.f(exc)); } public final void r() { synchronized (this.f21733k) { try { C2626d c2626d = this.f21731i; c2626d.getClass(); try { c2626d.f21641b.b(); } catch (IOException e6) { c2626d.f21640a.p(e6); } C0311u c0311u = new C0311u(); c0311u.e(7, this.f21728f); C2626d c2626d2 = this.f21731i; c2626d2.f21642c.n(2, c0311u); try { c2626d2.f21641b.g(c0311u); } catch (IOException e7) { c2626d2.f21640a.p(e7); } if (this.f21728f > 65535) { this.f21731i.f(0, r1 - 65535); } } catch (Throwable th) { throw th; } } } public final void s(int i6, EnumC2722a enumC2722a, r0 r0Var) { synchronized (this.f21733k) { try { if (this.f21743v == null) { this.f21743v = r0Var; this.f21730h.h(r0Var); } if (enumC2722a != null && !this.f21744w) { this.f21744w = true; this.f21731i.b(enumC2722a, new byte[0]); } Iterator it = this.f21735n.entrySet().iterator(); while (it.hasNext()) { Map.Entry entry = (Map.Entry) it.next(); if (((Integer) entry.getKey()).intValue() > i6) { it.remove(); ((k) entry.getValue()).f21698n.f(r0Var, EnumC2550v.f21202b, false, new g0()); o((k) entry.getValue()); } } for (k kVar : this.f21711D) { kVar.f21698n.f(r0Var, EnumC2550v.f21204d, true, new g0()); o(kVar); } this.f21711D.clear(); v(); } catch (Throwable th) { throw th; } } } public final boolean t() { boolean z6 = false; while (true) { LinkedList linkedList = this.f21711D; if (linkedList.isEmpty() || this.f21735n.size() >= this.f21710C) { break; } u((k) linkedList.poll()); z6 = true; } return z6; } public final String toString() { E3.j jVarI0 = AbstractC0872a.i0(this); jVarI0.b("logId", this.l.f19809c); jVarI0.a(this.f21723a, "address"); return jVarI0.toString(); } public final void u(k kVar) { boolean zE; A4.g.t(kVar.f21698n.f21687K == -1, "StreamId already assigned"); this.f21735n.put(Integer.valueOf(this.f21734m), kVar); if (!this.f21747z) { this.f21747z = true; A0 a02 = this.f21713F; if (a02 != null) { a02.b(); } } if (kVar.f20946e) { this.f21720M.l(kVar, true); } j jVar = kVar.f21698n; int i6 = this.f21734m; if (!(jVar.f21687K == -1)) { throw new IllegalStateException(L4.a.X("the stream has been started with id %s", Integer.valueOf(i6))); } jVar.f21687K = i6; O o6 = jVar.f21682F; jVar.f21686J = new w(o6, i6, o6.f2523a, jVar); j jVar2 = jVar.f21688L.f21698n; A4.g.s(jVar2.f20934j != null); synchronized (jVar2.f20926b) { A4.g.t(!jVar2.f20930f, "Already allocated"); jVar2.f20930f = true; } synchronized (jVar2.f20926b) { zE = jVar2.e(); } if (zE) { jVar2.f20934j.d(); } k2 k2Var = jVar2.f20927c; k2Var.getClass(); ((i2) k2Var.f21087b).e(); if (jVar.f21684H) { C2626d c2626d = jVar.f21681E; boolean z6 = jVar.f21688L.f21701q; int i7 = jVar.f21687K; ArrayList arrayList = jVar.f21691x; c2626d.getClass(); try { C2730i c2730i = c2626d.f21641b.f21625a; synchronized (c2730i) { if (c2730i.f23034e) { throw new IOException("closed"); } c2730i.b(z6, i7, arrayList); } } catch (IOException e6) { c2626d.f21640a.p(e6); } for (AbstractC2400m abstractC2400m : jVar.f21688L.l.f21042a) { abstractC2400m.h(); } jVar.f21691x = null; C2740j c2740j = jVar.f21692y; if (c2740j.f23100b > 0) { jVar.f21682F.a(jVar.f21693z, jVar.f21686J, c2740j, jVar.f21677A); } jVar.f21684H = false; } h0 h0Var = kVar.f21695j.f19878a; if ((h0Var != h0.f19874a && h0Var != h0.f19875b) || kVar.f21701q) { this.f21731i.flush(); } int i8 = this.f21734m; if (i8 < 2147483645) { this.f21734m = i8 + 2; } else { this.f21734m = Integer.MAX_VALUE; s(Integer.MAX_VALUE, EnumC2722a.NO_ERROR, r0.f19946n.g("Stream ids exhausted")); } } public final void v() { if (this.f21743v == null || !this.f21735n.isEmpty() || !this.f21711D.isEmpty() || this.f21746y) { return; } this.f21746y = true; A0 a02 = this.f21713F; if (a02 != null) { synchronized (a02) { try { if (a02.f20559d != 6) { a02.f20559d = 6; ScheduledFuture scheduledFuture = a02.f20560e; if (scheduledFuture != null) { scheduledFuture.cancel(false); } ScheduledFuture scheduledFuture2 = a02.f20561f; if (scheduledFuture2 != null) { scheduledFuture2.cancel(false); a02.f20561f = null; } } } finally { } } } C2519k0 c2519k0 = this.f21745x; if (c2519k0 != null) { s0 s0VarM = m(); synchronized (c2519k0) { try { if (!c2519k0.f21080d) { c2519k0.f21080d = true; c2519k0.f21081e = s0VarM; LinkedHashMap linkedHashMap = c2519k0.f21079c; c2519k0.f21079c = null; for (Map.Entry entry : linkedHashMap.entrySet()) { try { ((Executor) entry.getValue()).execute(new RunnableC2516j0((C2563z0) entry.getKey(), s0VarM)); } catch (Throwable th) { C2519k0.f21076g.log(Level.SEVERE, "Failed to execute PingCallback", th); } } } } finally { } } this.f21745x = null; } if (!this.f21744w) { this.f21744w = true; this.f21731i.b(EnumC2722a.NO_ERROR, new byte[0]); } this.f21731i.close(); } }