package r7;

import d5.AbstractC0844a;
import java.io.Closeable;
import java.io.EOFException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import n4.u0;
import u.AbstractC1563h;
import x7.C1731g;
import x7.C1734j;

/* JADX INFO: loaded from: classes.dex */
public final class s implements Closeable, AutoCloseable {

    /* JADX INFO: renamed from: t, reason: collision with root package name */
    public static final Logger f16670t;

    /* JADX INFO: renamed from: q, reason: collision with root package name */
    public final x7.B f16671q;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final r f16672r;

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

    static {
        Logger logger = Logger.getLogger(f.class.getName());
        P6.g.d(logger, "getLogger(Http2::class.java.name)");
        f16670t = logger;
    }

    public s(x7.B b8) {
        P6.g.e(b8, "source");
        this.f16671q = b8;
        r rVar = new r(b8);
        this.f16672r = rVar;
        this.f16673s = new c(rVar);
    }

    /* JADX WARN: Code restructure failed: missing block: B:83:0x013f, code lost:
    
        throw new java.io.IOException(d5.AbstractC0844a.j("PROTOCOL_ERROR SETTINGS_MAX_FRAME_SIZE: ", r10));
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean a(boolean z8, k kVar) throws IOException {
        int i;
        int i5 = 2;
        try {
            this.f16671q.O(9L);
            int iT = l7.b.t(this.f16671q);
            if (iT > 16384) {
                throw new IOException(AbstractC0844a.j("FRAME_SIZE_ERROR: ", iT));
            }
            int iG = this.f16671q.g() & 255;
            byte bG = this.f16671q.g();
            int i8 = bG & 255;
            int iM = this.f16671q.m();
            int i9 = Integer.MAX_VALUE & iM;
            Logger logger = f16670t;
            if (logger.isLoggable(Level.FINE)) {
                logger.fine(f.a(true, i9, iT, iG, i8));
            }
            if (z8 && iG != 4) {
                StringBuilder sb = new StringBuilder("Expected a SETTINGS frame but was ");
                String[] strArr = f.f16609b;
                sb.append(iG < strArr.length ? strArr[iG] : l7.b.i("0x%02x", Integer.valueOf(iG)));
                throw new IOException(sb.toString());
            }
            switch (iG) {
                case u0.f15495q /* 0 */:
                    b(kVar, iT, i8, i9);
                    return true;
                case 1:
                    m(kVar, iT, i8, i9);
                    return true;
                case 2:
                    if (iT != 5) {
                        throw new IOException(I1.a.k(iT, "TYPE_PRIORITY length: ", " != 5"));
                    }
                    if (i9 == 0) {
                        throw new IOException("TYPE_PRIORITY streamId == 0");
                    }
                    x7.B b8 = this.f16671q;
                    b8.m();
                    b8.g();
                    return true;
                case 3:
                    if (iT != 4) {
                        throw new IOException(I1.a.k(iT, "TYPE_RST_STREAM length: ", " != 4"));
                    }
                    if (i9 == 0) {
                        throw new IOException("TYPE_RST_STREAM streamId == 0");
                    }
                    int iM2 = this.f16671q.m();
                    int[] iArrD = AbstractC1563h.d(14);
                    int length = iArrD.length;
                    int i10 = 0;
                    while (true) {
                        if (i10 < length) {
                            int i11 = iArrD[i10];
                            if (AbstractC1563h.c(i11) == iM2) {
                                i = i11;
                            } else {
                                i10++;
                            }
                        } else {
                            i = 0;
                        }
                    }
                    if (i == 0) {
                        throw new IOException(AbstractC0844a.j("TYPE_RST_STREAM unexpected error code: ", iM2));
                    }
                    o oVar = kVar.f16621r;
                    oVar.getClass();
                    if (i9 == 0 || (iM & 1) != 0) {
                        int i12 = i;
                        w wVarJ = oVar.j(i9);
                        if (wVarJ != null) {
                            wVarJ.k(i12);
                        }
                        return true;
                    }
                    oVar.f16654y.c(new j(oVar.f16648s + '[' + i9 + "] onReset", oVar, i9, i, 1), 0L);
                    return true;
                case 4:
                    if (i9 != 0) {
                        throw new IOException("TYPE_SETTINGS streamId != 0");
                    }
                    if ((bG & 1) != 0) {
                        if (iT != 0) {
                            throw new IOException("FRAME_SIZE_ERROR ack frame should be empty!");
                        }
                        return true;
                    }
                    if (iT % 6 != 0) {
                        throw new IOException(AbstractC0844a.j("TYPE_SETTINGS length % 6 != 0: ", iT));
                    }
                    A a3 = new A();
                    U6.a aVarC = s7.d.C(s7.d.H(0, iT), 6);
                    int i13 = aVarC.f6797q;
                    int i14 = aVarC.f6798r;
                    int i15 = aVarC.f6799s;
                    if ((i15 > 0 && i13 <= i14) || (i15 < 0 && i14 <= i13)) {
                        while (true) {
                            x7.B b9 = this.f16671q;
                            short sU = b9.u();
                            byte[] bArr = l7.b.f14412a;
                            int i16 = sU & 65535;
                            int iM3 = b9.m();
                            if (i16 != 2) {
                                if (i16 == 3) {
                                    i16 = 4;
                                } else if (i16 == 4) {
                                    if (iM3 < 0) {
                                        throw new IOException("PROTOCOL_ERROR SETTINGS_INITIAL_WINDOW_SIZE > 2^31 - 1");
                                    }
                                    i16 = 7;
                                } else if (i16 == 5 && (iM3 < 16384 || iM3 > 16777215)) {
                                }
                            } else if (iM3 != 0 && iM3 != 1) {
                                throw new IOException("PROTOCOL_ERROR SETTINGS_ENABLE_PUSH != 0 or 1");
                            }
                            a3.c(i16, iM3);
                            if (i13 != i14) {
                                i13 += i15;
                            }
                            break;
                        }
                    }
                    o oVar2 = kVar.f16621r;
                    oVar2.f16653x.c(new i(I1.a.r(new StringBuilder(), oVar2.f16648s, " applyAndAckSettings"), kVar, a3, i5), 0L);
                    return true;
                case 5:
                    r(kVar, iT, i8, i9);
                    return true;
                case Z.g.STRING_SET_FIELD_NUMBER /* 6 */:
                    n(kVar, iT, i8, i9);
                    return true;
                case Z.g.DOUBLE_FIELD_NUMBER /* 7 */:
                    g(kVar, iT, i9);
                    return true;
                case Z.g.BYTES_FIELD_NUMBER /* 8 */:
                    if (iT != 4) {
                        throw new IOException(AbstractC0844a.j("TYPE_WINDOW_UPDATE length !=4: ", iT));
                    }
                    long jM = ((long) this.f16671q.m()) & 2147483647L;
                    if (jM == 0) {
                        throw new IOException("windowSizeIncrement was 0");
                    }
                    if (i9 == 0) {
                        o oVar3 = kVar.f16621r;
                        synchronized (oVar3) {
                            oVar3.f16641K += jM;
                            oVar3.notifyAll();
                        }
                        return true;
                    }
                    w wVarB = kVar.f16621r.b(i9);
                    if (wVarB != null) {
                        synchronized (wVarB) {
                            wVarB.f16690f += jM;
                            if (jM > 0) {
                                wVarB.notifyAll();
                            }
                            break;
                        }
                        return true;
                    }
                    return true;
                default:
                    this.f16671q.y(iT);
                    return true;
            }
        } catch (EOFException unused) {
            return false;
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:68:0x011d, code lost:
    
        if (r8 == false) goto L70;
     */
    /* JADX WARN: Code restructure failed: missing block: B:69:0x011f, code lost:
    
        r16.j(l7.b.f14413b, true);
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void b(k kVar, int i, int i5, int i8) throws IOException {
        int i9;
        w wVar;
        boolean z8;
        long j8;
        boolean z9;
        if (i8 == 0) {
            throw new IOException("PROTOCOL_ERROR: TYPE_DATA streamId == 0");
        }
        boolean z10 = (i5 & 1) != 0;
        if ((i5 & 32) != 0) {
            throw new IOException("PROTOCOL_ERROR: FLAG_COMPRESSED without SETTINGS_COMPRESS_DATA");
        }
        if ((i5 & 8) != 0) {
            byte bG = this.f16671q.g();
            byte[] bArr = l7.b.f14412a;
            i9 = bG & 255;
        } else {
            i9 = 0;
        }
        int iA = q.a(i, i5, i9);
        x7.B b8 = this.f16671q;
        P6.g.e(b8, "source");
        kVar.f16621r.getClass();
        long j9 = 0;
        if (!(i8 != 0 && (i8 & 1) == 0)) {
            w wVarB = kVar.f16621r.b(i8);
            if (wVarB != null) {
                byte[] bArr2 = l7.b.f14412a;
                u uVar = wVarB.i;
                long j10 = iA;
                uVar.getClass();
                long j11 = j10;
                while (true) {
                    if (j11 <= j9) {
                        wVar = wVarB;
                        byte[] bArr3 = l7.b.f14412a;
                        uVar.f16683v.f16686b.n(j10);
                        break;
                    }
                    synchronized (uVar.f16683v) {
                        z8 = uVar.f16679r;
                        j8 = j9;
                        wVar = wVarB;
                        z9 = uVar.f16681t.f18765r + j11 > uVar.f16678q;
                    }
                    if (z9) {
                        b8.y(j11);
                        uVar.f16683v.e(4);
                        break;
                    }
                    if (z8) {
                        b8.y(j11);
                        break;
                    }
                    long jM = b8.M(uVar.f16680s, j11);
                    if (jM == -1) {
                        throw new EOFException();
                    }
                    j11 -= jM;
                    w wVar2 = uVar.f16683v;
                    synchronized (wVar2) {
                        try {
                            if (uVar.f16682u) {
                                uVar.f16680s.m();
                            } else {
                                C1731g c1731g = uVar.f16681t;
                                boolean z11 = c1731g.f18765r == j8;
                                c1731g.t0(uVar.f16680s);
                                if (z11) {
                                    wVar2.notifyAll();
                                }
                            }
                        } catch (Throwable th) {
                            throw th;
                        }
                    }
                    j9 = j8;
                    wVarB = wVar;
                }
            } else {
                kVar.f16621r.u(i8, 2);
                long j12 = iA;
                kVar.f16621r.n(j12);
                b8.y(j12);
            }
        } else {
            o oVar = kVar.f16621r;
            oVar.getClass();
            C1731g c1731g2 = new C1731g();
            long j13 = iA;
            b8.O(j13);
            b8.M(c1731g2, j13);
            oVar.f16654y.c(new l(oVar.f16648s + '[' + i8 + "] onData", oVar, i8, c1731g2, iA, z10), 0L);
        }
        this.f16671q.y(i9);
    }

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

    public final void g(k kVar, int i, int i5) throws IOException {
        int i8;
        Object[] array;
        if (i < 8) {
            throw new IOException(AbstractC0844a.j("TYPE_GOAWAY length < 8: ", i));
        }
        if (i5 != 0) {
            throw new IOException("TYPE_GOAWAY streamId != 0");
        }
        int iM = this.f16671q.m();
        int iM2 = this.f16671q.m();
        int i9 = i - 8;
        int[] iArrD = AbstractC1563h.d(14);
        int length = iArrD.length;
        int i10 = 0;
        while (true) {
            if (i10 >= length) {
                i8 = 0;
                break;
            }
            i8 = iArrD[i10];
            if (AbstractC1563h.c(i8) == iM2) {
                break;
            } else {
                i10++;
            }
        }
        if (i8 == 0) {
            throw new IOException(AbstractC0844a.j("TYPE_GOAWAY unexpected error code: ", iM2));
        }
        C1734j c1734jJ = C1734j.f18766t;
        if (i9 > 0) {
            c1734jJ = this.f16671q.j(i9);
        }
        P6.g.e(c1734jJ, "debugData");
        c1734jJ.c();
        o oVar = kVar.f16621r;
        synchronized (oVar) {
            array = oVar.f16647r.values().toArray(new w[0]);
            oVar.f16651v = true;
        }
        for (w wVar : (w[]) array) {
            if (wVar.f16685a > iM && wVar.h()) {
                wVar.k(8);
                kVar.f16621r.j(wVar.f16685a);
            }
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:20:0x0067, code lost:
    
        throw new java.io.IOException(d5.AbstractC0844a.j("Header index too large ", r7));
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final List j(int i, int i5, int i8, int i9) throws IOException {
        c cVar;
        r rVar = this.f16672r;
        rVar.f16668u = i;
        rVar.f16665r = i;
        rVar.f16669v = i5;
        rVar.f16666s = i8;
        rVar.f16667t = i9;
        while (true) {
            cVar = this.f16673s;
            x7.B b8 = cVar.f16593c;
            boolean zA = b8.a();
            ArrayList arrayList = cVar.f16592b;
            if (zA) {
                List listX0 = B6.k.x0(arrayList);
                arrayList.clear();
                return listX0;
            }
            byte bG = b8.g();
            byte[] bArr = l7.b.f14412a;
            int i10 = bG & 255;
            if (i10 == 128) {
                throw new IOException("index == 0");
            }
            if ((bG & 128) == 128) {
                int iE = cVar.e(i10, 127);
                int i11 = iE - 1;
                if (i11 >= 0) {
                    C1512b[] c1512bArr = e.f16606a;
                    if (i11 <= c1512bArr.length - 1) {
                        arrayList.add(c1512bArr[i11]);
                    }
                }
                int length = cVar.f16595e + 1 + (i11 - e.f16606a.length);
                if (length < 0) {
                    break;
                }
                C1512b[] c1512bArr2 = cVar.f16594d;
                if (length >= c1512bArr2.length) {
                    break;
                }
                C1512b c1512b = c1512bArr2[length];
                P6.g.b(c1512b);
                arrayList.add(c1512b);
            } else if (i10 == 64) {
                C1512b[] c1512bArr3 = e.f16606a;
                C1734j c1734jD = cVar.d();
                e.a(c1734jD);
                cVar.c(new C1512b(c1734jD, cVar.d()));
            } else if ((bG & 64) == 64) {
                cVar.c(new C1512b(cVar.b(cVar.e(i10, 63) - 1), cVar.d()));
            } else if ((bG & 32) == 32) {
                int iE2 = cVar.e(i10, 31);
                cVar.f16591a = iE2;
                if (iE2 < 0 || iE2 > 4096) {
                    break;
                }
                int i12 = cVar.f16597g;
                if (iE2 < i12) {
                    if (iE2 == 0) {
                        C1512b[] c1512bArr4 = cVar.f16594d;
                        B6.j.L(c1512bArr4, 0, c1512bArr4.length);
                        cVar.f16595e = cVar.f16594d.length - 1;
                        cVar.f16596f = 0;
                        cVar.f16597g = 0;
                    } else {
                        cVar.a(i12 - iE2);
                    }
                }
            } else if (i10 == 16 || i10 == 0) {
                C1512b[] c1512bArr5 = e.f16606a;
                C1734j c1734jD2 = cVar.d();
                e.a(c1734jD2);
                arrayList.add(new C1512b(c1734jD2, cVar.d()));
            } else {
                arrayList.add(new C1512b(cVar.b(cVar.e(i10, 15) - 1), cVar.d()));
            }
        }
        throw new IOException("Invalid dynamic table size update " + cVar.f16591a);
    }

    public final void m(k kVar, int i, int i5, int i8) throws IOException {
        int i9;
        int i10 = 1;
        if (i8 == 0) {
            throw new IOException("PROTOCOL_ERROR: TYPE_HEADERS streamId == 0");
        }
        boolean z8 = false;
        boolean z9 = (i5 & 1) != 0;
        if ((i5 & 8) != 0) {
            byte bG = this.f16671q.g();
            byte[] bArr = l7.b.f14412a;
            i9 = bG & 255;
        } else {
            i9 = 0;
        }
        if ((i5 & 32) != 0) {
            x7.B b8 = this.f16671q;
            b8.m();
            b8.g();
            byte[] bArr2 = l7.b.f14412a;
            i -= 5;
        }
        List listJ = j(q.a(i, i5, i9), i9, i5, i8);
        kVar.f16621r.getClass();
        if (i8 != 0 && (i8 & 1) == 0) {
            z8 = true;
        }
        if (z8) {
            o oVar = kVar.f16621r;
            oVar.getClass();
            oVar.f16654y.c(new m(oVar.f16648s + '[' + i8 + "] onHeaders", oVar, i8, listJ, z9), 0L);
            return;
        }
        o oVar2 = kVar.f16621r;
        synchronized (oVar2) {
            w wVarB = oVar2.b(i8);
            if (wVarB != null) {
                wVarB.j(l7.b.v(listJ), z9);
                return;
            }
            if (oVar2.f16651v) {
                return;
            }
            if (i8 <= oVar2.f16649t) {
                return;
            }
            if (i8 % 2 == oVar2.f16650u % 2) {
                return;
            }
            w wVar = new w(i8, oVar2, false, z9, l7.b.v(listJ));
            oVar2.f16649t = i8;
            oVar2.f16647r.put(Integer.valueOf(i8), wVar);
            oVar2.f16652w.e().c(new i(oVar2.f16648s + '[' + i8 + "] onStream", oVar2, wVar, i10), 0L);
        }
    }

    public final void n(k kVar, int i, int i5, int i8) throws IOException {
        if (i != 8) {
            throw new IOException(AbstractC0844a.j("TYPE_PING length != 8: ", i));
        }
        if (i8 != 0) {
            throw new IOException("TYPE_PING streamId != 0");
        }
        int iM = this.f16671q.m();
        int iM2 = this.f16671q.m();
        if ((i5 & 1) == 0) {
            kVar.f16621r.f16653x.c(new j(I1.a.r(new StringBuilder(), kVar.f16621r.f16648s, " ping"), kVar.f16621r, iM, iM2, 0), 0L);
            return;
        }
        o oVar = kVar.f16621r;
        synchronized (oVar) {
            try {
                if (iM == 1) {
                    oVar.f16634B++;
                } else if (iM == 2) {
                    oVar.D++;
                } else if (iM == 3) {
                    oVar.notifyAll();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final void r(k kVar, int i, int i5, int i8) throws IOException {
        int i9;
        if (i8 == 0) {
            throw new IOException("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0");
        }
        if ((i5 & 8) != 0) {
            byte bG = this.f16671q.g();
            byte[] bArr = l7.b.f14412a;
            i9 = bG & 255;
        } else {
            i9 = 0;
        }
        int iM = this.f16671q.m() & Integer.MAX_VALUE;
        List listJ = j(q.a(i - 4, i5, i9), i9, i5, i8);
        o oVar = kVar.f16621r;
        oVar.getClass();
        synchronized (oVar) {
            if (oVar.f16645O.contains(Integer.valueOf(iM))) {
                oVar.u(iM, 2);
                return;
            }
            oVar.f16645O.add(Integer.valueOf(iM));
            oVar.f16654y.c(new m(oVar.f16648s + '[' + iM + "] onRequest", oVar, iM, listJ), 0L);
        }
    }
}