package kotlinx.coroutines.scheduling;

import d2.c0;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: compiled from: WorkQueue.kt */
/* JADX INFO: loaded from: classes.dex */
public final class n {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private static final /* synthetic */ AtomicReferenceFieldUpdater f5283b = AtomicReferenceFieldUpdater.newUpdater(n.class, Object.class, "lastScheduledTask");

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5284c = AtomicIntegerFieldUpdater.newUpdater(n.class, "producerIndex");

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5285d = AtomicIntegerFieldUpdater.newUpdater(n.class, "consumerIndex");

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private static final /* synthetic */ AtomicIntegerFieldUpdater f5286e = AtomicIntegerFieldUpdater.newUpdater(n.class, "blockingTasksInBuffer");

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private final AtomicReferenceArray<h> f5287a = new AtomicReferenceArray<>(128);
    private volatile /* synthetic */ Object lastScheduledTask = null;
    private volatile /* synthetic */ int producerIndex = 0;
    private volatile /* synthetic */ int consumerIndex = 0;
    private volatile /* synthetic */ int blockingTasksInBuffer = 0;

    public static /* synthetic */ h b(n nVar, h hVar, boolean z2, int i3, Object obj) {
        if ((i3 & 2) != 0) {
            z2 = false;
        }
        return nVar.a(hVar, z2);
    }

    private final h c(h hVar) {
        if (hVar.f5272f.a() == 1) {
            f5286e.incrementAndGet(this);
        }
        if (e() == 127) {
            return hVar;
        }
        int i3 = this.producerIndex & 127;
        while (this.f5287a.get(i3) != null) {
            Thread.yield();
        }
        this.f5287a.lazySet(i3, hVar);
        f5284c.incrementAndGet(this);
        return null;
    }

    private final void d(h hVar) {
        if (hVar != null) {
            if (hVar.f5272f.a() == 1) {
                int iDecrementAndGet = f5286e.decrementAndGet(this);
                if (c0.a()) {
                    if (!(iDecrementAndGet >= 0)) {
                        throw new AssertionError();
                    }
                }
            }
        }
    }

    private final h i() {
        h andSet;
        while (true) {
            int i3 = this.consumerIndex;
            if (i3 - this.producerIndex == 0) {
                return null;
            }
            int i4 = i3 & 127;
            if (f5285d.compareAndSet(this, i3, i3 + 1) && (andSet = this.f5287a.getAndSet(i4, null)) != null) {
                d(andSet);
                return andSet;
            }
        }
    }

    private final boolean j(d dVar) {
        h hVarI = i();
        if (hVarI == null) {
            return false;
        }
        dVar.a(hVarI);
        return true;
    }

    private final long m(n nVar, boolean z2) {
        h hVar;
        do {
            hVar = (h) nVar.lastScheduledTask;
            if (hVar == null) {
                return -2L;
            }
            if (z2) {
                if (!(hVar.f5272f.a() == 1)) {
                    return -2L;
                }
            }
            long jA = l.f5279e.a() - hVar.f5271e;
            long j3 = l.f5275a;
            if (jA < j3) {
                return j3 - jA;
            }
        } while (!f5283b.compareAndSet(nVar, hVar, null));
        b(this, hVar, false, 2, null);
        return -1L;
    }

    public final h a(h hVar, boolean z2) {
        if (z2) {
            return c(hVar);
        }
        h hVar2 = (h) f5283b.getAndSet(this, hVar);
        if (hVar2 == null) {
            return null;
        }
        return c(hVar2);
    }

    public final int e() {
        return this.producerIndex - this.consumerIndex;
    }

    public final int f() {
        Object obj = this.lastScheduledTask;
        int iE = e();
        return obj != null ? iE + 1 : iE;
    }

    public final void g(d dVar) {
        h hVar = (h) f5283b.getAndSet(this, null);
        if (hVar != null) {
            dVar.a(hVar);
        }
        while (j(dVar)) {
        }
    }

    public final h h() {
        h hVar = (h) f5283b.getAndSet(this, null);
        return hVar == null ? i() : hVar;
    }

    public final long k(n nVar) {
        if (c0.a()) {
            if (!(e() == 0)) {
                throw new AssertionError();
            }
        }
        int i3 = nVar.producerIndex;
        AtomicReferenceArray<h> atomicReferenceArray = nVar.f5287a;
        for (int i4 = nVar.consumerIndex; i4 != i3; i4++) {
            int i5 = i4 & 127;
            if (nVar.blockingTasksInBuffer == 0) {
                break;
            }
            h hVar = atomicReferenceArray.get(i5);
            if (hVar != null) {
                if ((hVar.f5272f.a() == 1) && atomicReferenceArray.compareAndSet(i5, hVar, null)) {
                    f5286e.decrementAndGet(nVar);
                    b(this, hVar, false, 2, null);
                    return -1L;
                }
            }
        }
        return m(nVar, true);
    }

    public final long l(n nVar) {
        if (c0.a()) {
            if (!(e() == 0)) {
                throw new AssertionError();
            }
        }
        h hVarI = nVar.i();
        if (hVarI == null) {
            return m(nVar, false);
        }
        h hVarB = b(this, hVarI, false, 2, null);
        if (!c0.a()) {
            return -1L;
        }
        if (hVarB == null) {
            return -1L;
        }
        throw new AssertionError();
    }
}