package defpackage;

import androidx.media3.container.NalUnitUtil;
import com.google.android.gms.measurement.api.AppMeasurementSdk;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\u001e\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0004\u001a?\u0010\t\u001a\u00020\u0007*\u00020\u00002\u0006\u0010\u0002\u001a\u00020\u00012!\u0010\b\u001a\u001d\u0012\u0013\u0012\u00110\u0001¢\u0006\f\b\u0004\u0012\b\b\u0005\u0012\u0004\b\b(\u0006\u0012\u0004\u0012\u00020\u00070\u0003H\u0082\b¢\u0006\u0004\b\t\u0010\n¨\u0006\u000b"}, d2 = {"Lnw;", "", "delta", "Lkotlin/Function1;", "Lj17;", AppMeasurementSdk.ConditionalUserProperty.NAME, "cur", "", "condition", "addConditionally", "(Lnw;ILsq3;)Z", "kotlinx-coroutines-core"}, k = 2, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class eb1 {
    public static final kg9 a = new kg9("CLOSED");

    public static final Object a(ne8 ne8Var, long j, gr3 gr3Var) {
        while (true) {
            if (ne8Var.c >= j && !ne8Var.d()) {
                return ne8Var;
            }
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = fb1.a;
            Object obj = atomicReferenceFieldUpdater.get(ne8Var);
            kg9 kg9Var = a;
            if (obj == kg9Var) {
                return kg9Var;
            }
            ne8 ne8Var2 = (ne8) ((fb1) obj);
            if (ne8Var2 == null) {
                ne8Var2 = (ne8) gr3Var.invoke(Long.valueOf(ne8Var.c + 1), ne8Var);
                while (!atomicReferenceFieldUpdater.compareAndSet(ne8Var, null, ne8Var2)) {
                    if (atomicReferenceFieldUpdater.get(ne8Var) != null) {
                        break;
                    }
                }
                if (ne8Var.d()) {
                    ne8Var.e();
                }
            }
            ne8Var = ne8Var2;
        }
    }
}