package defpackage; import androidx.media3.extractor.ts.PsExtractor; import defpackage.a21; import defpackage.dw7; import defpackage.kp3; import java.io.Serializable; import java.util.Iterator; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.coroutines.jvm.internal.SuspendLambda; /* JADX INFO: loaded from: classes3.dex */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "io.ktor.websocket.DefaultWebSocketSessionImpl$runIncomingProcessor$1", f = "DefaultWebSocketSession.kt", i = {0, 0, 0, 0, 0, 1, 1, 1, 3, 3, 3, 3, 3, 4, 4, 4, 4, 4, 5, 5, 5, 5, 5, 5, 6, 6, 6, 6, 6, 7, 7, 7, 7, 7}, l = {377, 183, 236, PsExtractor.PRIVATE_STREAM_1, 190, PsExtractor.AUDIO_STREAM, 207, 222, 236, 236, 236, 236}, m = "invokeSuspend", n = {"$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "frame", "$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv", "$this$launch", "firstFrame", "frameBody", "closeFramePresented", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$2", "L$3", "L$6", "L$0", "L$1", "L$2", "L$0", "L$1", "L$2", "L$3", "L$6", "L$0", "L$1", "L$2", "L$3", "L$6", "L$0", "L$1", "L$2", "L$3", "L$6", "L$8", "L$0", "L$1", "L$2", "L$3", "L$6", "L$0", "L$1", "L$2", "L$3", "L$6"}) @vx8 final class j22 extends SuspendLambda implements gr3, Object> { public Serializable a; public Object b; public dw7.a c; public g22 d; public hg8 e; public bv7 f; public lv0 i; public kp3 j; public int k; public /* synthetic */ Object l; public final /* synthetic */ g22 m; public final /* synthetic */ zg0 n; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public j22(g22 g22Var, zg0 zg0Var, Continuation continuation) { super(2, continuation); this.m = g22Var; this.n = zg0Var; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { j22 j22Var = new j22(this.m, this.n, continuation); j22Var.l = obj; return j22Var; } @Override // defpackage.gr3 public final Object invoke(Object obj, Object obj2) { return ((j22) create((ak1) obj, (Continuation) obj2)).invokeSuspend(e6a.a); } /* JADX WARN: Code restructure failed: missing block: B:106:0x032f, code lost: if (r5.s(r0, r24) == r3) goto L150; */ /* JADX WARN: Code restructure failed: missing block: B:163:0x0333, code lost: r6 = r12.a; defpackage.cr4.d(r6); defpackage.ym0.b((defpackage.nv8) r6, r0.c); r0 = r13; r13 = r7; r7 = r0; r0 = r12; r12 = r9; r9 = r10; r10 = r11; r11 = r0; r0 = r14; */ /* JADX WARN: Code restructure failed: missing block: B:164:0x029e, code lost: r0 = r7; r7 = r8; r8 = r9; r9 = r10; r10 = r11; r11 = r12; r12 = r13; r13 = r14; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:109:0x0337 A[Catch: all -> 0x01b7, o21 -> 0x0411, TRY_ENTER, TRY_LEAVE, TryCatch #7 {o21 -> 0x0411, all -> 0x01b7, blocks: (B:53:0x0177, B:109:0x0337, B:122:0x037d, B:123:0x0380, B:30:0x00d1), top: B:162:0x00d1 }] */ /* JADX WARN: Removed duplicated region for block: B:150:0x0450 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:35:0x00fd */ /* JADX WARN: Removed duplicated region for block: B:38:0x0110 A[Catch: all -> 0x0044, TryCatch #0 {all -> 0x0044, blocks: (B:11:0x003f, B:36:0x0108, B:38:0x0110, B:40:0x011e, B:41:0x013a, B:43:0x013e, B:45:0x0146, B:47:0x0152, B:48:0x0154, B:51:0x0173, B:65:0x01bb, B:67:0x01bf, B:69:0x01c5, B:72:0x01e0, B:74:0x01e4, B:77:0x01ff, B:24:0x009a, B:27:0x00b5), top: B:152:0x000c }] */ /* JADX WARN: Removed duplicated region for block: B:56:0x0185 */ /* JADX WARN: Removed duplicated region for block: B:59:0x0193 */ /* JADX WARN: Removed duplicated region for block: B:83:0x0230 A[Catch: all -> 0x007c, TryCatch #5 {all -> 0x007c, blocks: (B:81:0x022c, B:83:0x0230, B:85:0x0234, B:86:0x0236, B:88:0x023a, B:89:0x0241, B:90:0x0258, B:92:0x025c, B:93:0x0264, B:95:0x026a, B:96:0x0278, B:101:0x02ab, B:102:0x0303, B:104:0x0309, B:105:0x0314, B:17:0x0077), top: B:158:0x0077 }] */ /* JADX WARN: Removed duplicated region for block: B:90:0x0258 A[Catch: all -> 0x007c, TryCatch #5 {all -> 0x007c, blocks: (B:81:0x022c, B:83:0x0230, B:85:0x0234, B:86:0x0236, B:88:0x023a, B:89:0x0241, B:90:0x0258, B:92:0x025c, B:93:0x0264, B:95:0x026a, B:96:0x0278, B:101:0x02ab, B:102:0x0303, B:104:0x0309, B:105:0x0314, B:17:0x0077), top: B:158:0x0077 }] */ /* JADX WARN: Type inference failed for: r0v64, types: [zg0] */ /* JADX WARN: Type inference failed for: r0v68, types: [zg0] */ /* JADX WARN: Type inference failed for: r23v0 */ /* JADX WARN: Type inference failed for: r6v23, types: [bv7, dw7$a, g22, hg8, java.io.Serializable, java.lang.Object, java.lang.Throwable, java.util.concurrent.CancellationException, lv0] */ /* JADX WARN: Type inference failed for: r6v43 */ /* JADX WARN: Type inference failed for: r6v44 */ /* JADX WARN: Type inference failed for: r7v1, types: [bv7] */ /* JADX WARN: Type inference failed for: r7v12 */ /* JADX WARN: Type inference failed for: r7v13 */ /* JADX WARN: Type inference failed for: r7v15 */ /* JADX WARN: Type inference failed for: r7v16 */ /* JADX WARN: Type inference failed for: r7v19, types: [bv7] */ /* JADX WARN: Type inference failed for: r7v21, types: [bv7, java.lang.Object] */ /* JADX WARN: Type inference failed for: r7v25 */ /* JADX WARN: Type inference failed for: r7v27 */ /* JADX WARN: Type inference failed for: r7v29 */ /* JADX WARN: Type inference failed for: r7v31 */ /* JADX WARN: Type inference failed for: r7v32 */ /* JADX WARN: Type inference failed for: r7v33 */ /* JADX WARN: Type inference failed for: r7v34 */ /* JADX WARN: Type inference failed for: r7v35 */ /* JADX WARN: Type inference failed for: r7v36 */ /* JADX WARN: Type inference failed for: r7v37 */ /* JADX WARN: Type inference failed for: r8v12 */ /* JADX WARN: Type inference failed for: r8v13, types: [bv7] */ /* JADX WARN: Type inference failed for: r8v15 */ /* JADX WARN: Type inference failed for: r8v17 */ /* JADX WARN: Type inference failed for: r8v2, types: [bv7] */ /* JADX WARN: Type inference failed for: r8v20 */ /* JADX WARN: Type inference failed for: r8v21 */ /* JADX WARN: Type inference failed for: r8v22 */ /* JADX WARN: Type inference failed for: r8v4, types: [bv7] */ /* JADX WARN: Type inference failed for: r8v6 */ /* JADX WARN: Type inference failed for: r8v7 */ /* JADX WARN: Type inference failed for: r8v8, types: [bv7] */ /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:68:0x01c3 -> B:100:0x029e). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:70:0x01dc -> B:100:0x029e). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:75:0x01fb -> B:100:0x029e). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object invokeSuspend(Object obj) throws Throwable { Throwable th; ?? r7; ak1 ak1Var; dw7.h hVar; dw7.h hVar2; dw7.a aVar; ?? P; g22 g22Var; hg8 hg8Var; lv0 it; lv0 lv0Var; hg8 hg8Var2; dw7.h hVar3; ak1 ak1Var2; Object objB; kp3 kp3VarC; lv0 lv0Var2; ?? r8; hg8 hg8Var3; g22 g22Var2; dw7.a aVar2; dw7.h hVar4; dw7.h hVar5; ak1 ak1Var3; ?? r72; ?? r73; nv8 nv8Var; e6a e6aVar = e6a.a; ck1 ck1Var = ck1.a; int i = 1; kp3 kp3Var = null; ?? r6 = 0; try { switch (this.k) { case 0: s38.b(obj); ak1Var = (ak1) this.l; hVar = new dw7.h(); hVar2 = new dw7.h(); aVar = new dw7.a(); try { P = this.m.a.p(); g22Var = this.m; hg8Var = this.n; try { it = P.iterator(); P = P; this.l = ak1Var; this.a = hVar; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var; this.f = P; this.i = it; this.j = kp3Var; this.k = i; objB = it.b(this); break; } catch (Throwable th2) { th = th2; r7 = P; try { throw th; } catch (Throwable th3) { yv0.a(r7, th); throw th3; } } } catch (o21 unused) { this.n.r(null); nv8 nv8Var2 = (nv8) hVar2.a; if (nv8Var2 != null) { nv8Var2.close(); } this.m.c.r(null); if (!aVar.a) { g22 g22Var3 = this.m; a21 a21Var = new a21(a21.a.e, "Connection was closed without close frame"); this.l = null; this.a = null; this.b = null; this.c = null; this.d = null; this.e = null; this.f = null; this.i = null; this.j = null; this.k = 10; if (noa.a(g22Var3, a21Var, this) == ck1Var) { return ck1Var; } } } catch (Throwable th4) { try { this.n.r(null); this.m.c.m(th4, false); this.n.r(null); nv8 nv8Var3 = (nv8) hVar2.a; if (nv8Var3 != null) { nv8Var3.close(); } this.m.c.r(null); if (!aVar.a) { g22 g22Var4 = this.m; a21 a21Var2 = new a21(a21.a.e, "Connection was closed without close frame"); this.l = null; this.a = null; this.b = null; this.c = null; this.d = null; this.e = null; this.f = null; this.i = null; this.j = null; this.k = 11; if (noa.a(g22Var4, a21Var2, this) == ck1Var) { } } } catch (Throwable th5) { this.n.r(null); nv8 nv8Var4 = (nv8) hVar2.a; if (nv8Var4 != null) { nv8Var4.close(); } this.m.c.r(null); if (aVar.a) { throw th5; } g22 g22Var5 = this.m; a21 a21Var3 = new a21(a21.a.e, "Connection was closed without close frame"); this.l = th5; this.a = null; this.b = null; this.c = null; this.d = null; this.e = null; this.f = null; this.i = null; this.j = null; this.k = 12; if (noa.a(g22Var5, a21Var3, this) != ck1Var) { throw th5; } } } if (objB != ck1Var) { lv0 lv0Var3 = it; ak1Var2 = ak1Var; lv0Var = lv0Var3; hg8 hg8Var4 = hg8Var; hVar3 = hVar; r72 = P; hg8Var2 = hg8Var4; r6 = kp3Var; if (((Boolean) objB).booleanValue()) { r72.h(r6); this.n.r(r6); nv8 nv8Var5 = (nv8) hVar2.a; if (nv8Var5 != null) { nv8Var5.close(); } this.m.c.r(r6); if (!aVar.a) { g22 g22Var6 = this.m; a21 a21Var4 = new a21(a21.a.e, "Connection was closed without close frame"); this.l = r6; this.a = r6; this.b = r6; this.c = r6; this.d = r6; this.e = r6; this.f = r6; this.i = r6; this.k = 9; if (noa.a(g22Var6, a21Var4, this) == ck1Var) { } } return e6aVar; } kp3 kp3Var2 = (kp3) lv0Var.next(); jh5 jh5Var = n22.a; if (rh5.a(jh5Var)) { jh5Var.h("WebSocketSession(" + ak1Var2 + ") receiving frame " + kp3Var2); } if (kp3Var2 instanceof kp3.b) { r73 = r72; if (!g22Var.d.t()) { zg0 zg0Var = g22Var.d; a21 a21VarA = lp3.a((kp3.b) kp3Var2); if (a21VarA == null) { a21VarA = n22.d; } kp3.b bVar = new kp3.b(a21VarA); this.l = hVar2; this.a = aVar; this.b = r72; this.c = null; this.d = null; this.e = null; this.f = null; this.i = null; this.k = 2; r73 = r72; if (zg0Var.s(bVar, this) == ck1Var) { } } aVar.a = true; r73.h(null); this.n.r(null); nv8Var = (nv8) hVar2.a; if (nv8Var != null) { nv8Var.close(); } this.m.c.r(null); if (!aVar.a) { g22 g22Var7 = this.m; a21 a21Var5 = new a21(a21.a.e, "Connection was closed without close frame"); this.l = e6aVar; this.a = null; this.b = null; this.c = null; this.d = null; this.e = null; this.f = null; this.i = null; this.k = 3; if (noa.a(g22Var7, a21Var5, this) == ck1Var) { } } return e6aVar; } if (kp3Var2 instanceof kp3.e) { hg8 hg8Var5 = (hg8) g22Var.pinger; if (hg8Var5 != null) { this.l = ak1Var2; this.a = hVar3; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var2; this.f = r72; this.i = lv0Var; this.k = 4; if (hg8Var5.s(kp3Var2, this) == ck1Var) { } } ak1 ak1Var4 = ak1Var2; it = lv0Var; ak1Var = ak1Var4; hg8 hg8Var6 = hg8Var2; r8 = r72; hVar = hVar3; hg8Var = hg8Var6; } else if (kp3Var2 instanceof kp3.d) { this.l = ak1Var2; this.a = hVar3; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var2; this.f = r72; this.i = lv0Var; this.k = 5; if (hg8Var2.s(kp3Var2, this) == ck1Var) { } ak1 ak1Var42 = ak1Var2; it = lv0Var; ak1Var = ak1Var42; hg8 hg8Var62 = hg8Var2; r8 = r72; hVar = hVar3; hg8Var = hg8Var62; } else { nv8 nv8Var6 = (nv8) hVar2.a; this.l = ak1Var2; this.a = hVar3; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var2; this.f = r72; this.i = lv0Var; this.j = kp3Var2; this.k = 6; if (g22.c(g22Var, nv8Var6, kp3Var2, this) != ck1Var) { ?? r23 = r72; lv0Var2 = lv0Var; kp3VarC = kp3Var2; ak1Var3 = ak1Var2; hVar5 = hVar3; hVar4 = hVar2; aVar2 = aVar; g22Var2 = g22Var; hg8Var3 = hg8Var2; r8 = r23; if (!kp3VarC.a) { if (hVar5.a == null) { hVar5.a = kp3VarC; } if (hVar4.a == null) { hVar4.a = new mg0(); Object obj2 = hVar4.a; cr4.d(obj2); ym0.b((nv8) obj2, kp3VarC.c); dw7.h hVar6 = hVar5; it = lv0Var2; hVar = hVar6; dw7.h hVar7 = hVar4; hg8Var = hg8Var3; g22Var = g22Var2; aVar = aVar2; hVar2 = hVar7; ak1Var = ak1Var3; } else { Object obj22 = hVar4.a; cr4.d(obj22); ym0.b((nv8) obj22, kp3VarC.c); dw7.h hVar62 = hVar5; it = lv0Var2; hVar = hVar62; dw7.h hVar72 = hVar4; hg8Var = hg8Var3; g22Var = g22Var2; aVar = aVar2; hVar2 = hVar72; ak1Var = ak1Var3; } } else if (hVar5.a != null) { Object obj3 = hVar4.a; cr4.d(obj3); ym0.b((nv8) obj3, kp3VarC.c); Object obj4 = hVar5.a; cr4.d(obj4); pp3 pp3Var = ((kp3) obj4).b; Object obj5 = hVar4.a; cr4.d(obj5); byte[] bArrA = qy8.a(((nv8) obj5).getC()); Object obj6 = hVar5.a; cr4.d(obj6); boolean z = ((kp3) obj6).e; Object obj7 = hVar5.a; cr4.d(obj7); boolean z2 = ((kp3) obj7).f; Object obj8 = hVar5.a; cr4.d(obj8); kp3 kp3VarA = kp3.c.a(true, pp3Var, bArrA, z, z2, ((kp3) obj8).g); hVar5.a = null; zg0 zg0Var2 = g22Var2.c; Iterator it2 = g22Var2.f.iterator(); while (it2.hasNext()) { kp3VarA = ((zna) it2.next()).c(kp3VarA); } this.l = ak1Var3; this.a = hVar5; this.b = hVar4; this.c = aVar2; this.d = g22Var2; this.e = hg8Var3; this.f = r8; this.i = lv0Var2; this.j = null; this.k = 8; break; } else { zg0 zg0Var3 = g22Var2.c; Iterator it3 = g22Var2.f.iterator(); while (it3.hasNext()) { kp3VarC = ((zna) it3.next()).c(kp3VarC); } this.l = ak1Var3; this.a = hVar5; this.b = hVar4; this.c = aVar2; this.d = g22Var2; this.e = hg8Var3; this.f = r8; this.i = lv0Var2; this.j = null; this.k = 7; if (zg0Var3.s(kp3VarC, this) != ck1Var) { lv0Var = lv0Var2; r72 = r8; hg8Var2 = hg8Var3; g22Var = g22Var2; aVar = aVar2; hVar2 = hVar4; hVar3 = hVar5; ak1Var2 = ak1Var3; ak1 ak1Var422 = ak1Var2; it = lv0Var; ak1Var = ak1Var422; hg8 hg8Var622 = hg8Var2; r8 = r72; hVar = hVar3; hg8Var = hg8Var622; } } } } i = 1; kp3Var = null; P = r8; this.l = ak1Var; this.a = hVar; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var; this.f = P; this.i = it; this.j = kp3Var; this.k = i; objB = it.b(this); if (objB != ck1Var) { } } return ck1Var; case 1: lv0Var = this.i; bv7 bv7Var = this.f; hg8Var2 = this.e; g22Var = this.d; aVar = this.c; hVar2 = (dw7.h) this.b; hVar3 = (dw7.h) this.a; ak1Var2 = (ak1) this.l; s38.b(obj); objB = obj; r72 = bv7Var; if (((Boolean) objB).booleanValue()) { } return ck1Var; case 2: bv7 bv7Var2 = (bv7) this.b; aVar = (dw7.a) this.a; hVar2 = (dw7.h) this.l; s38.b(obj); r73 = bv7Var2; aVar.a = true; r73.h(null); this.n.r(null); nv8Var = (nv8) hVar2.a; if (nv8Var != null) { } this.m.c.r(null); if (!aVar.a) { } return e6aVar; case 3: e6a e6aVar2 = (e6a) this.l; s38.b(obj); return e6aVar2; case 4: case 5: case 8: lv0Var = this.i; bv7 bv7Var3 = this.f; hg8Var2 = this.e; g22Var = this.d; aVar = this.c; hVar2 = (dw7.h) this.b; hVar3 = (dw7.h) this.a; ak1Var2 = (ak1) this.l; r72 = bv7Var3; s38.b(obj); ak1 ak1Var4222 = ak1Var2; it = lv0Var; ak1Var = ak1Var4222; hg8 hg8Var6222 = hg8Var2; r8 = r72; hVar = hVar3; hg8Var = hg8Var6222; i = 1; kp3Var = null; P = r8; this.l = ak1Var; this.a = hVar; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var; this.f = P; this.i = it; this.j = kp3Var; this.k = i; objB = it.b(this); if (objB != ck1Var) { } return ck1Var; case 6: kp3VarC = this.j; lv0Var2 = this.i; r8 = this.f; hg8Var3 = this.e; g22Var2 = this.d; aVar2 = this.c; hVar4 = (dw7.h) this.b; hVar5 = (dw7.h) this.a; ak1Var3 = (ak1) this.l; try { s38.b(obj); r8 = r8; if (!kp3VarC.a) { } } catch (Throwable th6) { th = th6; r7 = r8; throw th; } break; case 7: lv0Var = this.i; bv7 bv7Var4 = this.f; hg8Var2 = this.e; g22Var = this.d; aVar = this.c; hVar2 = (dw7.h) this.b; hVar3 = (dw7.h) this.a; ak1Var2 = (ak1) this.l; r72 = bv7Var4; s38.b(obj); ak1 ak1Var42222 = ak1Var2; it = lv0Var; ak1Var = ak1Var42222; hg8 hg8Var62222 = hg8Var2; r8 = r72; hVar = hVar3; hg8Var = hg8Var62222; i = 1; kp3Var = null; P = r8; this.l = ak1Var; this.a = hVar; this.b = hVar2; this.c = aVar; this.d = g22Var; this.e = hg8Var; this.f = P; this.i = it; this.j = kp3Var; this.k = i; objB = it.b(this); if (objB != ck1Var) { } return ck1Var; case 9: s38.b(obj); return e6aVar; case 10: case 11: s38.b(obj); return e6aVar; case 12: Throwable th7 = (Throwable) this.l; s38.b(obj); throw th7; default: throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } } catch (Throwable th8) { th = th8; r7 = r73; } } }