package defpackage; import java.util.concurrent.locks.ReentrantLock; /* renamed from: ˀˎᵛᵖ, reason: contains not printable characters */ /* loaded from: classes3.dex */ public final class C0543 { /* renamed from: ˇʼʤˎ, reason: contains not printable characters */ public boolean f2830; /* renamed from: ˎˏʜʾ, reason: contains not printable characters */ public final C2516 f2831; /* renamed from: ˏˋٴ, reason: contains not printable characters */ public final C3689[] f2832; /* renamed from: ˏᵙ, reason: contains not printable characters */ public final ReentrantLock f2833 = new ReentrantLock(); /* renamed from: ᵥᵯˎ, reason: contains not printable characters */ public final int f2834; /* renamed from: ᵴᵳ, reason: contains not printable characters */ public final InterfaceC4622 f2835; /* renamed from: ᵹᵝᵶ, reason: contains not printable characters */ public final C1326 f2836; /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */ public int f2837; public C0543(int i, InterfaceC4622 interfaceC4622) { this.f2834 = i; this.f2835 = interfaceC4622; this.f2832 = new C3689[i]; int i2 = AbstractC2232.f8758; this.f2831 = new C2516(i); this.f2836 = new C1326(i); } /* renamed from: ˏᵙ, reason: contains not printable characters */ public final void m2337(StringBuilder sb) { C1326 c1326 = this.f2836; ReentrantLock reentrantLock = this.f2833; reentrantLock.lock(); try { C3947 c3947 = ᵿᵧ.ˎˏʜʾ(); int iM4061 = c1326.m4061(); for (int i = 0; i < iM4061; i++) { if (i < 0 || i >= c1326.m4061()) { throw new ArrayIndexOutOfBoundsException(); } c3947.add(((Object[]) c1326.f5442)[(c1326.f5445 + i) & c1326.f5446]); } C3947 c39472 = ᵿᵧ.ˏᵙ(c3947); sb.append('\t' + toString() + " ("); sb.append("capacity=" + this.f2834 + ", "); StringBuilder sb2 = new StringBuilder(); sb2.append("permits="); C2516 c2516 = this.f2831; c2516.getClass(); sb2.append(Math.max(C1679.f6690.get(c2516), 0)); sb2.append(", "); sb.append(sb2.toString()); sb.append("queue=(size=" + c39472.mo1040() + ")[" + AbstractC2767.m6822(c39472, null, null, null, null, 63) + "], "); sb.append(")"); sb.append('\n'); C3689[] c3689Arr = this.f2832; int length = c3689Arr.length; int i2 = 0; for (int i3 = 0; i3 < length; i3++) { C3689 c3689 = c3689Arr[i3]; i2++; StringBuilder sb3 = new StringBuilder(); sb3.append("\t\t["); sb3.append(i2); sb3.append("] - "); sb3.append(c3689 != null ? c3689.f13732.toString() : null); sb.append(sb3.toString()); sb.append('\n'); if (c3689 != null) { c3689.m8281(sb); } } reentrantLock.unlock(); } catch (Throwable th) { reentrantLock.unlock(); throw th; } } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* renamed from: ᵥᵯˎ, reason: contains not printable characters */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object m2338(defpackage.AbstractC1989 r8) throws kotlinx.coroutines.DispatchException { /* r7 = this; boolean r0 = r8 instanceof defpackage.C4551 if (r0 == 0) goto L13 r0 = r8 ᵳˀٴﹳ r0 = (defpackage.C4551) r0 int r1 = r0.f16911 r2 = -2147483648(0xffffffff80000000, float:-0.0) r3 = r1 & r2 if (r3 == 0) goto L13 int r1 = r1 - r2 r0.f16911 = r1 goto L18 L13: ᵳˀٴﹳ r0 = new ᵳˀٴﹳ r0.(r7, r8) L18: java.lang.Object r8 = r0.f16913 int r1 = r0.f16911 r2 = 0 r3 = 1 if (r1 == 0) goto L2e if (r1 != r3) goto L28 ˀˎᵛᵖ r7 = r0.f16914 ʼٴ.ᵺᵠ(r8) goto L40 L28: java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine" ᵹˉᵞ.ᵳٴᵶ(r7) return r2 L2e: ʼٴ.ᵺᵠ(r8) r0.f16914 = r7 r0.f16911 = r3 ᵘᵕᵖ r8 = r7.f2831 java.lang.Object r8 = r8.m4812(r0) ᵣˊᵛ r0 = defpackage.EnumC3346.f12524 if (r8 != r0) goto L40 return r0 L40: java.util.concurrent.locks.ReentrantLock r8 = r7.f2833 // Catch: java.lang.Throwable -> L8c ˊᐧʛᵔ r0 = r7.f2836 // Catch: java.lang.Throwable -> L8c r8.lock() // Catch: java.lang.Throwable -> L8c boolean r1 = r7.f2830 // Catch: java.lang.Throwable -> L8e if (r1 != 0) goto L96 int r1 = r0.f5445 // Catch: java.lang.Throwable -> L8e int r4 = r0.f5443 // Catch: java.lang.Throwable -> L8e if (r1 != r4) goto L72 int r1 = r7.f2837 // Catch: java.lang.Throwable -> L8e int r4 = r7.f2834 // Catch: java.lang.Throwable -> L8e if (r1 < r4) goto L58 goto L72 L58: ᵧᵻ r1 = new ᵧᵻ // Catch: java.lang.Throwable -> L8e ᵴʘ r4 = r7.f2835 // Catch: java.lang.Throwable -> L8e java.lang.Object r4 = r4.mo1401() // Catch: java.lang.Throwable -> L8e ᵟᴵ r4 = (defpackage.InterfaceC3042) r4 // Catch: java.lang.Throwable -> L8e r1.(r4) // Catch: java.lang.Throwable -> L8e ᵧᵻ[] r4 = r7.f2832 // Catch: java.lang.Throwable -> L8e int r5 = r7.f2837 // Catch: java.lang.Throwable -> L8e int r6 = r5 + 1 r7.f2837 = r6 // Catch: java.lang.Throwable -> L8e r4[r5] = r1 // Catch: java.lang.Throwable -> L8e r0.m4079(r1) // Catch: java.lang.Throwable -> L8e L72: int r1 = r0.f5445 // Catch: java.lang.Throwable -> L8e int r4 = r0.f5443 // Catch: java.lang.Throwable -> L8e if (r1 == r4) goto L90 java.lang.Object r4 = r0.f5442 // Catch: java.lang.Throwable -> L8e java.lang.Object[] r4 = (java.lang.Object[]) r4 // Catch: java.lang.Throwable -> L8e r5 = r4[r1] // Catch: java.lang.Throwable -> L8e r4[r1] = r2 // Catch: java.lang.Throwable -> L8e int r1 = r1 + r3 int r2 = r0.f5446 // Catch: java.lang.Throwable -> L8e r1 = r1 & r2 r0.f5445 = r1 // Catch: java.lang.Throwable -> L8e ᵧᵻ r5 = (defpackage.C3689) r5 // Catch: java.lang.Throwable -> L8e r8.unlock() // Catch: java.lang.Throwable -> L8c return r5 L8c: r8 = move-exception goto La2 L8e: r0 = move-exception goto L9e L90: java.lang.ArrayIndexOutOfBoundsException r0 = new java.lang.ArrayIndexOutOfBoundsException // Catch: java.lang.Throwable -> L8e r0.() // Catch: java.lang.Throwable -> L8e throw r0 // Catch: java.lang.Throwable -> L8e L96: java.lang.String r0 = "Connection pool is closed" r1 = 21 ᵭʝʜ.ˑᵥˁ(r1, r0) // Catch: java.lang.Throwable -> L8e throw r2 // Catch: java.lang.Throwable -> L8e L9e: r8.unlock() // Catch: java.lang.Throwable -> L8c throw r0 // Catch: java.lang.Throwable -> L8c La2: ᵘᵕᵖ r7 = r7.f2831 r7.m4810() throw r8 */ throw new UnsupportedOperationException("Method not decompiled: defpackage.C0543.m2338(ːᵱ):java.lang.Object"); } /* renamed from: ᵴᵳ, reason: contains not printable characters */ public final void m2339() { ReentrantLock reentrantLock = this.f2833; reentrantLock.lock(); try { this.f2830 = true; for (C3689 c3689 : this.f2832) { if (c3689 != null) { c3689.close(); } } } finally { reentrantLock.unlock(); } } }