package e.a.y;

import e.a.m;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

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

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    static final C0121a[] f3884g = new C0121a[0];

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    static final C0121a[] f3885h = new C0121a[0];

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    final AtomicReference<C0121a<T>[]> f3886b = new AtomicReference<>(f3885h);

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

    /* JADX INFO: renamed from: e.a.y.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: PublishSubject.java */
    static final class C0121a<T> extends AtomicBoolean implements e.a.r.b {

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

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

        C0121a(m<? super T> mVar, a<T> aVar) {
            this.f3888b = mVar;
            this.f3889f = aVar;
        }

        public void a() {
            if (get()) {
                return;
            }
            this.f3888b.a();
        }

        public void b(Throwable th) {
            if (get()) {
                e.a.w.a.p(th);
            } else {
                this.f3888b.b(th);
            }
        }

        public void c(T t) {
            if (get()) {
                return;
            }
            this.f3888b.d(t);
        }

        @Override // e.a.r.b
        public void dispose() {
            if (compareAndSet(false, true)) {
                this.f3889f.c0(this);
            }
        }

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

    a() {
    }

    public static <T> a<T> b0() {
        return new a<>();
    }

    @Override // e.a.h
    public void S(m<? super T> mVar) {
        C0121a<T> c0121a = new C0121a<>(mVar, this);
        mVar.c(c0121a);
        if (a0(c0121a)) {
            if (c0121a.isDisposed()) {
                c0(c0121a);
            }
        } else {
            Throwable th = this.f3887f;
            if (th != null) {
                mVar.b(th);
            } else {
                mVar.a();
            }
        }
    }

    @Override // e.a.m
    public void a() {
        C0121a<T>[] c0121aArr = this.f3886b.get();
        C0121a<T>[] c0121aArr2 = f3884g;
        if (c0121aArr == c0121aArr2) {
            return;
        }
        for (C0121a<T> c0121a : this.f3886b.getAndSet(c0121aArr2)) {
            c0121a.a();
        }
    }

    boolean a0(C0121a<T> c0121a) {
        C0121a<T>[] c0121aArr;
        C0121a<T>[] c0121aArr2;
        do {
            c0121aArr = this.f3886b.get();
            if (c0121aArr == f3884g) {
                return false;
            }
            int length = c0121aArr.length;
            c0121aArr2 = new C0121a[length + 1];
            System.arraycopy(c0121aArr, 0, c0121aArr2, 0, length);
            c0121aArr2[length] = c0121a;
        } while (!this.f3886b.compareAndSet(c0121aArr, c0121aArr2));
        return true;
    }

    @Override // e.a.m
    public void b(Throwable th) {
        if (this.f3886b.get() == f3884g) {
            e.a.w.a.p(th);
            return;
        }
        if (th == null) {
            th = new NullPointerException("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        }
        this.f3887f = th;
        for (C0121a<T> c0121a : this.f3886b.getAndSet(f3884g)) {
            c0121a.b(th);
        }
    }

    @Override // e.a.m
    public void c(e.a.r.b bVar) {
        if (this.f3886b.get() == f3884g) {
            bVar.dispose();
        }
    }

    void c0(C0121a<T> c0121a) {
        C0121a<T>[] c0121aArr;
        C0121a<T>[] c0121aArr2;
        do {
            c0121aArr = this.f3886b.get();
            if (c0121aArr == f3884g || c0121aArr == f3885h) {
                return;
            }
            int length = c0121aArr.length;
            int i2 = -1;
            int i3 = 0;
            while (true) {
                if (i3 >= length) {
                    break;
                }
                if (c0121aArr[i3] == c0121a) {
                    i2 = i3;
                    break;
                }
                i3++;
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                c0121aArr2 = f3885h;
            } else {
                C0121a<T>[] c0121aArr3 = new C0121a[length - 1];
                System.arraycopy(c0121aArr, 0, c0121aArr3, 0, i2);
                System.arraycopy(c0121aArr, i2 + 1, c0121aArr3, i2, (length - i2) - 1);
                c0121aArr2 = c0121aArr3;
            }
        } while (!this.f3886b.compareAndSet(c0121aArr, c0121aArr2));
    }

    @Override // e.a.m
    public void d(T t) {
        if (this.f3886b.get() == f3884g) {
            return;
        }
        if (t == null) {
            b(new NullPointerException("onNext called with null. Null values are generally not allowed in 2.x operators and sources."));
            return;
        }
        for (C0121a<T> c0121a : this.f3886b.get()) {
            c0121a.c(t);
        }
    }
}