package m4;

import java.util.concurrent.atomic.AtomicInteger;
import k4.AbstractC2392e;
import k4.AbstractC2400m;
import k4.C2394g;

/* JADX INFO: renamed from: m4.k, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes3.dex */
public final class C2518k extends Z {

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public volatile k4.r0 f21071c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public k4.r0 f21072d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public k4.r0 f21073e;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final /* synthetic */ C2521l f21075g;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final AtomicInteger f21070b = new AtomicInteger(androidx.media3.common.C.RATE_UNSET_INT);

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final l2.c f21074f = new l2.c(this, 2);

    public C2518k(C2521l c2521l, B b5, String str) {
        this.f21075g = c2521l;
        A4.g.o(b5, "delegate");
        this.f21069a = b5;
    }

    public static void h(C2518k c2518k) {
        synchronized (c2518k) {
            try {
                if (c2518k.f21070b.get() != 0) {
                    return;
                }
                k4.r0 r0Var = c2518k.f21072d;
                k4.r0 r0Var2 = c2518k.f21073e;
                c2518k.f21072d = null;
                c2518k.f21073e = null;
                if (r0Var != null) {
                    super.d(r0Var);
                }
                if (r0Var2 != null) {
                    super.a(r0Var2);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // m4.Z, m4.InterfaceC2490a1
    public final void a(k4.r0 r0Var) {
        A4.g.o(r0Var, "status");
        synchronized (this) {
            try {
                if (this.f21070b.get() < 0) {
                    this.f21071c = r0Var;
                    this.f21070b.addAndGet(Integer.MAX_VALUE);
                } else if (this.f21073e != null) {
                    return;
                }
                if (this.f21070b.get() != 0) {
                    this.f21073e = r0Var;
                } else {
                    super.a(r0Var);
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // m4.InterfaceC2556x
    public final InterfaceC2547u c(k4.i0 i0Var, k4.g0 g0Var, C2394g c2394g, AbstractC2400m[] abstractC2400mArr) {
        InterfaceC2547u interfaceC2547u;
        AbstractC2392e abstractC2392e = c2394g.f19860c;
        if (abstractC2392e == null) {
            this.f21075g.getClass();
            abstractC2392e = null;
        } else {
            this.f21075g.getClass();
        }
        if (abstractC2392e == null) {
            return this.f21070b.get() >= 0 ? new X(this.f21071c, abstractC2400mArr) : this.f21069a.c(i0Var, g0Var, c2394g, abstractC2400mArr);
        }
        C2508g1 c2508g1 = new C2508g1(this.f21069a, i0Var, g0Var, c2394g, this.f21074f, abstractC2400mArr);
        if (this.f21070b.incrementAndGet() > 0) {
            C2518k c2518k = (C2518k) this.f21074f.f20267b;
            if (c2518k.f21070b.decrementAndGet() == 0) {
                h(c2518k);
            }
            return new X(this.f21071c, abstractC2400mArr);
        }
        try {
            abstractC2392e.applyRequestMetadata(new C2515j(), this.f21075g.f21090b, c2508g1);
        } catch (Throwable th) {
            c2508g1.b(k4.r0.f19943j.g("Credentials should use fail() instead of throwing exceptions").f(th));
        }
        synchronized (c2508g1.f21038h) {
            try {
                InterfaceC2547u interfaceC2547u2 = c2508g1.f21039i;
                interfaceC2547u = interfaceC2547u2;
                if (interfaceC2547u2 == null) {
                    Q q6 = new Q();
                    c2508g1.f21041k = q6;
                    c2508g1.f21039i = q6;
                }
            } finally {
            }
        }
        return interfaceC2547u;
    }

    @Override // m4.Z, m4.InterfaceC2490a1
    public final void d(k4.r0 r0Var) {
        A4.g.o(r0Var, "status");
        synchronized (this) {
            try {
                if (this.f21070b.get() < 0) {
                    this.f21071c = r0Var;
                    this.f21070b.addAndGet(Integer.MAX_VALUE);
                    if (this.f21070b.get() != 0) {
                        this.f21072d = r0Var;
                    } else {
                        super.d(r0Var);
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @Override // m4.Z
    public final B g() {
        return this.f21069a;
    }
}