package d.a.w;

import d.a.l;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public final class a<T> extends c<T> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final C0085a[] f5919b = new C0085a[0];

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final C0085a[] f5920c = new C0085a[0];

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicReference<C0085a<T>[]> f5921d = new AtomicReference<>(f5920c);

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public Throwable f5922e;

    /* JADX INFO: renamed from: d.a.w.a$a, reason: collision with other inner class name */
    public static final class C0085a<T> extends AtomicBoolean implements d.a.p.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final l<? super T> f5923b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public final a<T> f5924c;

        public C0085a(l<? super T> lVar, a<T> aVar) {
            this.f5923b = lVar;
            this.f5924c = aVar;
        }

        @Override // d.a.p.b
        public void dispose() {
            if (compareAndSet(false, true)) {
                this.f5924c.s(this);
            }
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return get();
        }
    }

    @Override // d.a.l
    public void a(Throwable th) {
        Objects.requireNonNull(th, "onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        C0085a<T>[] c0085aArr = this.f5921d.get();
        C0085a<T>[] c0085aArr2 = f5919b;
        if (c0085aArr == c0085aArr2) {
            d.a.u.a.v(th);
            return;
        }
        this.f5922e = th;
        for (C0085a<T> c0085a : this.f5921d.getAndSet(c0085aArr2)) {
            if (c0085a.get()) {
                d.a.u.a.v(th);
            } else {
                c0085a.f5923b.a(th);
            }
        }
    }

    @Override // d.a.l
    public void b() {
        C0085a<T>[] c0085aArr = this.f5921d.get();
        C0085a<T>[] c0085aArr2 = f5919b;
        if (c0085aArr == c0085aArr2) {
            return;
        }
        for (C0085a<T> c0085a : this.f5921d.getAndSet(c0085aArr2)) {
            if (!c0085a.get()) {
                c0085a.f5923b.b();
            }
        }
    }

    @Override // d.a.l
    public void c(d.a.p.b bVar) {
        if (this.f5921d.get() == f5919b) {
            bVar.dispose();
        }
    }

    @Override // d.a.l
    public void d(T t) {
        Objects.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
        for (C0085a<T> c0085a : this.f5921d.get()) {
            if (!c0085a.get()) {
                c0085a.f5923b.d(t);
            }
        }
    }

    @Override // d.a.h
    public void o(l<? super T> lVar) {
        boolean z;
        C0085a<T> c0085a = new C0085a<>(lVar, this);
        lVar.c(c0085a);
        while (true) {
            C0085a<T>[] c0085aArr = this.f5921d.get();
            z = false;
            if (c0085aArr == f5919b) {
                break;
            }
            int length = c0085aArr.length;
            C0085a<T>[] c0085aArr2 = new C0085a[length + 1];
            System.arraycopy(c0085aArr, 0, c0085aArr2, 0, length);
            c0085aArr2[length] = c0085a;
            if (this.f5921d.compareAndSet(c0085aArr, c0085aArr2)) {
                z = true;
                break;
            }
        }
        if (z) {
            if (c0085a.get()) {
                s(c0085a);
            }
        } else {
            Throwable th = this.f5922e;
            if (th != null) {
                lVar.a(th);
            } else {
                lVar.b();
            }
        }
    }

    public void s(C0085a<T> c0085a) {
        C0085a<T>[] c0085aArr;
        C0085a<T>[] c0085aArr2;
        do {
            c0085aArr = this.f5921d.get();
            if (c0085aArr == f5919b || c0085aArr == f5920c) {
                return;
            }
            int length = c0085aArr.length;
            int i2 = 0;
            while (true) {
                if (i2 >= length) {
                    i2 = -1;
                    break;
                } else if (c0085aArr[i2] == c0085a) {
                    break;
                } else {
                    i2++;
                }
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                c0085aArr2 = f5920c;
            } else {
                C0085a<T>[] c0085aArr3 = new C0085a[length - 1];
                System.arraycopy(c0085aArr, 0, c0085aArr3, 0, i2);
                System.arraycopy(c0085aArr, i2 + 1, c0085aArr3, i2, (length - i2) - 1);
                c0085aArr2 = c0085aArr3;
            }
        } while (!this.f5921d.compareAndSet(c0085aArr, c0085aArr2));
    }
}