package defpackage;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import androidx.media3.extractor.ts.PsExtractor;
import androidx.media3.extractor.ts.TsExtractor;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@DebugMetadata(c = "io.ktor.websocket.RawWebSocketCommonKt", f = "RawWebSocketCommon.kt", i = {0, 0, 0, 0, 1, 1, 1, 1, 1, 2, 2, 2, 3, 3, 3, 4, 4, 4}, l = {178, TsExtractor.TS_PACKET_SIZE, 191, PsExtractor.AUDIO_STREAM, 200, 206}, m = "writeFrame", n = {"$this$writeFrame", "frame", "masking", SessionDescription.ATTR_LENGTH, "$this$writeFrame", "frame", "masking", SessionDescription.ATTR_LENGTH, "formattedLength", "$this$writeFrame", "frame", "masking", "$this$writeFrame", "frame", "masking", "$this$writeFrame", "data", "maskKey"}, s = {"L$0", "L$1", "Z$0", "I$0", "L$0", "L$1", "Z$0", "I$0", "I$1", "L$0", "L$1", "Z$0", "L$0", "L$1", "Z$0", "L$0", "L$1", "I$0"})
final class dt7 extends ContinuationImpl {
    public gp0 a;
    public Object b;
    public int c;
    public int d;
    public /* synthetic */ Object e;
    public int f;

    /* JADX WARN: Code restructure failed: missing block: B:35:0x00d6, code lost:
    
        if (r0 == r1) goto L48;
     */
    /* JADX WARN: Code restructure failed: missing block: B:37:0x00d9, code lost:
    
        r2 = r11;
        r3 = r12;
     */
    /* JADX WARN: Code restructure failed: missing block: B:43:0x00f4, code lost:
    
        if (r0 == r1) goto L48;
     */
    /* JADX WARN: Removed duplicated region for block: B:29:0x00ba  */
    /* JADX WARN: Removed duplicated region for block: B:39:0x00de  */
    /* JADX WARN: Removed duplicated region for block: B:48:0x0110 A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:49:0x0111 A[RETURN] */
    @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object invokeSuspend(Object obj) {
        dt7 dt7Var;
        kp3 kp3Var;
        gp0 gp0Var;
        int i;
        int i2;
        gp0 gp0Var2;
        mg0 mg0Var;
        this.e = obj;
        int i3 = this.f | Integer.MIN_VALUE;
        this.f = i3;
        if ((i3 & Integer.MIN_VALUE) != 0) {
            this.f = i3 - Integer.MIN_VALUE;
            dt7Var = this;
        } else {
            dt7Var = new dt7(this);
        }
        Object obj2 = dt7Var.e;
        ck1 ck1Var = ck1.a;
        int i4 = dt7Var.f;
        e6a e6aVar = e6a.a;
        switch (i4) {
            case 0:
                s38.b(obj2);
                throw null;
            case 1:
                int i5 = dt7Var.c;
                kp3Var = (kp3) dt7Var.b;
                gp0Var = dt7Var.a;
                s38.b(obj2);
                int i6 = i5 < 126 ? i5 : i5 <= 65535 ? 126 : 127;
                dt7Var.a = gp0Var;
                dt7Var.b = kp3Var;
                dt7Var.c = i5;
                dt7Var.d = i6;
                dt7Var.f = 2;
                if (kp0.b(gp0Var, (byte) i6, dt7Var) != ck1Var) {
                    i = i5;
                    i2 = i6;
                    if (i2 != 126) {
                        dt7Var.a = gp0Var;
                        dt7Var.b = kp3Var;
                        dt7Var.f = 3;
                        gp0Var.f().bd((short) i);
                        Object objA = ip0.a(gp0Var, dt7Var);
                        if (objA != ck1Var) {
                            objA = e6aVar;
                        }
                    } else if (i2 == 127) {
                        dt7Var.a = gp0Var;
                        dt7Var.b = kp3Var;
                        dt7Var.f = 4;
                        gp0Var.f().writeLong(i);
                        Object objA2 = ip0.a(gp0Var, dt7Var);
                        if (objA2 != ck1.a) {
                            objA2 = e6aVar;
                        }
                    } else {
                        gp0Var2 = gp0Var;
                        byte[] bArr = kp3Var.c;
                        int length = bArr.length;
                        mg0 mg0Var2 = new mg0();
                        mg0Var2.write(bArr, 0, length);
                        mg0Var = mg0Var2;
                        dt7Var.a = null;
                        dt7Var.b = null;
                        dt7Var.f = 6;
                        if (kp0.e(gp0Var2, mg0Var, dt7Var) != ck1Var) {
                            return e6aVar;
                        }
                    }
                    kp3Var = kp3Var;
                    gp0Var2 = gp0Var;
                    byte[] bArr2 = kp3Var.c;
                    int length2 = bArr2.length;
                    mg0 mg0Var22 = new mg0();
                    mg0Var22.write(bArr2, 0, length2);
                    mg0Var = mg0Var22;
                    dt7Var.a = null;
                    dt7Var.b = null;
                    dt7Var.f = 6;
                    if (kp0.e(gp0Var2, mg0Var, dt7Var) != ck1Var) {
                    }
                    break;
                }
                return ck1Var;
            case 2:
                i2 = dt7Var.d;
                i = dt7Var.c;
                kp3Var = (kp3) dt7Var.b;
                gp0Var = dt7Var.a;
                s38.b(obj2);
                if (i2 != 126) {
                }
                kp3Var = kp3Var;
                gp0Var2 = gp0Var;
                byte[] bArr22 = kp3Var.c;
                int length22 = bArr22.length;
                mg0 mg0Var222 = new mg0();
                mg0Var222.write(bArr22, 0, length22);
                mg0Var = mg0Var222;
                dt7Var.a = null;
                dt7Var.b = null;
                dt7Var.f = 6;
                if (kp0.e(gp0Var2, mg0Var, dt7Var) != ck1Var) {
                    return ck1Var;
                }
                break;
            case 3:
            case 4:
                kp3 kp3Var2 = (kp3) dt7Var.b;
                gp0 gp0Var3 = dt7Var.a;
                s38.b(obj2);
                kp3Var = kp3Var2;
                gp0Var2 = gp0Var3;
                byte[] bArr222 = kp3Var.c;
                int length222 = bArr222.length;
                mg0 mg0Var2222 = new mg0();
                mg0Var2222.write(bArr222, 0, length222);
                mg0Var = mg0Var2222;
                dt7Var.a = null;
                dt7Var.b = null;
                dt7Var.f = 6;
                if (kp0.e(gp0Var2, mg0Var, dt7Var) != ck1Var) {
                }
                break;
            case 5:
                int i7 = dt7Var.c;
                qx8 qx8Var = (qx8) dt7Var.b;
                gp0Var2 = dt7Var.a;
                s38.b(obj2);
                byte[] bArr3 = {(byte) (i7 >> 24), (byte) (i7 >> 16), (byte) (i7 >> 8), (byte) i7};
                mg0Var = new mg0();
                int iB = (int) oo0.b(qx8Var);
                for (int i8 = 0; i8 < iB; i8++) {
                    mg0Var.bk((byte) (qx8Var.readByte() ^ bArr3[i8 % 4]));
                }
                dt7Var.a = null;
                dt7Var.b = null;
                dt7Var.f = 6;
                if (kp0.e(gp0Var2, mg0Var, dt7Var) != ck1Var) {
                }
                break;
            case 6:
                s38.b(obj2);
                return e6aVar;
            default:
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
    }
}