package s.coroutines.scheduling; import com.cvte.vman.instance.InvokeCmd; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceArray; import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; import kotlin.Metadata; /* JADX INFO: renamed from: s.a.c2.n, reason: from Kotlin metadata */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000@\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\t\n\u0002\u0010\t\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0006\n\u0002\u0010\u0000\b\u0000\u0018\u00002\u00020*B\u0007¢\u0006\u0004\b\u0001\u0010\u0002J!\u0010\u0007\u001a\u0004\u0018\u00010\u00032\u0006\u0010\u0004\u001a\u00020\u00032\b\b\u0002\u0010\u0006\u001a\u00020\u0005¢\u0006\u0004\b\u0007\u0010\bJ\u0019\u0010\t\u001a\u0004\u0018\u00010\u00032\u0006\u0010\u0004\u001a\u00020\u0003H\u0002¢\u0006\u0004\b\t\u0010\nJ\u0015\u0010\u000e\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b¢\u0006\u0004\b\u000e\u0010\u000fJ\u000f\u0010\u0010\u001a\u0004\u0018\u00010\u0003¢\u0006\u0004\b\u0010\u0010\u0011J\u0011\u0010\u0012\u001a\u0004\u0018\u00010\u0003H\u0002¢\u0006\u0004\b\u0012\u0010\u0011J\u0017\u0010\u0014\u001a\u00020\u00052\u0006\u0010\u0013\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\u0014\u0010\u0015J\u0015\u0010\u0018\u001a\u00020\u00172\u0006\u0010\u0016\u001a\u00020\u0000¢\u0006\u0004\b\u0018\u0010\u0019J\u0015\u0010\u001a\u001a\u00020\u00172\u0006\u0010\u0016\u001a\u00020\u0000¢\u0006\u0004\b\u001a\u0010\u0019J\u001f\u0010\u001c\u001a\u00020\u00172\u0006\u0010\u0016\u001a\u00020\u00002\u0006\u0010\u001b\u001a\u00020\u0005H\u0002¢\u0006\u0004\b\u001c\u0010\u001dJ\u0015\u0010\u001e\u001a\u00020\r*\u0004\u0018\u00010\u0003H\u0002¢\u0006\u0004\b\u001e\u0010\u001fR\u001c\u0010!\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00030 8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b!\u0010\"R\u0014\u0010&\u001a\u00020#8@X\u0080\u0004¢\u0006\u0006\u001a\u0004\b$\u0010%R\u0014\u0010(\u001a\u00020#8@X\u0080\u0004¢\u0006\u0006\u001a\u0004\b'\u0010%¨\u0006)"}, d2 = {"Lkotlinx/coroutines/scheduling/WorkQueue;", "", "()V", "Lkotlinx/coroutines/scheduling/Task;", "task", "", "fair", "add", "(Lkotlinx/coroutines/scheduling/Task;Z)Lkotlinx/coroutines/scheduling/Task;", "addLast", "(Lkotlinx/coroutines/scheduling/Task;)Lkotlinx/coroutines/scheduling/Task;", "Lkotlinx/coroutines/scheduling/GlobalQueue;", "globalQueue", "", "offloadAllWorkTo", "(Lkotlinx/coroutines/scheduling/GlobalQueue;)V", "poll", "()Lkotlinx/coroutines/scheduling/Task;", "pollBuffer", "queue", "pollTo", "(Lkotlinx/coroutines/scheduling/GlobalQueue;)Z", "victim", "", "tryStealBlockingFrom", "(Lkotlinx/coroutines/scheduling/WorkQueue;)J", "tryStealFrom", "blockingOnly", "tryStealLastScheduled", "(Lkotlinx/coroutines/scheduling/WorkQueue;Z)J", "decrementIfBlocking", "(Lkotlinx/coroutines/scheduling/Task;)V", "Ljava/util/concurrent/atomic/AtomicReferenceArray;", "buffer", "Ljava/util/concurrent/atomic/AtomicReferenceArray;", "", "getBufferSize$kotlinx_coroutines_core", "()I", "bufferSize", "getSize$kotlinx_coroutines_core", "size", "kotlinx-coroutines-core", ""}, k = 1, mv = {1, 6, 0}, xi = 48) public final class WorkQueue { public static final /* synthetic */ AtomicReferenceFieldUpdater a = AtomicReferenceFieldUpdater.newUpdater(WorkQueue.class, Object.class, "lastScheduledTask"); /* JADX INFO: renamed from: b, reason: collision with root package name */ public static final /* synthetic */ AtomicIntegerFieldUpdater f9417b = AtomicIntegerFieldUpdater.newUpdater(WorkQueue.class, "producerIndex"); /* JADX INFO: renamed from: c, reason: collision with root package name */ public static final /* synthetic */ AtomicIntegerFieldUpdater f9418c = AtomicIntegerFieldUpdater.newUpdater(WorkQueue.class, "consumerIndex"); /* JADX INFO: renamed from: d, reason: collision with root package name */ public static final /* synthetic */ AtomicIntegerFieldUpdater f9419d = AtomicIntegerFieldUpdater.newUpdater(WorkQueue.class, "blockingTasksInBuffer"); /* JADX INFO: renamed from: e, reason: collision with root package name */ public final AtomicReferenceArray f9420e = new AtomicReferenceArray<>(128); private volatile /* synthetic */ Object lastScheduledTask = null; private volatile /* synthetic */ int producerIndex = 0; private volatile /* synthetic */ int consumerIndex = 0; private volatile /* synthetic */ int blockingTasksInBuffer = 0; public final Task a(Task task, boolean z2) { if (z2) { return b(task); } Task task2 = (Task) a.getAndSet(this, task); if (task2 == null) { return null; } return b(task2); } public final Task b(Task task) { if (task.f9408m.getA() == 1) { f9419d.incrementAndGet(this); } if (c() == 127) { return task; } int i2 = this.producerIndex & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE; while (this.f9420e.get(i2) != null) { Thread.yield(); } this.f9420e.lazySet(i2, task); f9417b.incrementAndGet(this); return null; } public final int c() { return this.producerIndex - this.consumerIndex; } public final int d() { return this.lastScheduledTask != null ? c() + 1 : c(); } public final Task e() { Task task = (Task) a.getAndSet(this, null); return task == null ? f() : task; } public final Task f() { Task andSet; while (true) { int i2 = this.consumerIndex; if (i2 - this.producerIndex == 0) { return null; } int i3 = i2 & InvokeCmd.CMD_SYSTEMCTRL_IS_PRODUCTION_MODE; if (f9418c.compareAndSet(this, i2, i2 + 1) && (andSet = this.f9420e.getAndSet(i3, null)) != null) { if (andSet.f9408m.getA() == 1) { f9419d.decrementAndGet(this); } return andSet; } } } /* JADX WARN: Code restructure failed: missing block: B:20:0x003d, code lost: return h(r9, true); */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final long g(s.coroutines.scheduling.WorkQueue r9) { /* r8 = this; int r0 = r9.consumerIndex int r1 = r9.producerIndex java.util.concurrent.atomic.AtomicReferenceArray r2 = r9.f9420e L6: r3 = 1 if (r0 == r1) goto L39 r4 = r0 & 127(0x7f, float:1.78E-43) int r5 = r9.blockingTasksInBuffer if (r5 == 0) goto L39 java.lang.Object r5 = r2.get(r4) s.a.c2.h r5 = (s.coroutines.scheduling.Task) r5 if (r5 == 0) goto L36 s.a.c2.i r6 = r5.f9408m int r6 = r6.getA() r7 = 0 if (r6 != r3) goto L21 goto L22 L21: r3 = r7 L22: if (r3 == 0) goto L36 r3 = 0 boolean r3 = r2.compareAndSet(r4, r5, r3) if (r3 == 0) goto L36 java.util.concurrent.atomic.AtomicIntegerFieldUpdater r0 = s.coroutines.scheduling.WorkQueue.f9419d r0.decrementAndGet(r9) r8.a(r5, r7) r0 = -1 return r0 L36: int r0 = r0 + 1 goto L6 L39: long r0 = r8.h(r9, r3) return r0 */ throw new UnsupportedOperationException("Method not decompiled: s.coroutines.scheduling.WorkQueue.g(s.a.c2.n):long"); } public final long h(WorkQueue workQueue, boolean z2) { Task task; do { task = (Task) workQueue.lastScheduledTask; if (task == null) { return -2L; } if (z2) { if (!(task.f9408m.getA() == 1)) { return -2L; } } long jA = l.f9413e.a() - task.f9407f; long j2 = l.a; if (jA < j2) { return j2 - jA; } } while (!a.compareAndSet(workQueue, task, null)); a(task, false); return -1L; } }