package d.a.s.e.c;

import a.a.a.a.c.n0;
import java.util.ArrayDeque;
import java.util.Objects;
import java.util.Queue;
import java.util.concurrent.Callable;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final d.a.r.c<? super T, ? extends d.a.k<? extends U>> f5707c;

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

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

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

    public static final class a<T, U> extends AtomicReference<d.a.p.b> implements d.a.l<U> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final long f5711b;

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

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public volatile d.a.s.c.d<U> f5714e;

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

        public a(b<T, U> bVar, long j2) {
            this.f5711b = j2;
            this.f5712c = bVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            if (!this.f5712c.k.a(th)) {
                d.a.u.a.v(th);
                return;
            }
            b<T, U> bVar = this.f5712c;
            if (!bVar.f5720f) {
                bVar.f();
            }
            this.f5713d = true;
            this.f5712c.g();
        }

        @Override // d.a.l
        public void b() {
            this.f5713d = true;
            this.f5712c.g();
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            if (d.a.s.a.b.setOnce(this, bVar) && (bVar instanceof d.a.s.c.a)) {
                d.a.s.c.a aVar = (d.a.s.c.a) bVar;
                int iRequestFusion = aVar.requestFusion(7);
                if (iRequestFusion == 1) {
                    this.f5715f = iRequestFusion;
                    this.f5714e = aVar;
                    this.f5713d = true;
                    this.f5712c.g();
                    return;
                }
                if (iRequestFusion == 2) {
                    this.f5715f = iRequestFusion;
                    this.f5714e = aVar;
                }
            }
        }

        @Override // d.a.l
        public void d(U u) {
            if (this.f5715f != 0) {
                this.f5712c.g();
                return;
            }
            b<T, U> bVar = this.f5712c;
            if (bVar.get() == 0 && bVar.compareAndSet(0, 1)) {
                bVar.f5718d.d(u);
                if (bVar.decrementAndGet() == 0) {
                    return;
                }
            } else {
                d.a.s.c.d bVar2 = this.f5714e;
                if (bVar2 == null) {
                    bVar2 = new d.a.s.f.b(bVar.f5722h);
                    this.f5714e = bVar2;
                }
                bVar2.offer(u);
                if (bVar.getAndIncrement() != 0) {
                    return;
                }
            }
            bVar.h();
        }
    }

    public static final class b<T, U> extends AtomicInteger implements d.a.p.b, d.a.l<T> {

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

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public static final a<?, ?>[] f5717c = new a[0];

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public final d.a.l<? super U> f5718d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final d.a.r.c<? super T, ? extends d.a.k<? extends U>> f5719e;

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

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

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

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        public volatile d.a.s.c.c<U> f5723i;

        /* JADX INFO: renamed from: j, reason: collision with root package name */
        public volatile boolean f5724j;
        public final d.a.s.h.b k = new d.a.s.h.b();
        public volatile boolean l;
        public final AtomicReference<a<?, ?>[]> m;
        public d.a.p.b n;
        public long o;
        public long p;
        public int q;
        public Queue<d.a.k<? extends U>> r;
        public int s;

        public b(d.a.l<? super U> lVar, d.a.r.c<? super T, ? extends d.a.k<? extends U>> cVar, boolean z, int i2, int i3) {
            this.f5718d = lVar;
            this.f5719e = cVar;
            this.f5720f = z;
            this.f5721g = i2;
            this.f5722h = i3;
            if (i2 != Integer.MAX_VALUE) {
                this.r = new ArrayDeque(i2);
            }
            this.m = new AtomicReference<>(f5716b);
        }

        @Override // d.a.l
        public void a(Throwable th) {
            if (this.f5724j) {
                d.a.u.a.v(th);
            } else if (!this.k.a(th)) {
                d.a.u.a.v(th);
            } else {
                this.f5724j = true;
                g();
            }
        }

        @Override // d.a.l
        public void b() {
            if (this.f5724j) {
                return;
            }
            this.f5724j = true;
            g();
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            if (d.a.s.a.b.validate(this.n, bVar)) {
                this.n = bVar;
                this.f5718d.c(this);
            }
        }

        @Override // d.a.l
        public void d(T t) {
            if (this.f5724j) {
                return;
            }
            try {
                d.a.k<? extends U> kVarA = this.f5719e.a(t);
                Objects.requireNonNull(kVarA, "The mapper returned a null ObservableSource");
                d.a.k<? extends U> kVar = kVarA;
                if (this.f5721g != Integer.MAX_VALUE) {
                    synchronized (this) {
                        int i2 = this.s;
                        if (i2 == this.f5721g) {
                            this.r.offer(kVar);
                            return;
                        }
                        this.s = i2 + 1;
                    }
                }
                j(kVar);
            } catch (Throwable th) {
                n0.y(th);
                this.n.dispose();
                a(th);
            }
        }

        @Override // d.a.p.b
        public void dispose() {
            Throwable thB;
            if (this.l) {
                return;
            }
            this.l = true;
            if (!f() || (thB = this.k.b()) == null || thB == d.a.s.h.d.f5898a) {
                return;
            }
            d.a.u.a.v(thB);
        }

        public boolean e() {
            if (this.l) {
                return true;
            }
            Throwable th = this.k.get();
            if (this.f5720f || th == null) {
                return false;
            }
            f();
            Throwable thB = this.k.b();
            if (thB != d.a.s.h.d.f5898a) {
                this.f5718d.a(thB);
            }
            return true;
        }

        public boolean f() {
            a<?, ?>[] andSet;
            this.n.dispose();
            a<?, ?>[] aVarArr = this.m.get();
            a<?, ?>[] aVarArr2 = f5717c;
            if (aVarArr == aVarArr2 || (andSet = this.m.getAndSet(aVarArr2)) == aVarArr2) {
                return false;
            }
            for (a<?, ?> aVar : andSet) {
                Objects.requireNonNull(aVar);
                d.a.s.a.b.dispose(aVar);
            }
            return true;
        }

        public void g() {
            if (getAndIncrement() == 0) {
                h();
            }
        }

        /* JADX WARN: Code restructure failed: missing block: B:128:0x0004, code lost:
        
            continue;
         */
        /* JADX WARN: Multi-variable type inference failed */
        /* JADX WARN: Removed duplicated region for block: B:120:0x00ea A[SYNTHETIC] */
        /* JADX WARN: Removed duplicated region for block: B:133:0x00f2 A[SYNTHETIC] */
        /* JADX WARN: Removed duplicated region for block: B:82:0x00eb  */
        /* JADX WARN: Removed duplicated region for block: B:85:0x00f1 A[PHI: r4
          0x00f1: PHI (r4v10 int) = (r4v8 int), (r4v11 int) binds: [B:72:0x00d0, B:84:0x00ef] A[DONT_GENERATE, DONT_INLINE]] */
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct add '--show-bad-code' argument
        */
        public void h() {
            /*
                Method dump skipped, instruction units count: 299
                To view this dump add '--comments-level debug' option
            */
            throw new UnsupportedOperationException("Method not decompiled: d.a.s.e.c.e.b.h():void");
        }

        /* JADX WARN: Multi-variable type inference failed */
        public void i(a<T, U> aVar) {
            a<?, ?>[] aVarArr;
            a<?, ?>[] aVarArr2;
            do {
                aVarArr = this.m.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;
                }
                if (length == 1) {
                    aVarArr2 = f5716b;
                } else {
                    a<?, ?>[] aVarArr3 = new a[length - 1];
                    System.arraycopy(aVarArr, 0, aVarArr3, 0, i2);
                    System.arraycopy(aVarArr, i2 + 1, aVarArr3, i2, (length - i2) - 1);
                    aVarArr2 = aVarArr3;
                }
            } while (!this.m.compareAndSet(aVarArr, aVarArr2));
        }

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

        /* JADX WARN: Multi-variable type inference failed */
        /* JADX WARN: Type inference failed for: r3v22 */
        /* JADX WARN: Type inference failed for: r3v23 */
        /* JADX WARN: Type inference failed for: r3v8, types: [d.a.s.c.d] */
        public void j(d.a.k<? extends U> kVar) {
            boolean z;
            boolean z2;
            Object objCall;
            do {
                z = false;
                if (!(kVar instanceof Callable)) {
                    long j2 = this.o;
                    this.o = 1 + j2;
                    a<?, ?> aVar = new a<>(this, j2);
                    while (true) {
                        a<?, ?>[] aVarArr = this.m.get();
                        if (aVarArr == f5717c) {
                            d.a.s.a.b.dispose(aVar);
                            break;
                        }
                        int length = aVarArr.length;
                        a<?, ?>[] aVarArr2 = new a[length + 1];
                        System.arraycopy(aVarArr, 0, aVarArr2, 0, length);
                        aVarArr2[length] = aVar;
                        if (this.m.compareAndSet(aVarArr, aVarArr2)) {
                            z = true;
                            break;
                        }
                    }
                    if (z) {
                        kVar.e(aVar);
                        return;
                    }
                    return;
                }
                try {
                    objCall = ((Callable) kVar).call();
                } catch (Throwable th) {
                    n0.y(th);
                    this.k.a(th);
                    g();
                }
                if (objCall == null) {
                    z2 = true;
                } else if (get() == 0 && compareAndSet(0, 1)) {
                    this.f5718d.d(objCall);
                    if (decrementAndGet() != 0) {
                        h();
                    }
                    z2 = true;
                } else {
                    d.a.s.c.c<U> cVar = this.f5723i;
                    ?? r3 = cVar;
                    if (cVar == false) {
                        d.a.s.c.c<U> bVar = this.f5721g == Integer.MAX_VALUE ? new d.a.s.f.b(this.f5722h) : new d.a.s.f.a(this.f5721g);
                        this.f5723i = bVar;
                        r3 = bVar;
                    }
                    if (r3.offer(objCall)) {
                        if (getAndIncrement() != 0) {
                            z2 = false;
                        }
                        h();
                        z2 = true;
                    } else {
                        a(new IllegalStateException("Scalar queue full?!"));
                        z2 = true;
                    }
                }
                if (!z2 || this.f5721g == Integer.MAX_VALUE) {
                    return;
                }
                synchronized (this) {
                    kVar = this.r.poll();
                    if (kVar == null) {
                        this.s--;
                        z = true;
                    }
                }
            } while (!z);
            g();
        }
    }

    public e(d.a.k<T> kVar, d.a.r.c<? super T, ? extends d.a.k<? extends U>> cVar, boolean z, int i2, int i3) {
        super(kVar);
        this.f5707c = cVar;
        this.f5708d = z;
        this.f5709e = i2;
        this.f5710f = i3;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0011  */
    @Override // d.a.h
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public void o(d.a.l<? super U> r9) {
        /*
            r8 = this;
            d.a.k<T> r0 = r8.f5688b
            d.a.r.c<? super T, ? extends d.a.k<? extends U>> r1 = r8.f5707c
            boolean r2 = r0 instanceof java.util.concurrent.Callable
            if (r2 == 0) goto L45
            r2 = 1
            java.util.concurrent.Callable r0 = (java.util.concurrent.Callable) r0     // Catch: java.lang.Throwable -> L3d
            java.lang.Object r0 = r0.call()     // Catch: java.lang.Throwable -> L3d
            if (r0 != 0) goto L15
        L11:
            d.a.s.a.c.complete(r9)
            goto L46
        L15:
            java.lang.Object r0 = r1.a(r0)     // Catch: java.lang.Throwable -> L3d
            java.lang.String r1 = "The mapper returned a null ObservableSource"
            java.util.Objects.requireNonNull(r0, r1)     // Catch: java.lang.Throwable -> L3d
            d.a.k r0 = (d.a.k) r0     // Catch: java.lang.Throwable -> L3d
            boolean r1 = r0 instanceof java.util.concurrent.Callable
            if (r1 == 0) goto L39
            java.util.concurrent.Callable r0 = (java.util.concurrent.Callable) r0     // Catch: java.lang.Throwable -> L3d
            java.lang.Object r0 = r0.call()     // Catch: java.lang.Throwable -> L3d
            if (r0 != 0) goto L2d
            goto L11
        L2d:
            d.a.s.e.c.l r1 = new d.a.s.e.c.l
            r1.<init>(r9, r0)
            r9.c(r1)
            r1.run()
            goto L46
        L39:
            r0.e(r9)
            goto L46
        L3d:
            r0 = move-exception
            a.a.a.a.c.n0.y(r0)
            d.a.s.a.c.error(r0, r9)
            goto L46
        L45:
            r2 = 0
        L46:
            if (r2 == 0) goto L49
            return
        L49:
            d.a.k<T> r0 = r8.f5688b
            d.a.s.e.c.e$b r7 = new d.a.s.e.c.e$b
            d.a.r.c<? super T, ? extends d.a.k<? extends U>> r3 = r8.f5707c
            boolean r4 = r8.f5708d
            int r5 = r8.f5709e
            int r6 = r8.f5710f
            r1 = r7
            r2 = r9
            r1.<init>(r2, r3, r4, r5, r6)
            r0.e(r7)
            return
        */
        throw new UnsupportedOperationException("Method not decompiled: d.a.s.e.c.e.o(d.a.l):void");
    }
}