package f.a.w.e.d;

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: ObservablePublishAlt.java */
/* JADX INFO: loaded from: classes.dex */
public final class w<T> extends f.a.x.a<T> implements f.a.w.a.e {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final f.a.l<T> f3892b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final AtomicReference<b<T>> f3893e = new AtomicReference<>();

    /* JADX INFO: compiled from: ObservablePublishAlt.java */
    public static final class a<T> extends AtomicReference<b<T>> implements f.a.t.b {

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

        public a(f.a.n<? super T> nVar, b<T> bVar) {
            this.f3894b = nVar;
            lazySet(bVar);
        }

        @Override // f.a.t.b
        public void dispose() {
            b<T> andSet = getAndSet(null);
            if (andSet != null) {
                andSet.d(this);
            }
        }
    }

    /* JADX INFO: compiled from: ObservablePublishAlt.java */
    public static final class b<T> extends AtomicReference<a<T>[]> implements f.a.n<T>, f.a.t.b {

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

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

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

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

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final AtomicBoolean f3897f = new AtomicBoolean();

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public final AtomicReference<f.a.t.b> f3899h = new AtomicReference<>();

        public b(AtomicReference<b<T>> atomicReference) {
            this.f3898g = atomicReference;
            lazySet(f3895b);
        }

        @Override // f.a.n
        public void a(Throwable th) {
            this.f3900i = th;
            this.f3899h.lazySet(f.a.w.a.b.DISPOSED);
            for (a<T> aVar : getAndSet(f3896e)) {
                aVar.f3894b.a(th);
            }
        }

        @Override // f.a.n
        public void b(f.a.t.b bVar) {
            f.a.w.a.b.setOnce(this.f3899h, bVar);
        }

        @Override // f.a.n
        public void c(T t) {
            for (a<T> aVar : get()) {
                aVar.f3894b.c(t);
            }
        }

        public void d(a<T> aVar) {
            a<T>[] aVarArr;
            a[] aVarArr2;
            do {
                aVarArr = get();
                int length = aVarArr.length;
                if (length == 0) {
                    return;
                }
                int i2 = 0;
                while (true) {
                    if (i2 >= length) {
                        i2 = -1;
                        break;
                    } else if (aVarArr[i2] == aVar) {
                        break;
                    } else {
                        i2++;
                    }
                }
                if (i2 < 0) {
                    return;
                }
                aVarArr2 = f3895b;
                if (length != 1) {
                    aVarArr2 = new a[length - 1];
                    System.arraycopy(aVarArr, 0, aVarArr2, 0, i2);
                    System.arraycopy(aVarArr, i2 + 1, aVarArr2, i2, (length - i2) - 1);
                }
            } while (!compareAndSet(aVarArr, aVarArr2));
        }

        @Override // f.a.t.b
        public void dispose() {
            getAndSet(f3896e);
            this.f3898g.compareAndSet(this, null);
            f.a.w.a.b.dispose(this.f3899h);
        }

        @Override // f.a.n
        public void onComplete() {
            this.f3899h.lazySet(f.a.w.a.b.DISPOSED);
            for (a<T> aVar : getAndSet(f3896e)) {
                aVar.f3894b.onComplete();
            }
        }
    }

    public w(f.a.l<T> lVar) {
        this.f3892b = lVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:9:0x0019  */
    @Override // f.a.x.a
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public void D(f.a.v.c<? super f.a.t.b> r6) {
        /*
            r5 = this;
        L0:
            java.util.concurrent.atomic.AtomicReference<f.a.w.e.d.w$b<T>> r0 = r5.f3893e
            java.lang.Object r0 = r0.get()
            f.a.w.e.d.w$b r0 = (f.a.w.e.d.w.b) r0
            r1 = 1
            r2 = 0
            if (r0 == 0) goto L19
            java.lang.Object r3 = r0.get()
            f.a.w.e.d.w$a[] r4 = f.a.w.e.d.w.b.f3896e
            if (r3 != r4) goto L16
            r3 = r1
            goto L17
        L16:
            r3 = r2
        L17:
            if (r3 == 0) goto L2a
        L19:
            f.a.w.e.d.w$b r3 = new f.a.w.e.d.w$b
            java.util.concurrent.atomic.AtomicReference<f.a.w.e.d.w$b<T>> r4 = r5.f3893e
            r3.<init>(r4)
            java.util.concurrent.atomic.AtomicReference<f.a.w.e.d.w$b<T>> r4 = r5.f3893e
            boolean r0 = r4.compareAndSet(r0, r3)
            if (r0 != 0) goto L29
            goto L0
        L29:
            r0 = r3
        L2a:
            java.util.concurrent.atomic.AtomicBoolean r3 = r0.f3897f
            boolean r3 = r3.get()
            if (r3 != 0) goto L3b
            java.util.concurrent.atomic.AtomicBoolean r3 = r0.f3897f
            boolean r3 = r3.compareAndSet(r2, r1)
            if (r3 == 0) goto L3b
            goto L3c
        L3b:
            r1 = r2
        L3c:
            f.a.w.e.d.y$a r6 = (f.a.w.e.d.y.a) r6     // Catch: java.lang.Throwable -> L49
            r6.accept(r0)     // Catch: java.lang.Throwable -> L49
            if (r1 == 0) goto L48
            f.a.l<T> r6 = r5.f3892b
            r6.d(r0)
        L48:
            return
        L49:
            r6 = move-exception
            d.i.c.a.L(r6)
            java.lang.RuntimeException r6 = f.a.w.h.c.a(r6)
            throw r6
        */
        throw new UnsupportedOperationException("Method not decompiled: f.a.w.e.d.w.D(f.a.v.c):void");
    }

    @Override // f.a.w.a.e
    public void e(f.a.t.b bVar) {
        this.f3893e.compareAndSet((b) bVar, null);
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        b<T> bVar;
        boolean z;
        while (true) {
            bVar = this.f3893e.get();
            if (bVar != null) {
                break;
            }
            b<T> bVar2 = new b<>(this.f3893e);
            if (this.f3893e.compareAndSet(bVar, bVar2)) {
                bVar = bVar2;
                break;
            }
        }
        a<T> aVar = new a<>(nVar, bVar);
        nVar.b(aVar);
        while (true) {
            a<T>[] aVarArr = bVar.get();
            if (aVarArr == b.f3896e) {
                z = false;
                break;
            }
            int length = aVarArr.length;
            a[] aVarArr2 = new a[length + 1];
            System.arraycopy(aVarArr, 0, aVarArr2, 0, length);
            aVarArr2[length] = aVar;
            if (bVar.compareAndSet(aVarArr, aVarArr2)) {
                z = true;
                break;
            }
        }
        if (z) {
            if (aVar.get() == null) {
                bVar.d(aVar);
            }
        } else {
            Throwable th = bVar.f3900i;
            if (th != null) {
                nVar.a(th);
            } else {
                nVar.onComplete();
            }
        }
    }
}