package c7;

import Z6.C0365e;
import Z6.C0369i;
import Z6.C0379t;
import Z6.d0;
import b7.EnumC0551a;
import com.google.android.gms.internal.measurement.C1;
import d7.AbstractC0851b;
import java.util.Arrays;

/* JADX INFO: loaded from: classes.dex */
public class G extends AbstractC0851b implements InterfaceC0590A, InterfaceC0596d, d7.t {

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

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

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

    /* JADX INFO: renamed from: v, reason: collision with root package name */
    public final EnumC0551a f9384v;

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

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

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

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

    public G(int i, int i5, EnumC0551a enumC0551a) {
        this.f9382t = i;
        this.f9383u = i5;
        this.f9384v = enumC0551a;
    }

    /* 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:0x00b2, code lost:
    
        r10 = move-exception;
     */
    /* JADX WARN: Code restructure failed: missing block: B:47:0x00b3, code lost:
    
        r5 = r8;
        r8 = r10;
     */
    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:34:0x0082 A[Catch: all -> 0x0038, TryCatch #1 {all -> 0x0038, blocks: (B:15:0x0031, B:32:0x007a, B:34:0x0082, B:38:0x0095, B:41:0x009c, B:42:0x00a0, B:43:0x00a1, B:22:0x004b), top: B:52:0x0020 }] */
    /* JADX WARN: Removed duplicated region for block: B:56:0x0093 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: [c7.e] */
    /* JADX WARN: Type inference failed for: r2v6 */
    /* JADX WARN: Type inference failed for: r2v7 */
    /* JADX WARN: Type inference failed for: r5v1, types: [d7.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: [c7.G] */
    /* 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: [c7.e] */
    /* 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: [d7.d] */
    /* JADX WARN: Type inference failed for: r9v3 */
    /* JADX WARN: Type inference failed for: r9v4 */
    /* JADX WARN: Type inference failed for: r9v5, types: [c7.I] */
    /* JADX WARN: Type inference failed for: r9v6 */
    /* JADX WARN: Type inference failed for: r9v7 */
    /* JADX WARN: Type inference failed for: r9v8, types: [c7.I] */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:44:0x00af -> B:16:0x0034). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static void g(G g8, InterfaceC0597e interfaceC0597e, E6.d dVar) throws Throwable {
        F f3;
        ?? r52;
        ?? r10;
        G g9;
        d0 d0Var;
        d0 d0Var2;
        ?? r22;
        Object objS;
        ?? r102;
        ?? r9;
        ?? r8;
        if (dVar instanceof F) {
            f3 = (F) dVar;
            int i = f3.f9380z;
            if ((i & Integer.MIN_VALUE) != 0) {
                f3.f9380z = i - Integer.MIN_VALUE;
            } else {
                f3 = new F(g8, dVar);
            }
        }
        Object obj = f3.f9378x;
        F6.a aVar = F6.a.f2580q;
        int i5 = f3.f9380z;
        try {
        } catch (Throwable th) {
            th = th;
        }
        if (i5 == 0) {
            C1.N(obj);
            r10 = interfaceC0597e;
            interfaceC0597e = (I) g8.a();
            g9 = g8;
        } else {
            if (i5 != 1) {
                if (i5 == 2) {
                    d0Var2 = f3.f9377w;
                    I i8 = f3.f9376v;
                    InterfaceC0597e interfaceC0597e2 = f3.f9375u;
                    G g10 = f3.f9374t;
                    C1.N(obj);
                    r22 = interfaceC0597e2;
                    r52 = g10;
                    interfaceC0597e = i8;
                    do {
                        objS = r52.s(interfaceC0597e);
                        if (objS == H.f9389a) {
                        }
                        r52.d(interfaceC0597e);
                        throw th;
                    } while (r52.e(interfaceC0597e, f3) != aVar);
                }
                if (i5 != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                d0Var2 = f3.f9377w;
                I i9 = f3.f9376v;
                InterfaceC0597e interfaceC0597e3 = f3.f9375u;
                G g11 = f3.f9374t;
                C1.N(obj);
                ?? r23 = interfaceC0597e3;
                ?? r53 = g11;
                ?? r92 = i9;
                r102 = r23;
                d0Var = d0Var2;
                r8 = r53;
                r9 = r92;
                r52 = r8;
                d0Var2 = d0Var;
                r22 = r102;
                interfaceC0597e = r9;
                do {
                    objS = r52.s(interfaceC0597e);
                    if (objS == H.f9389a) {
                        if (d0Var2 != null && !d0Var2.a()) {
                            throw d0Var2.r();
                        }
                        f3.f9374t = r52;
                        f3.f9375u = r22;
                        f3.f9376v = interfaceC0597e;
                        f3.f9377w = d0Var2;
                        f3.f9380z = 3;
                        Object objL = r22.l(objS, f3);
                        r23 = r22;
                        r53 = r52;
                        r92 = interfaceC0597e;
                        if (objL == aVar) {
                            return;
                        }
                        r102 = r23;
                        d0Var = d0Var2;
                        r8 = r53;
                        r9 = r92;
                        r52 = r8;
                        d0Var2 = d0Var;
                        r22 = r102;
                        interfaceC0597e = r9;
                        objS = r52.s(interfaceC0597e);
                        if (objS == H.f9389a) {
                            f3.f9374t = r52;
                            f3.f9375u = r22;
                            f3.f9376v = interfaceC0597e;
                            f3.f9377w = d0Var2;
                            f3.f9380z = 2;
                        }
                    }
                    r52.d(interfaceC0597e);
                    throw th;
                } while (r52.e(interfaceC0597e, f3) != aVar);
            }
            interfaceC0597e = f3.f9376v;
            InterfaceC0597e interfaceC0597e4 = f3.f9375u;
            G g12 = f3.f9374t;
            try {
                C1.N(obj);
                r10 = interfaceC0597e4;
                g9 = g12;
                interfaceC0597e = interfaceC0597e;
            } catch (Throwable th2) {
                th = th2;
                r52 = g12;
            }
        }
        E6.i iVar = f3.f3016r;
        P6.g.b(iVar);
        d0Var = (d0) iVar.K(C0379t.f7546r);
        r8 = g9;
        r9 = interfaceC0597e;
        r102 = r10;
        r52 = r8;
        d0Var2 = d0Var;
        r22 = r102;
        interfaceC0597e = r9;
        do {
            objS = r52.s(interfaceC0597e);
            if (objS == H.f9389a) {
            }
            r52.d(interfaceC0597e);
            throw th;
        } while (r52.e(interfaceC0597e, f3) != aVar);
    }

    @Override // d7.AbstractC0851b
    public final d7.d b() {
        I i = new I();
        i.f9392a = -1L;
        return i;
    }

    @Override // d7.AbstractC0851b
    public final d7.d[] c() {
        return new I[2];
    }

    public final Object e(I i, F f3) {
        C0369i c0369i = new C0369i(1, C1.A(f3));
        c0369i.v();
        synchronized (this) {
            if (r(i) < 0) {
                i.f9393b = c0369i;
            } else {
                c0369i.i(A6.n.f457a);
            }
        }
        Object objU = c0369i.u();
        return objU == F6.a.f2580q ? objU : A6.n.f457a;
    }

    public final void f() {
        if (this.f9383u != 0 || this.f9381A > 1) {
            Object[] objArr = this.f9385w;
            P6.g.b(objArr);
            while (this.f9381A > 0) {
                long jM = m();
                int i = this.f9388z;
                int i5 = this.f9381A;
                if (objArr[((int) ((jM + ((long) (i + i5))) - 1)) & (objArr.length - 1)] != H.f9389a) {
                    return;
                }
                this.f9381A = i5 - 1;
                H.d(objArr, m() + ((long) (this.f9388z + this.f9381A)), null);
            }
        }
    }

    public final void h() {
        d7.d[] dVarArr;
        Object[] objArr = this.f9385w;
        P6.g.b(objArr);
        H.d(objArr, m(), null);
        this.f9388z--;
        long jM = m() + 1;
        if (this.f9386x < jM) {
            this.f9386x = jM;
        }
        if (this.f9387y < jM) {
            if (this.f12343r != 0 && (dVarArr = this.f12342q) != null) {
                for (d7.d dVar : dVarArr) {
                    if (dVar != null) {
                        I i = (I) dVar;
                        long j8 = i.f9392a;
                        if (j8 >= 0 && j8 < jM) {
                            i.f9392a = jM;
                        }
                    }
                }
            }
            this.f9387y = jM;
        }
    }

    @Override // d7.t
    public final InterfaceC0596d i(E6.i iVar, int i, EnumC0551a enumC0551a) {
        return H.j(this, iVar, i, enumC0551a);
    }

    public final void j(Object obj) {
        int i = this.f9388z + this.f9381A;
        Object[] objArrN = this.f9385w;
        if (objArrN == null) {
            objArrN = n(null, 0, 2);
        } else if (i >= objArrN.length) {
            objArrN = n(objArrN, i, objArrN.length * 2);
        }
        H.d(objArrN, m() + ((long) i), obj);
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Type inference failed for: r11v0, types: [E6.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 E6.d[] k(E6.d[] dVarArr) {
        d7.d[] dVarArr2;
        I i;
        C0369i c0369i;
        int length = dVarArr.length;
        if (this.f12343r != 0 && (dVarArr2 = this.f12342q) != null) {
            int length2 = dVarArr2.length;
            int i5 = 0;
            dVarArr = dVarArr;
            while (i5 < length2) {
                d7.d dVar = dVarArr2[i5];
                if (dVar != null && (c0369i = (i = (I) dVar).f9393b) != null && r(i) >= 0) {
                    int length3 = dVarArr.length;
                    dVarArr = dVarArr;
                    if (length >= length3) {
                        Object[] objArrCopyOf = Arrays.copyOf((Object[]) dVarArr, Math.max(2, dVarArr.length * 2));
                        P6.g.d(objArrCopyOf, "copyOf(...)");
                        dVarArr = objArrCopyOf;
                    }
                    ((E6.d[]) dVarArr)[length] = c0369i;
                    i.f9393b = null;
                    length++;
                }
                i5++;
                dVarArr = dVarArr;
            }
        }
        return (E6.d[]) dVarArr;
    }

    @Override // c7.InterfaceC0597e
    public final Object l(Object obj, E6.d dVar) {
        Throwable th;
        E6.d[] dVarArrK;
        E e8;
        if (p(obj)) {
            return A6.n.f457a;
        }
        C0369i c0369i = new C0369i(1, C1.A(dVar));
        c0369i.v();
        E6.d[] dVarArrK2 = d7.c.f12345a;
        synchronized (this) {
            try {
                if (q(obj)) {
                    try {
                        c0369i.i(A6.n.f457a);
                        dVarArrK = k(dVarArrK2);
                        e8 = null;
                    } catch (Throwable th2) {
                        th = th2;
                        throw th;
                    }
                } else {
                    try {
                        E e9 = new E(this, m() + ((long) (this.f9388z + this.f9381A)), obj, c0369i);
                        j(e9);
                        this.f9381A++;
                        if (this.f9383u == 0) {
                            dVarArrK2 = k(dVarArrK2);
                        }
                        dVarArrK = dVarArrK2;
                        e8 = e9;
                    } catch (Throwable th3) {
                        th = th3;
                        th = th;
                        throw th;
                    }
                }
                if (e8 != null) {
                    c0369i.y(new C0365e(2, e8));
                }
                for (E6.d dVar2 : dVarArrK) {
                    if (dVar2 != null) {
                        dVar2.i(A6.n.f457a);
                    }
                }
                Object objU = c0369i.u();
                F6.a aVar = F6.a.f2580q;
                if (objU != aVar) {
                    objU = A6.n.f457a;
                }
                return objU == aVar ? objU : A6.n.f457a;
            } catch (Throwable th4) {
                th = th4;
            }
        }
    }

    public final long m() {
        return Math.min(this.f9387y, this.f9386x);
    }

    public final Object[] n(Object[] objArr, int i, int i5) {
        if (i5 <= 0) {
            throw new IllegalStateException("Buffer size overflow");
        }
        Object[] objArr2 = new Object[i5];
        this.f9385w = objArr2;
        if (objArr != null) {
            long jM = m();
            for (int i8 = 0; i8 < i; i8++) {
                long j8 = ((long) i8) + jM;
                H.d(objArr2, j8, objArr[((int) j8) & (objArr.length - 1)]);
            }
        }
        return objArr2;
    }

    @Override // c7.InterfaceC0596d
    public final Object o(InterfaceC0597e interfaceC0597e, E6.d dVar) throws Throwable {
        g(this, interfaceC0597e, dVar);
        return F6.a.f2580q;
    }

    public final boolean p(Object obj) {
        int i;
        boolean z8;
        E6.d[] dVarArrK = d7.c.f12345a;
        synchronized (this) {
            if (q(obj)) {
                dVarArrK = k(dVarArrK);
                z8 = true;
            } else {
                z8 = false;
            }
        }
        for (E6.d dVar : dVarArrK) {
            if (dVar != null) {
                dVar.i(A6.n.f457a);
            }
        }
        return z8;
    }

    /* 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 i = this.f12343r;
        int i5 = this.f9382t;
        if (i != 0) {
            int i8 = this.f9388z;
            int i9 = this.f9383u;
            if (i8 < i9 || this.f9387y > this.f9386x) {
                j(obj);
                int i10 = this.f9388z + 1;
                this.f9388z = i10;
                if (i10 > i9) {
                    h();
                }
                long jM = m() + ((long) this.f9388z);
                long j8 = this.f9386x;
                if (((int) (jM - j8)) > i5) {
                    t(1 + j8, this.f9387y, m() + ((long) this.f9388z), m() + ((long) this.f9388z) + ((long) this.f9381A));
                }
            } else {
                int iOrdinal = this.f9384v.ordinal();
                if (iOrdinal == 0) {
                    return false;
                }
                if (iOrdinal != 1) {
                    if (iOrdinal != 2) {
                        throw new A6.b();
                    }
                }
            }
        } else if (i5 != 0) {
            j(obj);
            int i11 = this.f9388z + 1;
            this.f9388z = i11;
            if (i11 > i5) {
                h();
            }
            this.f9387y = m() + ((long) this.f9388z);
            return true;
        }
        return true;
    }

    public final long r(I i) {
        long j8 = i.f9392a;
        if (j8 < m() + ((long) this.f9388z)) {
            return j8;
        }
        if (this.f9383u <= 0 && j8 <= m() && this.f9381A != 0) {
            return j8;
        }
        return -1L;
    }

    public final Object s(I i) {
        Object obj;
        E6.d[] dVarArrU = d7.c.f12345a;
        synchronized (this) {
            try {
                long jR = r(i);
                if (jR < 0) {
                    obj = H.f9389a;
                } else {
                    long j8 = i.f9392a;
                    Object[] objArr = this.f9385w;
                    P6.g.b(objArr);
                    Object obj2 = objArr[((int) jR) & (objArr.length - 1)];
                    if (obj2 instanceof E) {
                        obj2 = ((E) obj2).f9372s;
                    }
                    i.f9392a = jR + 1;
                    Object obj3 = obj2;
                    dVarArrU = u(j8);
                    obj = obj3;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        for (E6.d dVar : dVarArrU) {
            if (dVar != null) {
                dVar.i(A6.n.f457a);
            }
        }
        return obj;
    }

    public final void t(long j8, long j9, long j10, long j11) {
        long jMin = Math.min(j9, j8);
        for (long jM = m(); jM < jMin; jM++) {
            Object[] objArr = this.f9385w;
            P6.g.b(objArr);
            H.d(objArr, jM, null);
        }
        this.f9386x = j8;
        this.f9387y = j9;
        this.f9388z = (int) (j10 - jMin);
        this.f9381A = (int) (j11 - j10);
    }

    public final E6.d[] u(long j8) {
        long j9;
        long j10;
        long j11;
        int i;
        E6.d[] dVarArr;
        d7.d[] dVarArr2;
        long j12 = this.f9387y;
        E6.d[] dVarArr3 = d7.c.f12345a;
        if (j8 <= j12) {
            long jM = m();
            long j13 = ((long) this.f9388z) + jM;
            int i5 = this.f9383u;
            if (i5 == 0 && this.f9381A > 0) {
                j13++;
            }
            int i8 = 0;
            if (this.f12343r != 0 && (dVarArr2 = this.f12342q) != null) {
                for (d7.d dVar : dVarArr2) {
                    if (dVar != null) {
                        long j14 = ((I) dVar).f9392a;
                        if (j14 >= 0 && j14 < j13) {
                            j13 = j14;
                        }
                    }
                }
            }
            if (j13 > this.f9387y) {
                long jM2 = m() + ((long) this.f9388z);
                int iMin = this.f12343r > 0 ? Math.min(this.f9381A, i5 - ((int) (jM2 - j13))) : this.f9381A;
                long j15 = ((long) this.f9381A) + jM2;
                B3.f fVar = H.f9389a;
                if (iMin > 0) {
                    E6.d[] dVarArr4 = new E6.d[iMin];
                    j11 = 1;
                    Object[] objArr = this.f9385w;
                    P6.g.b(objArr);
                    i = i5;
                    long j16 = jM2;
                    while (true) {
                        if (jM2 >= j15) {
                            j9 = jM;
                            j10 = j13;
                            break;
                        }
                        j9 = jM;
                        Object obj = objArr[((int) jM2) & (objArr.length - 1)];
                        if (obj != fVar) {
                            P6.g.c(obj, "null cannot be cast to non-null type kotlinx.coroutines.flow.SharedFlowImpl.Emitter");
                            E e8 = (E) obj;
                            int i9 = i8 + 1;
                            j10 = j13;
                            dVarArr4[i8] = e8.f9373t;
                            H.d(objArr, jM2, fVar);
                            H.d(objArr, j16, e8.f9372s);
                            j16++;
                            if (i9 >= iMin) {
                                break;
                            }
                            i8 = i9;
                        } else {
                            j10 = j13;
                        }
                        jM2++;
                        jM = j9;
                        j13 = j10;
                    }
                    jM2 = j16;
                    dVarArr = dVarArr4;
                } else {
                    j9 = jM;
                    j10 = j13;
                    j11 = 1;
                    i = i5;
                    dVarArr = dVarArr3;
                }
                int i10 = (int) (jM2 - j9);
                long j17 = this.f12343r == 0 ? jM2 : j10;
                long jMax = Math.max(this.f9386x, jM2 - ((long) Math.min(this.f9382t, i10)));
                if (i == 0 && jMax < j15) {
                    Object[] objArr2 = this.f9385w;
                    P6.g.b(objArr2);
                    if (P6.g.a(objArr2[((int) jMax) & (objArr2.length - 1)], fVar)) {
                        jM2 += j11;
                        jMax += j11;
                    }
                }
                t(jMax, j17, jM2, j15);
                f();
                return dVarArr.length == 0 ? dVarArr : k(dVarArr);
            }
        }
        return dVarArr3;
    }
}