package Y4;

import I2.C0317a;
import V4.C0763h0;
import V4.C0766j;
import V4.C0772m;
import V4.InterfaceC0765i0;
import Z4.AbstractC0869b;
import Z4.AbstractC0870c;
import Z4.AbstractC0871d;
import a.AbstractC0872a;
import java.util.Arrays;
import m3.AbstractC2467b;
import w4.C3137A;

/* JADX INFO: loaded from: classes3.dex */
public class N extends AbstractC0869b implements G, InterfaceC0843i, Z4.u {

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

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

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public final X4.a f8885j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public Object[] f8886k;
    public long l;

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

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

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

    public N(int i6, int i7, X4.a aVar) {
        this.f8883e = i6;
        this.f8884f = i7;
        this.f8885j = aVar;
    }

    /* JADX WARN: Can't wrap try/catch for region: R(12:0|2|(2:4|(1:6)(1:7))(0)|8|(1:52)|(2:10|(1:(1:(7:14|15|16|31|58|(4:32|(9:56|(2:41|42)|43|(1:60)|16|31|58|32|(0)(1:34))(0)|48|49)|45)(2:19|20))(5:21|22|58|(4:32|(0)(0)|48|49)|45))(4:24|54|25|26))(1:29)|50|30|31|58|(4:32|(0)(0)|48|49)|45) */
    /* JADX WARN: Code restructure failed: missing block: B:46:0x00b1, code lost:
    
        r10 = move-exception;
     */
    /* JADX WARN: Code restructure failed: missing block: B:47:0x00b2, code lost:
    
        r5 = r8;
        r8 = r10;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:34:0x0081 A[Catch: all -> 0x0038, TryCatch #1 {all -> 0x0038, blocks: (B:15:0x0031, B:32:0x0079, B:34:0x0081, B:38:0x0094, B:41:0x009b, B:42:0x009f, B:43:0x00a0, B:22:0x004b), top: B:52:0x0020 }] */
    /* JADX WARN: Removed duplicated region for block: B:56:0x0092 A[SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Type inference failed for: r10v10 */
    /* JADX WARN: Type inference failed for: r10v11 */
    /* JADX WARN: Type inference failed for: r10v12 */
    /* JADX WARN: Type inference failed for: r10v13 */
    /* JADX WARN: Type inference failed for: r10v4 */
    /* JADX WARN: Type inference failed for: r10v5 */
    /* JADX WARN: Type inference failed for: r2v12 */
    /* JADX WARN: Type inference failed for: r2v13 */
    /* JADX WARN: Type inference failed for: r2v14 */
    /* JADX WARN: Type inference failed for: r2v4, types: [Y4.j] */
    /* JADX WARN: Type inference failed for: r2v6 */
    /* JADX WARN: Type inference failed for: r2v7 */
    /* JADX WARN: Type inference failed for: r5v1, types: [Z4.b] */
    /* JADX WARN: Type inference failed for: r5v10 */
    /* JADX WARN: Type inference failed for: r5v11 */
    /* JADX WARN: Type inference failed for: r5v12 */
    /* JADX WARN: Type inference failed for: r5v2 */
    /* JADX WARN: Type inference failed for: r5v4, types: [Y4.N] */
    /* JADX WARN: Type inference failed for: r5v5 */
    /* JADX WARN: Type inference failed for: r5v6 */
    /* JADX WARN: Type inference failed for: r5v7 */
    /* JADX WARN: Type inference failed for: r8v10 */
    /* JADX WARN: Type inference failed for: r8v18 */
    /* JADX WARN: Type inference failed for: r8v7 */
    /* JADX WARN: Type inference failed for: r9v0, types: [Y4.j] */
    /* JADX WARN: Type inference failed for: r9v1 */
    /* JADX WARN: Type inference failed for: r9v12 */
    /* JADX WARN: Type inference failed for: r9v13 */
    /* JADX WARN: Type inference failed for: r9v14 */
    /* JADX WARN: Type inference failed for: r9v15 */
    /* JADX WARN: Type inference failed for: r9v16 */
    /* JADX WARN: Type inference failed for: r9v17 */
    /* JADX WARN: Type inference failed for: r9v18 */
    /* JADX WARN: Type inference failed for: r9v2, types: [Z4.d] */
    /* JADX WARN: Type inference failed for: r9v3 */
    /* JADX WARN: Type inference failed for: r9v4 */
    /* JADX WARN: Type inference failed for: r9v5, types: [Y4.P] */
    /* JADX WARN: Type inference failed for: r9v6 */
    /* JADX WARN: Type inference failed for: r9v7 */
    /* JADX WARN: Type inference failed for: r9v8, types: [Y4.P] */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:44:0x00ae -> B:16:0x0034). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static void k(N n6, InterfaceC0844j interfaceC0844j, A4.d dVar) throws Throwable {
        M m6;
        ?? r5;
        ?? r10;
        N n7;
        InterfaceC0765i0 interfaceC0765i0;
        InterfaceC0765i0 interfaceC0765i02;
        ?? r22;
        Object objS;
        ?? r102;
        ?? r9;
        ?? r8;
        if (dVar instanceof M) {
            m6 = (M) dVar;
            int i6 = m6.f8882j;
            if ((i6 & Integer.MIN_VALUE) != 0) {
                m6.f8882j = i6 - Integer.MIN_VALUE;
            } else {
                m6 = new M(n6, dVar);
            }
        }
        Object obj = m6.f8880e;
        B4.a aVar = B4.a.f492a;
        int i7 = m6.f8882j;
        try {
        } catch (Throwable th) {
            th = th;
        }
        if (i7 == 0) {
            AbstractC2467b.l(obj);
            r10 = interfaceC0844j;
            interfaceC0844j = (P) n6.d();
            n7 = n6;
        } else {
            if (i7 != 1) {
                if (i7 == 2) {
                    interfaceC0765i02 = m6.f8879d;
                    P p6 = m6.f8878c;
                    InterfaceC0844j interfaceC0844j2 = m6.f8877b;
                    N n8 = m6.f8876a;
                    AbstractC2467b.l(obj);
                    r22 = interfaceC0844j2;
                    r5 = n8;
                    interfaceC0844j = p6;
                    do {
                        objS = r5.s(interfaceC0844j);
                        if (objS == O.f8890a) {
                        }
                        r5.g(interfaceC0844j);
                        throw th;
                    } while (r5.i(interfaceC0844j, m6) != aVar);
                }
                if (i7 != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                interfaceC0765i02 = m6.f8879d;
                P p7 = m6.f8878c;
                InterfaceC0844j interfaceC0844j3 = m6.f8877b;
                N n9 = m6.f8876a;
                AbstractC2467b.l(obj);
                ?? r23 = interfaceC0844j3;
                ?? r52 = n9;
                ?? r92 = p7;
                r102 = r23;
                interfaceC0765i0 = interfaceC0765i02;
                r8 = r52;
                r9 = r92;
                r5 = r8;
                interfaceC0765i02 = interfaceC0765i0;
                r22 = r102;
                interfaceC0844j = r9;
                do {
                    objS = r5.s(interfaceC0844j);
                    if (objS == O.f8890a) {
                        if (interfaceC0765i02 != null && !interfaceC0765i02.isActive()) {
                            throw interfaceC0765i02.getCancellationException();
                        }
                        m6.f8876a = r5;
                        m6.f8877b = r22;
                        m6.f8878c = interfaceC0844j;
                        m6.f8879d = interfaceC0765i02;
                        m6.f8882j = 3;
                        Object objEmit = r22.emit(objS, m6);
                        r23 = r22;
                        r52 = r5;
                        r92 = interfaceC0844j;
                        if (objEmit == aVar) {
                            return;
                        }
                        r102 = r23;
                        interfaceC0765i0 = interfaceC0765i02;
                        r8 = r52;
                        r9 = r92;
                        r5 = r8;
                        interfaceC0765i02 = interfaceC0765i0;
                        r22 = r102;
                        interfaceC0844j = r9;
                        objS = r5.s(interfaceC0844j);
                        if (objS == O.f8890a) {
                            m6.f8876a = r5;
                            m6.f8877b = r22;
                            m6.f8878c = interfaceC0844j;
                            m6.f8879d = interfaceC0765i02;
                            m6.f8882j = 2;
                        }
                    }
                    r5.g(interfaceC0844j);
                    throw th;
                } while (r5.i(interfaceC0844j, m6) != aVar);
            }
            interfaceC0844j = m6.f8878c;
            InterfaceC0844j interfaceC0844j4 = m6.f8877b;
            N n10 = m6.f8876a;
            try {
                AbstractC2467b.l(obj);
                r10 = interfaceC0844j4;
                n7 = n10;
                interfaceC0844j = interfaceC0844j;
            } catch (Throwable th2) {
                th = th2;
                r5 = n10;
            }
        }
        interfaceC0765i0 = (InterfaceC0765i0) m6.getContext().get(C0763h0.f8306a);
        r8 = n7;
        r9 = interfaceC0844j;
        r102 = r10;
        r5 = r8;
        interfaceC0765i02 = interfaceC0765i0;
        r22 = r102;
        interfaceC0844j = r9;
        do {
            objS = r5.s(interfaceC0844j);
            if (objS == O.f8890a) {
            }
            r5.g(interfaceC0844j);
            throw th;
        } while (r5.i(interfaceC0844j, m6) != aVar);
    }

    @Override // Y4.G
    public final void a() throws Throwable {
        synchronized (this) {
            try {
                try {
                    t(o() + ((long) this.f8888n), this.f8887m, o() + ((long) this.f8888n), o() + ((long) this.f8888n) + ((long) this.f8889o));
                } catch (Throwable th) {
                    th = th;
                    throw th;
                }
            } catch (Throwable th2) {
                th = th2;
            }
        }
    }

    @Override // Z4.u
    public final InterfaceC0843i b(A4.j jVar, int i6, X4.a aVar) {
        return O.n(this, jVar, i6, aVar);
    }

    @Override // Y4.G
    public final boolean c(Object obj) {
        int i6;
        boolean z6;
        A4.d[] dVarArrN = AbstractC0870c.f9162a;
        synchronized (this) {
            if (q(obj)) {
                dVarArrN = n(dVarArrN);
                z6 = true;
            } else {
                z6 = false;
            }
        }
        for (A4.d dVar : dVarArrN) {
            if (dVar != null) {
                dVar.resumeWith(C3137A.f25453a);
            }
        }
        return z6;
    }

    @Override // Y4.InterfaceC0843i
    public final Object collect(InterfaceC0844j interfaceC0844j, A4.d dVar) throws Throwable {
        k(this, interfaceC0844j, dVar);
        return B4.a.f492a;
    }

    @Override // Z4.AbstractC0869b
    public final AbstractC0871d e() {
        P p6 = new P();
        p6.f8893a = -1L;
        return p6;
    }

    @Override // Y4.InterfaceC0844j
    public final Object emit(Object obj, A4.d dVar) throws Throwable {
        Throwable th;
        A4.d[] dVarArrN;
        L l;
        if (c(obj)) {
            return C3137A.f25453a;
        }
        C0772m c0772m = new C0772m(1, AbstractC0872a.V(dVar));
        c0772m.s();
        A4.d[] dVarArrN2 = AbstractC0870c.f9162a;
        synchronized (this) {
            try {
                if (q(obj)) {
                    try {
                        c0772m.resumeWith(C3137A.f25453a);
                        dVarArrN = n(dVarArrN2);
                        l = null;
                    } catch (Throwable th2) {
                        th = th2;
                        throw th;
                    }
                } else {
                    try {
                        L l6 = new L(this, o() + ((long) (this.f8888n + this.f8889o)), obj, c0772m);
                        m(l6);
                        this.f8889o++;
                        if (this.f8884f == 0) {
                            dVarArrN2 = n(dVarArrN2);
                        }
                        dVarArrN = dVarArrN2;
                        l = l6;
                    } catch (Throwable th3) {
                        th = th3;
                        th = th;
                        throw th;
                    }
                }
                if (l != null) {
                    c0772m.v(new C0766j(l, 2));
                }
                for (A4.d dVar2 : dVarArrN) {
                    if (dVar2 != null) {
                        dVar2.resumeWith(C3137A.f25453a);
                    }
                }
                Object objR = c0772m.r();
                B4.a aVar = B4.a.f492a;
                if (objR != aVar) {
                    objR = C3137A.f25453a;
                }
                return objR == aVar ? objR : C3137A.f25453a;
            } catch (Throwable th4) {
                th = th4;
            }
        }
    }

    @Override // Z4.AbstractC0869b
    public final AbstractC0871d[] f() {
        return new P[2];
    }

    public final Object i(P p6, M m6) {
        C0772m c0772m = new C0772m(1, AbstractC0872a.V(m6));
        c0772m.s();
        synchronized (this) {
            if (r(p6) < 0) {
                p6.f8894b = c0772m;
            } else {
                c0772m.resumeWith(C3137A.f25453a);
            }
        }
        Object objR = c0772m.r();
        return objR == B4.a.f492a ? objR : C3137A.f25453a;
    }

    public final void j() {
        if (this.f8884f != 0 || this.f8889o > 1) {
            Object[] objArr = this.f8886k;
            kotlin.jvm.internal.o.e(objArr);
            while (this.f8889o > 0) {
                long jO = o();
                int i6 = this.f8888n;
                int i7 = this.f8889o;
                if (objArr[((int) ((jO + ((long) (i6 + i7))) - 1)) & (objArr.length - 1)] != O.f8890a) {
                    return;
                }
                this.f8889o = i7 - 1;
                O.e(objArr, o() + ((long) (this.f8888n + this.f8889o)), null);
            }
        }
    }

    public final void l() {
        AbstractC0871d[] abstractC0871dArr;
        Object[] objArr = this.f8886k;
        kotlin.jvm.internal.o.e(objArr);
        O.e(objArr, o(), null);
        this.f8888n--;
        long jO = o() + 1;
        if (this.l < jO) {
            this.l = jO;
        }
        if (this.f8887m < jO) {
            if (this.f9159b != 0 && (abstractC0871dArr = this.f9158a) != null) {
                for (AbstractC0871d abstractC0871d : abstractC0871dArr) {
                    if (abstractC0871d != null) {
                        P p6 = (P) abstractC0871d;
                        long j4 = p6.f8893a;
                        if (j4 >= 0 && j4 < jO) {
                            p6.f8893a = jO;
                        }
                    }
                }
            }
            this.f8887m = jO;
        }
    }

    public final void m(Object obj) {
        int i6 = this.f8888n + this.f8889o;
        Object[] objArrP = this.f8886k;
        if (objArrP == null) {
            objArrP = p(null, 0, 2);
        } else if (i6 >= objArrP.length) {
            objArrP = p(objArrP, i6, objArrP.length * 2);
        }
        O.e(objArrP, o() + ((long) i6), obj);
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Type inference failed for: r11v0, types: [A4.d[]] */
    /* JADX WARN: Type inference failed for: r11v1 */
    /* JADX WARN: Type inference failed for: r11v10 */
    /* JADX WARN: Type inference failed for: r11v3, types: [java.lang.Object[]] */
    /* JADX WARN: Type inference failed for: r11v4 */
    /* JADX WARN: Type inference failed for: r11v5 */
    /* JADX WARN: Type inference failed for: r11v7 */
    /* JADX WARN: Type inference failed for: r11v8 */
    /* JADX WARN: Type inference failed for: r11v9 */
    /* JADX WARN: Type inference failed for: r6v3 */
    public final A4.d[] n(A4.d[] dVarArr) {
        AbstractC0871d[] abstractC0871dArr;
        P p6;
        C0772m c0772m;
        int length = dVarArr.length;
        if (this.f9159b != 0 && (abstractC0871dArr = this.f9158a) != null) {
            int length2 = abstractC0871dArr.length;
            int i6 = 0;
            dVarArr = dVarArr;
            while (i6 < length2) {
                AbstractC0871d abstractC0871d = abstractC0871dArr[i6];
                if (abstractC0871d != null && (c0772m = (p6 = (P) abstractC0871d).f8894b) != null && r(p6) >= 0) {
                    int length3 = dVarArr.length;
                    dVarArr = dVarArr;
                    if (length >= length3) {
                        Object[] objArrCopyOf = Arrays.copyOf((Object[]) dVarArr, Math.max(2, dVarArr.length * 2));
                        kotlin.jvm.internal.o.g(objArrCopyOf, "copyOf(...)");
                        dVarArr = objArrCopyOf;
                    }
                    ((A4.d[]) dVarArr)[length] = c0772m;
                    p6.f8894b = null;
                    length++;
                }
                i6++;
                dVarArr = dVarArr;
            }
        }
        return (A4.d[]) dVarArr;
    }

    public final long o() {
        return Math.min(this.f8887m, this.l);
    }

    public final Object[] p(Object[] objArr, int i6, int i7) {
        if (i7 <= 0) {
            throw new IllegalStateException("Buffer size overflow");
        }
        Object[] objArr2 = new Object[i7];
        this.f8886k = objArr2;
        if (objArr != null) {
            long jO = o();
            for (int i8 = 0; i8 < i6; i8++) {
                long j4 = ((long) i8) + jO;
                O.e(objArr2, j4, objArr[((int) j4) & (objArr.length - 1)]);
            }
        }
        return objArr2;
    }

    /* JADX WARN: Removed duplicated region for block: B:25:0x0047  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final boolean q(Object obj) {
        int i6 = this.f9159b;
        int i7 = this.f8883e;
        if (i6 != 0) {
            int i8 = this.f8888n;
            int i9 = this.f8884f;
            if (i8 < i9 || this.f8887m > this.l) {
                m(obj);
                int i10 = this.f8888n + 1;
                this.f8888n = i10;
                if (i10 > i9) {
                    l();
                }
                long jO = o() + ((long) this.f8888n);
                long j4 = this.l;
                if (((int) (jO - j4)) > i7) {
                    t(1 + j4, this.f8887m, o() + ((long) this.f8888n), o() + ((long) this.f8888n) + ((long) this.f8889o));
                }
            } else {
                int iOrdinal = this.f8885j.ordinal();
                if (iOrdinal == 0) {
                    return false;
                }
                if (iOrdinal != 1) {
                    if (iOrdinal != 2) {
                        throw new E3.v();
                    }
                }
            }
        } else if (i7 != 0) {
            m(obj);
            int i11 = this.f8888n + 1;
            this.f8888n = i11;
            if (i11 > i7) {
                l();
            }
            this.f8887m = o() + ((long) this.f8888n);
            return true;
        }
        return true;
    }

    public final long r(P p6) {
        long j4 = p6.f8893a;
        if (j4 < o() + ((long) this.f8888n)) {
            return j4;
        }
        if (this.f8884f <= 0 && j4 <= o() && this.f8889o != 0) {
            return j4;
        }
        return -1L;
    }

    public final Object s(P p6) {
        Object obj;
        A4.d[] dVarArrU = AbstractC0870c.f9162a;
        synchronized (this) {
            try {
                long jR = r(p6);
                if (jR < 0) {
                    obj = O.f8890a;
                } else {
                    long j4 = p6.f8893a;
                    Object[] objArr = this.f8886k;
                    kotlin.jvm.internal.o.e(objArr);
                    Object obj2 = objArr[((int) jR) & (objArr.length - 1)];
                    if (obj2 instanceof L) {
                        obj2 = ((L) obj2).f8874c;
                    }
                    p6.f8893a = jR + 1;
                    Object obj3 = obj2;
                    dVarArrU = u(j4);
                    obj = obj3;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        for (A4.d dVar : dVarArrU) {
            if (dVar != null) {
                dVar.resumeWith(C3137A.f25453a);
            }
        }
        return obj;
    }

    public final void t(long j4, long j6, long j7, long j8) {
        long jMin = Math.min(j6, j4);
        for (long jO = o(); jO < jMin; jO++) {
            Object[] objArr = this.f8886k;
            kotlin.jvm.internal.o.e(objArr);
            O.e(objArr, jO, null);
        }
        this.l = j4;
        this.f8887m = j6;
        this.f8888n = (int) (j7 - jMin);
        this.f8889o = (int) (j8 - j7);
    }

    public final A4.d[] u(long j4) {
        long j6;
        long j7;
        long j8;
        int i6;
        A4.d[] dVarArr;
        AbstractC0871d[] abstractC0871dArr;
        long j9 = this.f8887m;
        A4.d[] dVarArr2 = AbstractC0870c.f9162a;
        if (j4 <= j9) {
            long jO = o();
            long j10 = ((long) this.f8888n) + jO;
            int i7 = this.f8884f;
            if (i7 == 0 && this.f8889o > 0) {
                j10++;
            }
            int i8 = 0;
            if (this.f9159b != 0 && (abstractC0871dArr = this.f9158a) != null) {
                for (AbstractC0871d abstractC0871d : abstractC0871dArr) {
                    if (abstractC0871d != null) {
                        long j11 = ((P) abstractC0871d).f8893a;
                        if (j11 >= 0 && j11 < j10) {
                            j10 = j11;
                        }
                    }
                }
            }
            if (j10 > this.f8887m) {
                long jO2 = o() + ((long) this.f8888n);
                int iMin = this.f9159b > 0 ? Math.min(this.f8889o, i7 - ((int) (jO2 - j10))) : this.f8889o;
                long j12 = ((long) this.f8889o) + jO2;
                C0317a c0317a = O.f8890a;
                if (iMin > 0) {
                    A4.d[] dVarArr3 = new A4.d[iMin];
                    j8 = 1;
                    Object[] objArr = this.f8886k;
                    kotlin.jvm.internal.o.e(objArr);
                    i6 = i7;
                    long j13 = jO2;
                    while (true) {
                        if (jO2 >= j12) {
                            j6 = jO;
                            j7 = j10;
                            break;
                        }
                        j6 = jO;
                        Object obj = objArr[((int) jO2) & (objArr.length - 1)];
                        if (obj != c0317a) {
                            kotlin.jvm.internal.o.f(obj, "null cannot be cast to non-null type kotlinx.coroutines.flow.SharedFlowImpl.Emitter");
                            L l = (L) obj;
                            int i9 = i8 + 1;
                            j7 = j10;
                            dVarArr3[i8] = l.f8875d;
                            O.e(objArr, jO2, c0317a);
                            O.e(objArr, j13, l.f8874c);
                            j13++;
                            if (i9 >= iMin) {
                                break;
                            }
                            i8 = i9;
                        } else {
                            j7 = j10;
                        }
                        jO2++;
                        jO = j6;
                        j10 = j7;
                    }
                    jO2 = j13;
                    dVarArr = dVarArr3;
                } else {
                    j6 = jO;
                    j7 = j10;
                    j8 = 1;
                    i6 = i7;
                    dVarArr = dVarArr2;
                }
                int i10 = (int) (jO2 - j6);
                long j14 = this.f9159b == 0 ? jO2 : j7;
                long jMax = Math.max(this.l, jO2 - ((long) Math.min(this.f8883e, i10)));
                if (i6 == 0 && jMax < j12) {
                    Object[] objArr2 = this.f8886k;
                    kotlin.jvm.internal.o.e(objArr2);
                    if (kotlin.jvm.internal.o.c(objArr2[((int) jMax) & (objArr2.length - 1)], c0317a)) {
                        jO2 += j8;
                        jMax += j8;
                    }
                }
                t(jMax, j14, jO2, j12);
                j();
                return dVarArr.length == 0 ? dVarArr : n(dVarArr);
            }
        }
        return dVarArr2;
    }
}