package h.a.k1;

import java.util.concurrent.atomic.AtomicLongFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceArray;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;

/* JADX INFO: compiled from: LockFreeTaskQueue.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public final class k<E> {
    private volatile /* synthetic */ Object _next = null;
    private volatile /* synthetic */ long _state = 0;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final int f4262e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final boolean f4263f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final int f4264g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public /* synthetic */ AtomicReferenceArray f4265h;
    public static final a a = new a(null);

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static final r f4261d = new r("REMOVE_FROZEN");

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final /* synthetic */ AtomicReferenceFieldUpdater f4259b = AtomicReferenceFieldUpdater.newUpdater(k.class, Object.class, "_next");

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final /* synthetic */ AtomicLongFieldUpdater f4260c = AtomicLongFieldUpdater.newUpdater(k.class, "_state");

    /* JADX INFO: compiled from: LockFreeTaskQueue.kt */
    @g.i
    public static final class a {
        public a(g.h0.c.g gVar) {
        }
    }

    /* JADX INFO: compiled from: LockFreeTaskQueue.kt */
    @g.i
    public static final class b {
        public final int a;

        public b(int i2) {
            this.a = i2;
        }
    }

    public k(int i2, boolean z) {
        this.f4262e = i2;
        this.f4263f = z;
        int i3 = i2 - 1;
        this.f4264g = i3;
        this.f4265h = new AtomicReferenceArray(i2);
        if (!(i3 <= 1073741823)) {
            throw new IllegalStateException("Check failed.".toString());
        }
        if (!((i2 & i3) == 0)) {
            throw new IllegalStateException("Check failed.".toString());
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:19:0x004e, code lost:
    
        return 1;
     */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final int a(E r15) {
        /*
            r14 = this;
        L0:
            long r2 = r14._state
            r0 = 3458764513820540928(0x3000000000000000, double:1.727233711018889E-77)
            long r0 = r0 & r2
            r6 = 0
            int r0 = (r0 > r6 ? 1 : (r0 == r6 ? 0 : -1))
            r1 = 1
            if (r0 == 0) goto L15
            r4 = 2305843009213693952(0x2000000000000000, double:1.4916681462400413E-154)
            long r2 = r2 & r4
            int r15 = (r2 > r6 ? 1 : (r2 == r6 ? 0 : -1))
            if (r15 == 0) goto L14
            r1 = 2
        L14:
            return r1
        L15:
            r4 = 1073741823(0x3fffffff, double:5.304989472E-315)
            long r4 = r4 & r2
            r8 = 0
            long r4 = r4 >> r8
            int r0 = (int) r4
            r4 = 1152921503533105152(0xfffffffc0000000, double:1.2882296003504729E-231)
            long r4 = r4 & r2
            r9 = 30
            long r4 = r4 >> r9
            int r10 = (int) r4
            int r11 = r14.f4264g
            int r4 = r10 + 2
            r4 = r4 & r11
            r5 = r0 & r11
            if (r4 != r5) goto L30
            return r1
        L30:
            boolean r4 = r14.f4263f
            r5 = 1073741823(0x3fffffff, float:1.9999999)
            if (r4 != 0) goto L4f
            java.util.concurrent.atomic.AtomicReferenceArray r4 = r14.f4265h
            r12 = r10 & r11
            java.lang.Object r4 = r4.get(r12)
            if (r4 == 0) goto L4f
            int r2 = r14.f4262e
            r3 = 1024(0x400, float:1.435E-42)
            if (r2 < r3) goto L4e
            int r10 = r10 - r0
            r0 = r10 & r5
            int r2 = r2 >> 1
            if (r0 <= r2) goto L0
        L4e:
            return r1
        L4f:
            int r0 = r10 + 1
            r0 = r0 & r5
            java.util.concurrent.atomic.AtomicLongFieldUpdater r1 = h.a.k1.k.f4260c
            r4 = -1152921503533105153(0xf00000003fffffff, double:-3.1050369248997324E231)
            long r4 = r4 & r2
            long r12 = (long) r0
            long r12 = r12 << r9
            long r4 = r4 | r12
            r0 = r1
            r1 = r14
            boolean r0 = r0.compareAndSet(r1, r2, r4)
            if (r0 == 0) goto L0
            java.util.concurrent.atomic.AtomicReferenceArray r0 = r14.f4265h
            r1 = r10 & r11
            r0.set(r1, r15)
            r0 = r14
        L6d:
            long r1 = r0._state
            r3 = 1152921504606846976(0x1000000000000000, double:1.2882297539194267E-231)
            long r1 = r1 & r3
            int r1 = (r1 > r6 ? 1 : (r1 == r6 ? 0 : -1))
            if (r1 != 0) goto L77
            goto L9a
        L77:
            h.a.k1.k r0 = r0.e()
            java.util.concurrent.atomic.AtomicReferenceArray r1 = r0.f4265h
            int r2 = r0.f4264g
            r2 = r2 & r10
            java.lang.Object r1 = r1.get(r2)
            boolean r2 = r1 instanceof h.a.k1.k.b
            if (r2 == 0) goto L97
            h.a.k1.k$b r1 = (h.a.k1.k.b) r1
            int r1 = r1.a
            if (r1 != r10) goto L97
            java.util.concurrent.atomic.AtomicReferenceArray r1 = r0.f4265h
            int r2 = r0.f4264g
            r2 = r2 & r10
            r1.set(r2, r15)
            goto L98
        L97:
            r0 = 0
        L98:
            if (r0 != 0) goto L6d
        L9a:
            return r8
        */
        throw new UnsupportedOperationException("Method not decompiled: h.a.k1.k.a(java.lang.Object):int");
    }

    public final boolean b() {
        long j2;
        do {
            j2 = this._state;
            if ((j2 & 2305843009213693952L) != 0) {
                return true;
            }
            if ((1152921504606846976L & j2) != 0) {
                return false;
            }
        } while (!f4260c.compareAndSet(this, j2, j2 | 2305843009213693952L));
        return true;
    }

    public final int c() {
        long j2 = this._state;
        return (((int) ((j2 & 1152921503533105152L) >> 30)) - ((int) ((1073741823 & j2) >> 0))) & 1073741823;
    }

    public final boolean d() {
        long j2 = this._state;
        return ((int) ((1073741823 & j2) >> 0)) == ((int) ((j2 & 1152921503533105152L) >> 30));
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final k<E> e() {
        long j2;
        while (true) {
            j2 = this._state;
            if ((j2 & 1152921504606846976L) != 0) {
                break;
            }
            long j3 = j2 | 1152921504606846976L;
            if (f4260c.compareAndSet(this, j2, j3)) {
                j2 = j3;
                break;
            }
        }
        while (true) {
            k<E> kVar = (k) this._next;
            if (kVar != null) {
                return kVar;
            }
            AtomicReferenceFieldUpdater atomicReferenceFieldUpdater = f4259b;
            k kVar2 = new k(this.f4262e * 2, this.f4263f);
            int i2 = (int) ((1073741823 & j2) >> 0);
            int i3 = (int) ((1152921503533105152L & j2) >> 30);
            while (true) {
                int i4 = this.f4264g;
                int i5 = i2 & i4;
                if (i5 != (i4 & i3)) {
                    Object bVar = this.f4265h.get(i5);
                    if (bVar == null) {
                        bVar = new b(i2);
                    }
                    kVar2.f4265h.set(kVar2.f4264g & i2, bVar);
                    i2++;
                }
            }
            kVar2._state = (-1152921504606846977L) & j2;
            atomicReferenceFieldUpdater.compareAndSet(this, null, kVar2);
        }
    }

    public final Object f() {
        while (true) {
            long j2 = this._state;
            if ((j2 & 1152921504606846976L) != 0) {
                return f4261d;
            }
            int i2 = (int) ((j2 & 1073741823) >> 0);
            int i3 = this.f4264g;
            int i4 = ((int) ((1152921503533105152L & j2) >> 30)) & i3;
            int i5 = i3 & i2;
            if (i4 == i5) {
                return null;
            }
            Object obj = this.f4265h.get(i5);
            if (obj == null) {
                if (this.f4263f) {
                    return null;
                }
            } else {
                if (obj instanceof b) {
                    return null;
                }
                long j3 = ((long) ((i2 + 1) & 1073741823)) << 0;
                if (f4260c.compareAndSet(this, j2, (j2 & (-1073741824)) | j3)) {
                    this.f4265h.set(this.f4264g & i2, null);
                    return obj;
                }
                if (this.f4263f) {
                    k<E> kVarE = this;
                    while (true) {
                        long j4 = kVarE._state;
                        int i6 = (int) ((j4 & 1073741823) >> 0);
                        if ((j4 & 1152921504606846976L) != 0) {
                            kVarE = kVarE.e();
                        } else {
                            if (f4260c.compareAndSet(kVarE, j4, (j4 & (-1073741824)) | j3)) {
                                kVarE.f4265h.set(kVarE.f4264g & i6, null);
                                kVarE = null;
                            } else {
                                continue;
                            }
                        }
                        if (kVarE == null) {
                            return obj;
                        }
                    }
                }
            }
        }
    }
}