package p4;

import C0.C0109j;
import E3.p;
import I0.C0311u;
import I2.O;
import Z0.o;
import androidx.recyclerview.widget.i0;
import java.io.Closeable;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;
import k4.C2389b;
import k4.g0;
import k4.q0;
import k4.r0;
import m4.C2519k0;
import m4.C2548u0;
import m4.C2563z0;
import m4.EnumC2501e0;
import m4.EnumC2550v;
import m4.RunnableC2516j0;
import m4.RunnableC2542s0;
import n4.C2626d;
import n4.m;
import n4.n;
import n4.w;
import p5.C2740j;
import p5.C2743m;
import p5.J;

/* JADX INFO: renamed from: p4.h, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public final class C2729h implements Closeable {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final J f23027a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final C2727f f23028b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final C2724c f23029c;

    public C2729h(J j4) {
        this.f23027a = j4;
        C2727f c2727f = new C2727f(j4);
        this.f23028b = c2727f;
        this.f23029c = new C2724c(c2727f);
    }

    public final boolean a(m mVar) throws IOException {
        C2519k0 c2519k0;
        EnumC2722a enumC2722a;
        w wVar;
        try {
            this.f23027a.A(9L);
            int iA = j.a(this.f23027a);
            if (iA < 0 || iA > 16384) {
                j.c("FRAME_SIZE_ERROR: %s", Integer.valueOf(iA));
                throw null;
            }
            byte b5 = (byte) (this.f23027a.b() & 255);
            byte b6 = (byte) (this.f23027a.b() & 255);
            int iD = this.f23027a.d() & Integer.MAX_VALUE;
            Logger logger = j.f23035a;
            if (logger.isLoggable(Level.FINE)) {
                logger.fine(AbstractC2728g.a(true, iD, iA, b5, b6));
            }
            switch (b5) {
                case 0:
                    b(mVar, iA, b6, iD);
                    return true;
                case 1:
                    d(mVar, iA, b6, iD);
                    return true;
                case 2:
                    if (iA != 5) {
                        j.c("TYPE_PRIORITY length: %d != 5", Integer.valueOf(iA));
                        throw null;
                    }
                    if (iD == 0) {
                        j.c("TYPE_PRIORITY streamId == 0", new Object[0]);
                        throw null;
                    }
                    J j4 = this.f23027a;
                    j4.d();
                    j4.b();
                    return true;
                case 3:
                    g(mVar, iA, iD);
                    return true;
                case 4:
                    i(mVar, iA, b6, iD);
                    return true;
                case 5:
                    f(mVar, iA, b6, iD);
                    return true;
                case 6:
                    if (iA != 8) {
                        j.c("TYPE_PING length != 8: %s", Integer.valueOf(iA));
                        throw null;
                    }
                    if (iD != 0) {
                        j.c("TYPE_PING streamId != 0", new Object[0]);
                        throw null;
                    }
                    int iD2 = this.f23027a.d();
                    int iD3 = this.f23027a.d();
                    i = (b6 & 1) != 0 ? 1 : 0;
                    long j6 = (((long) iD2) << 32) | (((long) iD3) & 4294967295L);
                    mVar.f21702a.l(1, j6);
                    if (i != 0) {
                        synchronized (mVar.f21705d.f21733k) {
                            try {
                                n nVar = mVar.f21705d;
                                c2519k0 = nVar.f21745x;
                                if (c2519k0 != null) {
                                    long j7 = c2519k0.f21077a;
                                    if (j7 == j6) {
                                        nVar.f21745x = null;
                                    } else {
                                        Logger logger2 = n.f21707Q;
                                        Level level = Level.WARNING;
                                        Locale locale = Locale.US;
                                        logger2.log(level, "Received unexpected ping ack. Expecting " + j7 + ", got " + j6);
                                    }
                                } else {
                                    n.f21707Q.warning("Received unexpected ping ack. No ping outstanding");
                                }
                                c2519k0 = null;
                            } finally {
                            }
                            break;
                        }
                        if (c2519k0 != null) {
                            synchronized (c2519k0) {
                                try {
                                    if (!c2519k0.f21080d) {
                                        c2519k0.f21080d = true;
                                        p pVar = c2519k0.f21078b;
                                        TimeUnit timeUnit = TimeUnit.NANOSECONDS;
                                        long jB = pVar.b();
                                        c2519k0.f21082f = jB;
                                        LinkedHashMap linkedHashMap = c2519k0.f21079c;
                                        c2519k0.f21079c = null;
                                        for (Map.Entry entry : linkedHashMap.entrySet()) {
                                            try {
                                                ((Executor) entry.getValue()).execute(new RunnableC2516j0((C2563z0) entry.getKey(), jB));
                                            } catch (Throwable th) {
                                                C2519k0.f21076g.log(Level.SEVERE, "Failed to execute PingCallback", th);
                                            }
                                        }
                                    }
                                } finally {
                                }
                            }
                        }
                        break;
                    } else {
                        synchronized (mVar.f21705d.f21733k) {
                            mVar.f21705d.f21731i.c(iD2, iD3, true);
                            break;
                        }
                    }
                    return true;
                case 7:
                    if (iA < 8) {
                        j.c("TYPE_GOAWAY length < 8: %s", Integer.valueOf(iA));
                        throw null;
                    }
                    if (iD != 0) {
                        j.c("TYPE_GOAWAY streamId != 0", new Object[0]);
                        throw null;
                    }
                    J j8 = this.f23027a;
                    int iD4 = j8.d();
                    int iD5 = j8.d();
                    int i6 = iA - 8;
                    EnumC2722a[] enumC2722aArrValues = EnumC2722a.values();
                    int length = enumC2722aArrValues.length;
                    while (true) {
                        if (i < length) {
                            enumC2722a = enumC2722aArrValues[i];
                            if (enumC2722a.f22993a != iD5) {
                                i++;
                            }
                        } else {
                            enumC2722a = null;
                        }
                    }
                    if (enumC2722a == null) {
                        j.c("TYPE_GOAWAY unexpected error code: %d", Integer.valueOf(iD5));
                        throw null;
                    }
                    C2743m c2743mC = C2743m.f23101d;
                    if (i6 > 0) {
                        c2743mC = j8.c(i6);
                    }
                    mVar.f21702a.k(1, iD4, enumC2722a, c2743mC);
                    EnumC2722a enumC2722a2 = EnumC2722a.ENHANCE_YOUR_CALM;
                    n nVar2 = mVar.f21705d;
                    if (enumC2722a == enumC2722a2) {
                        String strT = c2743mC.t();
                        n.f21707Q.log(Level.WARNING, mVar + ": Received GOAWAY with ENHANCE_YOUR_CALM. Debug data: " + strT);
                        if ("too_many_pings".equals(strT)) {
                            nVar2.f21717J.run();
                        }
                    }
                    long j9 = enumC2722a.f22993a;
                    EnumC2501e0[] enumC2501e0Arr = EnumC2501e0.f20988d;
                    EnumC2501e0 enumC2501e0 = (j9 >= ((long) enumC2501e0Arr.length) || j9 < 0) ? null : enumC2501e0Arr[(int) j9];
                    r0 r0VarA = (enumC2501e0 == null ? r0.c(EnumC2501e0.f20987c.f20991b.f19949a.f19933a).g("Unrecognized HTTP/2 error code: " + j9) : enumC2501e0.f20991b).a("Received Goaway");
                    if (c2743mC.d() > 0) {
                        r0VarA = r0VarA.a(c2743mC.t());
                    }
                    Map map = n.f21706P;
                    nVar2.s(iD4, null, r0VarA);
                    return true;
                case 8:
                    if (iA != 4) {
                        j.c("TYPE_WINDOW_UPDATE length !=4: %s", Integer.valueOf(iA));
                        throw null;
                    }
                    long jD = ((long) this.f23027a.d()) & 2147483647L;
                    if (jD == 0) {
                        j.c("windowSizeIncrement was 0", new Object[0]);
                        throw null;
                    }
                    mVar.f21702a.o(1, iD, jD);
                    if (jD == 0) {
                        if (iD == 0) {
                            n.g(mVar.f21705d, "Received 0 flow control window increment.");
                            return true;
                        }
                        mVar.f21705d.j(iD, r0.f19945m.g("Received 0 flow control window increment."), EnumC2550v.f21201a, false, EnumC2722a.PROTOCOL_ERROR, null);
                        return true;
                    }
                    synchronized (mVar.f21705d.f21733k) {
                        try {
                            if (iD == 0) {
                                mVar.f21705d.f21732j.o(null, (int) jD);
                                return true;
                            }
                            n4.k kVar = (n4.k) mVar.f21705d.f21735n.get(Integer.valueOf(iD));
                            if (kVar != null) {
                                O o6 = mVar.f21705d.f21732j;
                                n4.j jVar = kVar.f21698n;
                                synchronized (jVar.f21690w) {
                                    wVar = jVar.f21686J;
                                    break;
                                }
                                o6.o(wVar, (int) jD);
                            } else if (!mVar.f21705d.n(iD)) {
                                i = 1;
                            }
                            if (i != 0) {
                                n.g(mVar.f21705d, "Received window_update for unknown stream: " + iD);
                                return true;
                            }
                            return true;
                        } finally {
                        }
                    }
                default:
                    this.f23027a.B(iA);
                    return true;
            }
        } catch (IOException unused) {
            return false;
        }
    }

    public final void b(m mVar, int i6, byte b5, int i7) throws IOException {
        n4.k kVar;
        boolean z6 = (b5 & 1) != 0;
        if ((b5 & 32) != 0) {
            j.c("PROTOCOL_ERROR: FLAG_COMPRESSED without SETTINGS_COMPRESS_DATA", new Object[0]);
            throw null;
        }
        short sB = (b5 & 8) != 0 ? (short) (this.f23027a.b() & 255) : (short) 0;
        int iB = j.b(i6, b5, sB);
        J j4 = this.f23027a;
        mVar.f21702a.j(1, i7, j4.f23059b, iB, z6);
        n nVar = mVar.f21705d;
        synchronized (nVar.f21733k) {
            kVar = (n4.k) nVar.f21735n.get(Integer.valueOf(i7));
        }
        if (kVar != null) {
            long j6 = iB;
            j4.A(j6);
            C2740j c2740j = new C2740j();
            c2740j.write(j4.f23059b, j6);
            u4.c cVar = kVar.f21698n.f21685I;
            u4.b.f24588a.getClass();
            synchronized (mVar.f21705d.f21733k) {
                kVar.f21698n.n(i6 - iB, c2740j, z6);
            }
        } else {
            if (!mVar.f21705d.n(i7)) {
                n.g(mVar.f21705d, "Received data for unknown stream: " + i7);
                this.f23027a.B(sB);
            }
            synchronized (mVar.f21705d.f21733k) {
                mVar.f21705d.f21731i.d(i7, EnumC2722a.STREAM_CLOSED);
            }
            j4.B(iB);
        }
        n nVar2 = mVar.f21705d;
        int i8 = nVar2.f21740s + i6;
        nVar2.f21740s = i8;
        if (i8 >= nVar2.f21728f * 0.5f) {
            synchronized (nVar2.f21733k) {
                mVar.f21705d.f21731i.f(0, r11.f21740s);
            }
            mVar.f21705d.f21740s = 0;
        }
        this.f23027a.B(sB);
    }

    /* JADX WARN: Code restructure failed: missing block: B:20:0x0060, code lost:
    
        throw new java.io.IOException(Z0.o.l("Header index too large ", r4));
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final ArrayList c(int i6, short s6, byte b5, int i7) throws IOException {
        C2724c c2724c;
        C2727f c2727f = this.f23028b;
        c2727f.f23022e = i6;
        c2727f.f23019b = i6;
        c2727f.f23023f = s6;
        c2727f.f23020c = b5;
        c2727f.f23021d = i7;
        while (true) {
            c2724c = this.f23029c;
            J j4 = c2724c.f23003b;
            boolean zA = j4.a();
            ArrayList arrayList = c2724c.f23002a;
            if (zA) {
                ArrayList arrayList2 = new ArrayList(arrayList);
                arrayList.clear();
                return arrayList2;
            }
            byte b6 = j4.b();
            int i8 = b6 & 255;
            if (i8 == 128) {
                throw new IOException("index == 0");
            }
            if ((b6 & 128) == 128) {
                int iE = c2724c.e(i8, 127);
                int i9 = iE - 1;
                if (i9 >= 0) {
                    C2723b[] c2723bArr = AbstractC2726e.f23016b;
                    if (i9 <= c2723bArr.length - 1) {
                        arrayList.add(c2723bArr[i9]);
                    }
                }
                int length = c2724c.f23007f + 1 + (i9 - AbstractC2726e.f23016b.length);
                if (length < 0) {
                    break;
                }
                C2723b[] c2723bArr2 = c2724c.f23006e;
                if (length > c2723bArr2.length - 1) {
                    break;
                }
                arrayList.add(c2723bArr2[length]);
            } else if (i8 == 64) {
                C2743m c2743mD = c2724c.d();
                AbstractC2726e.a(c2743mD);
                c2724c.c(new C2723b(c2743mD, c2724c.d()));
            } else if ((b6 & 64) == 64) {
                c2724c.c(new C2723b(c2724c.b(c2724c.e(i8, 63) - 1), c2724c.d()));
            } else if ((b6 & 32) == 32) {
                int iE2 = c2724c.e(i8, 31);
                c2724c.f23005d = iE2;
                if (iE2 < 0 || iE2 > c2724c.f23004c) {
                    break;
                }
                int i10 = c2724c.f23009h;
                if (iE2 < i10) {
                    if (iE2 == 0) {
                        Arrays.fill(c2724c.f23006e, (Object) null);
                        c2724c.f23007f = c2724c.f23006e.length - 1;
                        c2724c.f23008g = 0;
                        c2724c.f23009h = 0;
                    } else {
                        c2724c.a(i10 - iE2);
                    }
                }
            } else if (i8 == 16 || i8 == 0) {
                C2743m c2743mD2 = c2724c.d();
                AbstractC2726e.a(c2743mD2);
                arrayList.add(new C2723b(c2743mD2, c2724c.d()));
            } else {
                arrayList.add(new C2723b(c2724c.b(c2724c.e(i8, 15) - 1), c2724c.d()));
            }
        }
        throw new IOException("Invalid dynamic table size update " + c2724c.f23005d);
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        this.f23027a.close();
    }

    public final void d(m mVar, int i6, byte b5, int i7) throws IOException {
        r0 r0VarG = null;
        boolean z6 = false;
        if (i7 == 0) {
            j.c("PROTOCOL_ERROR: TYPE_HEADERS streamId == 0", new Object[0]);
            throw null;
        }
        boolean z7 = (b5 & 1) != 0;
        short sB = (b5 & 8) != 0 ? (short) (this.f23027a.b() & 255) : (short) 0;
        if ((b5 & 32) != 0) {
            J j4 = this.f23027a;
            j4.d();
            j4.b();
            i6 -= 5;
        }
        ArrayList arrayListC = c(j.b(i6, b5, sB), sB, b5, i7);
        i0 i0Var = mVar.f21702a;
        if (i0Var.h()) {
            ((Logger) i0Var.f13105b).log((Level) i0Var.f13106c, "INBOUND HEADERS: streamId=" + i7 + " headers=" + arrayListC + " endStream=" + z7);
        }
        if (mVar.f21705d.f21718K != Integer.MAX_VALUE) {
            long jD = 0;
            for (int i8 = 0; i8 < arrayListC.size(); i8++) {
                C2723b c2723b = (C2723b) arrayListC.get(i8);
                jD += (long) (c2723b.f23000b.d() + c2723b.f22999a.d() + 32);
            }
            int iMin = (int) Math.min(jD, 2147483647L);
            int i9 = mVar.f21705d.f21718K;
            if (iMin > i9) {
                r0 r0Var = r0.f19944k;
                Locale locale = Locale.US;
                StringBuilder sbS = o.s(i9, "Response ", z7 ? "trailer" : "header", " metadata larger than ", ": ");
                sbS.append(iMin);
                r0VarG = r0Var.g(sbS.toString());
            }
        }
        synchronized (mVar.f21705d.f21733k) {
            try {
                n4.k kVar = (n4.k) mVar.f21705d.f21735n.get(Integer.valueOf(i7));
                if (kVar == null) {
                    if (mVar.f21705d.n(i7)) {
                        mVar.f21705d.f21731i.d(i7, EnumC2722a.STREAM_CLOSED);
                    } else {
                        z6 = true;
                    }
                } else if (r0VarG == null) {
                    u4.c cVar = kVar.f21698n.f21685I;
                    u4.b.f24588a.getClass();
                    kVar.f21698n.o(arrayListC, z7);
                } else {
                    if (!z7) {
                        mVar.f21705d.f21731i.d(i7, EnumC2722a.CANCEL);
                    }
                    kVar.f21698n.g(r0VarG, false, new g0());
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        if (z6) {
            n.g(mVar.f21705d, "Received header for unknown stream: " + i7);
        }
    }

    public final void f(m mVar, int i6, byte b5, int i7) throws IOException {
        if (i7 == 0) {
            j.c("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0", new Object[0]);
            throw null;
        }
        short sB = (b5 & 8) != 0 ? (short) (this.f23027a.b() & 255) : (short) 0;
        int iD = this.f23027a.d() & Integer.MAX_VALUE;
        ArrayList arrayListC = c(j.b(i6 - 4, b5, sB), sB, b5, i7);
        i0 i0Var = mVar.f21702a;
        if (i0Var.h()) {
            ((Logger) i0Var.f13105b).log((Level) i0Var.f13106c, "INBOUND PUSH_PROMISE: streamId=" + i7 + " promisedStreamId=" + iD + " headers=" + arrayListC);
        }
        synchronized (mVar.f21705d.f21733k) {
            mVar.f21705d.f21731i.d(i7, EnumC2722a.PROTOCOL_ERROR);
        }
    }

    public final void g(m mVar, int i6, int i7) throws IOException {
        EnumC2722a enumC2722a;
        if (i6 != 4) {
            j.c("TYPE_RST_STREAM length: %d != 4", Integer.valueOf(i6));
            throw null;
        }
        if (i7 == 0) {
            j.c("TYPE_RST_STREAM streamId == 0", new Object[0]);
            throw null;
        }
        int iD = this.f23027a.d();
        EnumC2722a[] enumC2722aArrValues = EnumC2722a.values();
        int length = enumC2722aArrValues.length;
        int i8 = 0;
        while (true) {
            if (i8 >= length) {
                enumC2722a = null;
                break;
            }
            enumC2722a = enumC2722aArrValues[i8];
            if (enumC2722a.f22993a == iD) {
                break;
            } else {
                i8++;
            }
        }
        if (enumC2722a == null) {
            j.c("TYPE_RST_STREAM unexpected error code: %d", Integer.valueOf(iD));
            throw null;
        }
        boolean z6 = true;
        mVar.f21702a.m(1, i7, enumC2722a);
        r0 r0VarA = n.w(enumC2722a).a("Rst Stream");
        q0 q0Var = r0VarA.f19949a;
        if (q0Var != q0.CANCELLED && q0Var != q0.DEADLINE_EXCEEDED) {
            z6 = false;
        }
        synchronized (mVar.f21705d.f21733k) {
            try {
                n4.k kVar = (n4.k) mVar.f21705d.f21735n.get(Integer.valueOf(i7));
                if (kVar != null) {
                    u4.c cVar = kVar.f21698n.f21685I;
                    u4.b.f24588a.getClass();
                    mVar.f21705d.j(i7, r0VarA, enumC2722a == EnumC2722a.REFUSED_STREAM ? EnumC2550v.f21202b : EnumC2550v.f21201a, z6, null, null);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX WARN: Can't fix incorrect switch cases order, some code will duplicate */
    /* JADX WARN: Code restructure failed: missing block: B:23:0x003c, code lost:
    
        p4.j.c("PROTOCOL_ERROR SETTINGS_MAX_FRAME_SIZE: %s", java.lang.Integer.valueOf(r6));
     */
    /* JADX WARN: Code restructure failed: missing block: B:24:0x0049, code lost:
    
        throw null;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void i(m mVar, int i6, byte b5, int i7) throws IOException {
        boolean z6;
        if (i7 != 0) {
            j.c("TYPE_SETTINGS streamId != 0", new Object[0]);
            throw null;
        }
        if ((b5 & 1) != 0) {
            if (i6 == 0) {
                return;
            }
            j.c("FRAME_SIZE_ERROR ack frame should be empty!", new Object[0]);
            throw null;
        }
        if (i6 % 6 != 0) {
            j.c("TYPE_SETTINGS length %% 6 != 0: %s", Integer.valueOf(i6));
            throw null;
        }
        C0311u c0311u = new C0311u();
        int i8 = 0;
        while (true) {
            short s6 = 4;
            if (i8 >= i6) {
                mVar.f21702a.n(1, c0311u);
                synchronized (mVar.f21705d.f21733k) {
                    try {
                        if (c0311u.a(4)) {
                            mVar.f21705d.f21710C = c0311u.f2462b[4];
                        }
                        if (c0311u.a(7)) {
                            int i9 = c0311u.f2462b[7];
                            O o6 = mVar.f21705d.f21732j;
                            if (i9 < 0) {
                                o6.getClass();
                                throw new IllegalArgumentException(o.l("Invalid initial window size: ", i9));
                            }
                            int i10 = i9 - o6.f2523a;
                            o6.f2523a = i9;
                            z6 = false;
                            for (w wVar : ((n) o6.f2524b).k()) {
                                wVar.a(i10);
                            }
                            if (i10 > 0) {
                                z6 = true;
                            }
                        } else {
                            z6 = false;
                        }
                        if (mVar.f21704c) {
                            n nVar = mVar.f21705d;
                            C0109j c0109j = nVar.f21730h;
                            C2389b c2389b = nVar.f21742u;
                            Iterator it = ((C2548u0) c0109j.f608d).f21181j.iterator();
                            if (it.hasNext()) {
                                it.next().getClass();
                                throw new ClassCastException();
                            }
                            nVar.f21742u = c2389b;
                            C0109j c0109j2 = mVar.f21705d.f21730h;
                            C2548u0 c2548u0 = (C2548u0) c0109j2.f608d;
                            c2548u0.f21180i.f(2, "READY");
                            c2548u0.f21182k.execute(new RunnableC2542s0(c0109j2, 0));
                            mVar.f21704c = false;
                        }
                        C2626d c2626d = mVar.f21705d.f21731i;
                        i0 i0Var = c2626d.f21642c;
                        if (i0Var.h()) {
                            ((Logger) i0Var.f13105b).log((Level) i0Var.f13106c, "OUTBOUND".concat(" SETTINGS: ack=true"));
                        }
                        try {
                            c2626d.f21641b.a(c0311u);
                        } catch (IOException e6) {
                            c2626d.f21640a.p(e6);
                        }
                        if (z6) {
                            mVar.f21705d.f21732j.p();
                        }
                        mVar.f21705d.t();
                    } catch (Throwable th) {
                        throw th;
                    }
                }
                int i11 = c0311u.f2461a;
                if (((i11 & 2) != 0 ? c0311u.f2462b[1] : -1) >= 0) {
                    C2724c c2724c = this.f23029c;
                    int i12 = (i11 & 2) != 0 ? c0311u.f2462b[1] : -1;
                    c2724c.f23004c = i12;
                    c2724c.f23005d = i12;
                    int i13 = c2724c.f23009h;
                    if (i12 < i13) {
                        if (i12 != 0) {
                            c2724c.a(i13 - i12);
                            return;
                        }
                        Arrays.fill(c2724c.f23006e, (Object) null);
                        c2724c.f23007f = c2724c.f23006e.length - 1;
                        c2724c.f23008g = 0;
                        c2724c.f23009h = 0;
                        return;
                    }
                    return;
                }
                return;
            }
            short sI = this.f23027a.i();
            int iD = this.f23027a.d();
            switch (sI) {
                case 1:
                case 6:
                    s6 = sI;
                    c0311u.e(s6, iD);
                    i8 += 6;
                    break;
                case 2:
                    if (iD != 0 && iD != 1) {
                        j.c("PROTOCOL_ERROR SETTINGS_ENABLE_PUSH != 0 or 1", new Object[0]);
                        throw null;
                    }
                    s6 = sI;
                    c0311u.e(s6, iD);
                    i8 += 6;
                    break;
                    break;
                case 3:
                    c0311u.e(s6, iD);
                    i8 += 6;
                    break;
                case 4:
                    if (iD < 0) {
                        j.c("PROTOCOL_ERROR SETTINGS_INITIAL_WINDOW_SIZE > 2^31 - 1", new Object[0]);
                        throw null;
                    }
                    s6 = 7;
                    c0311u.e(s6, iD);
                    i8 += 6;
                    break;
                    break;
                case 5:
                    if (iD >= 16384 && iD <= 16777215) {
                        s6 = sI;
                        c0311u.e(s6, iD);
                        i8 += 6;
                    }
                    break;
                default:
                    i8 += 6;
                    break;
            }
        }
    }
}