package X4;

import C0.O;
import I2.C0317a;
import V4.AbstractC0748a;
import V4.C0767j0;
import V4.E;
import V4.u0;
import java.util.concurrent.CancellationException;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: loaded from: classes3.dex */
public final class s extends AbstractC0748a implements t, i {

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

    public s(A4.j jVar, e eVar) {
        super(jVar, true);
        this.f8697d = eVar;
    }

    @Override // V4.AbstractC0748a
    public final void U(Throwable th, boolean z6) {
        if (this.f8697d.j(th, false) || z6) {
            return;
        }
        E.s(this.f8279c, th);
    }

    @Override // V4.AbstractC0748a
    public final void V(Object obj) {
        W.d.k(this.f8697d);
    }

    public final void X(O o6) {
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater;
        e eVar = this.f8697d;
        eVar.getClass();
        do {
            atomicReferenceFieldUpdater = e.f8660m;
            if (atomicReferenceFieldUpdater.compareAndSet(eVar, null, o6)) {
                return;
            }
        } while (atomicReferenceFieldUpdater.get(eVar) == null);
        while (true) {
            Object obj = atomicReferenceFieldUpdater.get(eVar);
            C0317a c0317a = g.f8678q;
            if (obj != c0317a) {
                if (obj == g.f8679r) {
                    throw new IllegalStateException("Another handler was already registered and successfully invoked");
                }
                throw new IllegalStateException(("Another handler is already registered: " + obj).toString());
            }
            C0317a c0317a2 = g.f8679r;
            while (!atomicReferenceFieldUpdater.compareAndSet(eVar, c0317a, c0317a2)) {
                if (atomicReferenceFieldUpdater.get(eVar) != c0317a) {
                    break;
                }
            }
            o6.invoke(eVar.o());
            return;
        }
    }

    @Override // X4.v
    public final Object a(Z4.s sVar) {
        e eVar = this.f8697d;
        eVar.getClass();
        Object objA = e.A(eVar, sVar);
        B4.a aVar = B4.a.f492a;
        return objA;
    }

    @Override // X4.v
    public final Object c() {
        return this.f8697d.c();
    }

    @Override // V4.u0, V4.InterfaceC0765i0
    public final void cancel(CancellationException cancellationException) {
        if (isCancelled()) {
            return;
        }
        if (cancellationException == null) {
            cancellationException = new C0767j0(q(), null, this);
        }
        o(cancellationException);
    }

    @Override // X4.v
    public final Object e(A4.d dVar) {
        return this.f8697d.e(dVar);
    }

    @Override // X4.w
    public final Object f(Object obj) {
        return this.f8697d.f(obj);
    }

    @Override // X4.w
    public final Object g(A4.d dVar, Object obj) {
        return this.f8697d.g(dVar, obj);
    }

    @Override // X4.v
    public final b iterator() {
        e eVar = this.f8697d;
        eVar.getClass();
        return new b(eVar);
    }

    @Override // V4.u0
    public final void o(CancellationException cancellationException) {
        CancellationException cancellationExceptionR = u0.R(this, cancellationException);
        this.f8697d.j(cancellationExceptionR, true);
        n(cancellationExceptionR);
    }
}