package o;

import io.reactivex.rxjava3.exceptions.QueueOverflowException;
import java.util.concurrent.atomic.AtomicLong;
import o.AbstractC13173fSu;

/* renamed from: o.fUz, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13247fUz<T> extends AbstractC13240fUs<T, T> {
    private boolean b;
    private AbstractC13173fSu c;
    private int d;

    public C13247fUz(AbstractC13155fSc<T> abstractC13155fSc, AbstractC13173fSu abstractC13173fSu, int i) {
        super(abstractC13155fSc);
        this.c = abstractC13173fSu;
        this.b = false;
        this.d = i;
    }

    @Override // o.AbstractC13155fSc
    public final void c(InterfaceC15338gnn<? super T> interfaceC15338gnn) {
        AbstractC13173fSu.Sts c = this.c.c();
        if (interfaceC15338gnn instanceof InterfaceC13405fZh) {
            this.e.a((InterfaceC13158fSf) new IeS((InterfaceC13405fZh) interfaceC15338gnn, c, this.b, this.d));
        } else {
            this.e.a((InterfaceC13158fSf) new LWm(interfaceC15338gnn, c, this.b, this.d));
        }
    }

    /* renamed from: o.fUz$HBt */
    /* loaded from: classes6.dex */
    static abstract class HBt<T> extends fYD<T> implements InterfaceC13158fSf<T>, Runnable {
        final int a;
        volatile boolean b;
        Throwable c;
        final int d;
        volatile boolean e;
        long f;
        InterfaceC13414fZq<T> g;
        InterfaceC15337gnm h;
        int i;
        final AtomicLong j = new AtomicLong();
        final AbstractC13173fSu.Sts k;
        private boolean m;
        private boolean n;

        abstract void d();

        abstract void f();

        abstract void i();

        HBt(AbstractC13173fSu.Sts sts, boolean z, int i) {
            this.k = sts;
            this.m = z;
            this.d = i;
            this.a = i - (i >> 2);
        }

        @Override // o.InterfaceC15338gnn
        public final void onError(Throwable th) {
            if (this.e) {
                C13418fZu.c(th);
                return;
            }
            this.c = th;
            this.e = true;
            if (getAndIncrement() == 0) {
                this.k.c(this);
            }
        }

        @Override // o.InterfaceC15337gnm
        public final void c(long j) {
            if (fYC.e(j)) {
                fYK.c(this.j, j);
                if (getAndIncrement() == 0) {
                    this.k.c(this);
                }
            }
        }

        @Override // o.InterfaceC15337gnm
        public final void a() {
            if (this.b) {
                return;
            }
            this.b = true;
            this.h.a();
            this.k.dispose();
            if (this.n || getAndIncrement() != 0) {
                return;
            }
            this.g.e();
        }

        @Override // java.lang.Runnable
        public final void run() {
            if (this.n) {
                f();
            } else if (this.i == 1) {
                i();
            } else {
                d();
            }
        }

        final boolean a(boolean z, boolean z2, InterfaceC15338gnn<?> interfaceC15338gnn) {
            if (this.b) {
                this.g.e();
                return true;
            }
            if (!z) {
                return false;
            }
            if (this.m) {
                if (!z2) {
                    return false;
                }
                this.b = true;
                Throwable th = this.c;
                if (th != null) {
                    interfaceC15338gnn.onError(th);
                } else {
                    interfaceC15338gnn.onComplete();
                }
                this.k.dispose();
                return true;
            }
            Throwable th2 = this.c;
            if (th2 != null) {
                this.b = true;
                this.g.e();
                interfaceC15338gnn.onError(th2);
                this.k.dispose();
                return true;
            }
            if (!z2) {
                return false;
            }
            this.b = true;
            interfaceC15338gnn.onComplete();
            this.k.dispose();
            return true;
        }

        @Override // o.InterfaceC13414fZq
        public final void e() {
            this.g.e();
        }

        @Override // o.InterfaceC13414fZq
        public final boolean c() {
            return this.g.c();
        }

        @Override // o.InterfaceC15338gnn
        public final void onComplete() {
            if (this.e) {
                return;
            }
            this.e = true;
            if (getAndIncrement() == 0) {
                this.k.c(this);
            }
        }

        @Override // o.InterfaceC15338gnn
        public final void onNext(T t) {
            if (this.e) {
                return;
            }
            if (this.i != 2) {
                if (!this.g.b(t)) {
                    this.h.a();
                    this.c = new QueueOverflowException();
                    this.e = true;
                }
                if (getAndIncrement() == 0) {
                    this.k.c(this);
                    return;
                }
                return;
            }
            if (getAndIncrement() == 0) {
                this.k.c(this);
            }
        }

        @Override // o.InterfaceC13413fZp
        public final int b(int i) {
            if ((i & 2) == 0) {
                return 0;
            }
            this.n = true;
            return 2;
        }
    }

    /* renamed from: o.fUz$LWm */
    /* loaded from: classes6.dex */
    static final class LWm<T> extends HBt<T> {
        private InterfaceC15338gnn<? super T> m;

        LWm(InterfaceC15338gnn<? super T> interfaceC15338gnn, AbstractC13173fSu.Sts sts, boolean z, int i) {
            super(sts, z, i);
            this.m = interfaceC15338gnn;
        }

        @Override // o.InterfaceC13158fSf, o.InterfaceC15338gnn
        public final void c(InterfaceC15337gnm interfaceC15337gnm) {
            if (fYC.e(this.h, interfaceC15337gnm)) {
                this.h = interfaceC15337gnm;
                if (interfaceC15337gnm instanceof InterfaceC13410fZm) {
                    InterfaceC13410fZm interfaceC13410fZm = (InterfaceC13410fZm) interfaceC15337gnm;
                    int b = interfaceC13410fZm.b(7);
                    if (b == 1) {
                        this.i = 1;
                        this.g = interfaceC13410fZm;
                        this.e = true;
                        this.m.c(this);
                        return;
                    }
                    if (b == 2) {
                        this.i = 2;
                        this.g = interfaceC13410fZm;
                        this.m.c(this);
                        interfaceC15337gnm.c(this.d);
                        return;
                    }
                }
                this.g = new C13415fZr(this.d);
                this.m.c(this);
                interfaceC15337gnm.c(this.d);
            }
        }

        @Override // o.C13247fUz.HBt
        final void i() {
            InterfaceC15338gnn<? super T> interfaceC15338gnn = this.m;
            InterfaceC13414fZq<T> interfaceC13414fZq = this.g;
            long j = this.f;
            int i = 1;
            do {
                long j2 = this.j.get();
                while (j != j2) {
                    try {
                        T b = interfaceC13414fZq.b();
                        if (this.b) {
                            return;
                        }
                        if (b == null) {
                            this.b = true;
                            interfaceC15338gnn.onComplete();
                            this.k.dispose();
                            return;
                        }
                        interfaceC15338gnn.onNext(b);
                        j++;
                    } catch (Throwable th) {
                        C13147fSI.c(th);
                        this.b = true;
                        this.h.a();
                        interfaceC15338gnn.onError(th);
                        this.k.dispose();
                        return;
                    }
                }
                if (this.b) {
                    return;
                }
                if (interfaceC13414fZq.c()) {
                    this.b = true;
                    interfaceC15338gnn.onComplete();
                    this.k.dispose();
                    return;
                }
                this.f = j;
                i = addAndGet(-i);
            } while (i != 0);
        }

        @Override // o.C13247fUz.HBt
        final void d() {
            InterfaceC15338gnn<? super T> interfaceC15338gnn = this.m;
            InterfaceC13414fZq<T> interfaceC13414fZq = this.g;
            long j = this.f;
            int i = 1;
            while (true) {
                long j2 = this.j.get();
                while (j != j2) {
                    boolean z = this.e;
                    try {
                        T b = interfaceC13414fZq.b();
                        boolean z2 = b == null;
                        if (!a(z, z2, interfaceC15338gnn)) {
                            if (z2) {
                                break;
                            }
                            interfaceC15338gnn.onNext(b);
                            j++;
                            if (j == this.a) {
                                if (j2 != Long.MAX_VALUE) {
                                    j2 = this.j.addAndGet(-j);
                                }
                                this.h.c(j);
                                j = 0;
                            }
                        } else {
                            return;
                        }
                    } catch (Throwable th) {
                        C13147fSI.c(th);
                        this.b = true;
                        this.h.a();
                        interfaceC13414fZq.e();
                        interfaceC15338gnn.onError(th);
                        this.k.dispose();
                        return;
                    }
                }
                if (j == j2 && a(this.e, interfaceC13414fZq.c(), interfaceC15338gnn)) {
                    return;
                }
                int i2 = get();
                if (i == i2) {
                    this.f = j;
                    i = addAndGet(-i);
                    if (i == 0) {
                        return;
                    }
                } else {
                    i = i2;
                }
            }
        }

        @Override // o.C13247fUz.HBt
        final void f() {
            int i = 1;
            while (!this.b) {
                boolean z = this.e;
                this.m.onNext(null);
                if (z) {
                    this.b = true;
                    Throwable th = this.c;
                    if (th != null) {
                        this.m.onError(th);
                    } else {
                        this.m.onComplete();
                    }
                    this.k.dispose();
                    return;
                }
                i = addAndGet(-i);
                if (i == 0) {
                    return;
                }
            }
        }

        @Override // o.InterfaceC13414fZq
        public final T b() throws Throwable {
            T b = this.g.b();
            if (b != null && this.i != 1) {
                long j = this.f + 1;
                if (j == this.a) {
                    this.f = 0L;
                    this.h.c(j);
                } else {
                    this.f = j;
                }
            }
            return b;
        }
    }

    /* renamed from: o.fUz$IeS */
    /* loaded from: classes6.dex */
    static final class IeS<T> extends HBt<T> {
        private InterfaceC13405fZh<? super T> m;
        private long n;

        IeS(InterfaceC13405fZh<? super T> interfaceC13405fZh, AbstractC13173fSu.Sts sts, boolean z, int i) {
            super(sts, z, i);
            this.m = interfaceC13405fZh;
        }

        @Override // o.InterfaceC13158fSf, o.InterfaceC15338gnn
        public final void c(InterfaceC15337gnm interfaceC15337gnm) {
            if (fYC.e(this.h, interfaceC15337gnm)) {
                this.h = interfaceC15337gnm;
                if (interfaceC15337gnm instanceof InterfaceC13410fZm) {
                    InterfaceC13410fZm interfaceC13410fZm = (InterfaceC13410fZm) interfaceC15337gnm;
                    int b = interfaceC13410fZm.b(7);
                    if (b == 1) {
                        this.i = 1;
                        this.g = interfaceC13410fZm;
                        this.e = true;
                        this.m.c(this);
                        return;
                    }
                    if (b == 2) {
                        this.i = 2;
                        this.g = interfaceC13410fZm;
                        this.m.c(this);
                        interfaceC15337gnm.c(this.d);
                        return;
                    }
                }
                this.g = new C13415fZr(this.d);
                this.m.c(this);
                interfaceC15337gnm.c(this.d);
            }
        }

        @Override // o.C13247fUz.HBt
        final void i() {
            InterfaceC13405fZh<? super T> interfaceC13405fZh = this.m;
            InterfaceC13414fZq<T> interfaceC13414fZq = this.g;
            long j = this.f;
            int i = 1;
            do {
                long j2 = this.j.get();
                while (j != j2) {
                    try {
                        T b = interfaceC13414fZq.b();
                        if (this.b) {
                            return;
                        }
                        if (b == null) {
                            this.b = true;
                            interfaceC13405fZh.onComplete();
                            this.k.dispose();
                            return;
                        } else if (interfaceC13405fZh.d()) {
                            j++;
                        }
                    } catch (Throwable th) {
                        C13147fSI.c(th);
                        this.b = true;
                        this.h.a();
                        interfaceC13405fZh.onError(th);
                        this.k.dispose();
                        return;
                    }
                }
                if (this.b) {
                    return;
                }
                if (interfaceC13414fZq.c()) {
                    this.b = true;
                    interfaceC13405fZh.onComplete();
                    this.k.dispose();
                    return;
                }
                this.f = j;
                i = addAndGet(-i);
            } while (i != 0);
        }

        @Override // o.C13247fUz.HBt
        final void d() {
            InterfaceC13405fZh<? super T> interfaceC13405fZh = this.m;
            InterfaceC13414fZq<T> interfaceC13414fZq = this.g;
            long j = this.f;
            long j2 = this.n;
            int i = 1;
            do {
                long j3 = this.j.get();
                while (j != j3) {
                    boolean z = this.e;
                    try {
                        boolean z2 = interfaceC13414fZq.b() == null;
                        if (!a(z, z2, interfaceC13405fZh)) {
                            if (z2) {
                                break;
                            }
                            if (interfaceC13405fZh.d()) {
                                j++;
                            }
                            j2++;
                            if (j2 == this.a) {
                                this.h.c(j2);
                                j2 = 0;
                            }
                        } else {
                            return;
                        }
                    } catch (Throwable th) {
                        C13147fSI.c(th);
                        this.b = true;
                        this.h.a();
                        interfaceC13414fZq.e();
                        interfaceC13405fZh.onError(th);
                        this.k.dispose();
                        return;
                    }
                }
                if (j == j3 && a(this.e, interfaceC13414fZq.c(), interfaceC13405fZh)) {
                    return;
                }
                this.f = j;
                this.n = j2;
                i = addAndGet(-i);
            } while (i != 0);
        }

        @Override // o.C13247fUz.HBt
        final void f() {
            int i = 1;
            while (!this.b) {
                boolean z = this.e;
                this.m.onNext(null);
                if (z) {
                    this.b = true;
                    Throwable th = this.c;
                    if (th != null) {
                        this.m.onError(th);
                    } else {
                        this.m.onComplete();
                    }
                    this.k.dispose();
                    return;
                }
                i = addAndGet(-i);
                if (i == 0) {
                    return;
                }
            }
        }

        @Override // o.InterfaceC13414fZq
        public final T b() throws Throwable {
            T b = this.g.b();
            if (b != null && this.i != 1) {
                long j = this.n + 1;
                if (j == this.a) {
                    this.n = 0L;
                    this.h.c(j);
                } else {
                    this.n = j;
                }
            }
            return b;
        }
    }
}