package g.a;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;

/* JADX INFO: compiled from: Builders.common.kt */
/* JADX INFO: loaded from: classes.dex */
public final class u0<T> extends g.a.n2.z<T> {

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f4152h = AtomicIntegerFieldUpdater.newUpdater(u0.class, "_decision");
    private volatile /* synthetic */ int _decision;

    public u0(f.w.g gVar, f.w.d<? super T> dVar) {
        super(gVar, dVar);
        this._decision = 0;
    }

    private final boolean x0() {
        do {
            int i2 = this._decision;
            if (i2 != 0) {
                if (i2 == 1) {
                    return false;
                }
                throw new IllegalStateException("Already resumed".toString());
            }
        } while (!f4152h.compareAndSet(this, 0, 2));
        return true;
    }

    private final boolean y0() {
        do {
            int i2 = this._decision;
            if (i2 != 0) {
                if (i2 == 2) {
                    return false;
                }
                throw new IllegalStateException("Already suspended".toString());
            }
        } while (!f4152h.compareAndSet(this, 0, 1));
        return true;
    }

    @Override // g.a.n2.z, g.a.u1
    protected void s(Object obj) {
        s0(obj);
    }

    @Override // g.a.n2.z, g.a.a
    protected void s0(Object obj) {
        if (x0()) {
            return;
        }
        g.a.n2.h.c(f.w.j.c.c(this.f4103g), x.a(obj, this.f4103g), null, 2, null);
    }

    public final Object w0() {
        if (y0()) {
            return f.w.j.d.d();
        }
        Object objH = v1.h(N());
        if (objH instanceof t) {
            throw ((t) objH).a;
        }
        return objH;
    }
}