package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.dw7;
import java.io.EOFException;
import java.io.Serializable;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u0002\n\u0000¨\u0006\u0000"}, d2 = {"ktor-io"}, k = 2, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class go0 {
    /* JADX WARN: Code restructure failed: missing block: B:27:0x006c, code lost:
    
        if (defpackage.swa.a(r0) == r1) goto L28;
     */
    /* JADX WARN: Removed duplicated region for block: B:20:0x004a  */
    /* JADX WARN: Removed duplicated region for block: B:26:0x0062  */
    /* JADX WARN: Removed duplicated region for block: B:29:0x006f  */
    /* JADX WARN: Removed duplicated region for block: B:32:0x0078  */
    /* JADX WARN: Removed duplicated region for block: B:34:0x007b  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:27:0x006c -> B:13:0x002d). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object a(bn0 bn0Var, int i, ContinuationImpl continuationImpl) throws EOFException {
        dn0 dn0Var;
        bn0 bn0Var2;
        int i2;
        if (continuationImpl instanceof dn0) {
            dn0Var = (dn0) continuationImpl;
            int i3 = dn0Var.d;
            if ((i3 & Integer.MIN_VALUE) != 0) {
                dn0Var.d = i3 - Integer.MIN_VALUE;
            } else {
                dn0Var = new dn0(continuationImpl);
            }
        }
        Object objH = dn0Var.c;
        ck1 ck1Var = ck1.a;
        int i4 = dn0Var.d;
        if (i4 == 0) {
            s38.b(objH);
            if (d(bn0Var) < i) {
            }
            if (d(bn0Var) < i) {
            }
        } else {
            if (i4 != 1) {
                if (i4 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                i2 = dn0Var.b;
                bn0Var2 = dn0Var.a;
                s38.b(objH);
                bn0 bn0Var3 = bn0Var2;
                i = i2;
                bn0Var = bn0Var3;
                if (d(bn0Var) < i) {
                    dn0Var.a = bn0Var;
                    dn0Var.b = i;
                    dn0Var.d = 1;
                    objH = bn0Var.h(i, dn0Var);
                    if (objH != ck1Var) {
                        int i5 = i;
                        bn0Var2 = bn0Var;
                        i2 = i5;
                        if (((Boolean) objH).booleanValue()) {
                            bn0 bn0Var4 = bn0Var2;
                            i = i2;
                            bn0Var = bn0Var4;
                        } else {
                            dn0Var.a = bn0Var2;
                            dn0Var.b = i2;
                            dn0Var.d = 2;
                        }
                    }
                    return ck1Var;
                }
                if (d(bn0Var) < i) {
                    return e6a.a;
                }
                throw new EOFException("Not enough data available");
            }
            i2 = dn0Var.b;
            bn0Var2 = dn0Var.a;
            s38.b(objH);
            if (((Boolean) objH).booleanValue()) {
            }
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:34:0x009d, code lost:
    
        if (r1.h(r7, r13) == r2) goto L54;
     */
    /* JADX WARN: Code restructure failed: missing block: B:40:0x00d2, code lost:
    
        if (r0 != r2) goto L20;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:46:0x00e8  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /* JADX WARN: Type inference failed for: r3v0, types: [int] */
    /* JADX WARN: Type inference failed for: r3v1 */
    /* JADX WARN: Type inference failed for: r3v10 */
    /* JADX WARN: Type inference failed for: r3v11 */
    /* JADX WARN: Type inference failed for: r3v12 */
    /* JADX WARN: Type inference failed for: r3v13 */
    /* JADX WARN: Type inference failed for: r3v2, types: [gp0] */
    /* JADX WARN: Type inference failed for: r3v3 */
    /* JADX WARN: Type inference failed for: r3v4, types: [gp0] */
    /* JADX WARN: Type inference failed for: r3v5, types: [gp0] */
    /* JADX WARN: Type inference failed for: r3v6 */
    /* JADX WARN: Type inference failed for: r3v9 */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:40:0x00d2 -> B:20:0x0056). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object b(bn0 bn0Var, gp0 gp0Var, long j, ContinuationImpl continuationImpl) throws Throwable {
        gn0 gn0Var;
        bn0 bn0Var2;
        long j2;
        long j3;
        gn0 gn0Var2;
        bn0 bn0Var3;
        long j4;
        long j5;
        ?? r3;
        if (continuationImpl instanceof gn0) {
            gn0Var = (gn0) continuationImpl;
            int i = gn0Var.f;
            if ((i & Integer.MIN_VALUE) != 0) {
                gn0Var.f = i - Integer.MIN_VALUE;
            } else {
                gn0Var = new gn0(continuationImpl);
            }
        }
        Object obj = gn0Var.e;
        ck1 ck1Var = ck1.a;
        ?? r32 = gn0Var.f;
        int i2 = 1;
        try {
            if (r32 == 0) {
                s38.b(obj);
                r32 = gp0Var;
                j2 = j;
                j3 = j2;
                gn0Var2 = gn0Var;
                bn0Var3 = bn0Var;
                if (bn0Var3.i()) {
                }
                gn0Var2.a = null;
                gn0Var2.b = null;
                gn0Var2.c = j3;
                gn0Var2.d = j2;
                gn0Var2.f = 3;
                if (r32.b(gn0Var2) != ck1Var) {
                }
                return ck1Var;
            }
            if (r32 == 1) {
                j2 = gn0Var.d;
                j3 = gn0Var.c;
                gp0 gp0Var2 = gn0Var.b;
                bn0Var2 = (bn0) gn0Var.a;
                s38.b(obj);
                r32 = gp0Var2;
                long jMin = Math.min(j2, oo0.b(bn0Var2.g()));
                bn0Var2.g().br(r32.f(), jMin);
                j2 -= jMin;
                gn0Var.a = bn0Var2;
                gn0Var.b = r32;
                gn0Var.c = j3;
                gn0Var.d = j2;
                gn0Var.f = 2;
                Object objB = r32.b(gn0Var);
                r3 = r32;
            } else {
                if (r32 != 2) {
                    if (r32 == 3) {
                        j4 = gn0Var.d;
                        j5 = gn0Var.c;
                        s38.b(obj);
                        return Boxing.boxLong(j5 - j4);
                    }
                    if (r32 != 4) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    Throwable th = (Throwable) gn0Var.a;
                    s38.b(obj);
                    throw th;
                }
                j2 = gn0Var.d;
                j3 = gn0Var.c;
                gp0 gp0Var3 = gn0Var.b;
                bn0Var2 = (bn0) gn0Var.a;
                s38.b(obj);
                r3 = gp0Var3;
                try {
                    bn0 bn0Var4 = bn0Var2;
                    gn0Var2 = gn0Var;
                    bn0Var3 = bn0Var4;
                    if (!bn0Var3.i() || j2 <= 0) {
                        gn0Var2.a = null;
                        gn0Var2.b = null;
                        gn0Var2.c = j3;
                        gn0Var2.d = j2;
                        gn0Var2.f = 3;
                        if (r32.b(gn0Var2) != ck1Var) {
                            j4 = j2;
                            j5 = j3;
                            return Boxing.boxLong(j5 - j4);
                        }
                    } else {
                        if (bn0Var3.g().j()) {
                            gn0Var2.a = bn0Var3;
                            gn0Var2.b = r32;
                            gn0Var2.c = j3;
                            gn0Var2.d = j2;
                            gn0Var2.f = i2;
                        }
                        gn0 gn0Var3 = gn0Var2;
                        bn0Var2 = bn0Var3;
                        gn0Var = gn0Var3;
                        r32 = r32;
                        long jMin2 = Math.min(j2, oo0.b(bn0Var2.g()));
                        bn0Var2.g().br(r32.f(), jMin2);
                        j2 -= jMin2;
                        gn0Var.a = bn0Var2;
                        gn0Var.b = r32;
                        gn0Var.c = j3;
                        gn0Var.d = j2;
                        gn0Var.f = 2;
                        Object objB2 = r32.b(gn0Var);
                        r3 = r32;
                    }
                    return ck1Var;
                } catch (Throwable th2) {
                    th = th2;
                    gn0 gn0Var4 = gn0Var2;
                    bn0Var2 = bn0Var3;
                    gn0Var = gn0Var4;
                    try {
                        bn0Var2.c(th);
                        kp0.a(r32, th);
                        throw th;
                    } catch (Throwable th3) {
                        gn0Var.a = th3;
                        gn0Var.b = null;
                        gn0Var.f = 4;
                        if (r32.b(gn0Var) != ck1Var) {
                            throw th3;
                        }
                    }
                }
                i2 = 1;
                r32 = r3;
            }
        } catch (Throwable th4) {
            th = th4;
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x003f  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:20:0x0049 -> B:26:0x0060). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005a -> B:25:0x005d). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object c(bn0 bn0Var, long j, ContinuationImpl continuationImpl) throws EOFException {
        hn0 hn0Var;
        long j2;
        if (continuationImpl instanceof hn0) {
            hn0Var = (hn0) continuationImpl;
            int i = hn0Var.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                hn0Var.e = i - Integer.MIN_VALUE;
            } else {
                hn0Var = new hn0(continuationImpl);
            }
        }
        Object obj = hn0Var.d;
        ck1 ck1Var = ck1.a;
        int i2 = hn0Var.e;
        if (i2 == 0) {
            s38.b(obj);
            j2 = j;
            if (j > 0) {
            }
            return Boxing.boxLong(j2 - j);
        }
        if (i2 != 1) {
            throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
        long j3 = hn0Var.c;
        j2 = hn0Var.b;
        bn0 bn0Var2 = hn0Var.a;
        s38.b(obj);
        long j4 = j3;
        bn0Var = bn0Var2;
        j = j4;
        long jMin = Math.min(j, oo0.b(bn0Var.g()));
        oo0.a(bn0Var.g(), jMin);
        j -= jMin;
        if (j > 0 || bn0Var.i()) {
            return Boxing.boxLong(j2 - j);
        }
        if (d(bn0Var) == 0) {
            hn0Var.a = bn0Var;
            hn0Var.b = j2;
            hn0Var.c = j;
            hn0Var.e = 1;
            if (bn0Var.h(1, hn0Var) == ck1Var) {
                return ck1Var;
            }
            bn0Var2 = bn0Var;
            j3 = j;
            long j42 = j3;
            bn0Var = bn0Var2;
            j = j42;
        }
        long jMin2 = Math.min(j, oo0.b(bn0Var.g()));
        oo0.a(bn0Var.g(), jMin2);
        j -= jMin2;
        if (j > 0) {
        }
        return Boxing.boxLong(j2 - j);
    }

    public static final int d(bn0 bn0Var) {
        cr4.g(bn0Var, "<this>");
        return (int) bn0Var.g().getC().c;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object e(bn0 bn0Var, byte[] bArr, int i, ContinuationImpl continuationImpl) {
        mn0 mn0Var;
        if (continuationImpl instanceof mn0) {
            mn0Var = (mn0) continuationImpl;
            int i2 = mn0Var.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                mn0Var.e = i2 - Integer.MIN_VALUE;
            } else {
                mn0Var = new mn0(continuationImpl);
            }
        }
        Object obj = mn0Var.d;
        ck1 ck1Var = ck1.a;
        int i3 = mn0Var.e;
        if (i3 == 0) {
            s38.b(obj);
            if (bn0Var.i()) {
                return Boxing.boxInt(-1);
            }
            if (bn0Var.g().j()) {
                mn0Var.a = bn0Var;
                mn0Var.b = bArr;
                mn0Var.c = i;
                mn0Var.e = 1;
                if (bn0Var.h(1, mn0Var) == ck1Var) {
                    return ck1Var;
                }
            }
        } else {
            if (i3 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i = mn0Var.c;
            bArr = mn0Var.b;
            bn0Var = mn0Var.a;
            s38.b(obj);
        }
        if (bn0Var.i()) {
            return Boxing.boxInt(-1);
        }
        qx8 qx8VarG = bn0Var.g();
        cr4.g(qx8VarG, "<this>");
        cr4.g(bArr, "buffer");
        int iBh = qx8VarG.bh(bArr, 0, i);
        return Boxing.boxInt(iBh != -1 ? iBh : 0);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object f(bn0 bn0Var, ContinuationImpl continuationImpl) throws Throwable {
        nn0 nn0Var;
        mg0 mg0Var;
        if (continuationImpl instanceof nn0) {
            nn0Var = (nn0) continuationImpl;
            int i = nn0Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                nn0Var.d = i - Integer.MIN_VALUE;
            } else {
                nn0Var = new nn0(continuationImpl);
            }
        }
        Object obj = nn0Var.c;
        ck1 ck1Var = ck1.a;
        int i2 = nn0Var.d;
        if (i2 == 0) {
            s38.b(obj);
            mg0Var = new mg0();
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            mg0 mg0Var2 = nn0Var.b;
            bn0 bn0Var2 = nn0Var.a;
            s38.b(obj);
            mg0Var = mg0Var2;
            bn0Var = bn0Var2;
        }
        while (!bn0Var.i()) {
            mg0Var.ai(bn0Var.g());
            nn0Var.a = bn0Var;
            nn0Var.b = mg0Var;
            nn0Var.d = 1;
            if (bn0Var.h(1, nn0Var) == ck1Var) {
                return ck1Var;
            }
        }
        Throwable thA = bn0Var.a();
        if (thA == null) {
            return mg0Var;
        }
        throw thA;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object g(bn0 bn0Var, ContinuationImpl continuationImpl) throws EOFException {
        pn0 pn0Var;
        if (continuationImpl instanceof pn0) {
            pn0Var = (pn0) continuationImpl;
            int i = pn0Var.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                pn0Var.c = i - Integer.MIN_VALUE;
            } else {
                pn0Var = new pn0(continuationImpl);
            }
        }
        Object obj = pn0Var.b;
        ck1 ck1Var = ck1.a;
        int i2 = pn0Var.c;
        if (i2 == 0) {
            s38.b(obj);
            if (bn0Var.g().j()) {
                pn0Var.a = bn0Var;
                pn0Var.c = 1;
                if (bn0Var.h(1, pn0Var) == ck1Var) {
                    return ck1Var;
                }
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            bn0Var = pn0Var.a;
            s38.b(obj);
        }
        if (bn0Var.g().j()) {
            throw new EOFException("Not enough data available");
        }
        return Boxing.boxByte(bn0Var.g().readByte());
    }

    /* JADX WARN: Removed duplicated region for block: B:18:0x004a  */
    /* JADX WARN: Removed duplicated region for block: B:27:0x006f  */
    /* JADX WARN: Removed duplicated region for block: B:28:0x0088  */
    /* JADX WARN: Removed duplicated region for block: B:30:0x008e  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:19:0x0052 -> B:25:0x0069). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:23:0x0065 -> B:24:0x0067). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object h(bn0 bn0Var, byte[] bArr, int i, ContinuationImpl continuationImpl) throws EOFException {
        rn0 rn0Var;
        bn0 bn0Var2;
        int i2;
        int i3;
        byte[] bArr2;
        if (continuationImpl instanceof rn0) {
            rn0Var = (rn0) continuationImpl;
            int i4 = rn0Var.f;
            if ((i4 & Integer.MIN_VALUE) != 0) {
                rn0Var.f = i4 - Integer.MIN_VALUE;
            } else {
                rn0Var = new rn0(continuationImpl);
            }
        }
        Object obj = rn0Var.e;
        ck1 ck1Var = ck1.a;
        int i5 = rn0Var.f;
        if (i5 == 0) {
            s38.b(obj);
            if (bn0Var.i()) {
                throw new EOFException("Channel is already closed");
            }
            bn0Var2 = bn0Var;
            i2 = 0;
            i3 = i;
            bArr2 = bArr;
            if (i2 >= i3) {
            }
        } else {
            if (i5 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            i2 = rn0Var.d;
            int i6 = rn0Var.c;
            bArr2 = rn0Var.b;
            bn0 bn0Var3 = rn0Var.a;
            s38.b(obj);
            i3 = i6;
            bn0Var2 = bn0Var3;
            if (bn0Var2.i()) {
                int iMin = Math.min(i3 - i2, (int) oo0.b(bn0Var2.g())) + i2;
                qy8.d(bn0Var2.g(), bArr2, i2, iMin);
                i2 = iMin;
                if (i2 >= i3) {
                    return e6a.a;
                }
                if (bn0Var2.g().j()) {
                    rn0Var.a = bn0Var2;
                    rn0Var.b = bArr2;
                    rn0Var.c = i3;
                    rn0Var.d = i2;
                    rn0Var.f = 1;
                    if (bn0Var2.h(1, rn0Var) == ck1Var) {
                        return ck1Var;
                    }
                    bn0Var3 = bn0Var2;
                    i6 = i3;
                    i3 = i6;
                    bn0Var2 = bn0Var3;
                }
                if (bn0Var2.i()) {
                    throw new EOFException("Channel is already closed");
                }
            }
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object i(bn0 bn0Var, ContinuationImpl continuationImpl) {
        sn0 sn0Var;
        if (continuationImpl instanceof sn0) {
            sn0Var = (sn0) continuationImpl;
            int i = sn0Var.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                sn0Var.c = i - Integer.MIN_VALUE;
            } else {
                sn0Var = new sn0(continuationImpl);
            }
        }
        Object obj = sn0Var.b;
        ck1 ck1Var = ck1.a;
        int i2 = sn0Var.c;
        if (i2 == 0) {
            s38.b(obj);
            sn0Var.a = bn0Var;
            sn0Var.c = 1;
            if (a(bn0Var, 4, sn0Var) == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            bn0Var = sn0Var.a;
            s38.b(obj);
        }
        return Boxing.boxInt(bn0Var.g().readInt());
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object j(bn0 bn0Var, ContinuationImpl continuationImpl) {
        tn0 tn0Var;
        if (continuationImpl instanceof tn0) {
            tn0Var = (tn0) continuationImpl;
            int i = tn0Var.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                tn0Var.c = i - Integer.MIN_VALUE;
            } else {
                tn0Var = new tn0(continuationImpl);
            }
        }
        Object obj = tn0Var.b;
        ck1 ck1Var = ck1.a;
        int i2 = tn0Var.c;
        if (i2 == 0) {
            s38.b(obj);
            tn0Var.a = bn0Var;
            tn0Var.c = 1;
            if (a(bn0Var, 8, tn0Var) == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            bn0Var = tn0Var.a;
            s38.b(obj);
        }
        return Boxing.boxLong(bn0Var.g().readLong());
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x0047  */
    /* JADX WARN: Removed duplicated region for block: B:26:0x006a  */
    /* JADX WARN: Removed duplicated region for block: B:32:0x0099 A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:33:0x009a  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:18:0x004f -> B:24:0x0064). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:22:0x0060 -> B:23:0x0062). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object k(bn0 bn0Var, int i, ContinuationImpl continuationImpl) throws EOFException {
        un0 un0Var;
        int i2;
        mg0 mg0Var;
        if (continuationImpl instanceof un0) {
            un0Var = (un0) continuationImpl;
            int i3 = un0Var.e;
            if ((i3 & Integer.MIN_VALUE) != 0) {
                un0Var.e = i3 - Integer.MIN_VALUE;
            } else {
                un0Var = new un0(continuationImpl);
            }
        }
        Object obj = un0Var.d;
        ck1 ck1Var = ck1.a;
        int i4 = un0Var.e;
        if (i4 != 0) {
            if (i4 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            int i5 = un0Var.c;
            mg0Var = un0Var.b;
            bn0 bn0Var2 = un0Var.a;
            s38.b(obj);
            i2 = i5;
            bn0Var = bn0Var2;
            if (!bn0Var.i()) {
                long j = i2;
                if (oo0.b(bn0Var.g()) > j - mg0Var.c) {
                    bn0Var.g().br(mg0Var, j - mg0Var.c);
                } else {
                    Boxing.boxLong(bn0Var.g().y(mg0Var));
                }
                if (mg0Var.c < i2) {
                    if (bn0Var.g().j()) {
                        un0Var.a = bn0Var;
                        un0Var.b = mg0Var;
                        un0Var.c = i2;
                        un0Var.e = 1;
                        if (bn0Var.h(1, un0Var) == ck1Var) {
                            return ck1Var;
                        }
                        bn0Var2 = bn0Var;
                        i5 = i2;
                        i2 = i5;
                        bn0Var = bn0Var2;
                    }
                    if (!bn0Var.i()) {
                    }
                }
            }
            if (mg0Var.c < i2) {
                return mg0Var;
            }
            throw new EOFException(n41.r(fi7.j(i2, "Not enough data available, required ", " bytes but only "), mg0Var.c, " available"));
        }
        s38.b(obj);
        i2 = i;
        mg0Var = new mg0();
        if (mg0Var.c < i2) {
        }
        if (mg0Var.c < i2) {
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object l(long j, ContinuationImpl continuationImpl) {
        wn0 wn0Var;
        bn0 bn0Var;
        nv8 mg0Var;
        if (continuationImpl instanceof wn0) {
            wn0Var = (wn0) continuationImpl;
            int i = wn0Var.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                wn0Var.e = i - Integer.MIN_VALUE;
            } else {
                wn0Var = new wn0(continuationImpl);
            }
        }
        Object obj = wn0Var.d;
        ck1 ck1Var = ck1.a;
        int i2 = wn0Var.e;
        if (i2 == 0) {
            s38.b(obj);
            bn0Var = null;
            mg0Var = new mg0();
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            j = wn0Var.c;
            mg0Var = wn0Var.b;
            bn0Var = wn0Var.a;
            s38.b(obj);
        }
        while (!bn0Var.i()) {
            long jB = 0;
            if (j <= 0) {
                break;
            }
            if (j >= oo0.b(bn0Var.g())) {
                jB = j - oo0.b(bn0Var.g());
                Boxing.boxLong(bn0Var.g().y(mg0Var));
            } else {
                bn0Var.g().br(mg0Var, j);
            }
            wn0Var.a = bn0Var;
            wn0Var.b = mg0Var;
            wn0Var.c = jB;
            wn0Var.e = 1;
            if (bn0Var.h(1, wn0Var) == ck1Var) {
                return ck1Var;
            }
            j = jB;
        }
        return mg0Var.getC();
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object m(bn0 bn0Var, ContinuationImpl continuationImpl) throws Throwable {
        vn0 vn0Var;
        nv8 mg0Var;
        if (continuationImpl instanceof vn0) {
            vn0Var = (vn0) continuationImpl;
            int i = vn0Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                vn0Var.d = i - Integer.MIN_VALUE;
            } else {
                vn0Var = new vn0(continuationImpl);
            }
        }
        Object obj = vn0Var.c;
        ck1 ck1Var = ck1.a;
        int i2 = vn0Var.d;
        if (i2 == 0) {
            s38.b(obj);
            mg0Var = new mg0();
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            nv8 nv8Var = vn0Var.b;
            bn0 bn0Var2 = vn0Var.a;
            s38.b(obj);
            mg0Var = nv8Var;
            bn0Var = bn0Var2;
        }
        while (!bn0Var.i()) {
            mg0Var.ai(bn0Var.g());
            vn0Var.a = bn0Var;
            vn0Var.b = mg0Var;
            vn0Var.d = 1;
            if (bn0Var.h(1, vn0Var) == ck1Var) {
                return ck1Var;
            }
        }
        Throwable thA = bn0Var.a();
        if (thA == null) {
            return mg0Var.getC();
        }
        throw thA;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object n(bn0 bn0Var, ContinuationImpl continuationImpl) {
        xn0 xn0Var;
        if (continuationImpl instanceof xn0) {
            xn0Var = (xn0) continuationImpl;
            int i = xn0Var.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                xn0Var.c = i - Integer.MIN_VALUE;
            } else {
                xn0Var = new xn0(continuationImpl);
            }
        }
        Object obj = xn0Var.b;
        ck1 ck1Var = ck1.a;
        int i2 = xn0Var.c;
        if (i2 == 0) {
            s38.b(obj);
            xn0Var.a = bn0Var;
            xn0Var.c = 1;
            if (a(bn0Var, 2, xn0Var) == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            bn0Var = xn0Var.a;
            s38.b(obj);
        }
        return Boxing.boxShort(bn0Var.g().readShort());
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object o(bn0 bn0Var, int i, ContinuationImpl continuationImpl) {
        yn0 yn0Var;
        StringBuilder sb;
        if (continuationImpl instanceof yn0) {
            yn0Var = (yn0) continuationImpl;
            int i2 = yn0Var.c;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                yn0Var.c = i2 - Integer.MIN_VALUE;
            } else {
                yn0Var = new yn0(continuationImpl);
            }
        }
        Object obj = yn0Var.b;
        ck1 ck1Var = ck1.a;
        int i3 = yn0Var.c;
        if (i3 == 0) {
            s38.b(obj);
            StringBuilder sb2 = new StringBuilder();
            yn0Var.a = sb2;
            yn0Var.c = 1;
            Object objP = p(bn0Var, sb2, i, yn0Var);
            if (objP == ck1Var) {
                return ck1Var;
            }
            obj = objP;
            sb = sb2;
        } else {
            if (i3 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            sb = yn0Var.a;
            s38.b(obj);
        }
        if (((Boolean) obj).booleanValue()) {
            return sb.toString();
        }
        return null;
    }

    /* JADX WARN: Code restructure failed: missing block: B:27:0x008f, code lost:
    
        if (r0.h(1, r2) == r3) goto L64;
     */
    /* JADX WARN: Code restructure failed: missing block: B:60:0x0130, code lost:
    
        r16 = r7;
     */
    /* JADX WARN: Code restructure failed: missing block: B:61:0x0137, code lost:
    
        if (r4.c >= r0) goto L66;
     */
    /* JADX WARN: Code restructure failed: missing block: B:62:0x0139, code lost:
    
        r2.a = r11;
        r2.b = r15;
        r2.c = r14;
        r2.d = r4;
        r2.e = r0;
        r6 = 3;
        r2.i = 3;
        r4 = r4;
     */
    /* JADX WARN: Code restructure failed: missing block: B:63:0x014a, code lost:
    
        if (r11.h(1, r2) != r3) goto L65;
     */
    /* JADX WARN: Code restructure failed: missing block: B:64:0x014c, code lost:
    
        return r3;
     */
    /* JADX WARN: Code restructure failed: missing block: B:66:0x0154, code lost:
    
        r0 = "Line exceeds limit of " + r0 + " characters";
        defpackage.cr4.g(r0, "message");
     */
    /* JADX WARN: Code restructure failed: missing block: B:67:0x0174, code lost:
    
        throw new defpackage.wp9(r0);
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Not initialized variable reg: 14, insn: 0x019a: INVOKE (r14 I:java.lang.AutoCloseable), (r1 I:java.lang.Throwable) STATIC call: t00.a(java.lang.AutoCloseable, java.lang.Throwable):void A[MD:(java.lang.AutoCloseable, java.lang.Throwable):void (m)], block:B:79:0x019a */
    /* JADX WARN: Removed duplicated region for block: B:37:0x00b2 A[Catch: all -> 0x0048, LOOP:0: B:37:0x00b2->B:59:0x012b, LOOP_START, TryCatch #0 {all -> 0x0048, blocks: (B:14:0x0040, B:35:0x00ac, B:37:0x00b2, B:39:0x00bc, B:41:0x00c8, B:43:0x00d2, B:48:0x00e9, B:50:0x00f7, B:51:0x0100, B:55:0x0116, B:59:0x012b, B:60:0x0130, B:62:0x0139, B:66:0x0154, B:67:0x0174, B:68:0x0175, B:72:0x0181, B:74:0x018b, B:21:0x005c), top: B:81:0x002c }] */
    /* JADX WARN: Removed duplicated region for block: B:50:0x00f7 A[Catch: all -> 0x0048, TryCatch #0 {all -> 0x0048, blocks: (B:14:0x0040, B:35:0x00ac, B:37:0x00b2, B:39:0x00bc, B:41:0x00c8, B:43:0x00d2, B:48:0x00e9, B:50:0x00f7, B:51:0x0100, B:55:0x0116, B:59:0x012b, B:60:0x0130, B:62:0x0139, B:66:0x0154, B:67:0x0174, B:68:0x0175, B:72:0x0181, B:74:0x018b, B:21:0x005c), top: B:81:0x002c }] */
    /* JADX WARN: Removed duplicated region for block: B:68:0x0175 A[Catch: all -> 0x0048, TryCatch #0 {all -> 0x0048, blocks: (B:14:0x0040, B:35:0x00ac, B:37:0x00b2, B:39:0x00bc, B:41:0x00c8, B:43:0x00d2, B:48:0x00e9, B:50:0x00f7, B:51:0x0100, B:55:0x0116, B:59:0x012b, B:60:0x0130, B:62:0x0139, B:66:0x0154, B:67:0x0174, B:68:0x0175, B:72:0x0181, B:74:0x018b, B:21:0x005c), top: B:81:0x002c }] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /* JADX WARN: Type inference failed for: r0v13 */
    /* JADX WARN: Type inference failed for: r0v23 */
    /* JADX WARN: Type inference failed for: r0v33 */
    /* JADX WARN: Type inference failed for: r4v12 */
    /* JADX WARN: Type inference failed for: r4v13 */
    /* JADX WARN: Type inference failed for: r4v14 */
    /* JADX WARN: Type inference failed for: r4v15 */
    /* JADX WARN: Type inference failed for: r4v4 */
    /* JADX WARN: Type inference failed for: r4v5, types: [java.lang.Object, mg0] */
    /* JADX WARN: Type inference failed for: r4v6 */
    /* JADX WARN: Type inference failed for: r4v7, types: [java.lang.Object, mg0] */
    /* JADX WARN: Type inference failed for: r4v8 */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:63:0x014a -> B:65:0x014d). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object p(bn0 bn0Var, StringBuilder sb, int i, ContinuationImpl continuationImpl) {
        zn0 zn0Var;
        boolean z;
        Appendable appendable;
        int i2;
        Appendable appendable2;
        AutoCloseable mg0Var;
        bn0 bn0Var2;
        int i3;
        ?? r4;
        ?? r42;
        Appendable appendable3;
        bn0 bn0Var3;
        ?? r0;
        bn0 bn0Var4 = bn0Var;
        if (continuationImpl instanceof zn0) {
            zn0Var = (zn0) continuationImpl;
            int i4 = zn0Var.i;
            if ((i4 & Integer.MIN_VALUE) != 0) {
                zn0Var.i = i4 - Integer.MIN_VALUE;
            } else {
                zn0Var = new zn0(continuationImpl);
            }
        }
        Object obj = zn0Var.f;
        ck1 ck1Var = ck1.a;
        int i5 = zn0Var.i;
        byte b = 10;
        long j = 0;
        try {
            if (i5 == 0) {
                z = false;
                s38.b(obj);
                if (bn0Var4.g().j()) {
                    zn0Var.a = bn0Var4;
                    appendable = sb;
                    zn0Var.b = appendable;
                    i2 = i;
                    zn0Var.e = i2;
                    zn0Var.i = 1;
                } else {
                    appendable = sb;
                    i2 = i;
                }
            } else {
                if (i5 != 1) {
                    if (i5 == 2) {
                        mg0 mg0Var2 = zn0Var.d;
                        mg0Var = zn0Var.c;
                        appendable3 = zn0Var.b;
                        bn0Var3 = zn0Var.a;
                        s38.b(obj);
                        r0 = mg0Var2;
                        r42 = r0;
                        bn0Var2 = bn0Var3;
                        appendable2 = appendable3;
                        if (bn0Var2.g().getC().a(j) == b) {
                        }
                        cr4.g(r42, "<this>");
                        appendable2.append(bda.a(r42, r42.c));
                        Boolean boolBoxBoolean = Boxing.boxBoolean(true);
                        t00.a(mg0Var, null);
                        return boolBoxBoolean;
                    }
                    if (i5 != 3) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    i3 = zn0Var.e;
                    mg0 mg0Var3 = zn0Var.d;
                    mg0Var = zn0Var.c;
                    appendable2 = zn0Var.b;
                    z = false;
                    bn0Var2 = zn0Var.a;
                    s38.b(obj);
                    long j2 = 0;
                    char c = 3;
                    ?? r43 = mg0Var3;
                    j = j2;
                    b = 10;
                    r4 = r43;
                    if (!bn0Var2.i()) {
                        Boolean boolBoxBoolean2 = Boxing.boxBoolean(r4.c > j ? true : z);
                        if (boolBoxBoolean2.booleanValue()) {
                            appendable2.append(bda.a(r4, r4.c));
                        }
                        t00.a(mg0Var, null);
                        return boolBoxBoolean2;
                    }
                    while (true) {
                        if (bn0Var2.g().j()) {
                            break;
                        }
                        byte b2 = bn0Var2.g().readByte();
                        if (b2 == 13) {
                            r42 = r4;
                            if (bn0Var2.g().j()) {
                                zn0Var.a = bn0Var2;
                                zn0Var.b = appendable2;
                                zn0Var.c = mg0Var;
                                zn0Var.d = r4;
                                zn0Var.i = 2;
                                if (bn0Var2.h(1, zn0Var) != ck1Var) {
                                    r0 = r4;
                                    bn0Var3 = bn0Var2;
                                    appendable3 = appendable2;
                                }
                            }
                        } else {
                            if (b2 == b) {
                                cr4.g(r4, "<this>");
                                appendable2.append(bda.a(r4, r4.c));
                                Boolean boolBoxBoolean3 = Boxing.boxBoolean(true);
                                t00.a(mg0Var, null);
                                return boolBoxBoolean3;
                            }
                            r4.bk(b2);
                        }
                    }
                    if (bn0Var2.g().getC().a(j) == b) {
                        oo0.a(bn0Var2.g(), 1L);
                    }
                    cr4.g(r42, "<this>");
                    appendable2.append(bda.a(r42, r42.c));
                    Boolean boolBoxBoolean4 = Boxing.boxBoolean(true);
                    t00.a(mg0Var, null);
                    return boolBoxBoolean4;
                }
                z = false;
                int i6 = zn0Var.e;
                Appendable appendable4 = zn0Var.b;
                bn0 bn0Var5 = zn0Var.a;
                s38.b(obj);
                appendable = appendable4;
                i2 = i6;
                bn0Var4 = bn0Var5;
            }
            if (bn0Var4.i()) {
                return Boxing.boxBoolean(z);
            }
            appendable2 = appendable;
            mg0Var = new mg0();
            bn0Var2 = bn0Var4;
            i3 = i2;
            r4 = mg0Var;
            if (!bn0Var2.i()) {
            }
        } finally {
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object q(gp0 gp0Var, byte[] bArr, dw7.f fVar, dw7.g gVar, ContinuationImpl continuationImpl) {
        bo0 bo0Var;
        if (continuationImpl instanceof bo0) {
            bo0Var = (bo0) continuationImpl;
            int i = bo0Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                bo0Var.d = i - Integer.MIN_VALUE;
            } else {
                bo0Var = new bo0(continuationImpl);
            }
        }
        Object obj = bo0Var.c;
        ck1 ck1Var = ck1.a;
        int i2 = bo0Var.d;
        if (i2 == 0) {
            s38.b(obj);
            int i3 = fVar.a;
            bo0Var.a = fVar;
            bo0Var.b = gVar;
            bo0Var.d = 1;
            if (kp0.c(gp0Var, bArr, 0, i3, bo0Var) == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            gVar = bo0Var.b;
            fVar = bo0Var.a;
            s38.b(obj);
        }
        gVar.a += (long) fVar.a;
        fVar.a = 0;
        return e6a.a;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Type inference failed for: r4v2, types: [byte[], java.io.Serializable] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Serializable r(bn0 bn0Var, ContinuationImpl continuationImpl) throws Throwable {
        fo0 fo0Var;
        if (continuationImpl instanceof fo0) {
            fo0Var = (fo0) continuationImpl;
            int i = fo0Var.b;
            if ((i & Integer.MIN_VALUE) != 0) {
                fo0Var.b = i - Integer.MIN_VALUE;
            } else {
                fo0Var = new fo0(continuationImpl);
            }
        }
        Object objF = fo0Var.a;
        ck1 ck1Var = ck1.a;
        int i2 = fo0Var.b;
        if (i2 == 0) {
            s38.b(objF);
            fo0Var.b = 1;
            objF = f(bn0Var, fo0Var);
            if (objF == ck1Var) {
                return ck1Var;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s38.b(objF);
        }
        mg0 mg0Var = (mg0) objF;
        return qy8.b(mg0Var, (int) mg0Var.c);
    }
}