package f.a.w.e.d;

import java.util.Objects;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: ObservableCombineLatest.java */
/* JADX INFO: loaded from: classes.dex */
public final class b<T, R> extends f.a.i<R> {

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final f.a.v.d<? super Object[], ? extends R> f3756e;

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

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

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final C0068b<T, R> f3758b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final int f3759e;

        public a(C0068b<T, R> c0068b, int i2) {
            this.f3758b = c0068b;
            this.f3759e = i2;
        }

        /* JADX WARN: Removed duplicated region for block: B:18:0x0029 A[Catch: all -> 0x002e, TryCatch #0 {, blocks: (B:7:0x0012, B:9:0x0016, B:11:0x0018, B:16:0x0021, B:19:0x002b, B:18:0x0029), top: B:29:0x0012 }] */
        @Override // f.a.n
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct add '--show-bad-code' argument
        */
        public void a(java.lang.Throwable r5) {
            /*
                r4 = this;
                f.a.w.e.d.b$b<T, R> r0 = r4.f3758b
                int r1 = r4.f3759e
                f.a.w.h.b r2 = r0.f3768l
                boolean r2 = r2.a(r5)
                if (r2 == 0) goto L3a
                boolean r5 = r0.f3765i
                r2 = 1
                if (r5 == 0) goto L31
                monitor-enter(r0)
                java.lang.Object[] r5 = r0.f3763g     // Catch: java.lang.Throwable -> L2e
                if (r5 != 0) goto L18
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L2e
                goto L3d
            L18:
                r1 = r5[r1]     // Catch: java.lang.Throwable -> L2e
                if (r1 != 0) goto L1e
                r1 = r2
                goto L1f
            L1e:
                r1 = 0
            L1f:
                if (r1 != 0) goto L29
                int r3 = r0.n     // Catch: java.lang.Throwable -> L2e
                int r3 = r3 + r2
                r0.n = r3     // Catch: java.lang.Throwable -> L2e
                int r5 = r5.length     // Catch: java.lang.Throwable -> L2e
                if (r3 != r5) goto L2b
            L29:
                r0.f3767k = r2     // Catch: java.lang.Throwable -> L2e
            L2b:
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L2e
                r2 = r1
                goto L31
            L2e:
                r5 = move-exception
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L2e
                throw r5
            L31:
                if (r2 == 0) goto L36
                r0.a()
            L36:
                r0.c()
                goto L3d
            L3a:
                f.a.y.a.C0(r5)
            L3d:
                return
            */
            throw new UnsupportedOperationException("Method not decompiled: f.a.w.e.d.b.a.a(java.lang.Throwable):void");
        }

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

        @Override // f.a.n
        public void c(T t) {
            boolean z;
            C0068b<T, R> c0068b = this.f3758b;
            int i2 = this.f3759e;
            synchronized (c0068b) {
                Object[] objArr = c0068b.f3763g;
                if (objArr == null) {
                    return;
                }
                Object obj = objArr[i2];
                int i3 = c0068b.m;
                if (obj == null) {
                    i3++;
                    c0068b.m = i3;
                }
                objArr[i2] = t;
                if (i3 == objArr.length) {
                    c0068b.f3764h.offer((Object[]) objArr.clone());
                    z = true;
                } else {
                    z = false;
                }
                if (z) {
                    c0068b.c();
                }
            }
        }

        /* JADX WARN: Removed duplicated region for block: B:15:0x001d A[Catch: all -> 0x0029, TryCatch #0 {, blocks: (B:4:0x0005, B:6:0x0009, B:8:0x000b, B:13:0x0015, B:16:0x001f, B:15:0x001d), top: B:24:0x0005 }] */
        @Override // f.a.n
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct add '--show-bad-code' argument
        */
        public void onComplete() {
            /*
                r5 = this;
                f.a.w.e.d.b$b<T, R> r0 = r5.f3758b
                int r1 = r5.f3759e
                monitor-enter(r0)
                java.lang.Object[] r2 = r0.f3763g     // Catch: java.lang.Throwable -> L29
                if (r2 != 0) goto Lb
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L29
                goto L28
            Lb:
                r1 = r2[r1]     // Catch: java.lang.Throwable -> L29
                r3 = 1
                if (r1 != 0) goto L12
                r1 = r3
                goto L13
            L12:
                r1 = 0
            L13:
                if (r1 != 0) goto L1d
                int r4 = r0.n     // Catch: java.lang.Throwable -> L29
                int r4 = r4 + r3
                r0.n = r4     // Catch: java.lang.Throwable -> L29
                int r2 = r2.length     // Catch: java.lang.Throwable -> L29
                if (r4 != r2) goto L1f
            L1d:
                r0.f3767k = r3     // Catch: java.lang.Throwable -> L29
            L1f:
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L29
                if (r1 == 0) goto L25
                r0.a()
            L25:
                r0.c()
            L28:
                return
            L29:
                r1 = move-exception
                monitor-exit(r0)     // Catch: java.lang.Throwable -> L29
                throw r1
            */
            throw new UnsupportedOperationException("Method not decompiled: f.a.w.e.d.b.a.onComplete():void");
        }
    }

    /* JADX INFO: renamed from: f.a.w.e.d.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: ObservableCombineLatest.java */
    public static final class C0068b<T, R> extends AtomicInteger implements f.a.t.b {

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final f.a.v.d<? super Object[], ? extends R> f3761e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final a<T, R>[] f3762f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public Object[] f3763g;

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

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

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

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

        /* JADX INFO: renamed from: l, reason: collision with root package name */
        public final f.a.w.h.b f3768l = new f.a.w.h.b();
        public int m;
        public int n;

        public C0068b(f.a.n<? super R> nVar, f.a.v.d<? super Object[], ? extends R> dVar, int i2, int i3, boolean z) {
            this.f3760b = nVar;
            this.f3761e = dVar;
            this.f3765i = z;
            this.f3763g = new Object[i2];
            a<T, R>[] aVarArr = new a[i2];
            for (int i4 = 0; i4 < i2; i4++) {
                aVarArr[i4] = new a<>(this, i4);
            }
            this.f3762f = aVarArr;
            this.f3764h = new f.a.w.f.c<>(i3);
        }

        public void a() {
            for (a<T, R> aVar : this.f3762f) {
                Objects.requireNonNull(aVar);
                f.a.w.a.b.dispose(aVar);
            }
        }

        public void b(f.a.w.f.c<?> cVar) {
            synchronized (this) {
                this.f3763g = null;
            }
            cVar.clear();
        }

        public void c() {
            if (getAndIncrement() != 0) {
                return;
            }
            f.a.w.f.c<Object[]> cVar = this.f3764h;
            f.a.n<? super R> nVar = this.f3760b;
            boolean z = this.f3765i;
            int iAddAndGet = 1;
            while (!this.f3766j) {
                if (!z && this.f3768l.get() != null) {
                    a();
                    b(cVar);
                    nVar.a(this.f3768l.b());
                    return;
                }
                boolean z2 = this.f3767k;
                Object[] objArrPoll = cVar.poll();
                boolean z3 = objArrPoll == null;
                if (z2 && z3) {
                    b(cVar);
                    Throwable thB = this.f3768l.b();
                    if (thB == null) {
                        nVar.onComplete();
                        return;
                    } else {
                        nVar.a(thB);
                        return;
                    }
                }
                if (z3) {
                    iAddAndGet = addAndGet(-iAddAndGet);
                    if (iAddAndGet == 0) {
                        return;
                    }
                } else {
                    try {
                        R rApply = this.f3761e.apply(objArrPoll);
                        Objects.requireNonNull(rApply, "The combiner returned a null value");
                        nVar.c(rApply);
                    } catch (Throwable th) {
                        d.i.c.a.L(th);
                        this.f3768l.a(th);
                        a();
                        b(cVar);
                        nVar.a(this.f3768l.b());
                        return;
                    }
                }
            }
            b(cVar);
        }

        @Override // f.a.t.b
        public void dispose() {
            if (this.f3766j) {
                return;
            }
            this.f3766j = true;
            a();
            if (getAndIncrement() == 0) {
                b(this.f3764h);
            }
        }
    }

    public b(f.a.l<? extends T>[] lVarArr, Iterable<? extends f.a.l<? extends T>> iterable, f.a.v.d<? super Object[], ? extends R> dVar, int i2, boolean z) {
        this.f3755b = lVarArr;
        this.f3756e = dVar;
        this.f3757f = i2;
    }

    @Override // f.a.i
    public void v(f.a.n<? super R> nVar) {
        f.a.l<? extends T>[] lVarArr = this.f3755b;
        Objects.requireNonNull(lVarArr);
        int length = lVarArr.length;
        if (length == 0) {
            f.a.w.a.c.complete(nVar);
            return;
        }
        C0068b c0068b = new C0068b(nVar, this.f3756e, length, this.f3757f, false);
        a<T, R>[] aVarArr = c0068b.f3762f;
        int length2 = aVarArr.length;
        c0068b.f3760b.b(c0068b);
        for (int i2 = 0; i2 < length2 && !c0068b.f3767k && !c0068b.f3766j; i2++) {
            lVarArr[i2].d(aVarArr[i2]);
        }
    }
}