package e.a.u.f;

import e.a.u.c.d;
import e.a.u.h.g;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReferenceArray;

/* JADX INFO: compiled from: SpscLinkedArrayQueue.java */
/* JADX INFO: loaded from: classes.dex */
public final class b<T> implements d<T> {
    static final int m = Integer.getInteger("jctools.spsc.max.lookahead.step", 4096).intValue();
    private static final Object n = new Object();

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    int f3783f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    long f3784g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    final int f3785h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    AtomicReferenceArray<Object> f3786i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    final int f3787j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    AtomicReferenceArray<Object> f3788k;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    final AtomicLong f3782b = new AtomicLong();
    final AtomicLong l = new AtomicLong();

    public b(int i2) {
        int iA = g.a(Math.max(8, i2));
        int i3 = iA - 1;
        AtomicReferenceArray<Object> atomicReferenceArray = new AtomicReferenceArray<>(iA + 1);
        this.f3786i = atomicReferenceArray;
        this.f3785h = i3;
        a(iA);
        this.f3788k = atomicReferenceArray;
        this.f3787j = i3;
        this.f3784g = i3 - 1;
        o(0L);
    }

    private void a(int i2) {
        this.f3783f = Math.min(i2 / 4, m);
    }

    private static int b(int i2) {
        return i2;
    }

    private static int c(long j2, int i2) {
        int i3 = ((int) j2) & i2;
        b(i3);
        return i3;
    }

    private long d() {
        return this.l.get();
    }

    private long e() {
        return this.f3782b.get();
    }

    private long f() {
        return this.l.get();
    }

    private static <E> Object g(AtomicReferenceArray<Object> atomicReferenceArray, int i2) {
        return atomicReferenceArray.get(i2);
    }

    private AtomicReferenceArray<Object> h(AtomicReferenceArray<Object> atomicReferenceArray) {
        int length = atomicReferenceArray.length() - 1;
        b(length);
        return (AtomicReferenceArray) g(atomicReferenceArray, length);
    }

    private long i() {
        return this.f3782b.get();
    }

    private T j(AtomicReferenceArray<Object> atomicReferenceArray, long j2, int i2) {
        this.f3788k = atomicReferenceArray;
        int iC = c(j2, i2);
        T t = (T) g(atomicReferenceArray, iC);
        if (t != null) {
            m(atomicReferenceArray, iC, null);
            l(j2 + 1);
        }
        return t;
    }

    private void k(AtomicReferenceArray<Object> atomicReferenceArray, long j2, int i2, T t, long j3) {
        AtomicReferenceArray<Object> atomicReferenceArray2 = new AtomicReferenceArray<>(atomicReferenceArray.length());
        this.f3786i = atomicReferenceArray2;
        this.f3784g = (j3 + j2) - 1;
        m(atomicReferenceArray2, i2, t);
        n(atomicReferenceArray, atomicReferenceArray2);
        m(atomicReferenceArray, i2, n);
        o(j2 + 1);
    }

    private void l(long j2) {
        this.l.lazySet(j2);
    }

    private static void m(AtomicReferenceArray<Object> atomicReferenceArray, int i2, Object obj) {
        atomicReferenceArray.lazySet(i2, obj);
    }

    private void n(AtomicReferenceArray<Object> atomicReferenceArray, AtomicReferenceArray<Object> atomicReferenceArray2) {
        int length = atomicReferenceArray.length() - 1;
        b(length);
        m(atomicReferenceArray, length, atomicReferenceArray2);
    }

    private void o(long j2) {
        this.f3782b.lazySet(j2);
    }

    private boolean p(AtomicReferenceArray<Object> atomicReferenceArray, T t, long j2, int i2) {
        m(atomicReferenceArray, i2, t);
        o(j2 + 1);
        return true;
    }

    @Override // e.a.u.c.e
    public void clear() {
        while (true) {
            if (poll() == null && isEmpty()) {
                return;
            }
        }
    }

    @Override // e.a.u.c.e
    public boolean isEmpty() {
        return i() == f();
    }

    @Override // e.a.u.c.e
    public boolean offer(T t) {
        if (t == null) {
            throw new NullPointerException("Null is not a valid element");
        }
        AtomicReferenceArray<Object> atomicReferenceArray = this.f3786i;
        long jE = e();
        int i2 = this.f3785h;
        int iC = c(jE, i2);
        if (jE < this.f3784g) {
            return p(atomicReferenceArray, t, jE, iC);
        }
        long j2 = ((long) this.f3783f) + jE;
        if (g(atomicReferenceArray, c(j2, i2)) == null) {
            this.f3784g = j2 - 1;
            return p(atomicReferenceArray, t, jE, iC);
        }
        if (g(atomicReferenceArray, c(1 + jE, i2)) == null) {
            return p(atomicReferenceArray, t, jE, iC);
        }
        k(atomicReferenceArray, jE, iC, t, i2);
        return true;
    }

    @Override // e.a.u.c.d, e.a.u.c.e
    public T poll() {
        AtomicReferenceArray<Object> atomicReferenceArray = this.f3788k;
        long jD = d();
        int i2 = this.f3787j;
        int iC = c(jD, i2);
        T t = (T) g(atomicReferenceArray, iC);
        boolean z = t == n;
        if (t == null || z) {
            if (z) {
                return j(h(atomicReferenceArray), jD, i2);
            }
            return null;
        }
        m(atomicReferenceArray, iC, null);
        l(jD + 1);
        return t;
    }
}