package Z6;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;

/* JADX INFO: loaded from: classes.dex */
public abstract class T extends U implements E {

    /* JADX INFO: renamed from: w, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f7485w = AtomicReferenceFieldUpdater.newUpdater(T.class, Object.class, "_queue$volatile");

    /* JADX INFO: renamed from: x, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f7486x = AtomicReferenceFieldUpdater.newUpdater(T.class, Object.class, "_delayed$volatile");

    /* JADX INFO: renamed from: y, reason: collision with root package name */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f7487y = AtomicIntegerFieldUpdater.newUpdater(T.class, "_isCompleted$volatile");
    private volatile /* synthetic */ Object _delayed$volatile;
    private volatile /* synthetic */ int _isCompleted$volatile;
    private volatile /* synthetic */ Object _queue$volatile;

    @Override // Z6.E
    public final void H(long j8, C0369i c0369i) {
        long j9 = j8 > 0 ? j8 >= 9223372036854L ? Long.MAX_VALUE : 1000000 * j8 : 0L;
        if (j9 < 4611686018427387903L) {
            long jNanoTime = System.nanoTime();
            O o8 = new O(this, j9 + jNanoTime, c0369i);
            w0(jNanoTime, o8);
            c0369i.y(new C0365e(2, o8));
        }
    }

    @Override // Z6.AbstractC0378s
    public final void j0(E6.i iVar, Runnable runnable) {
        s0(runnable);
    }

    /* JADX WARN: Code restructure failed: missing block: B:8:0x0018, code lost:
    
        r7 = null;
     */
    @Override // Z6.U
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final long p0() {
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater;
        B3.f fVar;
        Runnable runnable;
        Q q8;
        if (!q0()) {
            t0();
            loop0: while (true) {
                atomicReferenceFieldUpdater = f7485w;
                Object obj = atomicReferenceFieldUpdater.get(this);
                fVar = AbstractC0385z.f7566c;
                if (obj == null) {
                    break;
                }
                if (!(obj instanceof e7.m)) {
                    if (obj != fVar) {
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, null)) {
                            if (atomicReferenceFieldUpdater.get(this) != obj) {
                                break;
                            }
                        }
                        runnable = (Runnable) obj;
                        break loop0;
                    }
                    break;
                }
                e7.m mVar = (e7.m) obj;
                Object objD = mVar.d();
                if (objD != e7.m.f12565g) {
                    runnable = (Runnable) objD;
                    break;
                }
                e7.m mVarC = mVar.c();
                while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, mVarC) && atomicReferenceFieldUpdater.get(this) == obj) {
                }
            }
            if (runnable != null) {
                runnable.run();
                return 0L;
            }
            B6.i iVar = this.f7491u;
            if (((iVar == null || iVar.isEmpty()) ? Long.MAX_VALUE : 0L) != 0) {
                Object obj2 = atomicReferenceFieldUpdater.get(this);
                if (obj2 != null) {
                    if (obj2 instanceof e7.m) {
                        long j8 = e7.m.f12564f.get((e7.m) obj2);
                        if (((int) (1073741823 & j8)) != ((int) ((j8 & 1152921503533105152L) >> 30))) {
                            return 0L;
                        }
                    } else if (obj2 == fVar) {
                        return Long.MAX_VALUE;
                    }
                }
                S s8 = (S) f7486x.get(this);
                if (s8 != null) {
                    synchronized (s8) {
                        Q[] qArr = s8.f12582a;
                        q8 = qArr != null ? qArr[0] : null;
                    }
                    if (q8 != null) {
                        long jNanoTime = q8.f7482q - System.nanoTime();
                        if (jNanoTime >= 0) {
                            return jNanoTime;
                        }
                    }
                }
                return Long.MAX_VALUE;
            }
        }
        return 0L;
    }

    public void s0(Runnable runnable) {
        t0();
        if (!u0(runnable)) {
            A.f7467z.s0(runnable);
            return;
        }
        Thread threadN0 = n0();
        if (Thread.currentThread() != threadN0) {
            LockSupport.unpark(threadN0);
        }
    }

    @Override // Z6.U
    public void shutdown() {
        Q qC;
        t0.f7547a.set(null);
        f7487y.set(this, 1);
        loop0: while (true) {
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f7485w;
            Object obj = atomicReferenceFieldUpdater.get(this);
            B3.f fVar = AbstractC0385z.f7566c;
            if (obj != null) {
                if (!(obj instanceof e7.m)) {
                    if (obj != fVar) {
                        e7.m mVar = new e7.m(8, true);
                        mVar.a((Runnable) obj);
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, mVar)) {
                            if (atomicReferenceFieldUpdater.get(this) != obj) {
                                break;
                            }
                        }
                        break loop0;
                    }
                    break;
                }
                ((e7.m) obj).b();
                break;
            }
            while (!atomicReferenceFieldUpdater.compareAndSet(this, null, fVar)) {
                if (atomicReferenceFieldUpdater.get(this) != null) {
                    break;
                }
            }
            break loop0;
        }
        while (p0() <= 0) {
        }
        long jNanoTime = System.nanoTime();
        while (true) {
            S s8 = (S) f7486x.get(this);
            if (s8 == null) {
                return;
            }
            synchronized (s8) {
                qC = e7.w.f12581b.get(s8) > 0 ? s8.c(0) : null;
            }
            if (qC == null) {
                return;
            } else {
                r0(jNanoTime, qC);
            }
        }
    }

    public final void t0() {
        Q qC;
        S s8 = (S) f7486x.get(this);
        if (s8 == null || e7.w.f12581b.get(s8) == 0) {
            return;
        }
        long jNanoTime = System.nanoTime();
        do {
            synchronized (s8) {
                try {
                    Q[] qArr = s8.f12582a;
                    Q q8 = qArr != null ? qArr[0] : null;
                    if (q8 != null) {
                        qC = ((jNanoTime - q8.f7482q) > 0L ? 1 : ((jNanoTime - q8.f7482q) == 0L ? 0 : -1)) >= 0 ? u0(q8) : false ? s8.c(0) : null;
                    }
                } catch (Throwable th) {
                    throw th;
                }
            }
        } while (qC != null);
    }

    public L u(long j8, Runnable runnable, E6.i iVar) {
        return B.f7469a.u(j8, runnable, iVar);
    }

    /* JADX WARN: Code restructure failed: missing block: B:32:0x0050, code lost:
    
        return false;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean u0(Runnable runnable) {
        loop0: while (true) {
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f7485w;
            Object obj = atomicReferenceFieldUpdater.get(this);
            if (!(f7487y.get(this) == 1)) {
                if (obj != null) {
                    if (!(obj instanceof e7.m)) {
                        if (obj != AbstractC0385z.f7566c) {
                            e7.m mVar = new e7.m(8, true);
                            mVar.a((Runnable) obj);
                            mVar.a(runnable);
                            while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, mVar)) {
                                if (atomicReferenceFieldUpdater.get(this) != obj) {
                                    break;
                                }
                            }
                            break loop0;
                        }
                        break;
                    }
                    e7.m mVar2 = (e7.m) obj;
                    int iA = mVar2.a(runnable);
                    if (iA == 0) {
                        break;
                    }
                    if (iA == 1) {
                        e7.m mVarC = mVar2.c();
                        while (!atomicReferenceFieldUpdater.compareAndSet(this, obj, mVarC) && 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 {
                break;
            }
        }
        return true;
    }

    public final boolean v0() {
        S s8;
        B6.i iVar = this.f7491u;
        if (!(iVar != null ? iVar.isEmpty() : true) || ((s8 = (S) f7486x.get(this)) != null && e7.w.f12581b.get(s8) != 0)) {
            return false;
        }
        Object obj = f7485w.get(this);
        if (obj != null) {
            if (obj instanceof e7.m) {
                long j8 = e7.m.f12564f.get((e7.m) obj);
                return ((int) (1073741823 & j8)) == ((int) ((j8 & 1152921503533105152L) >> 30));
            }
            if (obj != AbstractC0385z.f7566c) {
                return false;
            }
        }
        return true;
    }

    public final void w0(long j8, Q q8) {
        int iD;
        Thread threadN0;
        boolean z8 = f7487y.get(this) == 1;
        AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f7486x;
        if (z8) {
            iD = 1;
        } else {
            S s8 = (S) atomicReferenceFieldUpdater.get(this);
            if (s8 == null) {
                S s9 = new S();
                s9.f7484c = j8;
                while (!atomicReferenceFieldUpdater.compareAndSet(this, null, s9) && atomicReferenceFieldUpdater.get(this) == null) {
                }
                Object obj = atomicReferenceFieldUpdater.get(this);
                P6.g.b(obj);
                s8 = (S) obj;
            }
            iD = q8.d(j8, s8, this);
        }
        if (iD != 0) {
            if (iD == 1) {
                r0(j8, q8);
                return;
            } else {
                if (iD != 2) {
                    throw new IllegalStateException("unexpected result");
                }
                return;
            }
        }
        S s10 = (S) atomicReferenceFieldUpdater.get(this);
        if (s10 != null) {
            synchronized (s10) {
                Q[] qArr = s10.f12582a;
                q = qArr != null ? qArr[0] : null;
            }
        }
        if (q != q8 || Thread.currentThread() == (threadN0 = n0())) {
            return;
        }
        LockSupport.unpark(threadN0);
    }
}