package defpackage;

import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import sun.misc.Unsafe;

/* JADX INFO: renamed from: ᵮᵙᵶ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4232 {
    private volatile /* synthetic */ int blockingTasksInBuffer$volatile;
    private volatile /* synthetic */ int consumerIndex$volatile;
    private volatile /* synthetic */ Object lastScheduledTask$volatile;
    private volatile /* synthetic */ int producerIndex$volatile;

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final AtomicReferenceArray f16146 = new AtomicReferenceArray(128);

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f16141 = AtomicReferenceFieldUpdater.newUpdater(C4232.class, Object.class, "lastScheduledTask$volatile");

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public static final /* synthetic */ long f16145 = AbstractC1929.f7689.objectFieldOffset(C4232.class.getDeclaredField("lastScheduledTask$volatile"));

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f16142 = AtomicIntegerFieldUpdater.newUpdater(C4232.class, "producerIndex$volatile");

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f16144 = AtomicIntegerFieldUpdater.newUpdater(C4232.class, "consumerIndex$volatile");

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public static final /* synthetic */ AtomicIntegerFieldUpdater f16143 = AtomicIntegerFieldUpdater.newUpdater(C4232.class, "blockingTasksInBuffer$volatile");

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final int m9204() {
        f16141.getClass();
        Object objectVolatile = AbstractC1929.f7689.getObjectVolatile(this, f16145);
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f16144;
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater2 = f16142;
        return objectVolatile != null ? (atomicIntegerFieldUpdater2.get(this) - atomicIntegerFieldUpdater.get(this)) + 1 : atomicIntegerFieldUpdater2.get(this) - atomicIntegerFieldUpdater.get(this);
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9205() {
        AbstractRunnableC1361 abstractRunnableC1361;
        while (true) {
            AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f16144;
            int i = atomicIntegerFieldUpdater.get(this);
            if (i - f16142.get(this) == 0) {
                return null;
            }
            int i2 = i & 127;
            if (atomicIntegerFieldUpdater.compareAndSet(this, i, i + 1) && (abstractRunnableC1361 = (AbstractRunnableC1361) this.f16146.getAndSet(i2, null)) != null) {
                if (abstractRunnableC1361.f5634) {
                    f16143.decrementAndGet(this);
                }
                return abstractRunnableC1361;
            }
        }
    }

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9206(int i, boolean z) {
        int i2 = i & 127;
        AtomicReferenceArray atomicReferenceArray = this.f16146;
        AbstractRunnableC1361 abstractRunnableC1361 = (AbstractRunnableC1361) atomicReferenceArray.get(i2);
        if (abstractRunnableC1361 != null && abstractRunnableC1361.f5634 == z) {
            while (!atomicReferenceArray.compareAndSet(i2, abstractRunnableC1361, null)) {
                if (atomicReferenceArray.get(i2) != abstractRunnableC1361) {
                }
            }
            if (z) {
                f16143.decrementAndGet(this);
            }
            return abstractRunnableC1361;
        }
        return null;
    }

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final AbstractRunnableC1361 m9207(AbstractRunnableC1361 abstractRunnableC1361) {
        AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f16142;
        if (atomicIntegerFieldUpdater.get(this) - f16144.get(this) == 127) {
            return abstractRunnableC1361;
        }
        if (abstractRunnableC1361.f5634) {
            f16143.incrementAndGet(this);
        }
        int i = atomicIntegerFieldUpdater.get(this) & 127;
        while (true) {
            AtomicReferenceArray atomicReferenceArray = this.f16146;
            if (atomicReferenceArray.get(i) == null) {
                atomicReferenceArray.lazySet(i, abstractRunnableC1361);
                atomicIntegerFieldUpdater.incrementAndGet(this);
                return null;
            }
            Thread.yield();
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:14:0x0030, code lost:
    
        r9 = defpackage.C4232.f16144.get(r4);
        r1 = defpackage.C4232.f16142.get(r4);
     */
    /* JADX WARN: Code restructure failed: missing block: B:15:0x003c, code lost:
    
        if (r9 == r1) goto L30;
     */
    /* JADX WARN: Code restructure failed: missing block: B:17:0x0044, code lost:
    
        if (defpackage.C4232.f16143.get(r4) != 0) goto L19;
     */
    /* JADX WARN: Code restructure failed: missing block: B:19:0x0047, code lost:
    
        r1 = r1 - 1;
        r2 = r4.m9206(r1, true);
     */
    /* JADX WARN: Code restructure failed: missing block: B:20:0x004d, code lost:
    
        if (r2 == null) goto L31;
     */
    /* JADX WARN: Code restructure failed: missing block: B:21:0x004f, code lost:
    
        return r2;
     */
    /* JADX WARN: Code restructure failed: missing block: B:22:0x0050, code lost:
    
        return null;
     */
    /* JADX WARN: Code restructure failed: missing block: B:32:?, code lost:
    
        return null;
     */
    /* JADX WARN: Code restructure failed: missing block: B:4:0x0013, code lost:
    
        r4 = r9;
     */
    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final AbstractRunnableC1361 m9208() {
        C4232 c4232;
        while (true) {
            f16141.getClass();
            Unsafe unsafe = AbstractC1929.f7689;
            long j = f16145;
            AbstractRunnableC1361 abstractRunnableC1361 = (AbstractRunnableC1361) unsafe.getObjectVolatile(this, j);
            if (abstractRunnableC1361 == null || !abstractRunnableC1361.f5634) {
                break;
            }
            while (true) {
                Unsafe unsafe2 = AbstractC1929.f7689;
                c4232 = this;
                if (unsafe2.compareAndSwapObject(c4232, f16145, abstractRunnableC1361, (Object) null)) {
                    return abstractRunnableC1361;
                }
                if (unsafe2.getObjectVolatile(c4232, j) != abstractRunnableC1361) {
                    break;
                }
                this = c4232;
            }
            this = c4232;
        }
    }

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public final long m9209(int i, C2761 c2761) {
        C4232 c4232;
        while (true) {
            f16141.getClass();
            Unsafe unsafe = AbstractC1929.f7689;
            long j = f16145;
            AbstractRunnableC1361 abstractRunnableC1361 = (AbstractRunnableC1361) unsafe.getObjectVolatile(this, j);
            if (abstractRunnableC1361 == null) {
                return -2L;
            }
            if (((abstractRunnableC1361.f5634 ? 1 : 2) & i) == 0) {
                return -2L;
            }
            AbstractC5244.f19768.getClass();
            long jNanoTime = System.nanoTime() - abstractRunnableC1361.f5633;
            long j2 = AbstractC5244.f19763;
            if (jNanoTime < j2) {
                return j2 - jNanoTime;
            }
            while (true) {
                Unsafe unsafe2 = AbstractC1929.f7689;
                c4232 = this;
                if (unsafe2.compareAndSwapObject(c4232, f16145, abstractRunnableC1361, (Object) null)) {
                    c2761.f10617 = abstractRunnableC1361;
                    return -1L;
                }
                if (unsafe2.getObjectVolatile(c4232, j) != abstractRunnableC1361) {
                    break;
                }
                this = c4232;
            }
            this = c4232;
        }
    }
}