package m4;

import I2.C0334s;
import androidx.navigation.C1134i;
import com.google.android.gms.common.internal.ServiceSpecificExtraArgs;
import java.util.concurrent.TimeUnit;
import java.util.logging.Logger;
import k4.AbstractC2395h;
import k4.C2394g;
import k4.C2408v;
import k4.C2410x;
import p5.C2740j;

/* JADX INFO: renamed from: m4.b, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public abstract class AbstractC2491b extends c2 implements InterfaceC2547u {

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public static final Logger f20943i = Logger.getLogger(AbstractC2491b.class.getName());

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

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final boolean f20946e;

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public k4.g0 f20948g;

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

    public AbstractC2491b(C1134i c1134i, g2 g2Var, k2 k2Var, k4.g0 g0Var, C2394g c2394g, boolean z6) {
        A4.g.o(g0Var, "headers");
        A4.g.o(k2Var, "transportTracer");
        this.f20944c = k2Var;
        this.f20946e = !Boolean.TRUE.equals(c2394g.a(AbstractC2504f0.f21007n));
        this.f20947f = z6;
        if (!z6) {
            this.f20945d = new C2505f1(this, c1134i, g2Var);
            this.f20948g = g0Var;
            return;
        }
        C0.D d6 = new C0.D();
        d6.f522e = this;
        A4.g.o(g0Var, "headers");
        d6.f519b = g0Var;
        d6.f520c = g2Var;
        this.f20945d = d6;
    }

    @Override // m4.InterfaceC2547u
    public final void c(int i6) {
        this.f20945d.c(i6);
    }

    @Override // m4.InterfaceC2547u
    public final void e(C0334s c0334s) {
        c0334s.g(((n4.k) this).f21700p.f19842a.get(AbstractC2395h.f19871a), "remote_addr");
    }

    @Override // m4.InterfaceC2547u
    public final void g(k4.r0 r0Var) {
        A4.g.l(!r0Var.e(), "Should not cancel with OK status");
        this.f20949h = true;
        l2.c cVar = ((n4.k) this).f21699o;
        cVar.getClass();
        u4.b.c();
        try {
            synchronized (((n4.k) cVar.f20267b).f21698n.f21690w) {
                ((n4.k) cVar.f20267b).f21698n.l(r0Var, true, null);
            }
            u4.b.f24588a.getClass();
        } catch (Throwable th) {
            try {
                u4.b.f24588a.getClass();
            } catch (Throwable th2) {
                th.addSuppressed(th2);
            }
            throw th;
        }
    }

    @Override // m4.InterfaceC2547u
    public final void h() {
        n4.k kVar = (n4.k) this;
        if (kVar.f21698n.f20937n) {
            return;
        }
        kVar.f21698n.f20937n = true;
        this.f20945d.close();
    }

    @Override // m4.h2
    public final boolean isReady() {
        return ((n4.k) this).f21698n.e() && !this.f20949h;
    }

    @Override // m4.InterfaceC2547u
    public final void j(int i6) {
        ((n4.k) this).f21698n.f20925a.f20958b = i6;
    }

    @Override // m4.InterfaceC2547u
    public final void k(C2410x c2410x) {
        n4.j jVar = ((n4.k) this).f21698n;
        A4.g.t(jVar.f20934j == null, "Already called start");
        A4.g.o(c2410x, "decompressorRegistry");
        jVar.f20935k = c2410x;
    }

    @Override // m4.InterfaceC2547u
    public final void l(InterfaceC2553w interfaceC2553w) {
        n4.k kVar = (n4.k) this;
        n4.j jVar = kVar.f21698n;
        A4.g.t(jVar.f20934j == null, "Already called setListener");
        A4.g.o(interfaceC2553w, ServiceSpecificExtraArgs.CastExtraArgs.LISTENER);
        jVar.f20934j = interfaceC2553w;
        if (this.f20947f) {
            return;
        }
        kVar.f21699o.l(this.f20948g, null);
        this.f20948g = null;
    }

    @Override // m4.InterfaceC2547u
    public final void n(C2408v c2408v) {
        k4.g0 g0Var = this.f20948g;
        k4.b0 b0Var = AbstractC2504f0.f20997c;
        g0Var.a(b0Var);
        TimeUnit timeUnit = TimeUnit.NANOSECONDS;
        this.f20948g.f(b0Var, Long.valueOf(Math.max(0L, c2408v.b())));
    }

    public final void w(n4.u uVar, boolean z6, boolean z7, int i6) {
        C2740j c2740j;
        A4.g.l(uVar != null || z6, "null frame before EOS");
        l2.c cVar = ((n4.k) this).f21699o;
        cVar.getClass();
        u4.b.c();
        try {
            if (uVar == null) {
                c2740j = n4.k.f21694r;
            } else {
                c2740j = uVar.f21767a;
                int i7 = (int) c2740j.f23100b;
                if (i7 > 0) {
                    n4.k kVar = (n4.k) cVar.f20267b;
                    kVar.getClass();
                    n4.j jVar = kVar.f21698n;
                    synchronized (jVar.f20926b) {
                        jVar.f20929e += i7;
                    }
                }
            }
            synchronized (((n4.k) cVar.f20267b).f21698n.f21690w) {
                n4.j.k(((n4.k) cVar.f20267b).f21698n, c2740j, z6, z7);
                k2 k2Var = ((n4.k) cVar.f20267b).f20944c;
                if (i6 == 0) {
                    k2Var.getClass();
                } else {
                    k2Var.getClass();
                    ((i2) k2Var.f21087b).e();
                }
            }
            u4.b.f24588a.getClass();
        } catch (Throwable th) {
            try {
                u4.b.f24588a.getClass();
            } catch (Throwable th2) {
                th.addSuppressed(th2);
            }
            throw th;
        }
    }
}