package p025.p026;

import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.concurrent.locks.LockSupport;
import p025.p026.p027.C1277;
import p025.p026.p027.C1288;
import p025.p026.p027.C1298;
import p025.p026.p027.InterfaceC1299;
import p138.p139.p143.p144.C2803;
import p402.C6549;
import p402.InterfaceC6540;
import p402.p405.InterfaceC6578;
import p402.p411.p413.C6635;

/* JADX INFO: renamed from: އ.֏.ࢢ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
@InterfaceC6540
public abstract class AbstractC1346 extends AbstractC1351 implements InterfaceC1335 {

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public static final AtomicReferenceFieldUpdater f4495 = AtomicReferenceFieldUpdater.newUpdater(AbstractC1346.class, Object.class, "_queue");

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public static final AtomicReferenceFieldUpdater f4496 = AtomicReferenceFieldUpdater.newUpdater(AbstractC1346.class, Object.class, "_delayed");
    public volatile Object _queue = null;
    public volatile Object _delayed = null;
    public volatile int _isCompleted = 0;

    /* JADX INFO: renamed from: އ.֏.ࢢ$֏, reason: contains not printable characters */
    public final class C1347 extends AbstractRunnableC1349 {

        /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
        public final InterfaceC1306<C6549> f4497;

        /* JADX WARN: Multi-variable type inference failed */
        public C1347(long j, InterfaceC1306<? super C6549> interfaceC1306) {
            super(j);
            this.f4497 = interfaceC1306;
        }

        @Override // java.lang.Runnable
        public void run() {
            this.f4497.mo2621(AbstractC1346.this, C6549.f19328);
        }

        @Override // p025.p026.AbstractC1346.AbstractRunnableC1349
        public String toString() {
            return super.toString() + this.f4497.toString();
        }
    }

    /* JADX INFO: renamed from: އ.֏.ࢢ$ؠ, reason: contains not printable characters */
    public static final class C1348 extends AbstractRunnableC1349 {

        /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
        public final Runnable f4499;

        public C1348(long j, Runnable runnable) {
            super(j);
            this.f4499 = runnable;
        }

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

        @Override // p025.p026.AbstractC1346.AbstractRunnableC1349
        public String toString() {
            return super.toString() + this.f4499.toString();
        }
    }

    /* JADX INFO: renamed from: އ.֏.ࢢ$ހ, reason: contains not printable characters */
    public static abstract class AbstractRunnableC1349 implements Runnable, Comparable<AbstractRunnableC1349>, InterfaceC1341, InterfaceC1299 {

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public Object f4500;

        /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
        public int f4501 = -1;

        /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
        public long f4502;

        public AbstractRunnableC1349(long j) {
            this.f4502 = j;
        }

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

        public String toString() {
            StringBuilder sbM4889 = C2803.m4889("Delayed[nanos=");
            sbM4889.append(this.f4502);
            sbM4889.append(']');
            return sbM4889.toString();
        }

        /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
        public final synchronized int m2680(long j, C1350 c1350, AbstractC1346 abstractC1346) {
            if (this.f4500 == C1352.f4504) {
                return 2;
            }
            synchronized (c1350) {
                AbstractRunnableC1349 abstractRunnableC1349M2595 = c1350.m2595();
                if (abstractC1346._isCompleted != 0) {
                    return 1;
                }
                if (abstractRunnableC1349M2595 == null) {
                    c1350.f4503 = j;
                } else {
                    long j2 = abstractRunnableC1349M2595.f4502;
                    if (j2 - j < 0) {
                        j = j2;
                    }
                    if (j - c1350.f4503 > 0) {
                        c1350.f4503 = j;
                    }
                }
                if (this.f4502 - c1350.f4503 < 0) {
                    this.f4502 = c1350.f4503;
                }
                c1350.m2598(this);
                return 0;
            }
        }

        @Override // p025.p026.p027.InterfaceC1299
        /* JADX INFO: renamed from: ֏ */
        public void mo2603(int i) {
            this.f4501 = i;
        }

        @Override // p025.p026.p027.InterfaceC1299
        /* JADX INFO: renamed from: ֏ */
        public void mo2604(C1298<?> c1298) {
            if (!(this.f4500 != C1352.f4504)) {
                throw new IllegalArgumentException("Failed requirement.".toString());
            }
            this.f4500 = c1298;
        }

        @Override // p025.p026.InterfaceC1341
        /* JADX INFO: renamed from: ރ */
        public final synchronized void mo2666() {
            Object obj = this.f4500;
            if (obj == C1352.f4504) {
                return;
            }
            if (!(obj instanceof C1350)) {
                obj = null;
            }
            C1350 c1350 = (C1350) obj;
            if (c1350 != null) {
                c1350.m2601(this);
            }
            this.f4500 = C1352.f4504;
        }

        @Override // p025.p026.p027.InterfaceC1299
        /* JADX INFO: renamed from: ބ */
        public int mo2605() {
            return this.f4501;
        }

        @Override // p025.p026.p027.InterfaceC1299
        /* JADX INFO: renamed from: ޅ */
        public C1298<?> mo2606() {
            Object obj = this.f4500;
            if (!(obj instanceof C1298)) {
                obj = null;
            }
            return (C1298) obj;
        }
    }

    /* JADX INFO: renamed from: އ.֏.ࢢ$ށ, reason: contains not printable characters */
    public static final class C1350 extends C1298<AbstractRunnableC1349> {

        /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
        public long f4503;

        public C1350(long j) {
            this.f4503 = j;
        }
    }

    /* JADX INFO: renamed from: ֏ */
    public InterfaceC1341 mo2655(long j, Runnable runnable) {
        return C1331.f4472.mo2655(j, runnable);
    }

    @Override // p025.p026.InterfaceC1335
    /* JADX INFO: renamed from: ֏ */
    public void mo2662(long j, InterfaceC1306<? super C6549> interfaceC1306) {
        long jM2681 = C1352.m2681(j);
        if (jM2681 < 4611686018427387903L) {
            long jNanoTime = System.nanoTime();
            C1347 c1347 = new C1347(jM2681 + jNanoTime, interfaceC1306);
            interfaceC1306.mo2624(new C1342(c1347));
            m2675(jNanoTime, (AbstractRunnableC1349) c1347);
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m2675(long j, AbstractRunnableC1349 abstractRunnableC1349) {
        int iM2680;
        Thread threadMo2618;
        if (this._isCompleted != 0) {
            iM2680 = 1;
        } else {
            C1350 c1350 = (C1350) this._delayed;
            if (c1350 == null) {
                f4496.compareAndSet(this, null, new C1350(j));
                Object obj = this._delayed;
                if (obj == null) {
                    C6635.m9822();
                    throw null;
                }
                c1350 = (C1350) obj;
            }
            iM2680 = abstractRunnableC1349.m2680(j, c1350, this);
        }
        if (iM2680 != 0) {
            if (iM2680 == 1) {
                RunnableC1330.f4471.m2675(j, abstractRunnableC1349);
                return;
            } else {
                if (iM2680 != 2) {
                    throw new IllegalStateException("unexpected result".toString());
                }
                return;
            }
        }
        C1350 c13502 = (C1350) this._delayed;
        if (!((c13502 != null ? c13502.m2599() : null) == abstractRunnableC1349) || Thread.currentThread() == (threadMo2618 = mo2618())) {
            return;
        }
        LockSupport.unpark(threadMo2618);
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m2676(Runnable runnable) {
        if (!m2677(runnable)) {
            RunnableC1330.f4471.m2676(runnable);
            return;
        }
        Thread threadMo2618 = mo2618();
        if (Thread.currentThread() != threadMo2618) {
            LockSupport.unpark(threadMo2618);
        }
    }

    @Override // p025.p026.AbstractC1323
    /* JADX INFO: renamed from: ֏ */
    public final void mo2643(InterfaceC6578 interfaceC6578, Runnable runnable) {
        m2676(runnable);
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final boolean m2677(Runnable runnable) {
        while (true) {
            Object obj = this._queue;
            if (this._isCompleted != 0) {
                return false;
            }
            if (obj == null) {
                if (f4495.compareAndSet(this, null, runnable)) {
                    return true;
                }
            } else if (obj instanceof C1288) {
                C1288 c1288 = (C1288) obj;
                int iM2585 = c1288.m2585(runnable);
                if (iM2585 == 0) {
                    return true;
                }
                if (iM2585 == 1) {
                    f4495.compareAndSet(this, obj, c1288.m2588());
                } else if (iM2585 == 2) {
                    return false;
                }
            } else {
                if (obj == C1352.f4505) {
                    return false;
                }
                C1288 c12882 = new C1288(8, true);
                c12882.m2585((Runnable) obj);
                c12882.m2585(runnable);
                if (f4495.compareAndSet(this, obj, c12882)) {
                    return true;
                }
            }
        }
    }

    /* JADX INFO: renamed from: ލ, reason: contains not printable characters */
    public boolean m2678() {
        C1277<AbstractC1339<?>> c1277 = this.f4494;
        if (!(c1277 == null || c1277.f4406 == c1277.f4407)) {
            return false;
        }
        C1350 c1350 = (C1350) this._delayed;
        if (c1350 != null) {
            if (!(c1350._size == 0)) {
                return false;
            }
        }
        Object obj = this._queue;
        if (obj == null) {
            return true;
        }
        return obj instanceof C1288 ? ((C1288) obj).m2587() : obj == C1352.f4505;
    }

    /* JADX WARN: Removed duplicated region for block: B:106:? A[RETURN, SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:64:0x009d  */
    /* JADX WARN: Removed duplicated region for block: B:83:0x00cf  */
    /* JADX INFO: renamed from: ސ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public long m2679() {
        long j;
        C1350 c1350;
        AbstractRunnableC1349 abstractRunnableC1349M2599;
        long jNanoTime;
        AbstractRunnableC1349 abstractRunnableC1349M2596;
        if (m2674()) {
            return 0L;
        }
        C1350 c13502 = (C1350) this._delayed;
        Runnable runnable = null;
        if (c13502 != null) {
            if (!(c13502._size == 0)) {
                long jNanoTime2 = System.nanoTime();
                do {
                    synchronized (c13502) {
                        AbstractRunnableC1349 abstractRunnableC1349M2595 = c13502.m2595();
                        if (abstractRunnableC1349M2595 != null) {
                            AbstractRunnableC1349 abstractRunnableC1349 = abstractRunnableC1349M2595;
                            abstractRunnableC1349M2596 = ((jNanoTime2 - abstractRunnableC1349.f4502) > 0L ? 1 : ((jNanoTime2 - abstractRunnableC1349.f4502) == 0L ? 0 : -1)) >= 0 ? m2677(abstractRunnableC1349) : false ? c13502.m2596(0) : null;
                        } else {
                            abstractRunnableC1349M2596 = null;
                        }
                    }
                } while (abstractRunnableC1349M2596 != null);
            }
        }
        while (true) {
            Object obj = this._queue;
            if (obj == null) {
                break;
            }
            if (!(obj instanceof C1288)) {
                if (obj == C1352.f4505) {
                    break;
                }
                if (f4495.compareAndSet(this, obj, null)) {
                    runnable = (Runnable) obj;
                    break;
                }
            } else {
                C1288 c1288 = (C1288) obj;
                Object objM2589 = c1288.m2589();
                if (objM2589 != C1288.f4421) {
                    runnable = (Runnable) objM2589;
                    break;
                }
                f4495.compareAndSet(this, obj, c1288.m2588());
            }
        }
        if (runnable != null) {
            runnable.run();
            return 0L;
        }
        C1277<AbstractC1339<?>> c1277 = this.f4494;
        if (c1277 == null) {
            j = Long.MAX_VALUE;
        } else {
            if (!(c1277.f4406 == c1277.f4407)) {
                j = 0;
            }
        }
        if (j == 0) {
            return 0L;
        }
        Object obj2 = this._queue;
        if (obj2 == null) {
            c1350 = (C1350) this._delayed;
            if (c1350 != null) {
                jNanoTime = abstractRunnableC1349M2599.f4502 - System.nanoTime();
                if (jNanoTime >= 0) {
                }
            }
        } else if (obj2 instanceof C1288) {
            if (!((C1288) obj2).m2587()) {
                return 0L;
            }
            c1350 = (C1350) this._delayed;
            if (c1350 != null && (abstractRunnableC1349M2599 = c1350.m2599()) != null) {
                jNanoTime = abstractRunnableC1349M2599.f4502 - System.nanoTime();
                if (jNanoTime >= 0) {
                    return 0L;
                }
                return jNanoTime;
            }
        } else if (obj2 != C1352.f4505) {
            return 0L;
        }
        return Long.MAX_VALUE;
    }
}