package defpackage;

import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000$\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b \u0018\u00002\u00020\u00012\u00020\u0002:\u0004\n\u000b\f\rR\u0013\u0010\u0005\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00040\u00038\u0002X\u0082\u0004R\u0013\u0010\u0007\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00060\u00038\u0002X\u0082\u0004R\u000b\u0010\t\u001a\u00020\b8\u0002X\u0082\u0004¨\u0006\u000e"}, d2 = {"Lcq2;", "Ldq2;", "Lf32;", "Lww;", "", "_queue", "Lcq2$d;", "_delayed", "Lew;", "_isCompleted", "c", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "b", "d", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public abstract class cq2 extends dq2 implements f32 {
    public static final /* synthetic */ AtomicReferenceFieldUpdater i = AtomicReferenceFieldUpdater.newUpdater(cq2.class, Object.class, "_queue$volatile");
    public static final /* synthetic */ AtomicReferenceFieldUpdater j = AtomicReferenceFieldUpdater.newUpdater(cq2.class, Object.class, "_delayed$volatile");
    public static final /* synthetic */ AtomicIntegerFieldUpdater k = AtomicIntegerFieldUpdater.newUpdater(cq2.class, "_isCompleted$volatile");
    private volatile /* synthetic */ Object _delayed$volatile;
    private volatile /* synthetic */ int _isCompleted$volatile = 0;
    private volatile /* synthetic */ Object _queue$volatile;

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0082\u0004\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcq2$a;", "Lcq2$c;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public final class a extends c {
        public final ts0 c;

        public a(long j, ts0 ts0Var) {
            super(j);
            this.c = ts0Var;
        }

        @Override // java.lang.Runnable
        public final void run() {
            this.c.ab(cq2.this, e6a.a);
        }

        @Override // cq2.c
        public final String toString() {
            return super.toString() + this.c;
        }
    }

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcq2$b;", "Lcq2$c;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class b extends c {
        public final Runnable c;

        public b(long j, Runnable runnable) {
            super(j);
            this.c = runnable;
        }

        @Override // java.lang.Runnable
        public final void run() {
            this.c.run();
        }

        @Override // cq2.c
        public final String toString() {
            return super.toString() + this.c;
        }
    }

    @Metadata(d1 = {"\u0000$\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\b \u0018\u00002\u00060\u0001j\u0002`\u00022\b\u0012\u0004\u0012\u00020\u00000\u00032\u00020\u00042\u00020\u00052\u00060\u0006j\u0002`\u0007R\u0018\u0010\b\u001a\u0004\u0018\u00010\u00068\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\b\u0010\t¨\u0006\n"}, d2 = {"Lcq2$c;", "Ljava/lang/Runnable;", "Lkotlinx/coroutines/Runnable;", "", "Lld2;", "Lkm9;", "", "Lkotlinx/coroutines/internal/SynchronizedObject;", "_heap", "Ljava/lang/Object;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public static abstract class c implements Runnable, Comparable<c>, ld2, km9 {

        @pq6
        private volatile Object _heap;
        public long a;
        public int b = -1;

        public c(long j) {
            this.a = j;
        }

        @Override // defpackage.km9
        public final void b(d dVar) {
            if (this._heap == C0551fq2.a) {
                throw new IllegalArgumentException("Failed requirement.");
            }
            this._heap = dVar;
        }

        @Override // defpackage.ld2
        public final void c() {
            synchronized (this) {
                try {
                    Object obj = this._heap;
                    kg9 kg9Var = C0551fq2.a;
                    if (obj == kg9Var) {
                        return;
                    }
                    d dVar = obj instanceof d ? (d) obj : null;
                    if (dVar != null) {
                        synchronized (dVar) {
                            Object obj2 = this._heap;
                            if ((obj2 instanceof jm9 ? (jm9) obj2 : null) != null) {
                                dVar.b(this.b);
                            }
                        }
                    }
                    this._heap = kg9Var;
                } catch (Throwable th) {
                    throw th;
                }
            }
        }

        @Override // java.lang.Comparable
        public final int compareTo(c cVar) {
            long j = this.a - cVar.a;
            if (j > 0) {
                return 1;
            }
            return j < 0 ? -1 : 0;
        }

        public final int d(long j, d dVar, cq2 cq2Var) {
            synchronized (this) {
                if (this._heap == C0551fq2.a) {
                    return 2;
                }
                synchronized (dVar) {
                    try {
                        km9[] km9VarArr = dVar.a;
                        c cVar = (c) (km9VarArr != null ? km9VarArr[0] : null);
                        if (cq2.k.get(cq2Var) != 0) {
                            return 1;
                        }
                        if (cVar == null) {
                            dVar.c = j;
                        } else {
                            long j2 = cVar.a;
                            if (j2 - j < 0) {
                                j = j2;
                            }
                            if (j - dVar.c > 0) {
                                dVar.c = j;
                            }
                        }
                        long j3 = this.a;
                        long j4 = dVar.c;
                        if (j3 - j4 < 0) {
                            this.a = j4;
                        }
                        dVar.a(this);
                        return 0;
                    } catch (Throwable th) {
                        throw th;
                    }
                }
            }
        }

        @Override // defpackage.km9
        public final void setIndex(int i) {
            this.b = i;
        }

        public String toString() {
            return "Delayed[nanos=" + this.a + ']';
        }
    }

    @Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0000\u0018\u00002\b\u0012\u0004\u0012\u00020\u00020\u0001¨\u0006\u0003"}, d2 = {"Lcq2$d;", "Ljm9;", "Lcq2$c;", "kotlinx-coroutines-core"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class d extends jm9<c> {
        public long c;
    }

    @Override // defpackage.f32
    public ld2 ad(long j2, Runnable runnable, gj1 gj1Var) {
        return zz1.a.ad(j2, runnable, gj1Var);
    }

    @Override // defpackage.lj1
    public final void as(gj1 gj1Var, Runnable runnable) {
        cm(runnable);
    }

    @Override // defpackage.f32
    public final void b(long j2, ts0 ts0Var) {
        long jA = C0551fq2.a(j2);
        if (jA < 4611686018427387903L) {
            long jNanoTime = System.nanoTime();
            a aVar = new a(jA + jNanoTime, ts0Var);
            cq(jNanoTime, aVar);
            vs0.a(ts0Var, aVar);
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:8:0x0018, code lost:
    
        r7 = null;
     */
    @Override // defpackage.bq2
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final long ci() {
        Runnable runnable;
        km9 km9Var;
        kg9 kg9Var = C0551fq2.b;
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = i;
        if (!cj()) {
            cn();
            loop0: while (true) {
                Object obj = atomicReferenceFieldUpdater.get(this);
                if (obj == null) {
                    break;
                }
                if (!(obj instanceof gg5)) {
                    if (obj != kg9Var) {
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, null)) {
                            if (atomicReferenceFieldUpdater.get(this) != obj) {
                                break;
                            }
                        }
                        runnable = (Runnable) obj;
                        break loop0;
                    }
                    break;
                }
                gg5 gg5Var = (gg5) obj;
                Object objD = gg5Var.d();
                if (objD != gg5.g) {
                    runnable = (Runnable) objD;
                    break;
                }
                gg5 gg5VarC = gg5Var.c();
                while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, gg5VarC) && atomicReferenceFieldUpdater.get(this) == obj) {
                }
            }
            if (runnable != null) {
                runnable.run();
                return 0L;
            }
            ds dsVar = this.e;
            if (((dsVar == null || dsVar.isEmpty()) ? Long.MAX_VALUE : 0L) != 0) {
                Object obj2 = atomicReferenceFieldUpdater.get(this);
                if (obj2 != null) {
                    if (obj2 instanceof gg5) {
                        long j2 = gg5.f.get((gg5) obj2);
                        if (((int) (1073741823 & j2)) != ((int) ((j2 & 1152921503533105152L) >> 30))) {
                            return 0L;
                        }
                    } else if (obj2 == kg9Var) {
                        return Long.MAX_VALUE;
                    }
                }
                d dVar = (d) j.get(this);
                if (dVar != null) {
                    synchronized (dVar) {
                        km9[] km9VarArr = dVar.a;
                        km9Var = km9VarArr != null ? km9VarArr[0] : null;
                    }
                    c cVar = (c) km9Var;
                    if (cVar != null) {
                        long jNanoTime = cVar.a - System.nanoTime();
                        if (jNanoTime >= 0) {
                            return jNanoTime;
                        }
                    }
                }
                return Long.MAX_VALUE;
            }
        }
        return 0L;
    }

    public void cm(Runnable runnable) {
        cn();
        if (!co(runnable)) {
            yz1.l.cm(runnable);
            return;
        }
        Thread threadCk = getL();
        if (Thread.currentThread() != threadCk) {
            LockSupport.unpark(threadCk);
        }
    }

    public final void cn() {
        km9 km9VarB;
        d dVar = (d) j.get(this);
        if (dVar == null || jm9.b.get(dVar) == 0) {
            return;
        }
        long jNanoTime = System.nanoTime();
        do {
            synchronized (dVar) {
                try {
                    km9[] km9VarArr = dVar.a;
                    km9 km9Var = km9VarArr != null ? km9VarArr[0] : null;
                    if (km9Var != null) {
                        c cVar = (c) km9Var;
                        km9VarB = ((jNanoTime - cVar.a) > 0L ? 1 : ((jNanoTime - cVar.a) == 0L ? 0 : -1)) >= 0 ? co(cVar) : false ? dVar.b(0) : null;
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        } while (((c) km9VarB) != null);
    }

    /* JADX WARN: Code restructure failed: missing block: B:30:0x004b, code lost:
    
        return false;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean co(Runnable runnable) {
        loop0: while (true) {
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = i;
            Object obj = atomicReferenceFieldUpdater.get(this);
            if (k.get(this) == 0) {
                if (obj != null) {
                    if (!(obj instanceof gg5)) {
                        if (obj != C0551fq2.b) {
                            gg5 gg5Var = new gg5(8, true);
                            gg5Var.a((Runnable) obj);
                            gg5Var.a(runnable);
                            while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, gg5Var)) {
                                if (atomicReferenceFieldUpdater.get(this) != obj) {
                                    break;
                                }
                            }
                            break loop0;
                        }
                        break;
                    }
                    gg5 gg5Var2 = (gg5) obj;
                    int iA = gg5Var2.a(runnable);
                    if (iA == 0) {
                        break;
                    }
                    if (iA == 1) {
                        gg5 gg5VarC = gg5Var2.c();
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, gg5VarC) && atomicReferenceFieldUpdater.get(this) == obj) {
                        }
                    } else if (iA == 2) {
                        break;
                    }
                } else {
                    while (!atomicReferenceFieldUpdater.compareAndSet(this, null, runnable)) {
                        if (atomicReferenceFieldUpdater.get(this) != null) {
                            break;
                        }
                    }
                    break loop0;
                }
            } else {
                return false;
            }
        }
        return true;
    }

    /* JADX WARN: Removed duplicated region for block: B:17:0x0027  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean cp() {
        ds dsVar = this.e;
        if (dsVar != null ? dsVar.isEmpty() : true) {
            d dVar = (d) j.get(this);
            if (dVar == null) {
                Object obj = i.get(this);
                if (obj != null) {
                    if (obj instanceof gg5) {
                        long j2 = gg5.f.get((gg5) obj);
                        return ((int) (1073741823 & j2)) == ((int) ((j2 & 1152921503533105152L) >> 30));
                    }
                    if (obj == C0551fq2.b) {
                    }
                }
                return true;
            }
            if (jm9.b.get(dVar) == 0) {
            }
        }
        return false;
    }

    public final void cq(long j2, c cVar) {
        int iD;
        Thread threadCk;
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = j;
        if (k.get(this) != 0) {
            iD = 1;
        } else {
            d dVar = (d) atomicReferenceFieldUpdater.get(this);
            if (dVar == null) {
                d dVar2 = new d();
                dVar2.c = j2;
                while (!atomicReferenceFieldUpdater.compareAndSet(this, null, dVar2) && atomicReferenceFieldUpdater.get(this) == null) {
                }
                Object obj = atomicReferenceFieldUpdater.get(this);
                cr4.d(obj);
                dVar = (d) obj;
            }
            iD = cVar.d(j2, dVar, this);
        }
        if (iD != 0) {
            if (iD == 1) {
                cl(j2, cVar);
                return;
            } else {
                if (iD != 2) {
                    throw new IllegalStateException("unexpected result");
                }
                return;
            }
        }
        d dVar3 = (d) atomicReferenceFieldUpdater.get(this);
        if (dVar3 != null) {
            synchronized (dVar3) {
                km9[] km9VarArr = dVar3.a;
                km9Var = km9VarArr != null ? km9VarArr[0] : null;
            }
            km9Var = (c) km9Var;
        }
        if (km9Var != cVar || Thread.currentThread() == (threadCk = getL())) {
            return;
        }
        LockSupport.unpark(threadCk);
    }

    @Override // defpackage.bq2
    public void shutdown() {
        km9 km9VarB;
        am9.a.set(null);
        k.set(this, 1);
        kg9 kg9Var = C0551fq2.b;
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = i;
        loop0: while (true) {
            Object obj = atomicReferenceFieldUpdater.get(this);
            if (obj != null) {
                if (!(obj instanceof gg5)) {
                    if (obj != kg9Var) {
                        gg5 gg5Var = new gg5(8, true);
                        gg5Var.a((Runnable) obj);
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, gg5Var)) {
                            if (atomicReferenceFieldUpdater.get(this) != obj) {
                                break;
                            }
                        }
                        break loop0;
                    }
                    break;
                }
                ((gg5) obj).b();
                break;
            }
            while (!atomicReferenceFieldUpdater.compareAndSet(this, null, kg9Var)) {
                if (atomicReferenceFieldUpdater.get(this) != null) {
                    break;
                }
            }
            break loop0;
        }
        while (ci() <= 0) {
        }
        long jNanoTime = System.nanoTime();
        while (true) {
            d dVar = (d) j.get(this);
            if (dVar == null) {
                return;
            }
            synchronized (dVar) {
                km9VarB = jm9.b.get(dVar) > 0 ? dVar.b(0) : null;
            }
            c cVar = (c) km9VarB;
            if (cVar == null) {
                return;
            } else {
                cl(jNanoTime, cVar);
            }
        }
    }
}