package m4;

import k4.AbstractC2400m;
import k4.C2401n;
import k4.C2409w;
import k4.C2410x;
import k4.InterfaceC2402o;

/* JADX INFO: renamed from: m4.a, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public abstract class AbstractC2488a {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public C2496c1 f20925a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Object f20926b = new Object();

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final C2496c1 f20928d;

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

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

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

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final g2 f20932h;

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

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public InterfaceC2553w f20934j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public C2410x f20935k;
    public boolean l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public F1.O f20936m;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public volatile boolean f20937n;

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

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

    public AbstractC2488a(int i6, g2 g2Var, k2 k2Var) {
        A4.g.o(k2Var, "transportTracer");
        this.f20927c = k2Var;
        C2496c1 c2496c1 = new C2496c1(this, i6, g2Var, k2Var);
        this.f20928d = c2496c1;
        this.f20925a = c2496c1;
        this.f20935k = C2410x.f19979d;
        this.l = false;
        this.f20932h = g2Var;
    }

    public abstract void a(int i6);

    public final void b(k4.r0 r0Var, EnumC2550v enumC2550v, k4.g0 g0Var) {
        if (this.f20933i) {
            return;
        }
        this.f20933i = true;
        g2 g2Var = this.f20932h;
        if (g2Var.f21043b.compareAndSet(false, true)) {
            for (AbstractC2400m abstractC2400m : g2Var.f21042a) {
                abstractC2400m.m(r0Var);
            }
        }
        if (this.f20927c != null) {
            r0Var.e();
        }
        this.f20934j.b(r0Var, enumC2550v, g0Var);
    }

    public abstract void c(boolean z6);

    public final void d(k4.g0 g0Var) {
        A4.g.t(!this.f20938o, "Received headers on closed stream");
        for (AbstractC2400m abstractC2400m : this.f20932h.f21042a) {
            abstractC2400m.b();
        }
        C2401n c2401n = C2401n.f19897b;
        String str = (String) g0Var.c(AbstractC2504f0.f20998d);
        if (str != null) {
            C2409w c2409w = (C2409w) this.f20935k.f19980a.get(str);
            InterfaceC2402o interfaceC2402o = c2409w != null ? c2409w.f19973a : null;
            if (interfaceC2402o == null) {
                ((n4.j) this).m(new k4.t0(k4.r0.f19945m.g("Can't find decompressor for ".concat(str))));
                return;
            } else if (interfaceC2402o != c2401n) {
                C2496c1 c2496c1 = this.f20925a;
                c2496c1.getClass();
                A4.g.t(true, "Already set full stream decompressor");
                c2496c1.f20961e = interfaceC2402o;
            }
        }
        this.f20934j.e(g0Var);
    }

    public final boolean e() {
        boolean z6;
        synchronized (this.f20926b) {
            try {
                z6 = this.f20930f && this.f20929e < 32768 && !this.f20931g;
            } finally {
            }
        }
        return z6;
    }

    public final void f(k4.r0 r0Var, EnumC2550v enumC2550v, boolean z6, k4.g0 g0Var) {
        A4.g.o(r0Var, "status");
        if (!this.f20938o || z6) {
            this.f20938o = true;
            this.f20939p = r0Var.e();
            synchronized (this.f20926b) {
                try {
                    this.f20931g = true;
                } catch (Throwable th) {
                    th = th;
                    while (true) {
                        try {
                            throw th;
                        } catch (Throwable th2) {
                            th = th2;
                        }
                    }
                }
            }
            if (this.l) {
                this.f20936m = null;
                b(r0Var, enumC2550v, g0Var);
                return;
            }
            this.f20936m = new F1.O(this, r0Var, enumC2550v, g0Var, 1);
            if (z6) {
                this.f20925a.close();
                return;
            }
            C2496c1 c2496c1 = this.f20925a;
            if (c2496c1.isClosed()) {
                return;
            }
            if (c2496c1.f20967o.f20553c == 0) {
                c2496c1.close();
            } else {
                c2496c1.f20972t = true;
            }
        }
    }

    public final void g(k4.r0 r0Var, boolean z6, k4.g0 g0Var) {
        f(r0Var, EnumC2550v.f21201a, z6, g0Var);
    }
}