package C1;

import F3.L;
import F3.M;
import F3.O;
import I2.C0317a;
import I2.C0320d;
import I2.C0328l;
import I2.C0341z;
import I2.V;
import J3.v;
import android.os.Handler;
import androidx.recyclerview.widget.i0;
import com.google.android.gms.internal.play_billing.zzie;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.URI;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicLong;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import javax.net.ssl.SSLSocketFactory;
import k4.AbstractC2395h;
import k4.AbstractC2396i;
import k4.C2385D;
import k4.C2389b;
import k4.C2401n;
import k4.EnumC2404q;
import k4.Q;
import k4.g0;
import k4.o0;
import k4.r0;
import k4.s0;
import k4.v0;
import k4.w0;
import m4.AbstractC2504f0;
import m4.C;
import m4.J;
import m4.K0;
import m4.O0;
import m4.S0;
import m4.c2;
import n4.C2625c;
import n4.t;
import p4.C2729h;
import p4.EnumC2722a;
import p5.AbstractC2732b;

/* JADX INFO: loaded from: classes.dex */
public final class o implements Runnable {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ int f698a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public Object f699b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public Object f700c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public Object f701d;

    public /* synthetic */ o() {
        this.f698a = 0;
    }

    @Override // java.lang.Runnable
    public final void run() {
        Object objCall;
        n4.n nVar;
        n4.m mVar;
        Socket socketH;
        SSLSession session;
        Socket socket;
        M m6;
        M m7;
        t4.m mVar2;
        t4.o oVar;
        switch (this.f698a) {
            case 0:
                try {
                    objCall = ((g) this.f699b).call();
                    break;
                } catch (Exception unused) {
                    objCall = null;
                }
                ((Handler) this.f701d).post(new a(1, (h) this.f700c, objCall));
                return;
            case 1:
                zzie zzieVar = zzie.EXECUTE_ASYNC_TIMEOUT;
                C0328l c0328l = V.f2552k;
                ((C0320d) this.f699b).I(4, c0328l, zzieVar);
                ((com.revenuecat.purchases.google.usecase.a) this.f700c).d(c0328l, ((C0317a) this.f701d).f2580b);
                return;
            case 2:
                super/*I2.d*/.f((C0341z) this.f700c, (com.revenuecat.purchases.google.usecase.c) this.f701d);
                return;
            case 3:
                super/*I2.d*/.b((C0317a) this.f700c, (com.revenuecat.purchases.google.usecase.a) this.f701d);
                return;
            case 4:
                super/*I2.d*/.a((C0317a) this.f700c, (com.revenuecat.purchases.google.usecase.a) this.f701d);
                return;
            case 5:
                ((w0) this.f701d).execute((v0) this.f699b);
                return;
            case 6:
                ((O0) this.f701d).f20705f.start((AbstractC2396i) this.f699b, (g0) this.f700c);
                return;
            case 7:
                ((J) this.f701d).f20650a.onClose((r0) this.f699b, (g0) this.f700c);
                return;
            case 8:
                S0 s02 = (S0) this.f701d;
                v vVar = s02.f20805r;
                com.google.firebase.firestore.remote.g gVar = (com.google.firebase.firestore.remote.g) this.f699b;
                Executor executor = s02.f20796h;
                EnumC2404q enumC2404q = (EnumC2404q) this.f700c;
                vVar.getClass();
                A4.g.o(executor, "executor");
                A4.g.o(enumC2404q, "source");
                C c6 = new C(gVar, executor);
                if (((EnumC2404q) vVar.f3544b) != enumC2404q) {
                    executor.execute(gVar);
                    return;
                } else {
                    ((ArrayList) vVar.f3543a).add(c6);
                    return;
                }
            case 9:
                K0 k02 = (K0) this.f701d;
                S0 s03 = k02.f20658e;
                if (k02 != s03.f20811x) {
                    return;
                }
                Q q6 = (Q) this.f699b;
                s03.f20812y = q6;
                s03.f20766E.i(q6);
                EnumC2404q enumC2404q2 = EnumC2404q.f19914e;
                EnumC2404q enumC2404q3 = (EnumC2404q) this.f700c;
                if (enumC2404q3 != enumC2404q2) {
                    k02.f20658e.f20776O.g(2, "Entering {0} state with picker: {1}", enumC2404q3, q6);
                    k02.f20658e.f20805r.c(enumC2404q3);
                    return;
                }
                return;
            case 10:
                try {
                    ((CountDownLatch) this.f699b).await();
                } catch (InterruptedException unused2) {
                    Thread.currentThread().interrupt();
                }
                p5.J jC = AbstractC2732b.c(new n4.l());
                try {
                    try {
                        n4.n nVar2 = (n4.n) this.f701d;
                        C2385D c2385d = nVar2.f21721N;
                        if (c2385d == null) {
                            socketH = nVar2.f21708A.createSocket(nVar2.f21723a.getAddress(), ((n4.n) this.f701d).f21723a.getPort());
                        } else {
                            InetSocketAddress inetSocketAddress = c2385d.f19788a;
                            if (inetSocketAddress == null) {
                                throw new s0(r0.f19945m.g("Unsupported SocketAddress implementation " + ((n4.n) this.f701d).f21721N.f19788a.getClass()));
                            }
                            socketH = n4.n.h(nVar2, c2385d.f19789b, inetSocketAddress, c2385d.f19790c, c2385d.f19791d);
                        }
                        n4.n nVar3 = (n4.n) this.f701d;
                        SSLSocketFactory sSLSocketFactory = nVar3.f21709B;
                        if (sSLSocketFactory != null) {
                            String host = nVar3.f21724b;
                            URI uriA = AbstractC2504f0.a(host);
                            if (uriA.getHost() != null) {
                                host = uriA.getHost();
                            }
                            SSLSocket sSLSocketA = t.a(sSLSocketFactory, socketH, host, ((n4.n) this.f701d).l(), ((n4.n) this.f701d).f21712E);
                            session = sSLSocketA.getSession();
                            socket = sSLSocketA;
                        } else {
                            session = null;
                            socket = socketH;
                        }
                        socket.setTcpNoDelay(true);
                        p5.J jC2 = AbstractC2732b.c(AbstractC2732b.l(socket));
                        ((C2625c) this.f700c).a(AbstractC2732b.i(socket), socket);
                        n4.n nVar4 = (n4.n) this.f701d;
                        C2389b c2389b = nVar4.f21742u;
                        c2389b.getClass();
                        i0 i0Var = new i0(c2389b, 3);
                        i0Var.u(AbstractC2395h.f19871a, socket.getRemoteSocketAddress());
                        i0Var.u(AbstractC2395h.f19872b, socket.getLocalSocketAddress());
                        i0Var.u(AbstractC2395h.f19873c, session);
                        i0Var.u(c2.f20974a, session == null ? o0.f19905a : o0.f19906b);
                        nVar4.f21742u = i0Var.c();
                        n4.n nVar5 = (n4.n) this.f701d;
                        nVar5.f21729g.getClass();
                        nVar5.f21741t = new n4.m(nVar5, new C2729h(jC2));
                        synchronized (((n4.n) this.f701d).f21733k) {
                            try {
                                ((n4.n) this.f701d).getClass();
                                if (session != null) {
                                    n4.n nVar6 = (n4.n) this.f701d;
                                    new C2401n(session);
                                    nVar6.getClass();
                                }
                            } finally {
                            }
                            break;
                        }
                        return;
                    } catch (Throwable th) {
                        n4.n nVar7 = (n4.n) this.f701d;
                        nVar7.f21729g.getClass();
                        nVar7.f21741t = new n4.m(nVar7, new C2729h(jC));
                        throw th;
                    }
                } catch (s0 e6) {
                    ((n4.n) this.f701d).s(0, EnumC2722a.INTERNAL_ERROR, e6.f19953a);
                    nVar = (n4.n) this.f701d;
                    nVar.f21729g.getClass();
                    mVar = new n4.m(nVar, new C2729h(jC));
                    nVar.f21741t = mVar;
                    return;
                } catch (Exception e7) {
                    ((n4.n) this.f701d).p(e7);
                    nVar = (n4.n) this.f701d;
                    nVar.f21729g.getClass();
                    mVar = new n4.m(nVar, new C2729h(jC));
                    nVar.f21741t = mVar;
                    return;
                }
                break;
            default:
                t4.t tVar = (t4.t) this.f701d;
                tVar.l = Long.valueOf(tVar.f24364i.e());
                for (t4.k kVar : ((t4.t) this.f701d).f24361f.f24333a.values()) {
                    i0 i0Var2 = kVar.f24329c;
                    ((AtomicLong) i0Var2.f13105b).set(0L);
                    ((AtomicLong) i0Var2.f13106c).set(0L);
                    i0 i0Var3 = kVar.f24328b;
                    kVar.f24328b = kVar.f24329c;
                    kVar.f24329c = i0Var3;
                }
                t4.o oVar2 = (t4.o) this.f699b;
                AbstractC2395h abstractC2395h = (AbstractC2395h) this.f700c;
                L lO = O.o();
                if (oVar2.f24345e != null) {
                    lO.a(new t4.m(oVar2, abstractC2395h, 1));
                }
                if (oVar2.f24346f != null) {
                    lO.a(new t4.m(oVar2, abstractC2395h, 0));
                }
                M mListIterator = lO.f().listIterator(0);
                while (mListIterator.hasNext()) {
                    t4.m mVar3 = (t4.m) mListIterator.next();
                    t4.t tVar2 = (t4.t) this.f701d;
                    t4.l lVar = tVar2.f24361f;
                    long jLongValue = tVar2.l.longValue();
                    switch (mVar3.f24334a) {
                        case 0:
                            m6 = mListIterator;
                            t4.o oVar3 = mVar3.f24335b;
                            ArrayList<t4.k> arrayListH = t4.t.h(lVar, oVar3.f24346f.f24340d.intValue());
                            int size = arrayListH.size();
                            t4.n nVar8 = oVar3.f24346f;
                            if (size >= nVar8.f24339c.intValue() && arrayListH.size() != 0) {
                                for (t4.k kVar2 : arrayListH) {
                                    if (lVar.a() >= oVar3.f24344d.intValue()) {
                                    }
                                    if (kVar2.c() >= nVar8.f24340d.intValue()) {
                                        if (((AtomicLong) kVar2.f24329c.f13106c).get() / kVar2.c() > ((double) nVar8.f24337a.intValue()) / 100.0d) {
                                            mVar3.f24336c.g(1, "FailurePercentage algorithm detected outlier: {0}, failureRate={1}", kVar2, Double.valueOf(((AtomicLong) kVar2.f24329c.f13106c).get() / kVar2.c()));
                                            if (new Random().nextInt(100) < nVar8.f24338b.intValue()) {
                                                kVar2.b(jLongValue);
                                            }
                                        }
                                    }
                                    break;
                                }
                            }
                            break;
                        default:
                            t4.o oVar4 = mVar3.f24335b;
                            ArrayList<t4.k> arrayListH2 = t4.t.h(lVar, oVar4.f24345e.f24340d.intValue());
                            int size2 = arrayListH2.size();
                            t4.n nVar9 = oVar4.f24345e;
                            if (size2 >= nVar9.f24339c.intValue() && arrayListH2.size() != 0) {
                                ArrayList arrayList = new ArrayList();
                                for (t4.k kVar3 : arrayListH2) {
                                    arrayList.add(Double.valueOf(((AtomicLong) kVar3.f24329c.f13105b).get() / kVar3.c()));
                                    mVar3 = mVar3;
                                }
                                t4.m mVar4 = mVar3;
                                Iterator it = arrayList.iterator();
                                double d6 = 0.0d;
                                double dDoubleValue = 0.0d;
                                while (it.hasNext()) {
                                    dDoubleValue = ((Double) it.next()).doubleValue() + dDoubleValue;
                                }
                                double size3 = dDoubleValue / ((double) arrayList.size());
                                Iterator it2 = arrayList.iterator();
                                while (it2.hasNext()) {
                                    double dDoubleValue2 = ((Double) it2.next()).doubleValue() - size3;
                                    d6 = (dDoubleValue2 * dDoubleValue2) + d6;
                                }
                                double dSqrt = Math.sqrt(d6 / ((double) arrayList.size()));
                                double dIntValue = size3 - (((double) (nVar9.f24337a.intValue() / 1000.0f)) * dSqrt);
                                for (t4.k kVar4 : arrayListH2) {
                                    double d7 = dSqrt;
                                    if (lVar.a() < oVar4.f24344d.intValue()) {
                                        if (((AtomicLong) kVar4.f24329c.f13105b).get() / kVar4.c() < dIntValue) {
                                            m7 = mListIterator;
                                            mVar2 = mVar4;
                                            oVar = oVar4;
                                            mVar2.f24336c.g(1, "SuccessRate algorithm detected outlier: {0}. Parameters: successRate={1}, mean={2}, stdev={3}, requiredSuccessRate={4}", kVar4, Double.valueOf(((AtomicLong) kVar4.f24329c.f13105b).get() / kVar4.c()), Double.valueOf(size3), Double.valueOf(d7), Double.valueOf(dIntValue));
                                            if (new Random().nextInt(100) < nVar9.f24338b.intValue()) {
                                                kVar4.b(jLongValue);
                                            }
                                        } else {
                                            m7 = mListIterator;
                                            mVar2 = mVar4;
                                            oVar = oVar4;
                                        }
                                        oVar4 = oVar;
                                        mListIterator = m7;
                                        mVar4 = mVar2;
                                        dSqrt = d7;
                                    }
                                }
                            }
                            m6 = mListIterator;
                            break;
                    }
                    mListIterator = m6;
                }
                t4.t tVar3 = (t4.t) this.f701d;
                t4.l lVar2 = tVar3.f24361f;
                Long l = tVar3.l;
                for (t4.k kVar5 : lVar2.f24333a.values()) {
                    if (!kVar5.d()) {
                        int i6 = kVar5.f24331e;
                        kVar5.f24331e = i6 == 0 ? 0 : i6 - 1;
                    }
                    if (kVar5.d()) {
                        if (l.longValue() > Math.min(kVar5.f24327a.f24342b.longValue() * ((long) kVar5.f24331e), Math.max(kVar5.f24327a.f24342b.longValue(), kVar5.f24327a.f24343c.longValue())) + kVar5.f24330d.longValue()) {
                            kVar5.e();
                        }
                    }
                }
                return;
        }
    }

    public String toString() {
        switch (this.f698a) {
            case 5:
                return ((Runnable) this.f700c).toString() + "(scheduled in SynchronizationContext)";
            default:
                return super.toString();
        }
    }

    public /* synthetic */ o(C0320d c0320d, Object obj, Object obj2, int i6) {
        this.f698a = i6;
        this.f699b = c0320d;
        this.f700c = obj;
        this.f701d = obj2;
    }

    public /* synthetic */ o(Object obj, Object obj2, Object obj3, int i6) {
        this.f698a = i6;
        this.f701d = obj;
        this.f699b = obj2;
        this.f700c = obj3;
    }
}