package c7;

import W.C0350q;
import Z6.AbstractC0385z;
import Z6.C0379t;
import Z6.d0;
import b7.AbstractC0558h;
import b7.C0553c;
import b7.C0556f;
import b7.EnumC0551a;
import com.google.android.gms.internal.measurement.C1;
import d5.AbstractC0844a;
import d7.C0850a;
import java.io.Serializable;
import java.util.NoSuchElementException;
import java.util.concurrent.CancellationException;

/* JADX INFO: loaded from: classes.dex */
public abstract class H {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public static final B3.f f9389a = new B3.f(5, "NO_VALUE");

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final B3.f f9390b = new B3.f(5, "NONE");

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final B3.f f9391c = new B3.f(5, "PENDING");

    public static final G a(int i, EnumC0551a enumC0551a) {
        if (i < 0) {
            throw new IllegalArgumentException(AbstractC0844a.j("replay cannot be negative, but was ", i).toString());
        }
        if (i > 0 || enumC0551a == EnumC0551a.f9221q) {
            return new G(i, i < 0 ? Integer.MAX_VALUE : i, enumC0551a);
        }
        throw new IllegalArgumentException(("replay or extraBufferCapacity must be positive with non-default onBufferOverflow strategy " + enumC0551a).toString());
    }

    public static final K b(Object obj) {
        if (obj == null) {
            obj = d7.c.f12346b;
        }
        return new K(obj);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object c(M m8, C0350q c0350q, Throwable th, G6.c cVar) throws Throwable {
        C0604l c0604l;
        if (cVar instanceof C0604l) {
            c0604l = (C0604l) cVar;
            int i = c0604l.f9444v;
            if ((i & Integer.MIN_VALUE) != 0) {
                c0604l.f9444v = i - Integer.MIN_VALUE;
            } else {
                c0604l = new C0604l(cVar);
            }
        }
        Object obj = c0604l.f9443u;
        Object obj2 = F6.a.f2580q;
        int i5 = c0604l.f9444v;
        try {
            if (i5 == 0) {
                C1.N(obj);
                c0604l.f9442t = th;
                c0604l.f9444v = 1;
                if (c0350q.j(m8, th, c0604l) == obj2) {
                    return obj2;
                }
            } else {
                if (i5 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                th = c0604l.f9442t;
                C1.N(obj);
            }
            return A6.n.f457a;
        } catch (Throwable th2) {
            if (th != null && th != th2) {
                android.support.v4.media.session.a.a(th2, th);
            }
            throw th2;
        }
    }

    public static final void d(Object[] objArr, long j8, Object obj) {
        objArr[((int) j8) & (objArr.length - 1)] = obj;
    }

    public static InterfaceC0596d e(InterfaceC0596d interfaceC0596d, int i) {
        EnumC0551a enumC0551a = EnumC0551a.f9221q;
        if (i < 0 && i != -2 && i != -1) {
            throw new IllegalArgumentException(AbstractC0844a.j("Buffer size should be non-negative, BUFFERED, or CONFLATED, but was ", i).toString());
        }
        if (i == -1) {
            enumC0551a = EnumC0551a.f9222r;
            i = 0;
        }
        boolean z8 = interfaceC0596d instanceof d7.t;
        E6.j jVar = E6.j.f2226q;
        return z8 ? ((d7.t) interfaceC0596d).i(jVar, i, enumC0551a) : new d7.j(interfaceC0596d, jVar, i, enumC0551a);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Serializable f(InterfaceC0596d interfaceC0596d, InterfaceC0597e interfaceC0597e, G6.c cVar) {
        q qVar;
        P6.m mVar;
        CancellationException cancellationExceptionR;
        if (cVar instanceof q) {
            qVar = (q) cVar;
            int i = qVar.f9465v;
            if ((i & Integer.MIN_VALUE) != 0) {
                qVar.f9465v = i - Integer.MIN_VALUE;
            } else {
                qVar = new q(cVar);
            }
        }
        Object obj = qVar.f9464u;
        F6.a aVar = F6.a.f2580q;
        int i5 = qVar.f9465v;
        if (i5 == 0) {
            C1.N(obj);
            P6.m mVar2 = new P6.m();
            try {
                InterfaceC0597e h8 = new Q4.H(interfaceC0597e, mVar2, 1);
                qVar.f9463t = mVar2;
                qVar.f9465v = 1;
                if (interfaceC0596d.o(h8, qVar) == aVar) {
                    return aVar;
                }
                return null;
            } catch (Throwable th) {
                th = th;
                mVar = mVar2;
            }
        } else {
            if (i5 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            mVar = qVar.f9463t;
            try {
                C1.N(obj);
                return null;
            } catch (Throwable th2) {
                th = th2;
            }
        }
        Throwable th3 = (Throwable) mVar.f5535q;
        if (th3 == null || !th3.equals(th)) {
            E6.i iVar = qVar.f3016r;
            P6.g.b(iVar);
            d0 d0Var = (d0) iVar.K(C0379t.f7546r);
            if (d0Var == null || !d0Var.isCancelled() || (cancellationExceptionR = d0Var.r()) == null || !cancellationExceptionR.equals(th)) {
                if (th3 == null) {
                    return th;
                }
                if (th instanceof CancellationException) {
                    android.support.v4.media.session.a.a(th3, th);
                    throw th3;
                }
                android.support.v4.media.session.a.a(th, th3);
                throw th;
            }
        }
        throw th;
    }

    public static final Object g(D d8, O6.p pVar, E6.d dVar) {
        int i = x.f9492a;
        Object objO = e(new d7.o(new w(pVar, null), d8, E6.j.f2226q, -2, EnumC0551a.f9221q), 0).o(d7.v.f12387q, dVar);
        F6.a aVar = F6.a.f2580q;
        A6.n nVar = A6.n.f457a;
        if (objO != aVar) {
            objO = nVar;
        }
        return objO == aVar ? objO : nVar;
    }

    /* JADX WARN: Code restructure failed: missing block: B:36:0x0094, code lost:
    
        if (r2.l(r11, r0) == r1) goto L37;
     */
    /* JADX WARN: Removed duplicated region for block: B:27:0x006e  */
    /* JADX WARN: Removed duplicated region for block: B:28:0x006f  */
    /* JADX WARN: Removed duplicated region for block: B:31:0x007a A[Catch: all -> 0x0036, TryCatch #1 {all -> 0x0036, blocks: (B:13:0x002f, B:25:0x005e, B:29:0x0072, B:31:0x007a, B:33:0x0080, B:35:0x0086, B:38:0x0097, B:39:0x009f, B:40:0x00a0, B:41:0x00a7, B:20:0x0049, B:24:0x0054), top: B:60:0x0021 }] */
    /* JADX WARN: Removed duplicated region for block: B:42:0x00a8  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:36:0x0094 -> B:14:0x0032). Please report as a decompilation issue!!! */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object h(InterfaceC0597e interfaceC0597e, b7.t tVar, boolean z8, G6.c cVar) throws Throwable {
        C0598f c0598f;
        C0553c c0553c;
        b7.v vVar;
        C0553c c0553c2;
        InterfaceC0597e interfaceC0597e2;
        b7.v vVar2;
        if (cVar instanceof C0598f) {
            c0598f = (C0598f) cVar;
            int i = c0598f.f9421y;
            if ((i & Integer.MIN_VALUE) != 0) {
                c0598f.f9421y = i - Integer.MIN_VALUE;
            } else {
                c0598f = new C0598f(cVar);
            }
        }
        Object objB = c0598f.f9420x;
        F6.a aVar = F6.a.f2580q;
        int i5 = c0598f.f9421y;
        try {
            if (i5 == 0) {
                C1.N(objB);
                if (interfaceC0597e instanceof M) {
                    throw ((M) interfaceC0597e).f9405q;
                }
                C0556f c0556f = tVar.f9273t;
                c0556f.getClass();
                c0553c = new C0553c(c0556f);
                vVar2 = tVar;
                c0598f.f9416t = interfaceC0597e;
                c0598f.f9417u = vVar2;
                c0598f.f9418v = c0553c;
                c0598f.f9419w = z8;
                c0598f.f9421y = 1;
                objB = c0553c.b(c0598f);
                if (objB != aVar) {
                }
            } else if (i5 == 1) {
                z8 = c0598f.f9419w;
                c0553c2 = c0598f.f9418v;
                b7.v vVar3 = c0598f.f9417u;
                interfaceC0597e2 = c0598f.f9416t;
                C1.N(objB);
                vVar = vVar3;
                if (!((Boolean) objB).booleanValue()) {
                }
            } else {
                if (i5 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                z8 = c0598f.f9419w;
                c0553c2 = c0598f.f9418v;
                b7.v vVar4 = c0598f.f9417u;
                interfaceC0597e2 = c0598f.f9416t;
                C1.N(objB);
                b7.v vVar5 = vVar4;
                InterfaceC0597e interfaceC0597e3 = interfaceC0597e2;
                c0553c = c0553c2;
                interfaceC0597e = interfaceC0597e3;
                vVar2 = vVar5;
                c0598f.f9416t = interfaceC0597e;
                c0598f.f9417u = vVar2;
                c0598f.f9418v = c0553c;
                c0598f.f9419w = z8;
                c0598f.f9421y = 1;
                objB = c0553c.b(c0598f);
                if (objB != aVar) {
                    return aVar;
                }
                C0553c c0553c3 = c0553c;
                interfaceC0597e2 = interfaceC0597e;
                c0553c2 = c0553c3;
                vVar = vVar2;
                if (!((Boolean) objB).booleanValue()) {
                    if (z8) {
                        vVar.b(null);
                    }
                    return A6.n.f457a;
                }
                Object obj = c0553c2.f9225q;
                B3.f fVar = AbstractC0558h.f9255p;
                if (obj == fVar) {
                    throw new IllegalStateException("`hasNext()` has not been invoked");
                }
                c0553c2.f9225q = fVar;
                if (obj == AbstractC0558h.f9251l) {
                    Throwable thO = c0553c2.f9227s.o();
                    int i8 = e7.s.f12575a;
                    throw thO;
                }
                c0598f.f9416t = interfaceC0597e2;
                c0598f.f9417u = vVar;
                c0598f.f9418v = c0553c2;
                c0598f.f9419w = z8;
                c0598f.f9421y = 2;
                vVar5 = vVar;
            }
        } catch (Throwable th) {
            try {
                throw th;
            } catch (Throwable th2) {
                if (z8) {
                    CancellationException cancellationException = th instanceof CancellationException ? th : null;
                    if (cancellationException == null) {
                        cancellationException = new CancellationException("Channel was consumed, consumer had failed");
                        cancellationException.initCause(th);
                    }
                    tVar.b(cancellationException);
                }
                throw th2;
            }
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:27:0x005e  */
    /* JADX WARN: Removed duplicated region for block: B:33:0x0073  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object i(InterfaceC0596d interfaceC0596d, G6.c cVar) throws Throwable {
        y yVar;
        P6.m mVar;
        C0850a e8;
        A5.c cVar2;
        if (cVar instanceof y) {
            yVar = (y) cVar;
            int i = yVar.f9496w;
            if ((i & Integer.MIN_VALUE) != 0) {
                yVar.f9496w = i - Integer.MIN_VALUE;
            } else {
                yVar = new y(cVar);
            }
        }
        Object obj = yVar.f9495v;
        Object obj2 = F6.a.f2580q;
        int i5 = yVar.f9496w;
        B3.f fVar = d7.c.f12346b;
        if (i5 == 0) {
            C1.N(obj);
            P6.m mVar2 = new P6.m();
            mVar2.f5535q = fVar;
            A5.c cVar3 = new A5.c(7, mVar2);
            try {
                yVar.f9493t = mVar2;
                yVar.f9494u = cVar3;
                yVar.f9496w = 1;
                if (interfaceC0596d.o(cVar3, yVar) == obj2) {
                    return obj2;
                }
                mVar = mVar2;
            } catch (C0850a e9) {
                mVar = mVar2;
                e8 = e9;
                cVar2 = cVar3;
                if (e8.f12341q == cVar2) {
                }
            }
        } else {
            if (i5 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            cVar2 = yVar.f9494u;
            mVar = yVar.f9493t;
            try {
                C1.N(obj);
            } catch (C0850a e10) {
                e8 = e10;
                if (e8.f12341q == cVar2) {
                    throw e8;
                }
                E6.i iVar = yVar.f3016r;
                P6.g.b(iVar);
                AbstractC0385z.i(iVar);
            }
        }
        Object obj3 = mVar.f5535q;
        if (obj3 != fVar) {
            return obj3;
        }
        throw new NoSuchElementException("Expected at least one element");
    }

    public static final InterfaceC0596d j(D d8, E6.i iVar, int i, EnumC0551a enumC0551a) {
        return ((i == 0 || i == -3) && enumC0551a == EnumC0551a.f9221q) ? d8 : new d7.j(d8, iVar, i, enumC0551a);
    }
}