package f.a.a0;

import f.a.n;
import f.a.w.h.a;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

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

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public static final C0061a[] f3671e = new C0061a[0];

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public static final C0061a[] f3672f = new C0061a[0];

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final AtomicReference<Object> f3673g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final AtomicReference<C0061a<T>[]> f3674h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final ReadWriteLock f3675i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final Lock f3676j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final Lock f3677k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final AtomicReference<Throwable> f3678l;
    public long m;

    /* JADX INFO: renamed from: f.a.a0.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: BehaviorSubject.java */
    public static final class C0061a<T> implements f.a.t.b, a.InterfaceC0073a<Object> {

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

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

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

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public boolean f3682g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public f.a.w.h.a<Object> f3683h;

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        public boolean f3684i;

        /* JADX INFO: renamed from: j, reason: collision with root package name */
        public volatile boolean f3685j;

        /* JADX INFO: renamed from: k, reason: collision with root package name */
        public long f3686k;

        public C0061a(n<? super T> nVar, a<T> aVar) {
            this.f3679b = nVar;
            this.f3680e = aVar;
        }

        public void a(Object obj, long j2) {
            if (this.f3685j) {
                return;
            }
            if (!this.f3684i) {
                synchronized (this) {
                    if (this.f3685j) {
                        return;
                    }
                    if (this.f3686k == j2) {
                        return;
                    }
                    if (this.f3682g) {
                        f.a.w.h.a<Object> aVar = this.f3683h;
                        if (aVar == null) {
                            aVar = new f.a.w.h.a<>(4);
                            this.f3683h = aVar;
                        }
                        aVar.a(obj);
                        return;
                    }
                    this.f3681f = true;
                    this.f3684i = true;
                }
            }
            test(obj);
        }

        @Override // f.a.t.b
        public void dispose() {
            if (this.f3685j) {
                return;
            }
            this.f3685j = true;
            this.f3680e.D(this);
        }

        @Override // f.a.w.h.a.InterfaceC0073a, f.a.v.e
        public boolean test(Object obj) {
            return this.f3685j || f.a.w.h.d.accept(obj, this.f3679b);
        }
    }

    public a() {
        ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
        this.f3675i = reentrantReadWriteLock;
        this.f3676j = reentrantReadWriteLock.readLock();
        this.f3677k = reentrantReadWriteLock.writeLock();
        this.f3674h = new AtomicReference<>(f3671e);
        this.f3673g = new AtomicReference<>();
        this.f3678l = new AtomicReference<>();
    }

    public void D(C0061a<T> c0061a) {
        C0061a<T>[] c0061aArr;
        C0061a<T>[] c0061aArr2;
        do {
            c0061aArr = this.f3674h.get();
            int length = c0061aArr.length;
            if (length == 0) {
                return;
            }
            int i2 = 0;
            while (true) {
                if (i2 >= length) {
                    i2 = -1;
                    break;
                } else if (c0061aArr[i2] == c0061a) {
                    break;
                } else {
                    i2++;
                }
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                c0061aArr2 = f3671e;
            } else {
                C0061a<T>[] c0061aArr3 = new C0061a[length - 1];
                System.arraycopy(c0061aArr, 0, c0061aArr3, 0, i2);
                System.arraycopy(c0061aArr, i2 + 1, c0061aArr3, i2, (length - i2) - 1);
                c0061aArr2 = c0061aArr3;
            }
        } while (!this.f3674h.compareAndSet(c0061aArr, c0061aArr2));
    }

    public void E(Object obj) {
        this.f3677k.lock();
        this.m++;
        this.f3673g.lazySet(obj);
        this.f3677k.unlock();
    }

    @Override // f.a.n
    public void a(Throwable th) {
        Objects.requireNonNull(th, "onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        if (!this.f3678l.compareAndSet(null, th)) {
            f.a.y.a.C0(th);
            return;
        }
        Object objError = f.a.w.h.d.error(th);
        AtomicReference<C0061a<T>[]> atomicReference = this.f3674h;
        C0061a<T>[] c0061aArr = f3672f;
        C0061a<T>[] andSet = atomicReference.getAndSet(c0061aArr);
        if (andSet != c0061aArr) {
            E(objError);
        }
        for (C0061a<T> c0061a : andSet) {
            c0061a.a(objError, this.m);
        }
    }

    @Override // f.a.n
    public void b(f.a.t.b bVar) {
        if (this.f3678l.get() != null) {
            bVar.dispose();
        }
    }

    @Override // f.a.n
    public void c(T t) {
        Objects.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
        if (this.f3678l.get() != null) {
            return;
        }
        Object next = f.a.w.h.d.next(t);
        E(next);
        for (C0061a<T> c0061a : this.f3674h.get()) {
            c0061a.a(next, this.m);
        }
    }

    @Override // f.a.n
    public void onComplete() {
        if (this.f3678l.compareAndSet(null, f.a.w.h.c.a)) {
            Object objComplete = f.a.w.h.d.complete();
            AtomicReference<C0061a<T>[]> atomicReference = this.f3674h;
            C0061a<T>[] c0061aArr = f3672f;
            C0061a<T>[] andSet = atomicReference.getAndSet(c0061aArr);
            if (andSet != c0061aArr) {
                E(objComplete);
            }
            for (C0061a<T> c0061a : andSet) {
                c0061a.a(objComplete, this.m);
            }
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:41:0x007a, code lost:
    
        r0.f3682g = false;
     */
    @Override // f.a.i
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public void v(f.a.n<? super T> r8) {
        /*
            r7 = this;
            f.a.a0.a$a r0 = new f.a.a0.a$a
            r0.<init>(r8, r7)
            r8.b(r0)
        L8:
            java.util.concurrent.atomic.AtomicReference<f.a.a0.a$a<T>[]> r1 = r7.f3674h
            java.lang.Object r1 = r1.get()
            f.a.a0.a$a[] r1 = (f.a.a0.a.C0061a[]) r1
            f.a.a0.a$a[] r2 = f.a.a0.a.f3672f
            r3 = 0
            r4 = 1
            if (r1 != r2) goto L18
            r1 = r3
            goto L2b
        L18:
            int r2 = r1.length
            int r5 = r2 + 1
            f.a.a0.a$a[] r5 = new f.a.a0.a.C0061a[r5]
            java.lang.System.arraycopy(r1, r3, r5, r3, r2)
            r5[r2] = r0
            java.util.concurrent.atomic.AtomicReference<f.a.a0.a$a<T>[]> r2 = r7.f3674h
            boolean r1 = r2.compareAndSet(r1, r5)
            if (r1 == 0) goto L8
            r1 = r4
        L2b:
            if (r1 == 0) goto L8c
            boolean r8 = r0.f3685j
            if (r8 == 0) goto L36
            r7.D(r0)
            goto L9f
        L36:
            boolean r8 = r0.f3685j
            if (r8 == 0) goto L3c
            goto L9f
        L3c:
            monitor-enter(r0)
            boolean r8 = r0.f3685j     // Catch: java.lang.Throwable -> L89
            if (r8 == 0) goto L43
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L89
            goto L9f
        L43:
            boolean r8 = r0.f3681f     // Catch: java.lang.Throwable -> L89
            if (r8 == 0) goto L49
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L89
            goto L9f
        L49:
            f.a.a0.a<T> r8 = r0.f3680e     // Catch: java.lang.Throwable -> L89
            java.util.concurrent.locks.Lock r1 = r8.f3676j     // Catch: java.lang.Throwable -> L89
            r1.lock()     // Catch: java.lang.Throwable -> L89
            long r5 = r8.m     // Catch: java.lang.Throwable -> L89
            r0.f3686k = r5     // Catch: java.lang.Throwable -> L89
            java.util.concurrent.atomic.AtomicReference<java.lang.Object> r8 = r8.f3673g     // Catch: java.lang.Throwable -> L89
            java.lang.Object r8 = r8.get()     // Catch: java.lang.Throwable -> L89
            r1.unlock()     // Catch: java.lang.Throwable -> L89
            if (r8 == 0) goto L61
            r1 = r4
            goto L62
        L61:
            r1 = r3
        L62:
            r0.f3682g = r1     // Catch: java.lang.Throwable -> L89
            r0.f3681f = r4     // Catch: java.lang.Throwable -> L89
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L89
            if (r8 == 0) goto L9f
            boolean r8 = r0.test(r8)
            if (r8 == 0) goto L70
            goto L9f
        L70:
            boolean r8 = r0.f3685j
            if (r8 == 0) goto L75
            goto L9f
        L75:
            monitor-enter(r0)
            f.a.w.h.a<java.lang.Object> r8 = r0.f3683h     // Catch: java.lang.Throwable -> L86
            if (r8 != 0) goto L7e
            r0.f3682g = r3     // Catch: java.lang.Throwable -> L86
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L86
            goto L9f
        L7e:
            r1 = 0
            r0.f3683h = r1     // Catch: java.lang.Throwable -> L86
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L86
            r8.b(r0)
            goto L70
        L86:
            r8 = move-exception
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L86
            throw r8
        L89:
            r8 = move-exception
            monitor-exit(r0)     // Catch: java.lang.Throwable -> L89
            throw r8
        L8c:
            java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> r0 = r7.f3678l
            java.lang.Object r0 = r0.get()
            java.lang.Throwable r0 = (java.lang.Throwable) r0
            java.lang.Throwable r1 = f.a.w.h.c.a
            if (r0 != r1) goto L9c
            r8.onComplete()
            goto L9f
        L9c:
            r8.a(r0)
        L9f:
            return
        */
        throw new UnsupportedOperationException("Method not decompiled: f.a.a0.a.v(f.a.n):void");
    }
}