package defpackage; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceArray; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import sun.misc.Unsafe; /* renamed from: ᵢᵵᵲˋ, reason: contains not printable characters */ /* loaded from: classes3.dex */ public final class C3302 { private volatile /* synthetic */ int blockingTasksInBuffer$volatile; private volatile /* synthetic */ int consumerIndex$volatile; private volatile /* synthetic */ Object lastScheduledTask$volatile; private volatile /* synthetic */ int producerIndex$volatile; /* renamed from: ᵥᵯˎ, reason: contains not printable characters */ public final AtomicReferenceArray f12372 = new AtomicReferenceArray(128); /* renamed from: ᵴᵳ, reason: contains not printable characters */ public static final /* synthetic */ AtomicReferenceFieldUpdater f12370 = AtomicReferenceFieldUpdater.newUpdater(C3302.class, Object.class, "lastScheduledTask$volatile"); /* renamed from: ˏˋٴ, reason: contains not printable characters */ public static final /* synthetic */ long f12368 = AbstractC3747.f13986.objectFieldOffset(C3302.class.getDeclaredField("lastScheduledTask$volatile")); /* renamed from: ˏᵙ, reason: contains not printable characters */ public static final /* synthetic */ AtomicIntegerFieldUpdater f12369 = AtomicIntegerFieldUpdater.newUpdater(C3302.class, "producerIndex$volatile"); /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */ public static final /* synthetic */ AtomicIntegerFieldUpdater f12371 = AtomicIntegerFieldUpdater.newUpdater(C3302.class, "consumerIndex$volatile"); /* renamed from: ˇʼʤˎ, reason: contains not printable characters */ public static final /* synthetic */ AtomicIntegerFieldUpdater f12367 = AtomicIntegerFieldUpdater.newUpdater(C3302.class, "blockingTasksInBuffer$volatile"); /* renamed from: ˇʼʤˎ, reason: contains not printable characters */ public final AbstractRunnableC2488 m7686(int i, boolean z) { int i2 = i & 127; AtomicReferenceArray atomicReferenceArray = this.f12372; AbstractRunnableC2488 abstractRunnableC2488 = (AbstractRunnableC2488) atomicReferenceArray.get(i2); if (abstractRunnableC2488 != null && abstractRunnableC2488.f9713 == z) { while (!atomicReferenceArray.compareAndSet(i2, abstractRunnableC2488, null)) { if (atomicReferenceArray.get(i2) != abstractRunnableC2488) { } } if (z) { f12367.decrementAndGet(this); } return abstractRunnableC2488; } return null; } /* renamed from: ˏˋٴ, reason: contains not printable characters */ public final long m7687(int i, C3057 c3057) { C3302 c3302; while (true) { f12370.getClass(); Unsafe unsafe = AbstractC3747.f13986; long j = f12368; AbstractRunnableC2488 abstractRunnableC2488 = (AbstractRunnableC2488) unsafe.getObjectVolatile(this, j); if (abstractRunnableC2488 == null) { return -2L; } if (((abstractRunnableC2488.f9713 ? 1 : 2) & i) == 0) { return -2L; } AbstractC2478.f9687.getClass(); long jNanoTime = System.nanoTime() - abstractRunnableC2488.f9714; long j2 = AbstractC2478.f9690; if (jNanoTime < j2) { return j2 - jNanoTime; } while (true) { Unsafe unsafe2 = AbstractC3747.f13986; c3302 = this; if (unsafe2.compareAndSwapObject(c3302, f12368, abstractRunnableC2488, (Object) null)) { c3057.f11710 = abstractRunnableC2488; return -1L; } if (unsafe2.getObjectVolatile(c3302, j) != abstractRunnableC2488) { break; } this = c3302; } this = c3302; } } /* renamed from: ˏᵙ, reason: contains not printable characters */ public final AbstractRunnableC2488 m7688() { AbstractRunnableC2488 abstractRunnableC2488; while (true) { AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f12371; int i = atomicIntegerFieldUpdater.get(this); if (i - f12369.get(this) == 0) { return null; } int i2 = i & 127; if (atomicIntegerFieldUpdater.compareAndSet(this, i, i + 1) && (abstractRunnableC2488 = (AbstractRunnableC2488) this.f12372.getAndSet(i2, null)) != null) { if (abstractRunnableC2488.f9713) { f12367.decrementAndGet(this); } return abstractRunnableC2488; } } } /* renamed from: ᵥᵯˎ, reason: contains not printable characters */ public final AbstractRunnableC2488 m7689(AbstractRunnableC2488 abstractRunnableC2488) { AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f12369; if (atomicIntegerFieldUpdater.get(this) - f12371.get(this) == 127) { return abstractRunnableC2488; } if (abstractRunnableC2488.f9713) { f12367.incrementAndGet(this); } int i = atomicIntegerFieldUpdater.get(this) & 127; while (true) { AtomicReferenceArray atomicReferenceArray = this.f12372; if (atomicReferenceArray.get(i) == null) { atomicReferenceArray.lazySet(i, abstractRunnableC2488); atomicIntegerFieldUpdater.incrementAndGet(this); return null; } Thread.yield(); } } /* renamed from: ᵴᵳ, reason: contains not printable characters */ public final int m7690() { f12370.getClass(); Object objectVolatile = AbstractC3747.f13986.getObjectVolatile(this, f12368); AtomicIntegerFieldUpdater atomicIntegerFieldUpdater = f12371; AtomicIntegerFieldUpdater atomicIntegerFieldUpdater2 = f12369; return objectVolatile != null ? (atomicIntegerFieldUpdater2.get(this) - atomicIntegerFieldUpdater.get(this)) + 1 : atomicIntegerFieldUpdater2.get(this) - atomicIntegerFieldUpdater.get(this); } /* JADX WARN: Code restructure failed: missing block: B:14:0x0030, code lost: r9 = defpackage.C3302.f12371.get(r4); r1 = defpackage.C3302.f12369.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.C3302.f12367.get(r4) != 0) goto L19; */ /* JADX WARN: Code restructure failed: missing block: B:19:0x0047, code lost: r1 = r1 - 1; r2 = r4.m7686(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; */ /* renamed from: ᵻᵢﹳᵰ, reason: contains not printable characters */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final defpackage.AbstractRunnableC2488 m7691() { /* r9 = this; L0: java.util.concurrent.atomic.AtomicReferenceFieldUpdater r0 = defpackage.C3302.f12370 r0.getClass() sun.misc.Unsafe r0 = defpackage.AbstractC3747.f13986 long r1 = defpackage.C3302.f12368 java.lang.Object r0 = r0.getObjectVolatile(r9, r1) r7 = r0 ᵗᵿᵛ r7 = (defpackage.AbstractRunnableC2488) r7 r0 = 1 if (r7 != 0) goto L15 L13: r4 = r9 goto L30 L15: boolean r3 = r7.f9713 if (r3 != r0) goto L13 L19: sun.misc.Unsafe r3 = defpackage.AbstractC3747.f13986 long r5 = defpackage.C3302.f12368 r8 = 0 r4 = r9 boolean r9 = r3.compareAndSwapObject(r4, r5, r7, r8) if (r9 == 0) goto L26 return r7 L26: java.lang.Object r9 = r3.getObjectVolatile(r4, r1) if (r9 == r7) goto L2e r9 = r4 goto L0 L2e: r9 = r4 goto L19 L30: java.util.concurrent.atomic.AtomicIntegerFieldUpdater r9 = defpackage.C3302.f12371 int r9 = r9.get(r4) java.util.concurrent.atomic.AtomicIntegerFieldUpdater r1 = defpackage.C3302.f12369 int r1 = r1.get(r4) L3c: if (r9 == r1) goto L50 java.util.concurrent.atomic.AtomicIntegerFieldUpdater r2 = defpackage.C3302.f12367 int r2 = r2.get(r4) if (r2 != 0) goto L47 goto L50 L47: int r1 = r1 + (-1) ᵗᵿᵛ r2 = r4.m7686(r1, r0) if (r2 == 0) goto L3c return r2 L50: r9 = 0 return r9 */ throw new UnsupportedOperationException("Method not decompiled: defpackage.C3302.m7691():ᵗᵿᵛ"); } }