package n4;

import I2.O;
import java.io.EOFException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedList;
import java.util.logging.Level;
import java.util.logging.Logger;
import k4.AbstractC2400m;
import k4.K;
import k4.L;
import k4.b0;
import k4.e0;
import k4.g0;
import k4.r0;
import m4.A0;
import m4.AbstractC2491b;
import m4.AbstractC2504f0;
import m4.AbstractC2513i0;
import m4.AbstractC2558x1;
import m4.C2496c1;
import m4.C2555w1;
import m4.EnumC2550v;
import m4.g2;
import m4.j2;
import p4.C2723b;
import p4.EnumC2722a;
import p5.C2740j;
import p5.C2743m;
import u4.C2965a;

/* JADX INFO: loaded from: classes3.dex */
public final class j extends AbstractC2513i0 implements v {

    /* JADX INFO: renamed from: A, reason: collision with root package name */
    public boolean f21677A;

    /* JADX INFO: renamed from: B, reason: collision with root package name */
    public boolean f21678B;

    /* JADX INFO: renamed from: C, reason: collision with root package name */
    public int f21679C;

    /* JADX INFO: renamed from: D, reason: collision with root package name */
    public int f21680D;

    /* JADX INFO: renamed from: E, reason: collision with root package name */
    public final C2626d f21681E;

    /* JADX INFO: renamed from: F, reason: collision with root package name */
    public final O f21682F;

    /* JADX INFO: renamed from: G, reason: collision with root package name */
    public final n f21683G;

    /* JADX INFO: renamed from: H, reason: collision with root package name */
    public boolean f21684H;

    /* JADX INFO: renamed from: I, reason: collision with root package name */
    public final u4.c f21685I;

    /* JADX INFO: renamed from: J, reason: collision with root package name */
    public w f21686J;

    /* JADX INFO: renamed from: K, reason: collision with root package name */
    public int f21687K;

    /* JADX INFO: renamed from: L, reason: collision with root package name */
    public final /* synthetic */ k f21688L;

    /* JADX INFO: renamed from: v, reason: collision with root package name */
    public final int f21689v;

    /* JADX INFO: renamed from: w, reason: collision with root package name */
    public final Object f21690w;

    /* JADX INFO: renamed from: x, reason: collision with root package name */
    public ArrayList f21691x;

    /* JADX INFO: renamed from: y, reason: collision with root package name */
    public final C2740j f21692y;

    /* JADX INFO: renamed from: z, reason: collision with root package name */
    public boolean f21693z;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public j(k kVar, int i6, g2 g2Var, Object obj, C2626d c2626d, O o6, n nVar, int i7) {
        super(i6, g2Var, kVar.f20944c);
        this.f21688L = kVar;
        this.f21056s = E3.f.f1145c;
        this.f21692y = new C2740j();
        this.f21693z = false;
        this.f21677A = false;
        this.f21678B = false;
        this.f21684H = true;
        this.f21687K = -1;
        A4.g.o(obj, "lock");
        this.f21690w = obj;
        this.f21681E = c2626d;
        this.f21682F = o6;
        this.f21683G = nVar;
        this.f21679C = i7;
        this.f21680D = i7;
        this.f21689v = i7;
        u4.b.f24588a.getClass();
        this.f21685I = C2965a.f24586a;
    }

    public static void j(j jVar, g0 g0Var, String str) {
        k kVar = jVar.f21688L;
        String str2 = kVar.f21697m;
        boolean z6 = kVar.f21701q;
        n nVar = jVar.f21683G;
        boolean z7 = nVar.f21709B == null;
        C2723b c2723b = AbstractC2627e.f21643a;
        A4.g.o(g0Var, "headers");
        A4.g.o(str, "defaultPath");
        A4.g.o(str2, "authority");
        g0Var.a(AbstractC2504f0.f21003i);
        g0Var.a(AbstractC2504f0.f21004j);
        b0 b0Var = AbstractC2504f0.f21005k;
        g0Var.a(b0Var);
        ArrayList arrayList = new ArrayList(g0Var.f19870b + 7);
        if (z7) {
            arrayList.add(AbstractC2627e.f21644b);
        } else {
            arrayList.add(AbstractC2627e.f21643a);
        }
        if (z6) {
            arrayList.add(AbstractC2627e.f21646d);
        } else {
            arrayList.add(AbstractC2627e.f21645c);
        }
        arrayList.add(new C2723b(C2723b.f22998h, str2));
        arrayList.add(new C2723b(C2723b.f22996f, str));
        arrayList.add(new C2723b(b0Var.f19845a, kVar.f21696k));
        arrayList.add(AbstractC2627e.f21647e);
        arrayList.add(AbstractC2627e.f21648f);
        Logger logger = j2.f21067a;
        Charset charset = K.f19810a;
        int i6 = g0Var.f19870b * 2;
        byte[][] bArr = new byte[i6][];
        Object[] objArr = g0Var.f19869a;
        if (objArr instanceof byte[][]) {
            System.arraycopy(objArr, 0, bArr, 0, i6);
        } else {
            for (int i7 = 0; i7 < g0Var.f19870b; i7++) {
                int i8 = i7 * 2;
                bArr[i8] = g0Var.e(i7);
                int i9 = i8 + 1;
                Object obj = g0Var.f19869a[i9];
                if (!(obj instanceof byte[])) {
                    A0.a.v(obj);
                    throw null;
                }
                bArr[i9] = (byte[]) obj;
            }
        }
        int i10 = 0;
        for (int i11 = 0; i11 < i6; i11 += 2) {
            byte[] bArr2 = bArr[i11];
            byte[] bArr3 = bArr[i11 + 1];
            if (j2.a(bArr2, j2.f21068b)) {
                bArr[i10] = bArr2;
                bArr[i10 + 1] = K.f19811b.c(bArr3).getBytes(E3.f.f1143a);
            } else {
                for (byte b5 : bArr3) {
                    if (b5 < 32 || b5 > 126) {
                        StringBuilder sbS = com.google.android.recaptcha.internal.a.s("Metadata key=", new String(bArr2, E3.f.f1143a), ", value=");
                        sbS.append(Arrays.toString(bArr3));
                        sbS.append(" contains invalid ASCII characters");
                        j2.f21067a.warning(sbS.toString());
                        break;
                    }
                }
                bArr[i10] = bArr2;
                bArr[i10 + 1] = bArr3;
            }
            i10 += 2;
        }
        if (i10 != i6) {
            bArr = (byte[][]) Arrays.copyOfRange(bArr, 0, i10);
        }
        for (int i12 = 0; i12 < bArr.length; i12 += 2) {
            C2743m c2743mL = C2743m.l(bArr[i12]);
            byte[] bArr4 = c2743mL.f23102a;
            if (bArr4.length != 0 && bArr4[0] != 58) {
                arrayList.add(new C2723b(c2743mL, C2743m.l(bArr[i12 + 1])));
            }
        }
        jVar.f21691x = arrayList;
        r0 r0Var = nVar.f21743v;
        if (r0Var != null) {
            kVar.f21698n.f(r0Var, EnumC2550v.f21204d, true, new g0());
            return;
        }
        if (nVar.f21735n.size() < nVar.f21710C) {
            nVar.u(kVar);
            return;
        }
        nVar.f21711D.add(kVar);
        if (!nVar.f21747z) {
            nVar.f21747z = true;
            A0 a02 = nVar.f21713F;
            if (a02 != null) {
                a02.b();
            }
        }
        if (kVar.f20946e) {
            nVar.f21720M.l(kVar, true);
        }
    }

    public static void k(j jVar, C2740j c2740j, boolean z6, boolean z7) {
        if (jVar.f21678B) {
            return;
        }
        if (!jVar.f21684H) {
            A4.g.t(jVar.f21687K != -1, "streamId should be set");
            jVar.f21682F.a(z6, jVar.f21686J, c2740j, z7);
        } else {
            jVar.f21692y.write(c2740j, (int) c2740j.f23100b);
            jVar.f21693z |= z6;
            jVar.f21677A |= z7;
        }
    }

    @Override // m4.AbstractC2488a
    public final void a(int i6) {
        int i7 = this.f21680D - i6;
        this.f21680D = i7;
        float f6 = i7;
        int i8 = this.f21689v;
        if (f6 <= i8 * 0.5f) {
            int i9 = i8 - i7;
            this.f21679C += i9;
            this.f21680D = i7 + i9;
            this.f21681E.f(this.f21687K, i9);
        }
    }

    @Override // m4.AbstractC2488a
    public final void c(boolean z6) {
        boolean z7 = this.f20937n;
        EnumC2550v enumC2550v = EnumC2550v.f21201a;
        if (z7) {
            this.f21683G.j(this.f21687K, null, enumC2550v, false, null, null);
        } else {
            this.f21683G.j(this.f21687K, null, enumC2550v, false, EnumC2722a.CANCEL, null);
        }
        A4.g.t(this.f20938o, "status should have been reported on deframer closed");
        this.l = true;
        if (this.f20939p && z6) {
            g(r0.f19945m.g("Encountered end-of-stream mid-frame"), true, new g0());
        }
        F1.O o6 = this.f20936m;
        if (o6 != null) {
            o6.run();
            this.f20936m = null;
        }
    }

    public final void l(r0 r0Var, boolean z6, g0 g0Var) throws EOFException {
        if (this.f21678B) {
            return;
        }
        this.f21678B = true;
        if (!this.f21684H) {
            this.f21683G.j(this.f21687K, r0Var, EnumC2550v.f21201a, z6, EnumC2722a.CANCEL, g0Var);
            return;
        }
        n nVar = this.f21683G;
        LinkedList linkedList = nVar.f21711D;
        k kVar = this.f21688L;
        linkedList.remove(kVar);
        nVar.o(kVar);
        this.f21691x = null;
        this.f21692y.a();
        this.f21684H = false;
        if (g0Var == null) {
            g0Var = new g0();
        }
        g(r0Var, true, g0Var);
    }

    public final void m(Throwable th) {
        l(r0.d(th), true, new g0());
    }

    public final void n(int i6, C2740j c2740j, boolean z6) throws Throwable {
        Throwable th;
        boolean z7 = true;
        long j4 = c2740j.f23100b;
        int i7 = this.f21679C - (((int) j4) + i6);
        this.f21679C = i7;
        this.f21680D -= i6;
        if (i7 < 0) {
            this.f21681E.d(this.f21687K, EnumC2722a.FLOW_CONTROL_ERROR);
            this.f21683G.j(this.f21687K, r0.f19945m.g("Received data size exceeded our receiving window size"), EnumC2550v.f21201a, false, null, null);
            return;
        }
        r rVar = new r(c2740j);
        r0 r0Var = this.f21054q;
        if (r0Var != null) {
            Charset charset = this.f21056s;
            C2555w1 c2555w1 = AbstractC2558x1.f21213a;
            A4.g.o(charset, "charset");
            int i8 = (int) c2740j.f23100b;
            byte[] bArr = new byte[i8];
            rVar.i(bArr, 0, i8);
            this.f21054q = r0Var.a("DATA-----------------------------\n".concat(new String(bArr, charset)));
            rVar.close();
            if (this.f21054q.f19950b.length() > 1000 || z6) {
                l(this.f21054q, false, this.f21055r);
                return;
            }
            return;
        }
        if (!this.f21057t) {
            l(r0.f19945m.g("headers not received before payload"), false, new g0());
            return;
        }
        int i9 = (int) j4;
        try {
            if (this.f20938o) {
                AbstractC2491b.f20943i.log(Level.INFO, "Received data on closed stream");
                rVar.close();
            } else {
                try {
                    C2496c1 c2496c1 = this.f20925a;
                    c2496c1.getClass();
                    try {
                        if (c2496c1.isClosed() || c2496c1.f20972t) {
                            rVar.close();
                        } else {
                            c2496c1.f20967o.B(rVar);
                            try {
                                c2496c1.a();
                            } catch (Throwable th2) {
                                th = th2;
                                z7 = false;
                                if (z7) {
                                    rVar.close();
                                }
                                throw th;
                            }
                        }
                    } catch (Throwable th3) {
                        th = th3;
                    }
                } catch (Throwable th4) {
                    try {
                        m(th4);
                    } catch (Throwable th5) {
                        th = th5;
                        z7 = false;
                        if (!z7) {
                            throw th;
                        }
                        rVar.close();
                        throw th;
                    }
                }
            }
            if (z6) {
                if (i9 > 0) {
                    this.f21054q = r0.f19945m.g("Received unexpected EOS on non-empty DATA frame from server");
                } else {
                    this.f21054q = r0.f19945m.g("Received unexpected EOS on empty DATA frame from server");
                }
                g0 g0Var = new g0();
                this.f21055r = g0Var;
                g(this.f21054q, false, g0Var);
            }
        } catch (Throwable th6) {
            th = th6;
        }
    }

    /* JADX WARN: Finally extract failed */
    public final void o(ArrayList arrayList, boolean z6) throws EOFException {
        r0 r0VarA;
        e0 e0Var = AbstractC2513i0.f21053u;
        if (z6) {
            byte[][] bArrA = x.a(arrayList);
            int length = bArrA.length / 2;
            g0 g0Var = new g0();
            g0Var.f19870b = length;
            g0Var.f19869a = bArrA;
            if (this.f21054q == null && !this.f21057t) {
                r0 r0VarI = AbstractC2513i0.i(g0Var);
                this.f21054q = r0VarI;
                if (r0VarI != null) {
                    this.f21055r = g0Var;
                }
            }
            r0 r0Var = this.f21054q;
            if (r0Var != null) {
                r0 r0VarA2 = r0Var.a("trailers: " + g0Var);
                this.f21054q = r0VarA2;
                l(r0VarA2, false, this.f21055r);
                return;
            }
            e0 e0Var2 = L.f19813b;
            r0 r0Var2 = (r0) g0Var.c(e0Var2);
            if (r0Var2 != null) {
                r0VarA = r0Var2.g((String) g0Var.c(L.f19812a));
            } else if (this.f21057t) {
                r0VarA = r0.f19940g.g("missing GRPC status in response");
            } else {
                Integer num = (Integer) g0Var.c(e0Var);
                r0VarA = (num != null ? AbstractC2504f0.g(num.intValue()) : r0.f19945m.g("missing HTTP status code")).a("missing GRPC status, inferred error from HTTP status code");
            }
            g0Var.a(e0Var);
            g0Var.a(e0Var2);
            g0Var.a(L.f19812a);
            if (this.f20938o) {
                AbstractC2491b.f20943i.log(Level.INFO, "Received trailers on closed stream:\n {1}\n {2}", new Object[]{r0VarA, g0Var});
                return;
            }
            for (AbstractC2400m abstractC2400m : this.f20932h.f21042a) {
                abstractC2400m.e(g0Var);
            }
            g(r0VarA, false, g0Var);
            return;
        }
        byte[][] bArrA2 = x.a(arrayList);
        int length2 = bArrA2.length / 2;
        g0 g0Var2 = new g0();
        g0Var2.f19870b = length2;
        g0Var2.f19869a = bArrA2;
        r0 r0Var3 = this.f21054q;
        if (r0Var3 != null) {
            this.f21054q = r0Var3.a("headers: " + g0Var2);
            return;
        }
        try {
            if (this.f21057t) {
                r0 r0VarG = r0.f19945m.g("Received headers twice");
                this.f21054q = r0VarG;
                this.f21054q = r0VarG.a("headers: " + g0Var2);
                this.f21055r = g0Var2;
                this.f21056s = AbstractC2513i0.h(g0Var2);
                return;
            }
            Integer num2 = (Integer) g0Var2.c(e0Var);
            if (num2 != null && num2.intValue() >= 100 && num2.intValue() < 200) {
                r0 r0Var4 = this.f21054q;
                if (r0Var4 != null) {
                    this.f21054q = r0Var4.a("headers: " + g0Var2);
                    this.f21055r = g0Var2;
                    this.f21056s = AbstractC2513i0.h(g0Var2);
                    return;
                }
                return;
            }
            this.f21057t = true;
            r0 r0VarI2 = AbstractC2513i0.i(g0Var2);
            this.f21054q = r0VarI2;
            if (r0VarI2 != null) {
                this.f21054q = r0VarI2.a("headers: " + g0Var2);
                this.f21055r = g0Var2;
                this.f21056s = AbstractC2513i0.h(g0Var2);
                return;
            }
            g0Var2.a(e0Var);
            g0Var2.a(L.f19813b);
            g0Var2.a(L.f19812a);
            d(g0Var2);
            r0 r0Var5 = this.f21054q;
            if (r0Var5 != null) {
                this.f21054q = r0Var5.a("headers: " + g0Var2);
                this.f21055r = g0Var2;
                this.f21056s = AbstractC2513i0.h(g0Var2);
            }
        } catch (Throwable th) {
            r0 r0Var6 = this.f21054q;
            if (r0Var6 != null) {
                this.f21054q = r0Var6.a("headers: " + g0Var2);
                this.f21055r = g0Var2;
                this.f21056s = AbstractC2513i0.h(g0Var2);
            }
            throw th;
        }
    }
}